如何使用 JDBC 將資料庫中的資料讀取/檢索到 JSON 中?


JSON 陣列是有序的值集合,用方括號括起來,即以“[”開頭,以“]”結尾。陣列中的值用“,”(逗號)分隔。

JSON 陣列示例

{
   "books": [ Java, JavaFX, Hbase, Cassandra, WebGL, JOGL]
}

json-simple 是一個輕量級的庫,用於處理 JSON 物件。使用它,您可以使用 Java 程式讀取或寫入 JSON 文件的內容。

JSON-Simple Maven 依賴項

以下是 JSON-simple 庫的 Maven 依賴項:

<dependencies>
   <dependency>
      <groupId>com.googlecode.json-simple</groupId>
      <artifactId>json-simple</artifactId>
      <version>1.1.1</version>
   </dependency>
</dependencies>

將其貼上到 pom.xml 檔案末尾的 <dependencies> </dependencies> 標記內。(在 </project> 標記之前)

示例

讓我們在 MySQL 資料庫中使用 CREATE 語句建立一個名為**MyPlayers**的表,如下所示:

CREATE TABLE MyPlayers(
   ID INT,
   First_Name VARCHAR(255),
   Last_Name VARCHAR(255),
   Date_Of_Birth date,
   Place_Of_Birth VARCHAR(255),
   Country VARCHAR(255),
   PRIMARY KEY (ID)
);

現在,我們將使用 INSERT 語句在**MyPlayers**表中插入 5 條記錄:

insert into MyPlayers values(1, 'Shikhar', 'Dhawan', DATE('1981-12-05'), 'Delhi', 'India');
insert into MyPlayers values(2, 'Jonathan', 'Trott', DATE('1981-04-22'), 'CapeTown', 'SouthAfrica');
insert into MyPlayers values(3, 'Kumara', 'Sangakkara', DATE('1977-10-27'), 'Matale', 'Srilanka');
insert into MyPlayers values(4, 'Virat', 'Kohli', DATE('1988-11-05'), 'Delhi', 'India');
insert into MyPlayers values(5, 'Rohit', 'Sharma', DATE('1987-04-30'), 'Nagpur', 'India');
insert into MyPlayers values(6, 'Ravindra', 'Jadeja', DATE('1988-12-06'), 'Nagpur', 'India');
insert into MyPlayers values(7, 'James', 'Anderson', DATE('1982-06-30'), 'Burnley', 'England');

要使用 JDBC 將上面建立的 MyPlayers 表的內容讀取到 JSON 檔案中:

檢索 MyPlayers 表的內容

  • 使用 DriverManager 類的**registerDriver()**方法或名為 Class 的類的 forName()方法註冊所需資料庫的 Driver 類。
DriverManager.registerDriver(new com.mysql.jdbc.Driver());
  • 透過將資料庫的 URL、資料庫中使用者的使用者名稱和密碼(以字串格式)作為引數傳遞給 DriverManager 類的**getConnection()**方法來建立連線物件。
Connection mysqlCon = DriverManager.getConnection(mysqlUrl, "root", "password");
  • 使用連線介面的**createStatement()**方法建立**Statement**物件。
Statement stmt = con.createStatement();
  • 執行 SELECT 查詢,使用 executeQuery() 方法將 MyPlayers 表的內容檢索到 ResultSet 物件中。
String query = "Select * from MyPlayers";
ResultSet rs = stmt.executeQuery(query);

建立一個 JSON 陣列並新增檢索到的 MyPlayers 資料

  • 透過例項化 json-simple 庫的**JSONObject**類來建立 JSON 文件(以表示 MyPlayers 表)。
//Creating a JSONObject object
JSONObject jsonObject = new JSONObject();
  • 透過例項化**JSONArray**類建立一個 JSON 陣列來儲存 MyPlayers 表的記錄。
JSONArray array = new JSONArray();
  • 對於**MyPLayers**表中的每條記錄,建立一個 JSON(再次)物件,使用**put()**方法將記錄的內容(從**ResultSet**物件中獲取)插入其中。

最後,將 JSON 物件新增到上一步建立的陣列中。

while(rs.next()) {
   JSONObject record = new JSONObject();
   //Inserting key-value pairs into the json object
   record.put("ID", rs.getInt("ID"));
   record.put("First_Name", rs.getString("First_Name"));
   record.put("Last_Name", rs.getString("Last_Name"));
   record.put("Date_Of_Birth", rs.getDate("Date_Of_Birth"));
   record.put("Place_Of_Birth", rs.getString("Place_Of_Birth"));
   record.put("Country", rs.getString("Country"));
   array.add(record);
}

使用 FileReader 將 JSON 物件寫入檔案

  • 將 JSON 陣列的所有必需記錄都新增到父 JSON 物件後,使用**put()**方法將其新增到父 JSON 物件中。
jsonObject.put("Players_data", array);
  • 使用 FileWriter 類將建立的 JSON 物件寫入檔案,如下所示:
FileWriter file = new FileWriter("E:/json_array_output.json");
file.write(jsonObject.toJSONString());
file.close();

以下 JDBC 程式將 MyPlayers 表的內容讀取到 JSON 檔案中。

示例

import java.io.FileWriter;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import org.json.simple.JSONArray;
import org.json.simple.JSONObject;
public class DataBaseToJson {
   public static ResultSet RetrieveData() throws Exception {
      //Registering the Driver
      DriverManager.registerDriver(new com.mysql.jdbc.Driver());
      //Getting the connection
      String mysqlUrl = "jdbc:mysql:///sample_database";
      Connection con = DriverManager.getConnection(mysqlUrl, "root", "password");
      System.out.println("Connection established......");
      //Creating the Statement
      Statement stmt = con.createStatement();
      //Retrieving the records
      ResultSet rs = stmt.executeQuery("Select * from MyPlayers");
      return rs;
   }
   public static void main(String args[]) throws Exception {
      //Creating a JSONObject object
      JSONObject jsonObject = new JSONObject();
      //Creating a json array
      JSONArray array = new JSONArray();
      ResultSet rs = RetrieveData();
      //Inserting ResutlSet data into the json object
      while(rs.next()) {
         JSONObject record = new JSONObject();
         //Inserting key-value pairs into the json object
         record.put("ID", rs.getInt("ID"));
         record.put("First_Name", rs.getString("First_Name"));
         record.put("Last_Name", rs.getString("Last_Name"));
         record.put("Date_Of_Birth", rs.getDate("Date_Of_Birth"));
         record.put("Place_Of_Birth", rs.getString("Place_Of_Birth"));
         record.put("Country", rs.getString("Country"));
         array.add(record);
      }
      jsonObject.put("Players_data", array);
      try {
         FileWriter file = new FileWriter("E:/output.json");
         file.write(jsonObject.toJSONString());
         file.close();
      } catch (IOException e) {
         // TODO Auto-generated catch block
         e.printStackTrace();
      }
      System.out.println("JSON file created......);
   }
}

輸出

JSON file created......

如果您觀察 output.json 檔案,您會看到讀取的內容如下所示:

{
   "Players_data":
   [
      {
         "First_Name":"Shikhar",
         "Place_Of_Birth":"Delhi",
         "Last_Name":"Dhawan",
         "Country":"India",
         "ID":1,
         "Date_Of_Birth":1981-12-05
      },
      {
         "First_Name":"Jonathan",
         "Place_Of_Birth":"CapeTown",
         "Last_Name":"Trott",
         "Country":"SouthAfrica",
         "ID":2,
         "Date_Of_Birth":1981-04-22
      },
      {
         "First_Name":"Kumara",
         "Place_Of_Birth":"Matale",
         "Last_Name":"Sangakkara",
         "Country":"Srilanka",
         "ID":3,
         "Date_Of_Birth":1977-10-27
      },
      {
         "First_Name":"Virat",
         "Place_Of_Birth":"Mumbai",
         "Last_Name":"Kohli",
         "Country":"India",
         "ID":4,
         "Date_Of_Birth":1988-11-05
      },
      {
         "First_Name":"Rohit",
         "Place_Of_Birth":"Nagpur",
         "Last_Name":"Sharma",
         "Country":"India",
         "ID":5,
         "Date_Of_Birth":1987-04-30
      },
      {
         "First_Name":"Ravindra",
         "Place_Of_Birth":"Nagpur",
         "Last_Name":"Jadeja",
         "Country":"India",
         "ID":6,
         "Date_Of_Birth":1988-12-06
      },
      {
         "First_Name":"James",
         "Place_Of_Birth":"Burnely",
         "Last_Name":"Anderson",
         "Country":"England",
         "ID":7,
         "Date_Of_Birth":1982-06-30
      },
      {
         "First_Name":"Ryan",
         "Place_Of_Birth":"South Africa",
         "Last_Name":"McLaren",
         "Country":"India",
         "ID":8,
         "Date_Of_Birth":1983-02-09
      }
   ]
}

更新於: 2019年7月30日

10K+ 瀏覽量

啟動您的 職業生涯

透過完成課程獲得認證

開始
廣告
© . All rights reserved.