工具类之数据库工具类：DBUtil（采用反射机制）

经常操作数据库的码农们一定知道操作数据库是一项很复杂的工作，它不仅要解决各种乱码的问题还要解决各种数据表的增删改查等的操作。 另外每次操作数据库都要用到数据库连接、执行SQL语句、关闭连接的操作，所以在这里我就把这些功能封装到了一个工具类中，

经常操作数据库的码农们一定知道操作数据库是一项很复杂的工作，它不仅要解决各种乱码的问题还要解决各种数据表的增删改查等的操作。

另外每次操作数据库都要用到数据库连接、执行SQL语句、关闭连接的操作，所以在这里我就把这些功能封装到了一个工具类中，该类使用的是反射机制写成的，也就是说它可以帮助你完成对任何数据表的操作。关键代码如下：

首先是配置文件：config.properties

driverName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/
dateName=dateName
sqlSetting=?useUnicode=true&characterEncoding=utf-8
user=userName
pwd=userPwd

 

其次是数据库连接工具类：DBUtil.java

public class DBUtil {

private static String driverName = null;
private static String url = null;
private static String dateName = null;
private static String sqlSetting = null;
private static String user = null;
private static String pwd = null;

/**
* 读取配置文件并为初始化成员变量
*/
static{
InputStream is = DBUtil.class.getClassLoader().getResourceAsStream("config.properties");
Properties properties = new Properties();
try {
if(is != null)
properties.load(is);
} catch (IOException e) {
e.printStackTrace();
}
driverName = properties.getProperty("driverName");
url = properties.getProperty("url");
dateName = properties.getProperty("dateName");
sqlSetting = properties.getProperty("sqlSetting");
user = properties.getProperty("user");
pwd = properties.getProperty("pwd");
url += dateName + sqlSetting;
}

/**
* 加载数据库驱动
*/
static{
try {
Class.forName(driverName);
} catch (ClassNotFoundException e) {
throw new ExceptionInInitializerError("加载驱动出错");
}
}

/**
* 获取数据库连接
* @return 返回数据库的连接
*/
public static Connection getConnection(){
try {
return DriverManager.getConnection(url, user, pwd);
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}

/**
* 关闭数据库连接
* @param rs 要关闭结果集对象
* @param pstat 要关闭的预编译语句对象
* @param conn 要关闭的数据库连接
*/
public static void close(ResultSet rs,PreparedStatement pstat,Connection conn){
try {
if(rs != null)
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}finally{
try {
if(pstat != null)
pstat.close();
} catch (SQLException e) {
e.printStackTrace();
}finally{
try {
if(conn != null)
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
}

 

然后就是泛型表的增删改查类：

public class DBDao {

/**
* 保存给出的t对象到相应的数据库中
* 
* @param t 要保存到数据库的对象
*/
public static void insert(T t) {
// 获取对象t的class对象
@SuppressWarnings("unchecked")
Class cla = (Class) t.getClass();
// 获取对象t的所有字段
Field[] fields = cla.getDeclaredFields();
// 声明列表用于存放对象t的字段变量名
List keys = new ArrayList();
// 声明列表用于存放对象t的字段的值
List