JSONObjectを解析してデータベースに動的キー/値を挿入

Question

JSONObjectの動的キー値をデータベースに挿入するにはどうすればよいですか？

投稿リクエストからキー値を抽出して別々に出力することはできますが、データベースに保存することはできません。

@POST 
@Path("/user") 
@Produces(MediaType.APPLICATION_JSON) 
@Consumes(MediaType.APPLICATION_JSON) 
public String keyValueFromJson(String userFormData) throws JSONException { 

    PreparedStatement query = null; 
    Connection conn = null; 

    JSONObject jsOb = new JSONObject(userFormData); 
    JSONArray jaArr = jsOb.getJSONArray("formData"); 

    try { 

     conn = DaoMessenger.PostGresCon().getConnection(); 

     for (int i = 0; i < jaArr.length();) { 
      JSONObject jsonObject = jaArr.getJSONObject(i); 
      Iterator<String> keys = jsonObject.keys(); 
      while (keys.hasNext()) { 
       String key = keys.next(); 
       Object value = jsonObject.get(key); 
       System.out.println(key + ": " + value); 
       query = conn.prepareStatement ("INSERT INTO users (" + key + ") values(" + value + ")"); 
       ResultSet rs = query.executeQuery(); 
      } 

      i++; 
     } 

    } catch (Exception e){ 
     e.printStackTrace(); 
    } 

    return userFormData; 
} 

JSONオブジェクトは角度でクライアントを経由して送信します。

{ 
"formData": 
[ 
    { 
     "id":235, 
     "username":"john", 
     "enabled":"true", 
     "last_login":"2017-03-03 19:49:56", 
     "pass":"xxxxx" 

    } 
] 
} 

をデータベースがPostgresの9.6.1で

エラー（のStackTrace）：

org.postgresql.util.PSQLException: ERROR: column "xxxxx" does not exist 
Position: 34 

私はロジックを持っていますwhileループの間違いですが、私はそれを理解できません。

Answer 1

私はいくつかの変更を行なったし、それがこのように動作します：

StringBuilder sbv = new StringBuilder(); 
StringBuilder sbk = new StringBuilder(); 
String prefix = ""; 

    try { 
     conn = DaoMessenger.PostGresCon().getConnection(); 
     for (int i = 0; i < jaArr.length();) { 
      JSONObject jsonObject = jaArr.getJSONObject(i); 
      Iterator<String> keys = jsonObject.keys(); 

      while (keys.hasNext()) { 
       String key = keys.next(); 
       Object value = jsonObject.get(key); 
       sbk.append(prefix); 
       sbv.append(prefix); 
       prefix = ","; 
       sbv.append("'").append(value).append("'"); 
       sbk.append(key); 
      } 
      query = conn.prepareStatement("INSERT INTO users (" + sbk.toString() + ") values (" + sbv.toString() + ")"); 
      ResultSet rs = query.executeQuery(); 

      i++; 
     } 

    } catch (Exception e){ 
     e.printStackTrace(); 
    }