聊聊claudb的scripting command
时间:2022-07-24
本文章向大家介绍聊聊claudb的scripting command,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
序
本文主要研究一下claudb的scripting command
AbstractEvalCommand
claudb-1.7.1/src/main/java/com/github/tonivade/claudb/command/scripting/AbstractEvalCommand.java
abstract class AbstractEvalCommand implements DBCommand {
@Override
public RedisToken execute(Database db, Request request) {
return script(request).map(script -> execute(request, script))
.getOrElse(error("NOSCRIPT No matching script. Please use EVAL"));
}
private RedisToken execute(Request request, SafeString script) {
int numParams = parseInt(request.getParam(1).toString());
if (numParams + 2 > request.getLength()) {
return error("invalid number of arguments");
}
List<SafeString> params = request.getParams().stream().skip(2).collect(toList());
List<SafeString> keys = readParams(numParams, params);
List<SafeString> argv = readArguments(numParams, params);
return LuaInterpreter.buildFor(request).execute(script, keys, argv);
}
protected abstract Option<SafeString> script(Request request);
private List<SafeString> readParams(int numParams, List<SafeString> params) {
List<SafeString> keys = new LinkedList<>();
for (int i = 0; i < numParams; i++) {
keys.add(params.get(i));
}
return keys;
}
private List<SafeString> readArguments(int numParams, List<SafeString> params) {
List<SafeString> argv = new LinkedList<>();
for (int i = numParams; i < params.size(); i++) {
argv.add(params.get(i));
}
return argv;
}
}
- AbstractEvalCommand实现了DBCommand接口,其execute方法先通过子类实现的script方法获取SafeString,然后再内部的execute方法执行脚本;execute方法先解析keys、argv,然后通过LuaInterpreter.buildFor(request).execute(script, keys, argv)执行lua脚本
EvalCommand
claudb-1.7.1/src/main/java/com/github/tonivade/claudb/command/scripting/EvalCommand.java
@Command("eval")
@ParamLength(2)
public class EvalCommand extends AbstractEvalCommand {
@Override
protected Option<SafeString> script(Request request) {
return Option.some(request.getParam(0));
}
}
- EvalCommand继承了AbstractEvalCommand,其script方法取request.getParam(0)
EvalShaCommand
claudb-1.7.1/src/main/java/com/github/tonivade/claudb/command/scripting/EvalShaCommand.java
@Command("evalsha")
@ParamLength(2)
public class EvalShaCommand extends AbstractEvalCommand {
@Override
protected Option<SafeString> script(Request request) {
DBServerState server = getServerState(request.getServerContext());
return server.getScript(request.getParam(0));
}
}
- EvalShaCommand继承了AbstractEvalCommand,其script方法先通过getServerState(request.getServerContext())获取server,再执行server.getScript(request.getParam(0))
ScriptCommands
claudb-1.7.1/src/main/java/com/github/tonivade/claudb/command/scripting/ScriptCommands.java
@ParamLength(1)
@Command("script")
public class ScriptCommands implements DBCommand {
@Override
public RedisToken execute(Database db, Request request) {
return Pattern1.<Request, RedisToken>build()
.when(isCommand("load"))
.then(this::load)
.when(isCommand("exists"))
.then(this::exists)
.when(isCommand("flush"))
.then(this::flush)
.otherwise()
.then(this::unknownCommand)
.apply(request);
}
private RedisToken unknownCommand(Request request) {
return RedisToken.error("Unknown SCRIPT subcommand: " + request.getParam(0));
}
private RedisToken load(Request request) {
SafeString script = request.getParam(1);
return Try.of(() -> digest(script)).map(sha1 -> {
DBServerState server = getServerState(request.getServerContext());
server.saveScript(safeString(sha1), script);
return RedisToken.string(sha1);
}).getOrElse(RedisToken.error("ERR cannot generate sha1 sum for script: " + script));
}
private RedisToken exists(Request request) {
DBServerState server = getServerState(request.getServerContext());
return integer(server.getScript(request.getParam(1)).isPresent());
}
private RedisToken flush(Request request) {
getServerState(request.getServerContext()).cleanScripts();
return RedisToken.responseOk();
}
private String digest(SafeString script) throws NoSuchAlgorithmException {
MessageDigest digest = MessageDigest.getInstance("SHA-1");
return new SafeString(digest.digest(script.getBytes())).toHexString();
}
private Matcher1<Request> isCommand(String command) {
return request -> request.getParam(0).toString().toLowerCase().equals(command);
}
}
- ScriptCommands实现了DBCommand接口,其execute方法支持load、exists、flush命令;其中load方法通过server.saveScript(safeString(sha1), script)来保存script;其exists方法通过server.getScript(request.getParam(1)).isPresent()来判断script是否存在;其flush方法执行getServerState(request.getServerContext()).cleanScripts()
小结
claudb scripting相关的command有EvalCommand、EvalShaCommand、ScriptCommands
doc
- 分布式监控系统Zabbix--完整安装记录 -添加web页面监控
- .Net中使用带UI的OCX的方法
- 2017数据科学领域15大热门GitHub项目
- 简单分页的性能优化
- Flash/Flex学习笔记(42):坐标旋转
- 分布式监控系统Zabbix-完整安装记录 -添加端口监控
- Flash/Flex学习笔记(40):弹性运动续--弹簧
- 表格样式—粗边框细表格线
- 分布式监控系统Zabbix--完整安装记录 -添加apache监控
- Flash/Flex学习笔记(38):缓动动画
- 把EmEditor改造成简单的Word
- centos7下FFmpeg环境部署记录
- Mac下使用rz、sz远程上传下载文件的配置记录
- 写文件
- 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 数组属性和方法
- reduce学习笔记
- 【python实现卷积神经网络】开始训练
- django实战(五)--增加数据
- 实战django(一)--(你也能看懂的)注册与登录(带前端模板)
- 【python-leetcode23-多路归并】合并k个排序链表
- 实战django(二)--登录实现记住我
- org.apache.ibatis.binding.BindingException: Invalid bound statement (not found): com.gong.mybatis.da
- 【python-leetcode378-二分查找】有序矩阵中的第k小元素
- 使用cookie来记录用户登录次数,为何次数不更新
- (二)golang--windows下vscode的安装以及go环境的配置
- mybatis文件映射之使用#取值时的一些规则
- 【论文笔记】Improved Residual Networks for Image and Video Recognition(ResNet新变体:IResNet)
- SQL语句在MYSQL中的运行过程和各个组件的介绍
- (五)golang--常用的一些玩意
- 关于MYSQL 的日志系统