Java插入JSON对象到PostgreSQL的步骤详解

<groupId>org.postgresql</groupId>  
<artifactId>postgresql</artifactId>  
<version>42.2.24</version> <!-- 确保使用最新版本 -->  
</dependency>

<dependency>
    <groupId>org.json</groupId>
    <artifactId>json</artifactId>
    <version>20240303</version>
</dependency>

create database your_database;
 
CREATE TABLE your_table (
    id SERIAL PRIMARY KEY,
    data JSONB
);

import java.sql.DriverManager;  
import java.sql.PreparedStatement;  
import java.sql.SQLException;  
import org.json.JSONObject;  
 
public class InsertJsonToPostgres {  
 public static void main(String[] args) {  
 // PostgreSQL 数据库连接信息 
String url = "jdbc:postgresql://localhost:5432/your_database";  
 String user = "your_username";  
 String password = "your_password";  
 
 // 示例 JSON 对象 JSONObject jsonObject = new JSONObject();  
 jsonObject.put("name", "John Doe");  
 jsonObject.put("age",30);  
 jsonObject.put("city", "New York");  
 
 // 插入 SQL语句 
String insertSQL = "INSERT INTO your_table(data) VALUES (?::jsonb)";  
 
 try (Connection conn = DriverManager.getConnection(url, user, password);  
 PreparedStatement pstmt = conn.prepareStatement(insertSQL)) {  
 // 将 JSON 对象转换为 String 并设置到 PreparedStatement 中 
pstmt.setString(1, jsonObject.toString());  
 
 // 执行插入操作 
int rowsInserted = pstmt.executeUpdate();  
 if (rowsInserted >0) {  
 System.out.println("A new row was inserted successfully!");  
 }  
 
 } catch (SQLException e) {  
 e.printStackTrace();  
 }  
 }  
}