设计通用的连接数据库的 JavaBean,供各个业务模块调用 在任何一个系统中,均需大量访问数据库,而访问数据库的流程基本一致,只是执行的SQL语句不同而已,因此可以设计一个通用的数据库访问 JavaBean,封装数据库访问的必要的步骤(如加载驱动,连接数据库,异常处理等),对外提供必要的接口,如查询接口、更新接口和关闭连接的接口等。这个通用的数据库访问组件 Conn.java 的主要代码
时间: 2024-01-22 22:19:57 浏览: 26
以下是一个简单的通用数据库访问 JavaBean - Conn.java 的主要代码:
```java
import java.sql.*;
public class Conn {
private Connection conn;
private Statement stmt;
private ResultSet rs;
private String driver;
private String url;
private String user;
private String password;
// 构造函数,初始化数据库连接
public Conn(String driver, String url, String user, String password) {
this.driver = driver;
this.url = url;
this.user = user;
this.password = password;
try {
Class.forName(driver);
conn = DriverManager.getConnection(url, user, password);
stmt = conn.createStatement();
} catch (Exception e) {
System.out.println("Error: " + e.getMessage());
}
}
// 查询数据,返回 ResultSet 对象
public ResultSet executeQuery(String sql) {
try {
rs = stmt.executeQuery(sql);
} catch (Exception e) {
System.out.println("Error: " + e.getMessage());
}
return rs;
}
// 更新数据,返回受影响的行数
public int executeUpdate(String sql) {
int result = 0;
try {
result = stmt.executeUpdate(sql);
} catch (Exception e) {
System.out.println("Error: " + e.getMessage());
}
return result;
}
// 关闭连接
public void close() {
try {
if (rs != null) rs.close();
if (stmt != null) stmt.close();
if (conn != null) conn.close();
} catch (Exception e) {
System.out.println("Error: " + e.getMessage());
}
}
}
```
使用方法如下:
```java
// 初始化数据库连接
Conn conn = new Conn("com.mysql.jdbc.Driver", "jdbc:mysql://localhost:3306/test", "root", "123456");
// 查询数据
ResultSet rs = conn.executeQuery("SELECT * FROM users");
// 更新数据
int result = conn.executeUpdate("UPDATE users SET name='John' WHERE id=1");
// 关闭连接
conn.close();
```
这个通用的数据库访问组件 Conn.java 可以方便地供各个业务模块调用,只需要传入相应的 SQL 语句即可完成对数据库的查询和更新操作。同时,它也封装了数据库访问的必要的步骤,对外提供了必要的接口,使用起来非常方便。