聊聊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
- transaction
- 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 数组属性和方法
- 浙大版《C语言程序设计(第3版)》题目集 习题9-6 按等级统计学生成绩
- 实战|用pandas+PyQt5制作一款数据分组透视处理工具
- 带权/种类并查集-POJ 1182食物链
- 浙大版《C语言程序设计(第3版)》题目集 练习10-1 使用递归函数计算1到n之和
- 十分钟快速了解Pandas的常用操作!
- 一行代码如何隐藏 Linux 进程?
- SSH 只能用于远程 Linux 主机?那说明你见识太小了!
- 干货 | Trip.com 机票React Native整洁架构2.0实践
- 干货 | 日均TB级数据,携程支付统一日志框架
- 为什么 HTTPS 是安全的?
- Hello World背后的故事:如何在Linux上编译C语言程序
- 浅谈Linux的动态链接库
- 初识ABP vNext(9):ABP模块化开发-文件管理
- NIFI里你用过PutDatabaseRecord嘛?
- NIFI里的数据库连接池