上一篇
在Java工程中连接数据库主要通过JDBC技术实现,步骤如下:,1. 加载数据库驱动(如com.mysql.jdbc.Driver),2. 使用DriverManager建立连接,传入URL、用户名和密码,3. 通过Connection对象创建Statement执行SQL,4. 处理ResultSet结果集,也可使用连接池(如HikariCP)或ORM框架(MyBatis/Hibernate)优化管理连接。
在Java工程中连接数据库是开发中的核心任务,主要通过JDBC(Java Database Connectivity) 实现,以下是详细步骤和最佳实践,确保安全、高效且符合现代工程标准:
连接数据库的核心步骤(以MySQL为例)
准备工作
- 数据库驱动:
添加数据库驱动依赖(如MySQL的mysql-connector-java),Maven项目中在pom.xml添加:<dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>8.0.33</version> <!-- 使用最新稳定版 --> </dependency> - 数据库信息:
准备数据库URL、用户名和密码(示例):String url = "jdbc:mysql://localhost:3306/mydb?useSSL=false&serverTimezone=UTC"; String user = "root"; String password = "your_password";
注册驱动并建立连接
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class DBConnector {
public static void main(String[] args) {
try {
// 1. 注册驱动(JDBC 4.0+ 可自动加载,此步可省略)
Class.forName("com.mysql.cj.jdbc.Driver");
// 2. 建立连接
try (Connection connection = DriverManager.getConnection(url, user, password)) {
System.out.println("数据库连接成功!");
// 后续执行SQL操作...
}
} catch (ClassNotFoundException | SQLException e) {
e.printStackTrace();
}
}
}
执行SQL操作(示例:查询数据)
try (Connection conn = DriverManager.getConnection(url, user, password);
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT * FROM users")) {
while (rs.next()) {
String name = rs.getString("name");
int age = rs.getInt("age");
System.out.println(name + ", " + age);
}
} catch (SQLException e) {
e.printStackTrace();
}
关键优化与安全实践
使用连接池提升性能
避免频繁创建连接,推荐连接池工具:
-
HikariCP(高性能):

<dependency> <groupId>com.zaxxer</groupId> <artifactId>HikariCP</artifactId> <version>5.0.1</version> </dependency>配置示例:
HikariConfig config = new HikariConfig(); config.setJdbcUrl(url); config.setUsername(user); config.setPassword(password); config.setMaximumPoolSize(10); // 连接池大小 try (HikariDataSource dataSource = new HikariDataSource(config); Connection conn = dataSource.getConnection()) { // 操作数据库... }
防止SQL注入
必须使用PreparedStatement替代Statement:
String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
pstmt.setString(1, "Alice");
pstmt.setString(2, "alice@example.com");
pstmt.executeUpdate();
}
安全管理敏感信息
- 绝不硬编码凭证:
将数据库配置存储在外部文件(如config.properties):
db.url=jdbc:mysql://localhost:3306/mydb db.user=root db.password=secret
通过类加载读取:
Properties props = new Properties(); props.load(new FileInputStream("config.properties")); String url = props.getProperty("db.url");
异常处理与资源释放
- 使用try-with-resources(Java 7+)自动关闭连接、Statement和ResultSet。
- 捕获
SQLException并记录日志(推荐SLF4J或Log4j)。
常见问题解决
-
驱动类找不到:
检查依赖是否引入,或显式调用Class.forName("com.mysql.cj.jdbc.Driver")。 -
时区错误:
在URL中添加serverTimezone=UTC(如jdbc:mysql://localhost:3306/db?serverTimezone=UTC)。 -
SSL警告:
测试环境可加useSSL=false,生产环境需配置真实证书。
进阶建议
- ORM框架:
使用MyBatis或Hibernate简化CRUD操作。 - 事务管理:
通过conn.setAutoCommit(false)和commit()/rollback()确保数据一致性。 - 连接池监控:
集成Micrometer等工具监控连接池状态。
Java连接数据库的核心是JDBC,但生产环境需结合连接池、预编译语句和外部化配置,遵循这些实践可保障代码的安全性、性能与可维护性,始终参考官方文档并根据数据库类型调整细节(如Oracle的驱动类为oracle.jdbc.OracleDriver)。
引用说明:
- MySQL官方文档:Connector/J Developer Guide
- HikariCP GitHub:性能基准测试
- Oracle JDBC指南:JDBC Basics
