jdbc在DAO层实现事务

package dao.oracleImpl; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import org.apache.log4j.Logger; import dao.Transactable; import dao.TransactionInterface; /** * 实现了事务接口的DAO帮助类 * @author Administrator * */ abstract class BaseDAO implements Transactable { private Logger logger = Logger.getLogger(this.getClass()); //Log4j日志工具 private Transaction trans; //与该帮助类关联的事务对象 private static final String DRIVER="oracle.jdbc.driver.OracleDriver"; private static final String URL="jdbc:oracle:thin:@127.0.0.1:1521:SZSX"; private static final String USERNAME="system"; private static final String PASSWORD="ok"; /** * 获取Connection 若要实现事务,必须使用该方法获取Connection而不是自己创建 * @return 获取到的Connection,若当前已启用事务,则获取的将是各DAO共用的Connection以实现事务操作 * @throws Exception 各种原因导致的获取Connection失败 */ Connection getConnection() throws Exception{ logger.debug("正在准备获取Connection"); if(trans !=null && trans.getConnection() !=null){ logger.debug("当前已开启事务,返回事务用Connection"); return trans.getConnection(); }else { logger.debug("判断Connection为空,构建Connection"); try { logger.debug("正在加载驱动"); Class.forName(DRIVER); logger.debug("驱动加载成功,正在构建Connection"); Connection con = DriverManager.getConnection(URL,USERNAME,PASSWORD); logger.debug("Connection构建成功"); return con; } catch (ClassNotFoundException e) { logger.warn("JDBC驱动加载失败"); throw e; } catch (SQLException e) { logger.warn("构建Connection失败"); throw e; } } } /** * 通过SQL语句构造PreparedStatement * @param sql 构造PreparedStatment所使用的SQL语句 * @return 构造完成的PreparedStatement * @throws Exception 各种原因导致的构造PreparedStatement失败 */ PreparedStatement getPreparedStatement(String sql) throws Exception{ logger.debug("即将通过SQL语句:"+sql+"\t构建PreparedStatement"); Connection con =null; PreparedStatement pst=null; try { con = getConnection(); pst = con.prepareStatement(sql); logger.debug("构建PreparedStatement成功"); return pst; } catch (Exception e) { logger.warn("构建PreparedStatement失败"); throw e; } finally{ if(con !=null && pst ==null){ logger.debug("为了保证系统正常运行,即将关闭已获取的Connection并返回空PreparedStatement"); closeAll(null, con); logger.debug("系统已经从异常中恢复"); } } } /** * 执行一个SQL语句(若已启用事务,则该方法不会关闭关联的Connection连接) * @param sql 要执行的SQL语句 * @return 该语句影响的行数 * @throws Exception 各种原因导致的执行失败 */ int executeUpdate(String sql) throws Exception{ logger.debug("即将执行SQL语句:"+sql); PreparedStatement pst =null; try { pst = getPreparedStatement(sql); int count = pst.executeUpdate(); logger.debug("SQL语句执行成功,返回结果:"+count); return count; } catch (Exception e) { logger.warn("SQL语句:"+sql+"\t执行失败"); throw e; }finally{ if(pst !=null){ closeAll(pst); } } } /** * 执行一个PreparedStatement(若已启用事务,则该方法不会关闭关联的Connection连接) * @param pst 要执行的PreparedStatement语句 * @return 该操作影响的行数 * @throws Exception 各种原因导致的执行失败 */ int executeUpdate(PreparedStatement pst) throws Exception{ logger.debug("即将执行PreparedStatement"); if(pst ==null){ logger.warn("发生异常:executeUpdate方法传入的PreparedStatement为null"); throw new NullPointerException("PreparedStatment不能为null"); } try { int count = pst.executeUpdate(); logger.debug("PreparedStatement执行成功,正在返回结果:"+count); return count; } catch (Exception e) { logger.warn("PreparedStatement执行失败"); throw e; }finally{ closeAll(pst); } } /** * 通过SQL语句执行查询(若已启用事务,则该方法不会关闭关联的Connection连接) * 若该操作执行失败,且未启用事务,则关联的Connection连接将自动关闭 * 若该操作执行成功,则关联的Connection连接不会自动关闭,必须手动调用本帮助类提供的closeAll方法来关闭ResultSet * @param sql 要执行的SQL语句 * @return ResultSet 返回结果集(需要调用closeAll方法手动关闭) * @throws Exception 各种原因导致的执行失败 */ ResultSet executeQuery(String sql) throws Exception{ logger.debug("即将执行SQL语句:"+sql); PreparedStatement pst =null; try { pst = getPreparedStatement(sql); ResultSet rs = pst.executeQuery(); logger.debug("SQL语句执行成功,返回ResultSet"); return rs; } catch (Exception e) { logger.warn("执行SQL语句产生异常,异常SQL语句为:"+sql); logger.debug("为了保证系统正常运行,即将关闭已获取的Connection"); if(pst !=null){ closeAll(pst); } logger.debug("系统已经从异常中恢复"); throw e; } } /** * 通过PreparedStatement执行查询(若已启用事务,则该方法不会关闭关联的Connection连接) * 若该操作执行失败,且未启用事务,则关联的Connection连接将自动关闭 * 若该操作执行成功,则关联的Connection连接不会自动关闭,必须手动调用本帮助类提供的closeAll方法来关闭ResultSet * @param pst 要执行的PrepredStatement * @return ResultSet 返回结果集(需要调用closeAll方法手动关闭) * @throws Exception 各种原因导致的执行失败 */ ResultSet executeQuery(PreparedStatement pst) throws Exception{ logger.debug("即将执行PreparedStatement"); if(pst ==null){ logger.warn("发生异常:executeQuery方法传入的PreparedStatement为null"); throw new NullPointerException("PreparedStatment不能为null"); } try { ResultSet rs = pst.executeQuery(); logger.debug("PreparedStatement执行成功,正在返回ResultSet"); return rs; } catch (Exception e) { logger.warn("执行PreparedStatement产生异常"); logger.debug("为了保证系统正常运行,即将关闭已获取的Connection"); closeAll(pst); logger.debug("系统已经从异常中恢复"); throw e; } } /** * 通过Statement关闭所有连接,若该Statement关联的Connection已通过本帮助类启用事务,则该Statement关联的Connection不会自动关闭 * @param st 需要关闭的Statement */ void closeAll(Statement st){ logger.debug("即将通过Statement关闭连接"); if(st !=null){ Connection con =null; try { con = st.getConnection(); logger.debug("通过Statement获取Connection成功,正在准备关闭连接"); } catch (SQLException e) { logger.warn("通过Statement获取Connection失败"); }finally{ closeAll(st,con); } }else{ logger.info("Statment为null,不需要关闭"); } } /** * 通过ResultSet关闭所有连接,若该ResultSet关联的Connection已通过本帮助类启用事务,则该ResultSet关联的Connection不会自动关闭 * @param rs 需要关闭的ResultSet */ void closeAll(ResultSet rs){ logger.debug("即将通过ResultSet关闭连接"); if(rs==null){ logger.info("ResultSet为null,不需要关闭"); }else{ Statement st =null; try { st = rs.getStatement(); logger.debug("通过ResultSet获取Statement成功,正在准备关闭连接"); closeAll(st); } catch (SQLException e) { logger.warn("通过ResultSet获取Statement失败"); } } } /** * 关闭所有连接,若该Connection已通过本帮助类启用事务,则Connection不会自动关闭 * @param st 需要关闭的Statement * @param con 需要关闭的Connection */ void closeAll(Statement st,Connection con) { logger.debug("即将关闭所有连接"); try{ if(st !=null){ st.close(); logger.debug("Statement成功关闭"); } if(this.trans ==null || this.trans.getConnection() ==null){ con.close(); logger.debug("Connection成功关闭"); }else{ logger.info("因存在事务,Connection未关闭"); } }catch (Exception err){ logger.warn("关闭连接发生异常"); } } /** * 启用事务(启用以后所有调用了LinkTransaction方法的DAO所实现的方法都需要手动提交) * @return 生成的用于在DAO之间实现事务关联与执