MySQL, Oracle, Linux, 软件架构及大数据技术知识分享平台

网站首页 > 数据库 / 正文

《Spring入门经典》:使用Spring进行JDBC数据库访问、事务管理

2024-11-26 17:45 huorong 数据库 6 ℃ 0 评论

第四章:使用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);
}

Tags:jdbc for oracle

控制面板
您好,欢迎到访网站!
  查看权限
网站分类
最新留言