如何使用 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://127.0.0.1/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+ 浏览量

启动您的 职业生涯

通过完成课程获得认证

开始
广告