聊聊claudb的transaction command
时间:2022-07-24
本文章向大家介绍聊聊claudb的transaction command,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
序
本文主要研究一下claudb的transaction command
TransactionState
claudb-1.7.1/src/main/java/com/github/tonivade/claudb/TransactionState.java
public class TransactionState implements Iterable<Request> {
private List<Request> requests = new LinkedList<>();
public void enqueue(Request request) {
requests.add(request);
}
public int size() {
return requests.size();
}
@Override
public Iterator<Request> iterator() {
return requests.iterator();
}
}
- TransactionState实现了Iterable<Request>接口,它定义了requests属性,提供了enqueue方法将request添加到requests中
MultiCommand
claudb-1.7.1/src/main/java/com/github/tonivade/claudb/command/transaction/MultiCommand.java
@Command("multi")
@TxIgnore
public class MultiCommand implements DBCommand {
private static final String TRASACTION_KEY = "tx";
@Override
public RedisToken execute(Database db, Request request) {
if (!isTxActive(request.getSession())) {
createTransaction(request.getSession());
return responseOk();
} else {
return error("ERR MULTI calls can not be nested");
}
}
private void createTransaction(Session session) {
session.putValue(TRASACTION_KEY, new TransactionState());
}
private boolean isTxActive(Session session) {
return session.getValue(TRASACTION_KEY).isPresent();
}
}
- MultiCommand实现了DBCommand接口,其execute方法先判断isTxActive,非active的话才createTransaction
ExecCommand
claudb-1.7.1/src/main/java/com/github/tonivade/claudb/command/transaction/ExecCommand.java
@Command("exec")
@TxIgnore
public class ExecCommand implements DBCommand {
@Override
public RedisToken execute(Database db, Request request) {
Option<TransactionState> transaction = getTransactionIfExists(request.getSession());
if (transaction.isPresent()) {
DBServerContext server = getClauDB(request.getServerContext());
List<RedisToken> responses = new ArrayList<>();
for (Request queuedRequest : transaction.get()) {
responses.add(executeCommand(server, queuedRequest));
}
return RedisToken.array(responses);
} else {
return RedisToken.error("ERR EXEC without MULTI");
}
}
private RedisToken executeCommand(DBServerContext server, Request queuedRequest) {
RespCommand command = server.getCommand(queuedRequest.getCommand());
return command.execute(queuedRequest);
}
private Option<TransactionState> getTransactionIfExists(Session session) {
return session.removeValue("tx");
}
}
- ExecCommand实现了DBCommand接口,其execute方法先通过getTransactionIfExists获取transaction,若transaction不存在则报错,存在的话则遍历transaction的queuedRequest,挨个执行executeCommand(server, queuedRequest)
DiscardCommand
claudb-1.7.1/src/main/java/com/github/tonivade/claudb/command/transaction/DiscardCommand.java
@Command("discard")
@TxIgnore
public class DiscardCommand implements DBCommand {
private static final String TX_KEY = "tx";
@Override
public RedisToken execute(Database db, Request request) {
removeTransactionIfExists(request.getSession());
return RedisToken.responseOk();
}
private Option<TransactionState> removeTransactionIfExists(Session session) {
return session.removeValue(TX_KEY);
}
}
- DiscardCommand实现了DBCommand接口,其execute方法执行removeTransactionIfExists(request.getSession())
小结
claudb transaction相关的command有MultiCommand、ExecCommand、DiscardCommand
doc
- 【Java提高十六】集合List接口详解
- JS的内建函数reduce
- Error: Cannot find module 'gulp-clone'问题的解决
- Spring+SpringMVC+MyBatis+easyUI整合基础篇(四)代码简化
- Angular源码分析之$compile
- TensorFlow实例: 手写汉字识别
- iOS引入JavaScriptCore引擎框架(一)
- Spring+SpringMVC+MyBatis+easyUI整合基础篇(三)搭建步骤
- iOS引入JavaScriptCore引擎框架(二)
- Java基础-03(01).总结运算符、键盘录入、if语句
- 使用git恢复未提交的误删数据
- Java web图片上传和文件上传
- 通过java程序模拟实现地铁票价2+2=12(r3笔记第94天)
- 由objC运行时所想到的。。。
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 函数式接口小结
- 冒泡排序+选择排序+插入排序+图与代码
- [解锁新姿势] 分享 7 个优化代码的技巧
- 常量池与堆中放入String数据,比较大小
- Could not find artifact org.apache.tomcat.maven:tomcat7-maven-plugin:pom.....
- try{}catch{}finally{}运行后的执行结果
- MySQL死锁产生原因和解决方法
- 文件操作与文件夹操作
- 使用文件字节输入流FileInputStream读取文件
- 二进制与十进制与十六进制介绍+转换+图解
- Swagger 3.0 官方 starter 诞生了,其它的都可以扔了~
- 原码+反码+补码概述与示范
- HTTP客户端连接,选择HttpClient还是OkHttp?
- 数据类型(基本数据类型和引用数据类型)范围与字符转换,代码示例+个位十位百位相加面试题
- Scanner关键字的使用+代码介绍+注意事项