写一个连接数据库并将数据插入数据库的工具类
时间: 2024-02-19 09:02:26 浏览: 71
连接数据库工具
3星 · 编辑精心推荐
好的,以下是一个简单的 Java 工具类,用于连接数据库并将数据插入数据库:
```java
import java.sql.*;
public class DBUtil {
private static final String url = "jdbc:mysql://localhost:3306/mydatabase"; // 数据库连接地址
private static final String username = "root"; // 数据库用户名
private static final String password = "123456"; // 数据库密码
/**
* 获取数据库连接
*/
public static Connection getConnection() {
Connection conn = null;
try {
// 加载数据库驱动
Class.forName("com.mysql.jdbc.Driver");
// 建立数据库连接
conn = DriverManager.getConnection(url, username, password);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
return conn;
}
/**
* 关闭数据库连接
*/
public static void close(Connection conn, Statement stmt, ResultSet rs) {
try {
if (rs != null) {
rs.close();
}
if (stmt != null) {
stmt.close();
}
if (conn != null) {
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
/**
* 将数据插入到数据库
*/
public static boolean insert(String sql, Object... params) {
Connection conn = null;
PreparedStatement pstmt = null;
boolean result = false;
try {
// 获取数据库连接
conn = getConnection();
// 创建 PreparedStatement 对象
pstmt = conn.prepareStatement(sql);
// 设置 SQL 参数
for (int i = 0; i < params.length; i++) {
pstmt.setObject(i + 1, params[i]);
}
// 执行 SQL 语句并获取执行结果
int count = pstmt.executeUpdate();
result = (count > 0);
} catch (SQLException e) {
e.printStackTrace();
} finally {
// 关闭 PreparedStatement 对象和数据库连接
close(conn, pstmt, null);
}
return result;
}
}
```
这个工具类封装了获取数据库连接、关闭数据库连接和将数据插入到数据库的方法。其中,getConnection() 方法用于获取数据库连接,close() 方法用于关闭数据库连接和相关资源,insert() 方法用于将数据插入到数据库。在 insert() 方法中,我们使用 PreparedStatement 对象设置 SQL 参数,然后通过 executeUpdate() 方法执行 SQL 语句,最后返回执行结果。需要注意的是,在使用完 PreparedStatement 对象和数据库连接之后,一定要调用它们的 close() 方法关闭资源,否则会导致数据库连接泄露。
阅读全文