iBATISDAO事务浅析

iBATIS DAO事务的理解要从iBATIS DAO 框架开始，它提供了事务管理模块。而这个事务管理可以应用到很多场合，包括JDBC、Hibernate、JTA、SQLMAP等。

创新互联专注于企业营销型网站、网站重做改版、会宁网站定制设计、自适应品牌网站建设、H5响应式网站、成都做商城网站、集团公司官网建设、成都外贸网站建设公司、高端网站制作、响应式网页设计等建站业务，价格优惠性价比高，为会宁等各大城市提供网站开发制作服务。

下面以最简单的JDBC来分析一下其如何实现iBATIS DAO事务管理。

首先来看一段代码：

 
 
 
    
  
  
  
  1. public class OrderService {  
    2. 
  
  
  
  2.  
    3. 
  
  
  
  3. private DaoManager daoManager;  
    4. 
  
  
  
  4.  
    5. 
  
  
  
  5. private OrderDao orderDao;  
    6. 
  
  
  
  6.  
    7. 
  
  
  
  7. public OrderService() {  
    8. 
  
  
  
  8. daoManager = DaoConfig.getDaoManager();  
    9. 
  
  
  
  9. orderDao = (OrderDao) daoManager.getDao(OrderDao.class);  
    10. 
  
  
  
  10. }  
    11. 
  
  
  
  11.  
    12. 
  
  
  
  12. public void method() {  
    13. 
  
  
  
  13. try {  
    14. 
  
  
  
  14. //a separate transaction  
    15. 
  
  
  
  15. orderDao.method1(); //***个事务  
    16. 
  
  
  
  16.  
    17. 
  
  
  
  17. daoManager.startTransaction(); //开始第二个事务  
    18. 
  
  
  
  18.  
    19. 
  
  
  
  19. orderDao.method1();  
    20. 
  
  
  
  20. orderDao.method2();  
    21. 
  
  
  
  21.  
    22. 
  
  
  
  22. daoManager.commitTransaction();//提交第二个事务  
    23. 
  
  
  
  23. } finally {  
    24. 
  
  
  
  24. daoManager.endTransaction();  
    25. 
  
  
  
  25. }  
    26. 
  
  
  
  26. }  
    27. 
  
  
  
  27. } 
    28.

在method()方法里有着两个事务，如果在方法里不显式的调用daoManager.startTransaction()，则每个DAO的一次方法调用就是一个独立的事务。

iBATIS DAO事务，有两个核心接口DaoTransactionManager和DaoTransaction

对应着不同的数据库持久层实现，两个接口分别对应着不同实现

查看iBATIS 代码，可以发现这些manager实现事务，就是调用事务源的事务操作方法

 
 
 
    
  
  
  
  1. JdbcDaoTransactionManager  
    2. 
  
  
  
  2. public void commitTransaction(DaoTransaction trans) {  
    3. 
  
  
  
  3. ((JdbcDaoTransaction) trans).commit();  
    4. 
  
  
  
  4. }  
    5. 
  
  
  
  5.  JdbcDaoTransaction  
    6. 
  
  
  
  6. public JdbcDaoTransaction(DataSource dataSource) {  
    7. 
  
  
  
  7. try {  
    8. 
  
  
  
  8. connection = dataSource.getConnection();  
    9. 
  
  
  
  9. if (connection == null) {  
    10. 
  
  
  
  10. throw new DaoException("Could not start transaction.Cause: The DataSource returned a null connection.");  
    11. 
  
  
  
  11. }  
    12. 
  
  
  
  12. if (connection.getAutoCommit()) {  
    13. 
  
  
  
  13. connection.setAutoCommit(false);  
    14. 
  
  
  
  14. }  
    15. 
  
  
  
  15. if (connectionLog.isDebugEnabled()) {  
    16. 
  
  
  
  16. connection = ConnectionLogProxy.newInstance(connection);  
    17. 
  
  
  
  17. }  
    18. 
  
  
  
  18. } catch (SQLException e) {  
    19. 
  
  
  
  19. throw new DaoException("Error starting JDBC transaction.Cause: " + e);  
    20. 
  
  
  
  20. }  
    21. 
  
  
  
  21. }  
    22. 
  
  
  
  22.  
    23. 
  
  
  
  23. public void commit() {  
    24. 
  
  
  
  24. try {  
    25. 
  
  
  
  25. try {  
    26. 
  
  
  
  26. connection.commit();  
    27. 
  
  
  
  27. } finally {  
    28. 
  
  
  
  28. connection.close();  
    29. 
  
  
  
  29. }  
    30. 
  
  
  
  30. } catch (SQLException e) {  
    31. 
  
  
  
  31. throw new DaoException("Error committing JDBC transaction.Cause: " + e);  
    32. 
  
  
  
  32. }  
    33. 
  
  
  
  33. } 
    34.

那么DaoTransactionManager以什么依据处理事务呢？DaoTransactionState看看DaoTransactionState的代码，非常简单，四个常量来表示事务处于的不同的状态

public static final DaoTransactionState ACTIVE = new DaoTransactionState();

public static final DaoTransactionState INACTIVE = new DaoTransactionState();

public static final DaoTransactionState COMMITTED = new DaoTransactionState();

public static final DaoTransactionState ROLLEDBACK = new DaoTransactionState();

那么实际程序中是如何控制事务的呢

在***段代码中，我们是这样取得DAO

orderDao = (OrderDao) daoManager.getDao(OrderDao.class);

实际daoManager返回的并不是orderDao的具体实现类，它返回的DaoProxy

DaoProxy

 
 
 
    
  
  
  
  1. public Object invoke(Object proxy, Method method, Object[] args)  
    2. 
  
  
  
  2. throws Throwable {  
    3. 
  
  
  
  3. Object result = null;  
    4. 
  
  
  
  4. if (PASSTHROUGH_METHODS.contains(method.getName())) {  
    5. 
  
  
  
  5. try {  
    6. 
  
  
  
  6. result = method.invoke(daoImpl.getDaoInstance(), args);  
    7. 
  
  
  
  7. } catch (Throwable t) {  
    8. 
  
  
  
  8. throw ClassInfo.unwrapThrowable(t);  
    9. 
  
  
  
  9. }  
    10. 
  
  
  
  10. } else {  
    11. 
  
  
  
  11. StandardDaoManager daoManager = daoImpl.getDaoManager();  
    12. 
  
  
  
  12. DaoContext context = daoImpl.getDaoContext();  
    13. 
  
  
  
  13.  
    14. 
  
  
  
  14. if (daoManager.isExplicitTransaction()) {  
    15. 
  
  
  
  15. // Just start the transaction (explicit)  
    16. 
  
  
  
  16. try {  
    17. 
  
  
  
  17. context.startTransaction();  
    18. 
  
  
  
  18. result = method.invoke(daoImpl.getDaoInstance(), args);  
    19. 
  
  
  
  19. } catch (Throwable t) {  
    20. 
  
  
  
  20. throw ClassInfo.unwrapThrowable(t);  
    21. 
  
  
  
  21. }  
    22. 
  
  
  
  22. } else {  
    23. 
  
  
  
  23. // Start, commit and end the transaction (autocommit)  
    24. 
  
  
  
  24. try {  
    25. 
  
  
  
  25. context.startTransaction();  
    26. 
  
  
  
  26. result = method.invoke(daoImpl.getDaoInstance(), args);  
    27. 
  
  
  
  27. context.commitTransaction();  
    28. 
  
  
  
  28. } catch (Throwable t) {  
    29. 
  
  
  
  29. throw ClassInfo.unwrapThrowable(t);  
    30. 
  
  
  
  30. } finally {  
    31. 
  
  
  
  31. context.endTransaction();  
    32. 
  
  
  
  32. }  
    33. 
  
  
  
  33. }  
    34. 
  
  
  
  34.  
    35. 
  
  
  
  35. }  
    36. 
  
  
  
  36. return result;  
    37. 
  
  
  
  37. } 
    38.

看到这段代码就非常清楚了，每调用DAO的一次方法时，如果不显式的调用daoManager.startTransaction()，就会成为单独的一个iBATIS DAO事务。再看看iBATIS为我们提供的摸板JdbcDaoTemplate

 
 
 
    
  
  
  
  1. protected Connection getConnection() {  
    2. 
  
  
  
  2. DaoTransaction trans = daoManager.getTransaction(this);  
    3. 
  
  
  
  3. if (!(trans instanceof ConnectionDaoTransaction)) {  
    4. 
  
  
  
  4. throw new DaoException("The DAO manager of type " + daoManager.getClass().getName() +  
    5. 
  
  
  
  5. " cannot supply a JDBC Connection for this template, and is therefore not" +  
    6. 
  
  
  
  6. "supported by JdbcDaoTemplate.");  
    7. 
  
  
  
  7. }  
    8. 
  
  
  
  8. return ((ConnectionDaoTransaction) trans).getConnection();  
    9. 
  
  
  
  9. } 
    10.

iBATIS控制多个DAO的事务实际是让这些DAO共用了一个DaoTransaction（ThreadLocal），一个Connection

这里是一个事务源的情况，如果多个事务源之间要完成全局事务，还是老老实实用分布式事务管理服务吧（jta）。

iBATIS DAO事务的相关信息就向你介绍到这里，之后的文章里我们还会提及的，请关注。

名称栏目：iBATISDAO事务浅析
文章出自：http://www.shufengxianlan.com/qtweb/news6/288006.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

云服务器知识

分类信息网

网站SEO优化　　 　网站推广公司　　 　温江网站建设　　 　艾名斯线缆　　 　400电话申请　　 　关键词排名优化　　 　长城雪茄　　 　云主机　　 　成都二枢机房　　 　成都添翼二手车　　 　成都门窗定制　　 　企业网站设计　　 　网站空间　　 　复盛机电设备　　 　腾讯云虚拟主机　　 　保温橡塑管　　 　成都网站设计　　 　成都微信开发　　 　成都网站推广　　 　成都广告公司