阿里云首页 云原生多模数据库 Lindorm

代码示例

1、示例下载

lindorm-ganos-mod-sample

下载解压后进入lindorm-sample目录,执行

mvn install -Dmaven.test.skip=true -s ../settings.xml

编译成功后,在target目录下生成 lindorm-mod-sample-1.0.0.jar

2、使用示例

进入lindorm-sample目录,执行

java -jar target/lindorm-mod-sample-1.0.0.jar src/main/resources/template/mod_template.json

通过json文件指定操作和参数,json文件可参照示例mod_template.json

2.1 写入数据

在 mod_template.json 中,设置写入参数。该示例指定AIS轨迹点数据集目录,读取数据并以分段二级索引模型存储轨迹,以id为主索引,xz2t为二级索引创建表 "traj"并写入数据。分段策略为每50个点划分一段(目前支持BY_DURATION、BY_DISTANCE、BY_ANGLE、BY_COUNT四种分段策略,可以通过修改MOD.java中的SplitConfigs设置,使用其它分段策略)。

{
  "operation" : "WRITE",
  "zk_address" : "your_zk_address",
  "catalog" : "example",
  "schema" : "traj",
  "enable_secondary_index" : "true",
  "print_info": "false",
  "enabled_indices" : "id,xz2t",
  "primary_index" : "id",
  "thread_num": 8,
  "input_dir": "path_to_repository/lindorm-sample/src/main/resources/data/traj",
}

"enabled_indices" 指定需要创建的索引(索引类型参见创建索引表),注意需要设置"enable_secondary_index" 为true才能使用二级索引,并设置"primary_index"指定其中的主索引。"thread_num"设置写入数据时的并行线程数,默认为1。

然后执行sample写入

java -jar target/lindorm-mod-sample-1.0.0.jar src/main/resources/template/mod_template.json

2.2 查询数据

在 mod_template.json 中设置查询参数,使用示例代码默认的查询范围

{
  "operation" : "QUERY",
  "zk_address" : "your_zk_address",
  "catalog" : "example",
  "schema" : "traj",
  "predicate" : "INTERSECTS(geom, POLYGON ((-76 28, -74 28, -74 30, -76 30, -76 28))) and traj_start_time >= 1549510271 AND traj_start_time <= 1549583941",
  "return_complete_trajectory" : "false",
  "print_results" : "true"
}

"predicate"设置查询语句,"return_complete_trajectory" 指定是否返回完整轨迹(分段存储的轨迹在查询时默认返回符合查询条件的轨迹段,需设定该参数为true才会返回完整轨迹)

执行sample查询

java -jar target/lindorm-mod-sample-1.0.0.jar src/main/resources/template/mod_template.json

可以看到返回显示的查询结果。