Skip to content

Latest commit

 

History

History
84 lines (63 loc) · 2.93 KB

README.md

File metadata and controls

84 lines (63 loc) · 2.93 KB

License version

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配置