第四章：使用Spring进行JDBC数据访问

重点：使用普通JDBC访问所带来的问题

Spring的JDBC支持的优势

配置和使用Spring的JDBC支持

正确处理和转换SQLException和SQL错误代码

4.1使用普通JDBC访问，如下的数据库访问模板代码会散落在数据访问层的各个角落，长期维护将会变成一场噩梦。

Connection conn = null;try {         Class.forName("oracle.jdbc.driver.OracleDriver");         String  url="jdbc:oracle:thin:@192.168.5.108:1530:billdb";         String  username="oracle";         String  password=" oracle ";         conn  = DriverManager.getConnection(url, username, password);         conn.setAutoCommit(false);  //将自动提交设置为false          conn.begin();                        //执行CRUD操作  //业务处理         conn.commit();      //当CRUD操作成功后手动提交  }catch (Exception e) {         conn.rollback();}finally {         conn.close(); }

4.2.1管理JDBC连接，两种方式，一种是DriverManager，另一种是DataSource。

DriverManagerDataSource是DataSource接口的简单实现，不具备连接池功能，每次使用都会尝试打开新的物理JDBC连接，非常耗性能。

SingleConnectionDataSource是DataSource接口另一种实现，该类重复使用相同的连接。

BasicDataSource是带有连接池功能的DataSource实例，对于企业级Java生产环境推荐使用。

4.2.2配置和使用Spring的JDBC支持

Spring的JDBC支持核心类是JdbcTemplate，该类是线程安全的，主要依赖项是一个DataSource对象。

public JdbcTemplate(DataSource  dataSource) {
         setDataSource(dataSource);
         afterPropertiesSet();
}
public JdbcTemplate(DataSource  dataSource, boolean lazyInit) {
         setDataSource(dataSource);
         setLazyInit(lazyInit);
         afterPropertiesSet();
}

4.3使用Spring执行数据库访问

JdbcTemplate实现了Template Method模式，该模式尝试将一个算法的主要步骤进行封装，从而能够让开发人员通过方法参数更改算法的不同部分。下面列几个常用的数据库访问方法：

public class JdbcTemplate {
  void execute(String sql) throws DataAccessException;
  <T> List<T> query(String sql, RowMapper<T> rowMapper) throws DataAccessException;
  <T> T queryForObject(String sql, RowMapper<T> rowMapper) throws DataAccessException;
  Map<String, Object> queryForMap(String sql) throws DataAccessException;
  List<Map<String, Object>> queryForList(String sql) throws DataAccessException;
  SqlRowSet queryForRowSet(String sql) throws DataAccessException;
  int update(String sql) throws DataAccessException;
  int[] batchUpdate(String... sql) throws DataAccessException;
  ……
  ……
}

4.5.2SQLException的自动处理和转换

第五章：通过Spring使用JPA进行数据库访问，暂且忽略待研究。

第六章：使用Spring管理事务

重点：理解事务管理的工作原理

Spring事务抽象的优点

使用Spring执行声明式和编程式事务管理

细节参考spring事务管理与配置

Spring事务传播性

connection.setAutoCommit(false);用来定义事务边界的起点；

connection. commit();用来定义事务成功终止；

connection. rollback();用来定义事务失败终止，告诉JDBC抛弃所做的任何更改；

6.4使用Spring进行编程式事务管理

（1）使用TransactionTemplate，Spring推荐方法；

（2）直接使用PlatformTransactionManager，这是一种低级的方法。

@Override
public void transferA(final String  out, final String in, final Double money)
     throws Exception {
     transactionTemplate.execute(new TransactionCallbackWithoutResult() {
        protected void  doInTransactionWithoutResult(TransactionStatus status) {
         //执行CRUD操作  //业务处理
        }
     });
}

注意：在类和方法上都不使用@Transactional注解

TransactionTemplate是基于Template Method模式。当一个算法的主要流程被预先定义且固定时，该模式是非常有用的。我们只需要通过回调将更改的部分添加到算法中，就可以在正确的时间在算法逻辑流程中执行这些部分。

try
{
         begin  transaction
         execute transactional code block//TODO:回调
         commit  transaction
} catch (Exception e)
{
         //  TODO: handle exception
         rollback  transaction
} finally {
         do  resource clean up
}

TransactionTemplate，不管是受检查的异常还是非检查异常，都会执行回滚操作。

6.5在事务之前或之后执行自定义逻辑

允许开发人员注册一个自定义业务逻辑，可以在当前事务划分之前或之后执行该逻辑。有两种实现方法：一种是Spring Aop，另一种是注册一个在当前事务结束时执行的回调实例TransactionSynchronization。

6.5.1通知事务性操作，可以通过实现MethodInterceptor接口来拦截方法调用

public interface MethodInterceptor  extends Interceptor {
         Object  invoke(MethodInvocation invocation) throws Throwable;
}
public class Profiler implements  MethodInterceptor
{
         @Override
         public  Object invoke(MethodInvocation invocation) throws Throwable {
                   //  TODO 调用之前做一些额外操作
                   try
                   {
                            return  invocation.proceed();
                   }  finally
                   {
                            //  TODO: 调用之后做一些额外操作
                   }
         }
}

6.5.2使用TransactionSynchronization，在执行事务之后执行自定义业务逻辑的回调接口

public interface  TransactionSynchronization extends Flushable {
         int  STATUS_COMMITTED = 0;
         int  STATUS_ROLLED_BACK = 1;
         int  STATUS_UNKNOWN = 2;
         void  suspend();
         void  resume();
         @Override
         void  flush();
         void  beforeCommit(boolean readOnly);
         void  beforeCompletion();
         void  afterCommit();
         void  afterCompletion(int status);
}