文章目录
- JDBC的概念
- JDBC的常用API
- JDBC示例代码
- PreparedStatement
- CallableStatement
JDBC（Java Database Connectivity）是Java的一种数据库访问标准，它提供了一套API，使得我们可以通过Java程序来访问和操作各种关系型数据库。
下面我们详细介绍JDBC编程，包括JDBC的概念、JDBC的常用API以及示例代码。
JDBC的概念
JDBC是Java的一种数据库访问标准，它提供了一套API，使用这些API可以让Java程序连接各种关系型数据库，并且进行数据的增、删、改、查等操作。
JDBC的架构分为两部分：JDBC API和JDBC Driver。JDBC API定义了Java程序与数据库之间的接口规范；JDBC Driver则负责将Java程序中的JDBC API调用转换成特定数据库的协议，实现与特定数据库的通信。
在JDBC编程中，开发者需要关注以下几个核心概念：
- Connection（连接对象）：表示与数据库的连接。
- Statement（语句对象）：表示执行SQL语句的对象。
- ResultSet（结果集对象）：表示查询结果集的对象。
- PreparedStatement（预编译语句对象）：表示一个预编译的SQL语句对象，可以有效地防止SQL注入攻击。
- CallableStatement（存储过程对象）：表示调用存储过程的对象。
JDBC的常用API
- 加载驱动程序
在使用JDBC之前，需要先加载相应的数据库驱动程序。可以通过Class.forName()方法实现。
Class.forName("com.mysql.jdbc.Driver");
- 建立连接
使用DriverManager.getConnection()方法建立与数据库的连接。
String url = "jdbc:mysql://localhost:3306/test";
String user = "root";
String password = "123456";
Connection conn = DriverManager.getConnection(url, user, password);
- 创建Statement对象
通过Connection对象创建Statement对象。
Statement stmt = conn.createStatement();
- 执行SQL语句
通过Statement对象执行SQL语句。
String sql = "SELECT * FROM users";
ResultSet rs = stmt.executeQuery(sql); // 查询操作
- 处理查询结果
对于查询操作，可以通过ResultSet对象获取查询结果集中的数据。
while (rs.next()) {
int id = rs.getInt("id");
String name = rs.getString("name");
int age = rs.getInt("age");
System.out.println("id=" + id + ", name=" + name + ", age=" + age);
}
- 关闭资源
在使用完JDBC资源后，需要及时关闭它们，以释放内存和资源。
if (rs != null) {
rs.close();
}
if (stmt != null) {
stmt.close();
}
if (conn != null) {
conn.close();
}
JDBC示例代码
下面是一个使用JDBC进行简单查询的示例代码。
import java.sql.*;
public class JdbcDemo {
public static void main(String[] args) {
try {
// 加载MySQL驱动程序
Class.forName("com.mysql.jdbc.Driver");
// 建立与MySQL的连接
String url = "jdbc:mysql://localhost:3306/test";
String user = "root";
String password = "123456";
Connection conn = DriverManager.getConnection(url, user, password);
// 创建Statement对象
Statement stmt = conn.createStatement();
// 执行查询操作
String sql = "SELECT * FROM users WHERE age > 18";
ResultSet rs = stmt.executeQuery(sql);
// 处理查询结果
while (rs.next()) {
int id = rs.getInt("id");
String name = rs.getString("name");
int age = rs.getInt("age");
System.out.println("id=" + id + ", name=" + name + ", age=" + age);
}
// 关闭资源
if (rs != null) {
rs.close();
}
if (stmt != null) {
stmt.close();
}
if (conn != null) {
conn.close();
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException
e) {
e.printStackTrace();
}
}
}
上面的代码使用了JDBC连接到MySQL数据库，并执行了一个查询操作，将年龄大于18岁的用户信息打印出来。在代码中使用了try-catch语句块捕获了异常，并在finally块中关闭了资源。
需要注意的是，在实际开发中，建议使用连接池来管理数据库连接，以提高性能和可靠性。常用的连接池有Apache Commons DBCP和C3P0等。
下面再来介绍一些JDBC的高级特性。
PreparedStatement
使用PreparedStatement可以有效地防止SQL注入攻击，并提升SQL语句执行效率。它是Statement的一个子类，用于预编译SQL语句，然后在执行时只需要传递参数即可。
下面是一个使用PreparedStatement执行插入操作的示例代码。
import java.sql.*;
import org.apache.commons.dbcp2.BasicDataSource;
public class JdbcDemo {
public static void main(String[] args) {
BasicDataSource dataSource = new BasicDataSource();
// 设置数据库连接信息
dataSource.setDriverClassName("com.mysql.jdbc.Driver");
dataSource.setUrl("jdbc:mysql://localhost:3306/test");
dataSource.setUsername("root");
dataSource.setPassword("123456");
try {
// 从连接池中获取连接
Connection conn = dataSource.getConnection();
// 创建PreparedStatement对象
String sql = "INSERT INTO users(name, age) VALUES (?, ?)";
PreparedStatement stmt = conn.prepareStatement(sql);
// 设置参数值
stmt.setString(1, "Tom");
stmt.setInt(2, 25);
// 执行插入操作
int count = stmt.executeUpdate();
System.out.println(count + " rows affected.");
// 关闭资源
if (stmt != null) {
stmt.close();
}
if (conn != null) {
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
在上面的代码中，使用了PreparedStatement的setXXX()方法设置参数值，然后通过executeUpdate()方法执行插入操作。
CallableStatement
使用CallableStatement可以调用存储过程，它是PreparedStatement的另一个子类。
下面是一个使用CallableStatement调用存储过程的示例代码。
import java.sql.*;
import org.apache.commons.dbcp2.BasicDataSource;
public class JdbcDemo {
public static void main(String[] args) {
BasicDataSource dataSource = new BasicDataSource();
// 设置数据库连接信息
dataSource.setDriverClassName("com.mysql.jdbc.Driver");
dataSource.setUrl("jdbc:mysql://localhost:3306/test");
dataSource.setUsername("root");
dataSource.setPassword("123456");
try {
// 从连接池中获取连接
Connection conn = dataSource.getConnection();
// 创建CallableStatement对象
String sql = "{CALL get_user(?, ?)}";
CallableStatement stmt = conn.prepareCall(sql);
// 设置参数值
stmt.setInt(1, 1);
// 注册输出参数类型
stmt.registerOutParameter(2, Types.VARCHAR);
// 执行存储过程
stmt.execute();
// 获取输出参数值
String name = stmt.getString(2);
System.out.println("User name: " + name);
// 关闭资源
if (stmt != null) {
stmt.close();
}
if (conn != null) {
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
在上面的代码中，使用了CallableStatement的registerOutParameter()方法注册输出参数类型，并使用getString()方法获取输出参数值。
总结一下，JDBC是Java的一种数据库访问标准，它提供了一套API，使用这些API可以让Java程序连接各种关系型数据库，并且进行数据的增、删、改、查等操作。JDBC的核心概念包括Connection、Statement、ResultSet、PreparedStatement和CallableStatement等。在实际开发中，建议使用连接池来管理数据库连接，常用的连接池有Apache Commons DBCP和C3P0等。
