在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
原创文章,发布者:酷盾叔,转转请注明出处:https://www.kd.cn/ask/23310.html