如何使用 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
}
]
}
廣告
資料結構
網路
關係型資料庫管理系統
作業系統
Java
iOS
HTML
CSS
Android
Python
C 程式設計
C++
C#
MongoDB
MySQL
Javascript
PHP