JDBC 进阶

JDBC 进阶

预编译 PreparedStatement

PreparedStatement 类继承自 Statement 类，在 JDBC 开发中用来取代前者。有以下两个优势：

• 可对 SQL 语句进行预编译，可以灵活地修改 SQL 语句，提高开发效率。

• 把用户输入单引号转义，防止恶意注入，保护数据库安全。

Connection connection = DriverManager.getConnection();
String sql = "INSERT INTO test(id,name) VALUES (?,?)";
PreparedStatement stmt = connection.preparedStatement(sql); // 创建对象并预编译
stmt.setInt(1, 755); // 在第一个占位符(?)位置插入数字
stmt.setString(2, "MrJoker"); // 在第二个占位符(?)位置插入字符串
stmt.executeUpdate(); // 更新并执行Copy to clipboardErrorCopied


批处理 executeBath

PreparedStatement 类可以通过 executeBath 方法批量处理 SQL 语句，进一步提高效率。其返回值为一个 int[] 数组。

Connection connection = DriverManager.getConnection();
String sql = "INSERT INTO test(id,name) VALUES (?,?)";
PreparedStatement stmt = connection.prepareStatement(sql);
for (int i = 1; i <= 1000; i++) {
 stmt.setInt(1, i);
 stmt.setString(2, (i + &quot;号士兵&quot;));
 stmt.addBatch(); // 语句添加到批处理序列中
}
preparedStatement.executeBatch(); // 语句发送给数据库批量处理
preparedStatement.clearBatch(); // 清空批处理序列Copy to clipboardErrorCopied


大文本和二进制数据

• clob 用于存储大文本

• blob用于存储二进制数据

JDBC 示例

// 适用于 JDK 1.8 以后版本

import java.sql.*; 

public class MySQLTest{

 static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver"; 
 static final String DB_URL = "jdbc:mysql://localhost:3306/RUNOOB?useSSL=false&serverTimezone=UTC";
 static final String USER = "root"; 
 static final String PASS = "123456";

 public static void useMethod（）{
 Connection conn = null; 
 PreparedStatement stmt = null; 
 try{
 Class.forName(JDBC_DRIVER); 
 conn = DriverManager.getConnection(DB_URL,USER,PASS); 
 stmt = conn.preparedStatement("SELECT id, name, url FROM websites"); 
 ResultSet rs = stmt.executeQuery(); 
 while(rs.next()){
 System.out.println(rs.getString("area_id")); 
 }
 rs.close(); 
 stmt.close(); 
 conn.close(); 
 }catch(SQLException se){ // 处理 JDBC 错误
 se.printStackTrace(); 
 }catch(Exception e){ // 处理 Class.forName 错误
 e.printStackTrace(); 
 }finally{ 
 try{ 
 if(stmt != null) stmt.close(); 
 }catch(SQLException se2){}
 try{
 if(conn != null) conn.close(); 
 }catch(SQLException se){} 
 }
 }
}