上一篇
JDBC连接数据库，加载驱动，获取连接，创建语句
Java中实现数据库登录功能,通常需要以下几个步骤：加载数据库驱动、建立数据库连接、执行SQL查询或更新操作、处理结果集以及关闭资源，下面将详细介绍如何使用Java连接不同类型的数据库（以MySQL为例），并提供相应的代码示例。
准备工作
-
引入数据库驱动库
要在Java项目中连接数据库,首先需要引入相应数据库的JDBC驱动，对于MySQL数据库，可以使用
mysql-connector-java驱动，可以通过Maven、Gradle或手动下载JAR文件并添加到项目的类路径中。Maven依赖示例：
<dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>8.0.33</version> </dependency> -
配置数据库连接参数
需要准备数据库的URL、用户名和密码，以MySQL为例：
参数 说明 示例值 URL 数据库的JDBC连接地址 jdbc:mysql://localhost:3306/mydb用户名 数据库的登录用户名 root密码 数据库的登录密码 password
编写Java代码实现数据库登录
以下是一个完整的Java示例,展示如何连接到MySQL数据库并执行简单的查询操作。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.SQLException;
public class DatabaseLoginExample {
// 数据库连接参数
private static final String DB_URL = "jdbc:mysql://localhost:3306/mydb?useSSL=false&serverTimezone=UTC";
private static final String DB_USERNAME = "root";
private static final String DB_PASSWORD = "password";
public static void main(String[] args) {
Connection connection = null;
Statement statement = null;
ResultSet resultSet = null;
try {
// 1. 加载数据库驱动
Class.forName("com.mysql.cj.jdbc.Driver");
System.out.println("数据库驱动加载成功！");
// 2. 建立数据库连接
connection = DriverManager.getConnection(DB_URL, DB_USERNAME, DB_PASSWORD);
System.out.println("数据库连接成功！");
// 3. 创建Statement对象
statement = connection.createStatement();
// 4. 执行SQL查询
String sql = "SELECT id, name, email FROM users";
resultSet = statement.executeQuery(sql);
// 5. 处理结果集
System.out.println("查询结果：");
while (resultSet.next()) {
int id = resultSet.getInt("id");
String name = resultSet.getString("name");
String email = resultSet.getString("email");
System.out.println("ID: " + id + ", Name: " + name + ", Email: " + email);
}
} catch (ClassNotFoundException e) {
System.err.println("数据库驱动未找到！");
e.printStackTrace();
} catch (SQLException e) {
System.err.println("数据库操作错误！");
e.printStackTrace();
} finally {
// 6. 关闭资源
try {
if (resultSet != null) resultSet.close();
if (statement != null) statement.close();
if (connection != null) connection.close();
System.out.println("数据库连接已关闭。");
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
代码详解
| 步骤 | 描述 | 代码片段 |
|---|---|---|
| 1 | 加载数据库驱动 | Class.forName("com.mysql.cj.jdbc.Driver"); |
| 2 | 建立数据库连接 | DriverManager.getConnection(DB_URL, DB_USERNAME, DB_PASSWORD); |
| 3 | 创建Statement对象 | connection.createStatement(); |
| 4 | 执行SQL查询 | statement.executeQuery(sql); |
| 5 | 处理结果集 | 遍历ResultSet并提取数据 |
| 6 | 关闭资源 | 依次关闭ResultSet、Statement、Connection |
使用PreparedStatement防止SQL注入
在实际开发中,直接使用Statement拼接SQL语句存在SQL注入的风险，推荐使用PreparedStatement来预编译SQL语句，提高安全性和性能。
示例代码：
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class SecureDatabaseLoginExample {
// 数据库连接参数
private static final String DB_URL = "jdbc:mysql://localhost:3306/mydb?useSSL=false&serverTimezone=UTC";
private static final String DB_USERNAME = "root";
private static final String DB_PASSWORD = "password";
public static void main(String[] args) {
Connection connection = null;
PreparedStatement preparedStatement = null;
ResultSet resultSet = null;
try {
// 1. 加载数据库驱动
Class.forName("com.mysql.cj.jdbc.Driver");
System.out.println("数据库驱动加载成功！");
// 2. 建立数据库连接
connection = DriverManager.getConnection(DB_URL, DB_USERNAME, DB_PASSWORD);
System.out.println("数据库连接成功！");
// 3. 创建PreparedStatement对象
String sql = "SELECT id, name, email FROM users WHERE id = ?";
preparedStatement = connection.prepareStatement(sql);
preparedStatement.setInt(1, 1); // 设置参数
// 4. 执行SQL查询
resultSet = preparedStatement.executeQuery();
// 5. 处理结果集
System.out.println("查询结果：");
while (resultSet.next()) {
int id = resultSet.getInt("id");
String name = resultSet.getString("name");
String email = resultSet.getString("email");
System.out.println("ID: " + id + ", Name: " + name + ", Email: " + email);
}
} catch (ClassNotFoundException e) {
System.err.println("数据库驱动未找到！");
e.printStackTrace();
} catch (SQLException e) {
System.err.println("数据库操作错误！");
e.printStackTrace();
} finally {
// 6. 关闭资源
try {
if (resultSet != null) resultSet.close();
if (preparedStatement != null) preparedStatement.close();
if (connection != null) connection.close();
System.out.println("数据库连接已关闭。");
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
使用连接池优化性能
频繁地创建和关闭数据库连接会影响性能,推荐使用连接池（如HikariCP、C3P0）来管理数据库连接，提高应用的性能和稳定性。
HikariCP示例：
-
添加HikariCP依赖（Maven）：
<dependency> <groupId>com.zaxxer</groupId> <artifactId>HikariCP</artifactId> <version>5.0.1</version> </dependency> -
配置和使用HikariCP：
import com.zaxxer.hikari.HikariConfig; import com.zaxxer.hikari.HikariDataSource; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; public class HikariCPExample { private static HikariDataSource dataSource; static { HikariConfig config = new HikariConfig(); config.setJdbcUrl("jdbc:mysql://localhost:3306/mydb?useSSL=false&serverTimezone=UTC"); config.setUsername("root"); config.setPassword("password"); config.setMaximumPoolSize(10); // 设置最大连接数 dataSource = new HikariDataSource(config); } public static void main(String[] args) { Connection connection = null; PreparedStatement preparedStatement = null; ResultSet resultSet = null; try { // 获取连接 connection = dataSource.getConnection(); System.out.println("数据库连接成功！"); // 创建PreparedStatement对象 String sql = "SELECT id, name, email FROM users WHERE id = ?"; preparedStatement = connection.prepareStatement(sql); preparedStatement.setInt(1, 1); // 设置参数 // 执行SQL查询 resultSet = preparedStatement.executeQuery(); // 处理结果集 System.out.println("查询结果："); while (resultSet.next()) { int id = resultSet.getInt("id"); String name = resultSet.getString("name"); String email = resultSet.getString("email"); System.out.println("ID: " + id + ", Name: " + name + ", Email: " + email); } } catch (SQLException e) { System.err.println("数据库操作错误！"); e.printStackTrace(); } finally { // 关闭资源 try { if (resultSet != null) resultSet.close(); if (preparedStatement != null) preparedStatement.close(); if (connection != null) connection.close(); // 连接会返回连接池，不会物理关闭 System.out.println("数据库连接已释放。"); } catch (SQLException e) { e.printStackTrace(); } } } }
异常处理与资源管理
在数据库操作中,务必处理好异常并确保资源的正确关闭，Java 7引入的try-with-resources语法可以简化资源管理，自动关闭实现了AutoCloseable接口的资源。
示例代码：
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class TryWithResourcesExample {
private static final String DB_URL = "jdbc:mysql://localhost:3306/mydb?useSSL=false&serverTimezone=UTC";
private static final String DB_USERNAME = "root";
private static final String DB_PASSWORD = "password";
public static void main(String[] args) {
// 使用try-with-resources自动管理资源
try (Connection connection = DriverManager.getConnection(DB_URL, DB_USERNAME, DB_PASSWORD);
PreparedStatement preparedStatement = connection.prepareStatement("SELECT id, name, email FROM users WHERE id = ?");
ResultSet resultSet = preparedStatement) {
preparedStatement.setInt(1, 1); // 设置参数
resultSet.next(); // 执行查询并移动到第一行
int id = resultSet.getInt("id");
String name = resultSet.getString("name");
String email = resultSet.getString("email");
System.out.println("ID: " + id + ", Name: " + name + ", Email: " + email);
} catch (SQLException e) {
System.err.println("数据库操作错误！");
e.printStackTrace();
}
}
}
归纳与最佳实践
- 使用PreparedStatement：避免SQL注入，提高查询效率。
- 使用连接池：如HikariCP，减少连接创建开销，提升性能。
- 合理管理资源：使用try-with-resources确保资源自动关闭，防止资源泄漏。
- 异常处理：捕获并处理
SQLException，记录日志以便排查问题。 - 配置文件管理：将数据库连接参数放在配置文件中，便于管理和修改。
- 安全性考虑：保护好数据库凭证，避免硬编码敏感信息，建议使用环境变量或加密存储。
相关问答FAQs
问题1：如何处理数据库连接失败的情况？
解答：
当数据库连接失败时，通常会抛出SQLException，应在代码中捕获该异常，并进行适当的处理，例如记录错误日志、提示用户检查数据库配置或重试连接，确保在捕获异常后正确关闭已打开的资源，以防止资源泄漏，示例如下：
try {
connection = DriverManager.getConnection(DB_URL, DB_USERNAME, DB_PASSWORD);
} catch (SQLException e) {
System.err.println("无法连接到数据库，请检查配置！");
e.printStackTrace();
// 根据需求决定是否退出程序或进行其他处理
}
问题2：为什么推荐使用连接池而不是每次操作都创建新的数据库连接？
解答：
每次创建和关闭数据库连接都是一个耗时的操作，尤其是在高并发环境下，频繁地创建和销毁连接会显著影响应用的性能和响应速度，连接池通过预先创建一定数量的连接并重复利用这些连接，减少了连接建立和销毁的开销，提高了资源利用率和应用的整体性能。
