聊聊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
- 我所理解的Remoting (2) :远程对象的生命周期管理[下篇]
- struts2(六)之ognl表达式与ActionContext、ValueStack
- Windows8异步编程的注意事项
- CSS魔法堂:深入理解line-height和vertical-align
- Gradle 10分钟上手指南
- gradle项目中profile的实现
- 欧盟推出“数字经济税收制度”优化了税收制度,却影响区块链行业
- CSS魔法堂:你一定误解过的Normal flow
- ASP.NET输出JSON格式数据
- haproxy 新手上路
- 区块链是如何保护交易隐私的?eprint这篇论文告诉你答案
- gradle项目中资源文件的相对路径打包处理技巧
- Markdown 语法手册 (完整整理版)
- WordPress3.5安装出现的几个问题
- 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 数组属性和方法
- [Centos7]XlsxWriter模块安装
- [Centos7]安装pycurl
- [Centos7]python-nmap端口扫描
- [docker]Nginx安装部署
- Lua语言-入门语法
- Redis 三种启动方式
- OpenWRT结合tinc组自己的SDLAN
- 通过Cloudflare API更新DNS记录
- Vedastr:基于PyTorch的场景文本识别工具箱
- vue-element-admin项目关闭eslint校验
- 搞了半天,终于弄懂了TCP Socket数据的接收和发送,太难~
- 每天一个小技巧:CSS clip-path 的妙用 Clip Path分类Clippy
- 20 个值得学习的 Vue 开源项目
- 小白入门WEB前端编程,必看知识点!核心干货
- 新网站 Robots 和 SiteMap 优化