使用Java JDBC访问数据库：连接池管理及错误处理

原创青旅半醒 2024-11-21 15:51 50阅读 0赞

在Java中，我们可以使用JDBC（Java Database Connectivity）来访问数据库。下面是一个基本的例子，包括连接池管理和错误处理。

1. **导入相关库**：
```java
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;
```

2. **配置连接池**：
你可以使用JNDI（Java Naming and Directory Interface）来管理连接池，或者直接使用如Apache DBCP或HikariCP等数据库连接池库。

3. **创建Connection对象并处理错误**：
```java
// 设置连接属性
Properties props = new Properties();
props.put("driver", "com.mysql.jdbc.Driver"); // 你的数据库驱动
props.put("url", "jdbc:mysql://localhost:3306/mydatabase"); // 数据库URL
props.put("username", "yourusername"); // 登录用户名
props.put("password", "yourpassword"); // 登录密码

// 创建Connection对象并加入连接池
Connection connection = DriverManager.getConnection(props);
connection.setAutoCommit(false); // 非自动提交模式

// 执行SQL语句，这里假设你有一个表需要查询
String sql = "SELECT * FROM mytable WHERE condition";
try {
    Statement stmt = connection.createStatement();
    ResultSet rs = stmt.executeQuery(sql);

// 处理结果集
    while (rs.next()) {
        // 获取字段名
        String columnName = rs.getMetaData().getColumnLabel(rs.getColumnIndex("myfield"))); 
        // 打印数据
        System.out.println(columnName + " : " + rs.getString(rs.getColumnIndex("myfield")))));
    }
    
} catch (SQLException e) {
    // 处理SQL异常，例如记录错误日志
    System.err.println("An error occurred while executing the SQL: " + e.getMessage());
    
    // 关闭连接，释放资源
    try {
        connection.close();
    } catch (SQLException se) {
        System.out.println("Failed to close connection : " + se.getMessage());
    }
}

// 设置为自动提交
connection.setAutoCommit(true);

```
在这个例子中，我们首先配置了数据库连接属性。然后创建了一个`Connection`对象，并将其加入到连接池中。

在执行SQL语句时，我们捕获并处理了可能的SQLException异常。最后，关闭`Connection`，释放资源。

这就是使用Java JDBC访问数据库，包括连接池管理以及错误处理的基本过程。