dbutils簡單封裝
阿新 • • 發佈：2019-01-03
dbutils是一個為簡化JDBC操作的小類庫。
pom.xml配置
<dependency>
<groupId>commons-dbutils</groupId>
<artifactId>commons-dbutils</artifactId>
<version>1.6</version>
</dependency>BaseDAO:
public class BaseDAO<T> {
protected BaseDAO中使用的兩個工具類
SpringBeanUtils：
public class SpringBeanUtils implements BeanFactoryAware {
private static BeanFactory beanFactory;
public void setBeanFactory(BeanFactory beanFactory) throws BeansException {
SpringBeanUtils.beanFactory = beanFactory;
}
public static Object getBean(String beanName) {
return beanFactory.getBean(beanName);
}
public static Object getBean(Class clazz) {
WebApplicationContext wac = ContextLoader.getCurrentWebApplicationContext();
return wac.getBean(clazz);
}
}
JdbcUtils：
/**
* 資料庫的常用操作,資料庫連線直接繫結到當前執行緒。
* <p>
* 1、獲取資料庫連線 {@link #getConnection()}
* <p>
* 2、開啟事務 {@link #startTransaction()}
* <p>
* 3、回滾事務 {@link #rollback()}
* <p>
* 4、提交事務 {@link #commit()}
* <p>
* 5、關閉資料庫連線 {@link #close()}
*
*
*/
public class JdbcUtils {
private static DruidDataSource ds = null;
private static ThreadLocal<Connection> threadLocal = new ThreadLocal<Connection>();
/**
* 獲取資料來源
*/
static {
ds = (DruidDataSource) SpringBeanUtils.getBean(DruidDataSource.class);
}
/**
* 從資料來源中獲取資料庫連線
*
* @return Connection
* @throws SQLException
*/
public static Connection getConnection() throws SQLException {
Connection conn = threadLocal.get();
if (conn == null) {
conn = getDataSource().getConnection();
threadLocal.set(conn);
}
return conn;
}
/**
* 開啟事務
*
*/
public static void startTransaction() {
try {
Connection conn = threadLocal.get();
if (conn == null) {
conn = getConnection();
// 把 conn繫結到當前執行緒上
threadLocal.set(conn);
}
// 開啟事務
conn.setAutoCommit(false);
} catch (Exception e) {
throw new RuntimeException(e);
}
}
/**
* 回滾事務
*
*/
public static void rollback() {
try {
// 從當前執行緒中獲取Connection
Connection conn = threadLocal.get();
if (conn != null) {
// 回滾事務
conn.rollback();
}
} catch (Exception e) {
throw new RuntimeException(e);
}
}
/**
* 提交事務
*
*/
public static void commit() {
try {
// 從當前執行緒中獲取Connection
Connection conn = threadLocal.get();
if (conn != null) {
// 提交事務
conn.commit();
}
} catch (Exception e) {
throw new RuntimeException(e);
}
}
/**
* 關閉資料庫連線(注意，這裡只是把連線還給資料庫連線池)
*
*/
public static void close() {
try {
// 從當前執行緒中獲取Connection
Connection conn = threadLocal.get();
if (conn != null) {
conn.close();
// 解除當前執行緒上繫結conn
threadLocal.remove();
}
} catch (Exception e) {
throw new RuntimeException(e);
}
}
/**
* 獲取資料來源
*/
public static DataSource getDataSource() {
// 從資料來源中獲取資料庫連線
return ds;
}
}