当前位置：首页 > 后端开发 > 正文

Java如何快速连接数据库？

admin
后端开发
2025-06-19
7

在Java中连接数据库需加载 JDBC驱动，通过DriverManager获取Connection对象，使用Statement或PreparedStatement执行SQL语句，最后处理结果集并关闭资源。

核心步骤：Java连接数据库

Java通过JDBC（Java Database Connectivity） 标准接口实现数据库操作，需以下步骤：

准备数据库驱动

下载JDBC驱动：根据数据库类型选择驱动（如MySQL用mysql-connector-java，Oracle用ojdbc）。
添加依赖：
- Maven项目（在pom.xml中）： <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>8.0.33</version>  </dependency>
- 手动导入：下载JAR文件，放入项目的lib目录并添加到构建路径。

建立数据库连接

使用DriverManager获取连接对象，需提供URL、用户名、密码：

import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class DBConnection { private static final String URL = "jdbc:mysql://localhost:3306/your_database?useSSL=false&serverTimezone=UTC"; private static final String USER = "your_username"; private static final String PASSWORD = "your_password"; public static Connection getConnection() throws SQLException { return DriverManager.getConnection(URL, USER, PASSWORD); } }

关键参数说明：

Java如何快速连接数据库？第1张

URL格式：jdbc:数据库类型://主机:端口/数据库名?参数
例：MySQL需加时区参数serverTimezone=UTC。
安全提示：避免硬编码密码，使用环境变量或配置文件（见下文）。

执行SQL操作

通过Connection创建Statement或PreparedStatement执行SQL：

try (Connection conn = DBConnection.getConnection(); PreparedStatement stmt = conn.prepareStatement("SELECT * FROM users WHERE id=?")) { stmt.setInt(1, 1001); // 设置参数（防SQL载入） ResultSet rs = stmt.executeQuery(); while (rs.next()) { System.out.println(rs.getString("username")); } } catch (SQLException e) { e.printStackTrace(); // 实际项目中应记录日志 }

关闭资源

使用 try-with-resources 自动关闭连接、语句和结果集（Java 7+支持），避免资源泄漏：

Java如何快速连接数据库？第2张

安全与优化实践

避免硬编码敏感信息
- 使用配置文件（如config.properties）： db.url=jdbc:mysql://localhost:3306/mydb db.user=admin db.password=secret
- Java读取配置： Properties props = new Properties(); props.load(new FileInputStream("config.properties")); String url = props.getProperty("db.url");
防SQL载入
务必用PreparedStatement替代Statement，禁止拼接SQL字符串：
// 错误示例（危险！） String sql = "SELECT * FROM users WHERE name='" + inputName + "'"; // 正确做法 PreparedStatement stmt = conn.prepareStatement("SELECT * FROM users WHERE name=?"); stmt.setString(1, inputName);
连接池管理
高并发场景使用连接池（如HikariCP、Tomcat JDBC Pool）提升性能：

HikariConfig config = new HikariConfig(); config.setJdbcUrl("jdbc:mysql://localhost:3306/mydb"); config.setUsername("user"); config.setPassword("password"); try (HikariDataSource ds = new HikariDataSource(config); Connection conn = ds.getConnection()) { // 操作数据库... }

常见问题解决

驱动加载失败：
检查JAR是否在类路径中，MySQL 8+驱动类名为com.mysql.cj.jdbc.Driver（无需显式调用Class.forName()）。
时区错误：
MySQL URL中添加?serverTimezone=UTC。
连接超时：
检查数据库服务是否运行，防火墙是否开放端口（默认MySQL端口3306）。

完整示例代码

import java.sql.*; import java.util.Properties; public class DatabaseDemo { public static void main(String[] args) { // 从配置文件读取信息（安全推荐） Properties props = new Properties(); try { props.load(DatabaseDemo.class.getResourceAsStream("/config.properties")); String url = props.getProperty("db.url"); String user = props.getProperty("db.user"); String password = props.getProperty("db.password"); // 连接并查询 try (Connection conn = DriverManager.getConnection(url, user, password); PreparedStatement stmt = conn.prepareStatement("SELECT email FROM users WHERE id=?")) { stmt.setInt(1, 1001); ResultSet rs = stmt.executeQuery(); if (rs.next()) { System.out.println("Email: " + rs.getString("email")); } } } catch (Exception e) { System.err.println("数据库错误: " + e.getMessage()); } } }