sedis

SQL for Redis

基于Apache Calcite实现了通过jdbc的方法连接Redis Cluster

快速入门

1. .进入项目根目录，使用maven打包

   mvn clean package打包完成后，会在target的目录里面生成一个sedis-0.1-bundle.jar包

2. 在Redis cluster中创建HASH类型的数据，例如创建两个key

   >hmset BAZ:1 ID 1 NAME spark
   >hmset BAZ:2 ID 2 NAME flink

3. 通过jdbc客户端写sql查询

   在pom中配置

   <dependency>
       <groupId>com.woople</groupId>
       <artifactId>sedis</artifactId>
       <version>0.1-bundle</version>
       <scope>system</scope>
       <systemPath>/tmp/sedis-0.1-bundle.jar</systemPath>
   </dependency>

   客户端代码

   import java.sql.*;
   import java.util.LinkedHashMap;
   import java.util.Map;
   
   public class SedisExamples {
       public static void main(String[] args) throws Exception{
           //sedis.redis.cluster.nodes如果只配置一个节点表示使用的为redis单机模式
           String model = "{\"version\":\"1.0\",\"defaultSchema\":\"SEDIS\",\"schemas\":[{\"name\":\"SEDIS\",\"type\":\"custom\",\"factory\":\"com.woople.calcite.adapter.redis.RedisSchemaFactory\",\"operand\":{\"sedis.redis.cluster.nodes\":\"10.1.236.179:6379,10.1.236.179:6380,10.1.236.179:6381\",\"sedis.redis.table\":{\"tableName\":\"BAZ\",\"fields\":\"ID:VARCHAR,NAME:VARCHAR\",\"keys\":\"ID\"}}}]}";
           Connection connection = DriverManager.getConnection("jdbc:calcite:model=inline:" + model);
   
           Statement statement = connection.createStatement();
           //如果表名和字段名为小写单词，需要加引号，例如select * from "baz" where "id"='2'
           ResultSet resultSet = statement.executeQuery("select * from BAZ where ID='2'");
           ResultSetMetaData metaData = resultSet.getMetaData();
           int columnSize = metaData.getColumnCount();
   
           while (resultSet.next()) {
               Map<String, Object> result = new LinkedHashMap<>();
               for (int i = 1; i < columnSize + 1; i++) {
                   result.put(metaData.getColumnLabel(i), resultSet.getObject(i));
               }
               System.out.println(result);
           }
   
           statement.close();
           connection.close();
       }
   }

   输出结果

   {ID=2, NAME=flink}

特性

目前0.1版本为简单的体验版

1. 支持Redis单机模式和cluster模式
2. 只支持Redis cluster中的HASH结构的数据
3. 只支持简单select查询语句，不支持join

后续计划

1. 优化参数配置
2. 支持redis其他格式数据的查询
3. 支持update和insert语句
4. 整合redis配置