Fix JSON for ScalarTypePostgresHstore with field name and nulls

src/main/java/com/avaje/ebean/text/json/EJson.java

@@ -8,6 +8,7 @@ import java.util.Map;
 
 import com.fasterxml.jackson.core.JsonGenerator;
 import com.fasterxml.jackson.core.JsonParser;
+import com.fasterxml.jackson.core.JsonToken;
 
 /**
  * Utility that converts between JSON content and simple java Maps/Lists.
@@ -55,7 +56,17 @@ public class EJson {
   public static Map<String,Object> parseObject(JsonParser parser) throws IOException {
     return EJsonReader.parseObject(parser);
   }
-  
+
+  /**
+   * Parse the json and return as a Map taking a JsonParser and a starting token.
+   * <p>
+   * Used when the first token is checked to see if the value is null prior to calling this.
+   * </p>
+   */
+  public static Map<String,Object> parseObject(JsonParser parser, JsonToken token) throws IOException {
+    return EJsonReader.parseObject(parser, token);
+  }
+
   /**
    * Parse the json and return as a List.
    * @throws IOException 

src/main/java/com/avaje/ebean/text/json/EJsonReader.java

@@ -32,6 +32,11 @@ class EJsonReader {
     return (Map<String, Object>) parse(parser);
   }
 
+  @SuppressWarnings("unchecked")
+  static Map<String, Object> parseObject(JsonParser parser, JsonToken token) throws IOException {
+    return (Map<String, Object>)parse(parser, token);
+  }
+
   @SuppressWarnings("unchecked")
   static List<Object> parseList(String json) throws IOException {
     return (List<Object>) parse(json);
@@ -56,7 +61,11 @@ class EJsonReader {
   }
 
   static Object parse(JsonParser parser) throws IOException {
-    return new EJsonReader(parser).parseJson();
+    return parse(parser, null);
+  }
+
+  static Object parse(JsonParser parser, JsonToken token) throws IOException {
+    return new EJsonReader(parser).parseJson(token);
   }
 
   private final JsonParser parser;
@@ -106,28 +115,27 @@ class EJsonReader {
     currentContext.setValueNull();
   }
 
-  private Object parseJson() {
+  private Object parseJson(JsonToken token) throws IOException {
 
-    try {
-      JsonToken token = parser.nextToken();
+    if (token == null) {
+      // no initial token so expect to read START_OBJECT or similar
+      token = parser.nextToken();
       if (JsonToken.VALUE_NULL == token) {
         return null;
       }
-
-      stack = new Stack();
-      // it is a object or array, process the first JsonToken
-      processJsonToken(token);
-
-      // process the rest of the object or array
-      while (depth > 0) {
-        token = parser.nextToken();
-        processJsonToken(token);
-      }
-
-      return currentContext.getValue();
-    } catch (IOException e) {
-      throw new RuntimeException(e);
     }
+
+    stack = new Stack();
+    // it is a object or array, process the first JsonToken
+    processJsonToken(token);
+
+    // process the rest of the object or array
+    while (depth > 0) {
+      token = parser.nextToken();
+      processJsonToken(token);
+    }
+
+    return currentContext.getValue();
   }
 
   /**

src/main/java/com/avaje/ebeaninternal/server/type/ScalarTypePostgresHstore.java

@@ -48,7 +48,7 @@ public class ScalarTypePostgresHstore extends ScalarTypeBase<Map> {
     if (value == null) {
       return null;
     }
-    if (value instanceof Map == false) {
+    if (!(value instanceof Map)) {
       throw new RuntimeException("Expecting Hstore to return as Map but got type "+value.getClass());
     }
     return new ModifyAwareMap((Map)value);
@@ -111,12 +111,21 @@ public class ScalarTypePostgresHstore extends ScalarTypeBase<Map> {
 
   @Override
   public void jsonWrite(JsonGenerator ctx, String name, Object value) throws IOException {
-    EJson.write(value, ctx);
+    // write the field name followed by the Map/JSON Object
+    if (value == null) {
+      ctx.writeNullField(name);
+    } else {
+      ctx.writeFieldName(name);
+      EJson.write(value, ctx);
+    }
   }
 
   @Override
   public Object jsonRead(JsonParser ctx, JsonToken event) throws IOException {
-    return EJson.parseObject(ctx);
+    // at this point the BeanProperty has read the START_OBJECT token
+    // to check for a null value. Pass the START_OBJECT token through to
+    // the EJson parsing so that it knows the first token has been read
+    return EJson.parseObject(ctx, event);
   }
   
 }