Skip to content

Java客户端 事务处理 基于注解

Jump to bottom
He, Jiehui edited this page Apr 2, 2018 · 3 revisions

简介

为了使用事务，用户需要通过某种方式通知DAL，声明事务的起始与结束。事务的声明有两种方式：

  • 实现DalCommand接口
  • 标注@DalTransactional注解。since1.15.0

配置方法

可以用以下两种方式中任一种方式进行配置

config类配置

import org.springframework.context.annotation.Configuration;
import com.ctrip.platform.dal.dao.annotation.EnableDalTransaction;
  
@Configuration
@EnableDalTransaction
public class TransactionConfig {}

xml文件配置

<bean class="com.ctrip.platform.dal.dao.client.DalTransactionalEnabler"/>  
<bean id="TransactionAnnoClassSqlServer" class="test.com.ctrip.platform.dal.dao.annotation.normal.TransactionAnnoClassSqlServer"/>

使用方法

在需要事务的方法上加上@DalTransactional注解以及指定逻辑库，如下示例中的perform()方法

@Component
public class TransactionAnnoClassSqlServer {
    public static final String DB_NAME = MySqlDatabaseInitializer.DATABASE_NAME;
   
    @DalTransactional(logicDbName = DB_NAME)
    public String perform() {
        Assert.assertTrue(DalTransactionManager.isInTransaction());
        return null;
    }
}

通过spring的@Autowired注解来注入配置的包含事务方法的类，比如 TransactionAnnoClassSqlServer，即可调用该类中的事务方法，比如perform()方法

public class TransactionTestSqlServerUser implements TransactionTestUser{
    @Autowired
    private TransactionAnnoClassSqlServer test;
      
    public String perform() {
        return test.perform();
    }
}

包含分片的逻辑数据库

@Shard的定义

对于包含数据库分片的逻辑数据库，需要额外指定当前事务在那个分片上执行。可以有两种方式：

  • 在整形或字符串类型的参数前面标记@Shard
  • 在方法的参数中包含DalHints。

支持整形和字符串型的参数。如果方法的参数包含可以计算出分片值的DalHints，这个注解不是一定得要。

获取分片的逻辑

  • 同时存在@Shard和DalHints参数的时候，优先考虑@Shard标注的值。

  • 如果@Shard对应的值是null，则会通过配置的分片策略计算DalHints里面分片值。

  • 如果没有@Shard，则通过配置的分片策略计算DalHints里面分片值。

    public class TransactionAnnoClassSqlServer { public static final String DB_NAME_SHARD = "dao_test_sqlsvr_dbShard";

      @Transactional(logicDbName = DB_NAME_SHARD)
  public String perform(@Shard String id) {
      return performTask(id);
  }

  @Transactional(logicDbName = "dao_test_sqlsvr_dbShard_another")
  public String perform(@Shard Integer id) {
      return performTask(id);
  }

  @Transactional(logicDbName = DB_NAME_SHARD)
  public String perform(@Shard int id) {
      return performTask(id);
  }

  @Transactional(logicDbName = DB_NAME_SHARD)
  public String perform(String id, DalHints hints) {
      return performTask(id, hints);
  }
    
  @Transactional(logicDbName = DB_NAME_SHARD)
  public String performAnotherTask(String id, DalHints hints) {
      return performTask(id, hints);
  }
    
  @Transactional(logicDbName = DB_NAME_SHARD)
  public String performWitShard(@Shard String id, DalHints hints) {
      return performTaskWitShard(id, hints);
  }

限制

DAL不支持分布式事务，当检测到下列可能引起分布式事务的情况下，Dal会报错并触发回滚：

  • 当前事务所与同一线程新的事务或非事务调用不在同一个逻辑数据库（databaseSet级别）时
  • 是同一个逻辑数据库，但操作可能不是同一个分片时

如果用户确实有需求要在一个事务执行过程中，调用其它数据库，可以考虑通过DAL内置的异步支持来实现。例如如果通过Aspect的方式在某事务执行的时候，调用其它数据库写log，可以通过异步的方式来实现：

if(changeLogList == null || changeLogList.size() == 0)
    return;
  
// 告诉DAL，当前操作要使用异步执行的方式
DalHints hints = new DalHints().asyncExecution();
// 这里changeLogList里面必须有值，否则生成的代码会判断changeLogList为空并直接返回，会导致后面的future 报告NPE
logInputchangelogDao.batchInsert(hints, changeLogList);
// 如果需要同步等待结束，可以用下面的代码。如果不关心，则可以忽略
Future<?> future = hints.getAsyncResult();     
future.get();

隔离级别

在没有预先指定的情况下，DAL事务的隔离级别会使用驱动提供的缺省隔离级别，请注意不同数据库驱动，其缺省隔离级别可能不同。

一般来说mysql的缺省级别是TRANSACTION_REPEATABLE_READ，sqlserver是TRANSACTION_READ_COMMITTED

如果希望自己指定隔离级别，可以通过DalHints设置isolationLevel来实现

Clone this wiki locally