JDBC封装学习笔记（一）

这几天一直在研究JDBC，相比于之前那种简单的代码，更需要追求封装性更好的代码，这样耦合度才会降低，比如，各种数据库的配置都放在一个properties文件中，这样在维护时就可以不用修改代码，直接修改配置文件的数据库信息即可。这个例子我用的是Mysql数据库，首先目录结构如下图所示：

jdbc.properties中的主要内容如下图所示，localhost:3306/后面是数据库的名称

然后接下来就到了重头戏了，代码部分，这里我封装了一个公共类，然后里面暂时写了两个方法，连接数据库和释放资源，当然这一次的实例不涉及到select操作，所以释放资源没有，不过道理是一样的，不过释放资源时，相比statement，connection。ResultSet对象是要先释放的

公共类：JDBCUtils

package com.jdbc.basedemo;

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

/*
* 操作数据库的公共类，里面是一些公共方法
* */
public class JDBCUtils {
// 获取数据库连接
// 连接数据库

public static Connection getConnection() throws ClassNotFoundException, IOException, SQLException {
// 定义相关变量
String driverClass = null;
String jdbcUrl = null;
String user = null;
String password = null;

// 读取配置文件jdbc.properties
InputStream in = JDBCUtils.class.getClassLoader().getResourceAsStream("jdbc.properties");

Properties properties = new Properties();
properties.load(in);
driverClass = properties.getProperty("driver");
jdbcUrl = properties.getProperty("jdbcUrl");
user = properties.getProperty("user");
password = properties.getProperty("password");
// 加载数据库驱动
Class.forName(driverClass);
// 获取连接
Connection conn = DriverManager.getConnection(jdbcUrl, user, password);
return conn;
}

// 释放资源的方法

public static void closeSource(ResultSet rs, Statement statement, Connection conn) {
if (rs != null) {
try {
rs.close();
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
}
if (statement != null) {
try {
statement.close();
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
}
if (conn != null) {
try {
conn.close();
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
}
}

}

然后写了一个测试类，里面封装了一个公共的执行SQL的方法：

TestJDBCDemo文件：

package com.jdbc.basedemo;

import java.io.IOException;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;

import org.junit.Test;

public class TestJDBCDemo {

public static void main(String[] args) {
// TODO Auto-generated method stub

}

// 封装一个通用的更新方法，适用于INSERT,UPDATE,DELETE
public void updateData(String sql) {
// 获取连接
Connection conn = null;
Statement statement = null;
try {
conn = JDBCUtils.getConnection();// 获得连接
statement = conn.createStatement(); // 创建statement对象
statement.executeUpdate(sql);
System.out.println(sql);
System.out.println("SQL执行成功");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
JDBCUtils.closeSource(rs,statement, conn);
System.out.println("资源关闭成功");
}

}

// 测试方法

//这里用的是Junit框架，需要Junit的jar包
@Test
public void test01() {
String sql = "UPDATE userinfo SET username='伊戈达拉' WHERE username like '%杜兰特%'";
updateData(sql);
}

}

最后控制台运行结果截图附上：