來自java數據庫的Json對象

任何人都可以幫助我如何從數據庫創建JSON對象嗎？來自java數據庫的Json對象

這是JSON輸出應該是什麼樣子：

{「devicelist」:{ 
    「device」: [ 
    {「id」: 「01」, 「type」: 「CAM」, 「name」: 「Livingroom」} 
    {「id」: 「15」, 「type」: 「CAM」, 「name」: 「Kitchen」} 
] 
}}

這是我的代碼：

if (reg!=null) 
{ 

    try 
        { 
        con = ds.getConnection(); 
        Statement select = con.createStatement(); 
        ResultSet result=select.executeQuery("Select type,name,demo from register_device"); 
         while (result.next()) 
         { 
         String type_json=result.getString("type"); 
         String name_json=result.getString("name"); 
         String id_json=result.getString("demo"); 
         JSONArray arrayObj=new JSONArray(); 

         } 
        } 
        catch(Exception e) 
        { 

        } 
     }

我能夠獲得所選擇的類型，名稱，演示從數據庫中。

我不知道如何啓動JSON編碼。

來源

2011-07-20 bharathi

哪個數據庫表列（如上所述）存儲JSON值？ –

你好，我有相同的要求，我會非常感激，如果你能告訴我有什麼簡單和優雅的方式來使用Java標準庫（Java.net。*）將SQL轉換爲JSON或任何不是第三方的罐子。另外，「JSONARRAY」......這是第三方嗎？我會非常感謝，如果有人可以回覆我 – user3384231

如果你想提取從數據庫中的數據，並構建JSON對象自己，你可以這樣做：

JsonArray jArray = new JsonArray(); 
while (result.next()) 
{ 
    String type_json=result.getString("type"); 
    String name_json=result.getString("name"); 
    String id_json=result.getString("demo"); 
    JsonObject jObj = new JsonObject(); 
    jobj.put("id", id_json); 
    jobj.put("type", type_json); 
    jobj.put("name", name_json); 
    jArray.put(jObj); 
} 

JsonObject jObjDevice = new JsonObject(); 
jObjDevice.put("device", jArray); 
JsonObject jObjDeviceList = new JsonObject(); 
jObjDevice.put("devicelist", jObjDevice);

現在jObjDeviceList包含所有數據。

來源

2011-07-20 09:16:03 MByD

隨着jOOQ，你可以從你的數據庫產生類似的JSON列表：

String json = create.select(TYPE, NAME, DEMO) 
        .from(REGISTER_DEVICE) 
        .fetch() 
        .formatJSON();

JSON字符串應該是這樣的：

{fields:["TYPE","NAME","DEMO"], 
records:[["01","CAM","Livingroom"],["15","CAM","Kitchen"]]}

不是正是你在問題中要求，但也許你不依賴於你建議的確切的JSON格式？此外，您可能稍後可以轉換該JSON對象。

來源

2011-07-20 09:13:50

如果您有Device對象，json-lib可以使用get()方法作爲JSON序列化對象。

import java.util.*; 
import net.sf.json.*; 

public class JsonEncode { 
    public static void main(String[] args) throws Exception { 
     Device d1 = new Device("01", "CAM", "LivingRoom"); 
     Device d2 = new Device("15", "CAM", "Kitchen"); 

     List<Device> devices = new ArrayList<Device>(Arrays.asList(d1, d2)); 

     JSONArray serializedDevices = JSONArray.fromObject(devices); 
     JSONObject jsonDevices = new JSONObject(); 
     jsonDevices.put("devices", serializedDevices); 

     JSONObject json = new JSONObject(); 
     json.put("deviceList", jsonDevices); 
     System.out.println(json); 
    } 

    public static class Device { 
     Device(String id, String type, String name) { 
      this.id = id; 
      this.type = type; 
      this.name = name; 
     } 
     private String id; 
     public String getId() { return id; } 
     private String type; 
     public String getType() { return type; } 
     private String name; 
     public String getName() { return name; } 
    } 
}

保存爲：JsonEncode.java

編譯時：

javac -cp json-lib-2.4-jdk15.jar JsonEncode.java

與執行的（注：類路徑具有DOS分離器）：

java -cp .;json-lib-2.4-jdk15.jar;commons-lang-2.6.jar;commons-logging-1.1.1.jar;commons-collections-3.2.1.jar;ezmorph-1.0.6.jar;commons-beanutils-1.8.0.jar JsonEncode

依賴關係：

來源

2011-07-20 10:01:22 andyb

package com.idal.cib; 

import java.sql.Connection; 
import java.sql.DriverManager; 
import java.sql.SQLException; 

public class DatabaseConnector { 

    static Connection conn1 = null; 

    public static Connection getDbConnection(String driver, String url, 
      String username, String password) { 
     // TODO Auto-generated constructor stub 
     try { 

      Class.forName(driver); 

      conn1 = DriverManager.getConnection(url, username, password); 
     } catch (ClassNotFoundException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } catch (SQLException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 
     return conn1; 
    } 

} 


package com.idal.cib; 

import java.io.FileWriter; 
import java.io.IOException; 
import java.sql.Connection; 
import java.sql.PreparedStatement; 
import java.sql.ResultSet; 
import java.sql.ResultSetMetaData; 
import java.sql.SQLException; 
import java.util.ArrayList; 

import org.json.simple.JSONArray; 
import org.json.simple.JSONObject; 

public class DBJsonConverter { 

    static ArrayList<String> data = new ArrayList<String>(); 
    static Connection conn = null; 
    static PreparedStatement ps = null; 
    static ResultSet rs = null; 
    static String path = ""; 
    static String driver=""; 
    static String url=""; 
    static String username=""; 
    static String password=""; 
    static String query=""; 

    @SuppressWarnings({ "unchecked" }) 
    public static void dataLoad(String path) { 
     JSONObject obj1 = new JSONObject(); 
     JSONArray jsonArray = new JSONArray(); 
     conn = DatabaseConnector.getDbConnection(driver, url, username, 
       password); 
     try { 
      ps = conn.prepareStatement(query); 
      rs = ps.executeQuery(); 
      ArrayList<String> columnNames = new ArrayList<String>(); 
      if (rs != null) { 
       ResultSetMetaData columns = rs.getMetaData(); 
       int i = 0; 
       while (i < columns.getColumnCount()) { 
        i++; 
        columnNames.add(columns.getColumnName(i)); 
       } 
       while (rs.next()) { 
        JSONObject obj = new JSONObject(); 
        for (i = 0; i < columnNames.size(); i++) { 
         data.add(rs.getString(columnNames.get(i))); 
         { 
          for (int j = 0; j < data.size(); j++) { 
           if (data.get(j) != null) { 
            obj.put(columnNames.get(i), data.get(j)); 
           }else { 
            obj.put(columnNames.get(i), ""); 
           } 
          } 
         } 
        } 

        jsonArray.add(obj); 
        obj1.put("header", jsonArray); 
        FileWriter file = new FileWriter(path); 
        file.write(obj1.toJSONString()); 
        file.flush(); 
        file.close(); 
       } 
       ps.close(); 
      } else { 
       JSONObject obj2 = new JSONObject(); 
       obj2.put(null, null); 
       jsonArray.add(obj2); 
       obj1.put("header", jsonArray); 
      } 
     } catch (SQLException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } catch (IOException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } finally { 
      if (conn != null) { 
       try { 
        conn.close(); 
        rs.close(); 
        ps.close(); 
       } catch (SQLException e) { 
        // TODO Auto-generated catch block 
        e.printStackTrace(); 
       } 
      } 
     } 
    } 

    @SuppressWarnings("static-access") 
    public static void main(String[] args) { 
     // TODO Auto-generated method stub 
     driver = "oracle.jdbc.driver.OracleDriver"; 
     url = "jdbc:oracle:thin:@10.11.34.134:1521:COREMUAT"; 
     username = "oasisusr"; 
     password = "p#g_ay0w"; 
     path = "D:\\VF_Polaris\\968670\\category_list1.json"; 
     query = "select * from temp_employee"; 

     DatabaseConnector dc = new DatabaseConnector(); 
     dc.getDbConnection(driver,url,username,password); 
     DBJsonConverter formatter = new DBJsonConverter(); 
     formatter.dataLoad(path); 

    } 

}

來源

2017-07-11 06:07:42

Pl爲你的答案添加一些解釋。 –

來自java數據庫的Json對象

回答

相關問題