|
此版本仍在开发中，尚不被认为是稳定的。对于最新的稳定版本，请使用 Spring Data Couchbase 5.5.2！ |
Couchbase 交易
Couchbase 支持分布式事务。本节记录如何将其与 Spring Data Couchbase 一起使用。
要求
-
Couchbase Server 6.6.1 或更高版本。
-
Spring Data Couchbase 5.0.0-M5 或更高版本。
-
应配置 NTP，以便 Couchbase 集群的节点与时间同步。不同步的时间不会导致不正确的行为，但可能会影响元数据清理。
-
实体类必须具有
@Version Long属性来保存文档的 CAS 值。
概述
Spring Data Couchbase 模板作插入、查找、替换和删除，使用这些调用的存储库方法可以参与 Couchbase 事务。它们可以通过使用 @Transactional 注释、CouchbaseTransactionalOperator 或在 Couchbase 事务的 lambda 中在事务中执行。
入门和配置
Couchbase 交易通常使用带有 @Transactional 注释的方法进行杠杆。 @Transactional运算符是通过CouchbaseTransactionManager实现的，该Manager在AbstractCouchbaseConfiguration中作为bean提供。 Couchbase 事务可以在不定义服务类的情况下使用 CouchbaseTransactionOperator，CouchbaseTransactionOperator 也作为 Bean 在 AbtractCouchbaseConfiguration 中提供。 Couchbase 事务也可以直接使用 lambda 中的 Spring Data Couchbase作使用事务
与@Transactional的交易
@Transactional 将一个或一个类上的所有方法定义为事务性方法。
当在类级别声明此注释时，它作为默认值应用 声明类及其子类的所有方法。
[[-属性语义]] === 属性语义
在此版本中，Couchbase 事务忽略回滚属性。 事务隔离级别是读取提交的;
@Configuration
@EnableCouchbaseRepositories("<parent-dir-of-repository-interfaces>")
@EnableReactiveCouchbaseRepositories("<parent-dir-of-repository-interfaces>")
@EnableTransactionManagement (1)
static class Config extends AbstractCouchbaseConfiguration {
// Usual Setup
@Override public String getConnectionString() { /* ... */ }
@Override public String getUserName() { /* ... */ }
@Override public String getPassword() { /* ... */ }
@Override public String getBucketName() { /* ... */ }
// Customization of transaction behavior is via the configureEnvironment() method
@Override protected void configureEnvironment(final Builder builder) {
builder.transactionsConfig(
TransactionsConfig.builder().timeout(Duration.ofSeconds(30)));
}
}请注意，如果事务失败，可以重新执行@Transactional方法的主体。 方法体中的所有内容都必须是幂等的。
import reactor.core.publisher.Mono;
import reactor.core.publisher.Flux;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
final CouchbaseOperations personOperations;
final ReactiveCouchbaseOperations reactivePersonOperations;
@Service (2)
public class PersonService {
final CouchbaseOperations operations;
final ReactiveCouchbaseOperations reactiveOperations;
public PersonService(CouchbaseOperations ops, ReactiveCouchbaseOperations reactiveOps) {
operations = ops;
reactiveOperations = reactiveOps;
}
// no annotation results in this method being executed not in a transaction
public Person save(Person p) {
return operations.save(p);
}
@Transactional
public Person changeFirstName(String id, String newFirstName) {
Person p = operations.findById(Person.class).one(id); (3)
return operations.replaceById(Person.class).one(p.withFirstName(newFirstName);
}
@Transactional
public Mono<Person> reactiveChangeFirstName(String id, String newFirstName) {
return personOperationsRx.findById(Person.class).one(person.id())
.flatMap(p -> personOperationsRx.replaceById(Person.class).one(p.withFirstName(newFirstName)));
}
}@Autowired PersonService personService; (4)
Person walterWhite = new Person( "Walter", "White");
Person p = personService.save(walterWhite); // this is not a transactional method
...
Person renamedPerson = personService.changeFirstName(walterWhite.getId(), "Ricky"); (5)@Transactional方法注释的功能需要
-
要用@EnableTransactionManagement进行注释的配置类;
-
具有带注释方法的服务对象必须用 @Service 进行注释;
-
该方法的主体在事务中执行。
-
必须通过@Autowired获取带有注释方法的服务对象。
-
对方法的调用必须从与 service 不同的类进行，因为调用 Commentted 来自同一类的方法将不会调用执行事务处理的方法拦截器。
使用 CouchbaseTransactionalOperator 进行交易
CouchbaseTransactionalOperator 可用于内联构造事务，而无需创建使用 @Transactional 的服务类。CouchbaseTransactionalOperator 可作为 bean 使用，并且可以使用 @Autowired 实例化。如果显式创建一个，则必须使用 CouchbaseTransactionalOperator.create（manager）（而不是 TransactionalOperator.create（manager））创建它。
@Autowired TransactionalOperator txOperator;
@Autowired ReactiveCouchbaseTemplate reactiveCouchbaseTemplate;
Flux<Person> result = txOperator.execute((ctx) ->
reactiveCouchbaseTemplate.findById(Person.class).one(person.id())
.flatMap(p -> reactiveCouchbaseTemplate.replaceById(Person.class).one(p.withFirstName("Walt")))
);直接与 SDK 进行交易
Spring Data Couchbase 与 Couchbase Java SDK 无缝协作以进行事务处理。Spring Data Couchbase作可以在事务中执行，将直接在 transactions（）.run（） 的 lambda 中工作，而不涉及任何 SpringTransactions 机制。这是在 Spring Data Couchbase 中利用 Couchbase 事务的最直接方法。
请参阅参考文档
@Autowired CouchbaseTemplate couchbaseTemplate;
TransactionResult result = couchbaseTemplate.getCouchbaseClientFactory().getCluster().transactions().run(ctx -> {
Person p = couchbaseTemplate.findById(Person.class).one(personId);
couchbaseTemplate.replaceById(Person.class).one(p.withFirstName("Walt"));
});@Autowired ReactiveCouchbaseTemplate reactiveCouchbaseTemplate;
Mono<TransactionResult> result = reactiveCouchbaseTemplate.getCouchbaseClientFactory().getCluster().reactive().transactions()
.run(ctx ->
reactiveCouchbaseTemplate.findById(Person.class).one(personId)
.flatMap(p -> reactiveCouchbaseTemplate.replaceById(Person.class).one(p.withFirstName("Walt")))
);