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

Java连接SQL数据库，哪种方式最适合我的项目需求？

admin
后端开发
2025-09-16
4

Java连接SQL数据库是一个常见的需求，下面将详细介绍如何使用Java连接SQL数据库,包括使用JDBC和连接池等技术。

使用JDBC连接SQL数据库

JDBC（Java Database Connectivity）是Java访问数据库的标准API,以下是如何使用JDBC连接SQL数据库的基本步骤：

Java连接SQL数据库，哪种方式最适合我的项目需求？第1张

步骤	说明
1	导入JDBC驱动包，根据数据库类型导入相应的驱动包，例如MySQL的驱动包为com.mysql.cj.jdbc.Driver。
2	加载JDBC驱动，使用Class.forName()方法加载JDBC驱动。
3	建立数据库连接，使用DriverManager.getConnection()方法建立连接，传入数据库URL、用户名和密码。
4	创建Statement或PreparedStatement，使用Connection.createStatement()或Connection.prepareStatement()方法创建SQL语句执行对象。
5	执行SQL语句，使用Statement.execute()或PreparedStatement.executeUpdate()方法执行SQL语句。
6	处理结果，使用ResultSet对象处理查询结果。
7	关闭资源，使用Statement.close()、ResultSet.close()和Connection.close()方法关闭资源。

以下是一个简单的示例代码：

import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; public class JDBCExample { public static void main(String[] args) { try { // 1. 加载JDBC驱动 Class.forName("com.mysql.cj.jdbc.Driver"); // 2. 建立数据库连接 Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/testdb", "root", "password"); // 3. 创建Statement Statement stmt = conn.createStatement(); // 4. 执行SQL语句 ResultSet rs = stmt.executeQuery("SELECT * FROM users"); // 5. 处理结果 while (rs.next()) { System.out.println("User ID: " + rs.getInt("id") + ", Name: " + rs.getString("name")); } // 6. 关闭资源 rs.close(); stmt.close(); conn.close(); } catch (Exception e) { e.printStackTrace(); } } }

使用连接池连接SQL数据库

连接池可以有效地管理数据库连接，提高数据库访问效率,以下是如何使用连接池连接SQL数据库的基本步骤：

Java连接SQL数据库，哪种方式最适合我的项目需求？第2张

步骤	说明
1	选择连接池实现，常见的连接池实现有Apache DBCP、C3P0和HikariCP等。
2	创建连接池，根据所选连接池实现，创建连接池实例。
3	从连接池获取连接，使用连接池的getConnection()方法获取数据库连接。
4	执行SQL语句，使用获取的连接创建Statement或PreparedStatement，并执行SQL语句。
5	释放连接，使用连接池的close()方法释放连接，返回连接池。

以下是一个使用HikariCP连接池的示例代码：

import com.zaxxer.hikari.HikariConfig; import com.zaxxer.hikari.HikariDataSource; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; public class HikariCPExample { private static HikariDataSource dataSource; static { HikariConfig config = new HikariConfig(); config.setJdbcUrl("jdbc:mysql://localhost:3306/testdb"); config.setUsername("root"); config.setPassword("password"); config.addDataSourceProperty("cachePrepStmts", "true"); config.addDataSourceProperty("prepStmtCacheSize", "250"); config.addDataSourceProperty("prepStmtCacheSqlLimit", "2048"); dataSource = new HikariDataSource(config); } public static void main(String[] args) { try (Connection conn = dataSource.getConnection(); PreparedStatement stmt = conn.prepareStatement("SELECT * FROM users")) { ResultSet rs = stmt.executeQuery(); while (rs.next()) { System.out.println("User ID: " + rs.getInt("id") + ", Name: " + rs.getString("name")); } } catch (Exception e) { e.printStackTrace(); } } }