當(dāng)編寫一些小功能的的程序的時候荞胡，需要對數(shù)據(jù)庫進行操作，如果我們還使用spring + mybatis 的方式來訪問數(shù)據(jù)庫的話砰盐，會顯得略微龐大肿仑，這時可以使用Commons DbUtils 與 c3p0 結(jié)合，輕量小巧腥泥，很適合小項目開發(fā)匾南。
簡介
commons-dbutils是Apache組織提供的一個開源JDBC工具類庫，它是對JDBC的簡單封裝蛔外，學(xué)習(xí)成本極低蛆楞，并且使用dbutils能極大簡化jdbc編碼的工作量，同時也不會影響程序的性能夹厌。
c3p0數(shù)據(jù)庫連接池配置文件
在項目的src或resource目錄下加入c3p0-config.xml 配置文件豹爹，配置如下
<?xml version="1.0" encoding="UTF-8" ?>
<c3p0-config>
<default-config> 33
<property name="jdbcUrl">jdbc:mysql://localhost:3306/test</property>
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="user">root</property>
<property name="password">dre@mtech1012</property>
<property name="acquireIncrement">3</property>
<property name="initialPoolSize">10</property>
<property name="minPoolSize">2</property>
<property name="maxPoolSize">10</property>
</default-config>
</c3p0-config>
數(shù)據(jù)庫鏈接工具
獲取c3p0鏈接池工具，并使用ThreadLocal來實現(xiàn)事務(wù)尊流。
public class JdbcUtils {
// 餓漢式
private static DataSource ds = new ComboPooledDataSource();
/**
* 它為null表示沒有事務(wù)
* 它不為null表示有事務(wù)
* 當(dāng)開啟事務(wù)時帅戒，需要給它賦值
* 當(dāng)結(jié)束事務(wù)時，需要給它賦值為null
* 并且在開啟事務(wù)時崖技，讓dao的多個方法共享這個Connection
*/
private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();
public static DataSource getDataSource() {
return ds;
}
// 如果不把c3p0配置文件放在src或resource下的話逻住，就使用如下方式加載
// static {
// try {
// Properties prop = new Properties();
// InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");
// prop.load(in);
// BasicDataSourceFactory factory = new BasicDataSourceFactory();
// ds = factory.createDataSource(prop);
// } catch (Exception e) {
// throw new ExceptionInInitializerError(e);
// }
// }
/**
* dao使用本方法來獲取連接
*/
public static Connection getConnection() throws SQLException {
/*
* 如果有事務(wù)，返回當(dāng)前事務(wù)的con
* 如果沒有事務(wù)迎献，通過連接池返回新的con
*/
Connection con = tl.get();//獲取當(dāng)前線程的事務(wù)連接
if (con != null) return con;
return ds.getConnection();
}
/**
* 開啟事務(wù)
*/
public static void beginTransaction() throws SQLException {
Connection con = tl.get();//獲取當(dāng)前線程的事務(wù)連接
if (con != null) throw new SQLException("已經(jīng)開啟了事務(wù)瞎访，不能重復(fù)開啟！");
con = ds.getConnection();//給con賦值吁恍，表示開啟了事務(wù)
con.setAutoCommit(false);//設(shè)置為手動提交
tl.set(con);//把當(dāng)前事務(wù)連接放到tl中
}
/**
* 提交事務(wù)
*/
public static void commitTransaction() throws SQLException {
Connection con = tl.get();//獲取當(dāng)前線程的事務(wù)連接
if (con == null) throw new SQLException("沒有事務(wù)不能提交扒秸！");
con.commit();//提交事務(wù)
con.close();//關(guān)閉連接
con = null;//表示事務(wù)結(jié)束播演！
tl.remove();
}
/**
* 回滾事務(wù)
*/
public static void rollbackTransaction() throws SQLException {
Connection con = tl.get();//獲取當(dāng)前線程的事務(wù)連接
if (con == null) throw new SQLException("沒有事務(wù)不能回滾！");
con.rollback();
con.close();
con = null;
tl.remove();
}
/**
* 釋放Connection
*/
public static void releaseConnection(Connection connection) throws SQLException {
Connection con = tl.get();//獲取當(dāng)前線程的事務(wù)連接
if (connection != con) {//如果參數(shù)連接伴奥，與當(dāng)前事務(wù)連接不同写烤，說明這個連接不是當(dāng)前事務(wù)，可以關(guān)閉拾徙！
if (connection != null && !connection.isClosed()) {//如果參數(shù)連接沒有關(guān)閉洲炊，關(guān)閉之！
connection.close();
}
}
}
}
dbutils 中的 CRUD
public class Demo {
@Test
public void insert() throws SQLException {
QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
String sql = "insert into users(id,name,password,email,birthday) values(?,?,?,?,?)";
Object[] params = {2, "bbb", "123", "bbb@163.com", new Date()};
runner.update(sql, params);
}
@Test
public void update() throws SQLException {
QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
String sql = "update users set email=? where id=?";
Object[] params = {"yeyiyi@126.com", 1};
runner.update(sql, params);
}
@Test
public void delete() throws SQLException {
QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
String sql = "delete from users where id=?";
runner.update(sql, 2);
}
@Test
public void find() throws SQLException {
QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
String sql = "select * from users where id=?";
User user = (User) runner.query(sql, 1, new BeanHandler(User.class));
System.out.println(user.getEmail());
}
@Test
public void getAll() throws SQLException {
QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
String sql = "select * from users";
List list = (List) runner.query(sql, new BeanListHandler(User.class));
System.out.println(list);
}
@Test
public void batch() throws SQLException {
QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
String sql = "insert into users(id,name,password,email,birthday) values(?,?,?,?,?)";
Object[][] params = new Object[3][5];
for (int i = 0; i < params.length; i++) {
params[i] = new Object[]{i+1, "aa"+i, "123", i+"@sian.com", new Date()};
}
runner.batch(sql, params);
}
}
查詢結(jié)果的封裝
- ArrayHandler：把結(jié)果集中的第一行數(shù)據(jù)轉(zhuǎn)成對象數(shù)組尼啡。
- ArrayListHandler：把結(jié)果集中的每一行數(shù)據(jù)都轉(zhuǎn)成一個數(shù)組暂衡，再存放到List中。
- BeanHandler：將結(jié)果集中的第一行數(shù)據(jù)封裝到一個對應(yīng)的JavaBean實例中崖瞭。
- BeanListHandler：將結(jié)果集中的每一行數(shù)據(jù)都封裝到一個對應(yīng)的JavaBean實例中狂巢，存放到List里。
- ColumnListHandler：將結(jié)果集中某一列的數(shù)據(jù)存放到List中书聚。
- KeyedHandler(name)：將結(jié)果集中的每一行數(shù)據(jù)都封裝到一個Map里唧领，再把這些map再存到一個map里，其key為指定的key寺惫。
- MapHandler：將結(jié)果集中的第一行數(shù)據(jù)封裝到一個Map里疹吃，key是列名，value就是對應(yīng)的值西雀。
- MapListHandler：將結(jié)果集中的每一行數(shù)據(jù)都封裝到一個Map里，然后再存放到List歉摧。
