数据结构
网络
关系数据库管理系统 (RDBMS)
操作系统
Java
MS Excel
iOS
HTML
CSS
Android
Python
C语言编程
C++
C#
MongoDB
MySQL
Javascript
PHP
物理学
化学
生物学
数学
英语
经济学
心理学
社会学
服装学
法学如何使用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文件的`
示例
让我们使用CREATE语句在MySQL数据库中创建一个名为**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) );
现在，我们将创建一个JSON文档 (players_data.json)，其中包含一个文档数组，数组中的每个文档代表上面创建的MyPlayers表中的一条记录，如下所示：
{
"players_data": [
{
"ID": "1",
"First_Name": "Shikhar",
"Last_Name": "Dhawan",
"Date_Of_Birth": "1981-12-05",
"Place_Of_Birth":"Delhi",
"Country": "India"
},
{
"ID": "2",
"First_Name": "Jonathan",
"Last_Name": "Trott",
"Date_Of_Birth": "1981-04-22",
"Place_Of_Birth":"CapeTown",
"Country": "SouthAfrica"
},
{
"ID": "3",
"First_Name": "Kumara",
"Last_Name": "Sangakkara",
"Date_Of_Birth": "1977-10-27",
"Place_Of_Birth":"Matale",
"Country": "Srilanka"
},
{
"ID": "4",
"First_Name": "Virat",
"Last_Name": "Kohli",
"Date_Of_Birth": "1988-11-05",
"Place_Of_Birth":"Mumbai",
"Country": "India"
},
{
"ID": "5",
"First_Name": "Rohit",
"Last_Name": "Sharma",
"Date_Of_Birth": "1987-04-30",
"Place_Of_Birth":"Nagpur",
"Country": "India"
},
{
"ID": "6",
"First_Name": "Ravindra",
"Last_Name": "Jadeja",
"Date_Of_Birth": "1988-12-06",
"Place_Of_Birth":"Nagpur",
"Country": "India"
},
{
"ID": "7",
"First_Name": "James",
"Last_Name": "Anderson",
"Date_Of_Birth": "1982-06-30",
"Place_Of_Birth":"Burnely",
"Country": "England"
},
{
"ID": "8",
"First_Name": "Ryan",
"Last_Name": "McLaren",
"Date_Of_Birth": "1983-02-09",
"Place_Of_Birth":"South Africa",
"Country": "India"
}
]
}要使用JDBC将**JSON**数组的内容写入数据库：
获取数据库连接
- 使用DriverManager类的**registerDriver()**方法或名为Class的类的forName()方法注册所需数据库的驱动程序类。
DriverManager.registerDriver(new com.mysql.jdbc.Driver());
- 通过将数据库的URL、数据库用户的用户名和密码（以字符串格式）作为参数传递给DriverManager类的**getConnection()**方法来创建一个连接对象。
Connection mysqlCon = DriverManager.getConnection(mysqlUrl, "root", "password");
读取JSON文件的内容
- 实例化json-simple库的JSONParser类。
JSONParser jsonParser = new JSONParser();
- 使用**parse()**方法解析获得的对象的内容。
//Parsing the contents of the JSON file
JSONObject jsonObject = (JSONObject) jsonParser(new FileReader("E:/players_data.json"));- 使用**get()**方法将json数组检索到JSONArray对象中。
JSONArray jsonArray = (JSONArray) jsonObject.get("contact");将读取的JSON内容插入MyPlayers表
- 创建一个**PreparedStatement**对象以将值插入MyPLayers表。
PreparedStatement pstmt = con.prepareStatement("INSERT INTO MyPlayers values (?, ?, ?, ?, ?, ? )");- 对于JSON数组中的每条记录，使用get方法检索键值对，并使用setXXX()方法将值设置到PreparedStatement的相应绑定变量。
JSONObject record = (JSONObject) object;
int id = Integer.parseInt((String) record.get("ID"));
String first_name = (String) record.get("First_Name");
pstmt.setInt(1, id);
pstmt.setString(2, first_name);下面的JDBC程序将players_data.json文件的内容插入MyPlayers表。
示例
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.sql.Connection;
import java.sql.Date;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import org.json.simple.JSONArray;
import org.json.simple.JSONObject;
import org.json.simple.parser.JSONParser;
import org.json.simple.parser.ParseException;
public class JsonToDatabase {
public static Connection ConnectToDB() throws Exception {
//Registering the Driver
DriverManager.registerDriver(new com.mysql.jdbc.Driver());
//Getting the connection
String mysqlUrl = "jdbc:mysql:///mydatabase";
Connection con = DriverManager.getConnection(mysqlUrl, "root", "password");
System.out.println("Connection established......");
return con;
}
public static void main(String args[]) {
//Creating a JSONParser object
JSONParser jsonParser = new JSONParser();
try {
//Parsing the contents of the JSON file
JSONObject jsonObject = (JSONObject) jsonParser.parse(new FileReader("E:/players_data.json"));
//Retrieving the array
JSONArray jsonArray = (JSONArray) jsonObject.get("players_data");
Connection con = ConnectToDB();
//Insert a row into the MyPlayers table
PreparedStatement pstmt = con.prepareStatement("INSERT INTO MyPlayers values (?, ?, ?, ?, ?, ? )");
for(Object object : jsonArray) {
JSONObject record = (JSONObject) object;
int id = Integer.parseInt((String) record.get("ID"));
String first_name = (String) record.get("First_Name");
String last_name = (String) record.get("Last_Name");
String date = (String) record.get("Date_Of_Birth");
long date_of_birth = Date.valueOf(date).getTime();
String place_of_birth = (String) record.get("Place_Of_Birth");
String country = (String) record.get("Country");
pstmt.setInt(1, id);
pstmt.setString(2, first_name);
pstmt.setString(3, last_name);
pstmt.setDate(4, new Date(date_of_birth));
pstmt.setString(5, place_of_birth);
pstmt.setString(6, country);
pstmt.executeUpdate();
}
System.out.println("Records inserted.....");
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} catch (ParseException e) {
e.printStackTrace();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}输出
Connection established...... Records inserted......
如果您使用SELECT语句验证MyPlayers表的内容，您可以看到插入的记录如下：
mysql> select * from MyPlayers; +----+------------+------------+---------------+----------------+-------------+ | ID | First_Name | Last_Name | Date_Of_Birth | Place_Of_Birth | Country | +----+------------+------------+---------------+----------------+-------------+ | 1 | Shikhar | Dhawan | 1981-12-05 | Delhi | India | | 2 | Jonathan | Trott | 1981-04-22 | CapeTown | SouthAfrica | | 3 | Kumara | Sangakkara | 1977-10-27 | Matale | Srilanka | | 4 | Virat | Kohli | 1988-11-05 | Mumbai | India | | 5 | Rohit | Sharma | 1987-04-30 | Nagpur | India | | 6 | Ravindra | Jadeja | 1988-12-06 | Nagpur | India | | 7 | James | Anderson | 1982-06-30 | Burnely | England | | 8 | Ryan | McLaren | 1983-02-09 | South Africa | India | +----+------------+------------+---------------+----------------+-------------+ 8 rows in set (0.00 sec
更新于：2019年7月30日
9K+ 浏览量
广告