|
|
package com.utils;
|
|
|
// 声明该类所在的包名为com.utils
|
|
|
|
|
|
import java.sql.Connection;
|
|
|
// 导入java.sql包中的Connection类,用于表示与数据库的连接
|
|
|
|
|
|
import java.sql.DriverManager;
|
|
|
// 导入java.sql包中的DriverManager类,用于管理数据库驱动程序
|
|
|
|
|
|
import java.sql.ResultSet;
|
|
|
// 导入java.sql包中的ResultSet类,用于处理数据库查询结果集
|
|
|
|
|
|
import java.sql.Statement;
|
|
|
// 导入java.sql包中的Statement类,用于执行SQL语句
|
|
|
|
|
|
/**
|
|
|
* JDBC工具类,提供数据库连接和资源关闭的静态方法
|
|
|
*/
|
|
|
public class JDBCUtils {
|
|
|
|
|
|
// 数据库驱动类名,这里使用的是MySQL的旧驱动
|
|
|
private static String driver = "com.mysql.jdbc.Driver";
|
|
|
// 数据库连接URL,指定了连接的主机、端口和数据库名
|
|
|
private static String url = "jdbc:mysql://localhost:3306/lsyqfksys";
|
|
|
// 数据库用户名
|
|
|
private static String user = "root";
|
|
|
// 数据库密码
|
|
|
private static String psw = "105293";
|
|
|
|
|
|
/**
|
|
|
* 获取数据库连接
|
|
|
* @return 数据库连接对象,如果连接失败则返回null
|
|
|
*/
|
|
|
public static Connection getConnection(){
|
|
|
// 声明数据库连接对象
|
|
|
Connection connection = null;
|
|
|
try {
|
|
|
// 加载数据库驱动类
|
|
|
Class.forName(driver);
|
|
|
// 通过DriverManager获取数据库连接
|
|
|
connection = DriverManager.getConnection(url, user, psw);
|
|
|
// 打印连接成功信息
|
|
|
System.out.println("连接成功");
|
|
|
}
|
|
|
catch (Exception e){
|
|
|
// 打印异常堆栈信息
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
|
|
|
// 返回数据库连接对象
|
|
|
return connection;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 释放查询操作相关的资源(ResultSet, Statement, Connection)
|
|
|
* @param resultSet 结果集对象
|
|
|
* @param statement SQL语句执行对象
|
|
|
* @param connection 数据库连接对象
|
|
|
*/
|
|
|
public static void close(ResultSet resultSet, Statement statement, Connection connection) {
|
|
|
// 关闭结果集
|
|
|
if (resultSet != null) {
|
|
|
try {
|
|
|
resultSet.close();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
// 关闭Statement对象
|
|
|
if (statement != null) {
|
|
|
try {
|
|
|
statement.close();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
// 关闭数据库连接
|
|
|
if (connection != null) {
|
|
|
try {
|
|
|
connection.close();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 释放更新操作相关的资源(Statement, Connection)
|
|
|
* @param statement SQL语句执行对象
|
|
|
* @param connection 数据库连接对象
|
|
|
*/
|
|
|
public static void close(Statement statement, Connection connection) {
|
|
|
// 关闭Statement对象
|
|
|
if (statement != null) {
|
|
|
try {
|
|
|
statement.close();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
// 关闭数据库连接
|
|
|
if (connection != null) {
|
|
|
try {
|
|
|
connection.close();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 关闭结果集资源
|
|
|
* @param resultSet 结果集对象
|
|
|
*/
|
|
|
public static void close(ResultSet resultSet) {
|
|
|
// 关闭结果集
|
|
|
if (resultSet != null) {
|
|
|
try {
|
|
|
resultSet.close();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
} |