表格存储 Java SDK 开发入门

本文涉及的产品
表格存储 Tablestore,50G 2个月
简介: 本文将结合电商订单场景为例,介绍表格存储 Tablestore Java SDK 的基本使用方法。

准备工作

在您开始Tablestore SDK开发前,需确保已开通表格存储服务并且已创建表格存储实例。

您需要提前获取到以下几个参数


开发简介

开发示例中将以订单场景为例,使用Tablestore SDK实现如下几个功能。

  • 订单表创建。
  • 订单插入。
  • 订单号查询。
  • 订单搜索。


字段名

字段类型

字段描述

order_id

String

主键

订单号

customer_name

String

属性列

消费者姓名

product_name

String

属性列

产品名

product_type

String

属性列

产品类型

order_time

String

属性列

下单时间

pay_time

String

属性列

支付时间

订单表

开发步骤

初始化连接

Tablestore支持Http/Https协议访问服务端,使用Java SDK发起请求前,您需要初始化一个OTSClinet实例,初始化需要获取到服务地址(endpoint)、实例名(instanceName)、密钥(accessKeyId、accessSecret)等信息。代码如下

publicstaticvoidmain(String[] args) {
SyncClientsyncClient=newSyncClient(
"https://order-instance.cn-beijing.ots.aliyuncs.com",//your endpoint,此处可选择公网地址"",//your accessKeyId"",//your accessSecret"order-instance");//your instance name//operation_method(syncClinet);//operation method}


创建数据表

示例代码中创建了一张订单数据表order。

publicstaticvoidcreateOrderTable(SyncClientsyncClient){
TableOptionstableOptions=newTableOptions();
tableOptions.setMaxVersions(1);
tableOptions.setTimeToLive(-1);
TableMetatableMeta=newTableMeta("order");//设置表名tableMeta.addPrimaryKeyColumn("order_id",PrimaryKeyType.STRING);//设置主键CreateTableRequestcreateTableRequest=newCreateTableRequest(tableMeta,tableOptions);
syncClient.createTable(createTableRequest);//发送创建表请求System.out.println("create order table succeed");
    }

写入数据

示例代码中写入了一条订单数据,订单号order_id为“o1”。样例中模拟了一万条订单数据,这里不作展示。

publicstaticvoidputOrder(SyncClientsyncClient){
RowPutChangerowPutChange=newRowPutChange("order");//设置表名rowPutChange.setPrimaryKey(PrimaryKeyBuilder.createPrimaryKeyBuilder()
                .addPrimaryKeyColumn("order_id",PrimaryKeyValue.fromString("o1"))//设置主键                .build());
rowPutChange.addColumns(Arrays.asList(
newColumn("customer_name",ColumnValue.fromString("消十一")),//设置属性列信息newColumn("product_name",ColumnValue.fromString("iphone 6")),
newColumn("product_type",ColumnValue.fromString("手机")),
newColumn("order_time",ColumnValue.fromString("2021-10-25 09:20:01")),
newColumn("pay_time",ColumnValue.fromString("2017-10-25 10:00:01"))
        ));
syncClient.putRow(newPutRowRequest(rowPutChange));//发送插入数据请求System.out.println("put order succeed");
    }

查询数据

示例代码中查询订单号order_id为“o1”的记录

 

publicstaticvoidgetOrder(SyncClientsyncClient){
SingleRowQueryCriteriacriteria=newSingleRowQueryCriteria("order");//设置表名criteria.setPrimaryKey(PrimaryKeyBuilder.createPrimaryKeyBuilder()
                .addPrimaryKeyColumn("order_id",PrimaryKeyValue.fromString("o1"))//设置主键                .build());
criteria.setMaxVersions(1);
GetRowResponseresponse=syncClient.getRow(newGetRowRequest(criteria));//发送读取数据请求System.out.println(response.getRow());
    }

创建多元索引

示例代码中创建了一个多元索引order_index。分别设置customer_name字符串类型、order_time字符串类型、pay_time字符串类型、product_name分词类型、product_type字符串类型。关于索引字段类型的介绍请参考多元索引概述

publicstaticvoidcreateSearchIndex(SyncClientsyncClient){
CreateSearchIndexRequestcreateSearchIndexRequest=newCreateSearchIndexRequest("order","order_index");//设置表名和索引名IndexSchemaindexSchema=newIndexSchema();
indexSchema.setFieldSchemas(Arrays.asList(//设置索引结构newFieldSchema("customer_name",FieldType.KEYWORD),
newFieldSchema("order_time",FieldType.KEYWORD),
newFieldSchema("pay_time",FieldType.KEYWORD),
newFieldSchema("product_name",FieldType.TEXT),
newFieldSchema("product_type",FieldType.KEYWORD)
        ));
createSearchIndexRequest.setIndexSchema(indexSchema);
syncClient.createSearchIndex(createSearchIndexRequest);//发送创建索引请求System.out.println("create search index succeed");
    }

搜索数据

示例代码中查询产品类型为“手机”的订单,并统计了符合条件的行数。

publicstaticvoidsearchQuery1(SyncClientsyncClient){
SearchRequestsearchRequest=SearchRequest.newBuilder()
                .tableName("order").indexName("order_index")//设置表名、索引名                .searchQuery(SearchQuery.newBuilder()
                        .query(QueryBuilders.term("product_type","手机"))//查询类型为手机的记录                        .getTotalCount(true)//获取查询命中的行数                        .build())
                .returnAllColumns(true)
                .build();
SearchResponseresponse=syncClient.search(searchRequest);
System.out.println("total rows:"+response.getTotalCount());
for(Rowrow : response.getRows()){
System.out.println(row);
        }
    }

示例代码中搜索产品名包含“iphone”的订单,并统计了符合条件的行数。

publicstaticvoidsearchQuery2(SyncClientsyncClient){
SearchRequestsearchRequest=SearchRequest.newBuilder()
                .tableName("order").indexName("order_index")//设置表名、索引名                .searchQuery(SearchQuery.newBuilder()
                        .query(QueryBuilders.match("product_name","iphone"))//搜索产品名中包含iphone的行                        .getTotalCount(true)//获取查询命中的行数                        .build())
                .returnAllColumns(true)
                .build();
SearchResponseresponse=syncClient.search(searchRequest);
System.out.println("total rows:"+response.getTotalCount());
for(Rowrow : response.getRows()){
System.out.println(row);
        }
    }

示例代码中查询了消费者姓名为“消十一”并且下单时间在“2021-10-24 00:00:00”之间的订单。并统计了行数。

publicstaticvoidsearchQuery3(SyncClientsyncClient){
SearchRequestsearchRequest=SearchRequest.newBuilder()
                .tableName("order").indexName("order_index")//设置表名、索引名                .searchQuery(SearchQuery.newBuilder()
                        .query(QueryBuilders.bool()
                                .must(QueryBuilders.term("customer_name","消十一"))
                                .must(QueryBuilders.range("order_time").lessThan("2021-10-24 00:00:00")))
                        .getTotalCount(true)//获取查询命中的行数                        .build())
                .returnAllColumns(true)
                .build();
SearchResponseresponse=syncClient.search(searchRequest);
System.out.println("total rows:"+response.getTotalCount());
for(Rowrow : response.getRows()){
System.out.println(row);
        }
    }

删除多元索引

示例代码中展示了删除订单表order中的order_index多元索引。

publicstaticvoiddeleteSearchIndex(SyncClientsyncClient){
DeleteSearchIndexRequestdeleteSearchIndexRequest=newDeleteSearchIndexRequest();
deleteSearchIndexRequest.setTableName("order");
deleteSearchIndexRequest.setIndexName("order_index");
syncClient.deleteSearchIndex(deleteSearchIndexRequest);
System.out.println("delete search index succeed");
    }

删除数据表

示例代码中展示了删除订单表order。删除表之前需确保先删除表中的多元索引。

publicstaticvoiddeleteTable(SyncClientsyncClient){
syncClient.deleteTable(newDeleteTableRequest("order"));//发送删除数据表请求System.out.println("delete table succeed");
    }

更多关于Tablestore JAVA SDK的介绍请参考Tablestore JAVA SDK

相关实践学习
阿里云表格存储使用教程
表格存储(Table Store)是构建在阿里云飞天分布式系统之上的分布式NoSQL数据存储服务,根据99.99%的高可用以及11个9的数据可靠性的标准设计。表格存储通过数据分片和负载均衡技术,实现数据规模与访问并发上的无缝扩展,提供海量结构化数据的存储和实时访问。 产品详情:https://www.aliyun.com/product/ots
目录
相关文章
|
4天前
|
Java API 开发工具
百宝箱开放平台 ✖️ Java SDK
百宝箱提供Java SDK,支持开发者集成其开放能力。需先发布应用,准备Java 8+及Maven环境,通过添加依赖安装SDK,并初始化客户端调用对话型或生成型智能体,实现会话管理、消息查询与文件上传等功能。
556 0
百宝箱开放平台 ✖️ Java SDK
|
1月前
|
开发工具 Android开发
X Android SDK file not found: adb.安卓开发常见问题-Android SDK 缺少 `adb`(Android Debug Bridge)-优雅草卓伊凡
X Android SDK file not found: adb.安卓开发常见问题-Android SDK 缺少 `adb`(Android Debug Bridge)-优雅草卓伊凡
328 11
X Android SDK file not found: adb.安卓开发常见问题-Android SDK 缺少 `adb`(Android Debug Bridge)-优雅草卓伊凡
|
4月前
|
存储 Java API
MinIO Java SDK 7.1.4 升级到 8.5.17 需要注意什么
现在我需要你帮我分析对比这个两个sdk在对外的接口设计上是否有不兼容的变更
354 5
|
8月前
|
前端开发 安全 开发工具
【11】flutter进行了聊天页面的开发-增加了即时通讯聊天的整体页面和组件-切换-朋友-陌生人-vip开通详细页面-即时通讯sdk准备-直播sdk准备-即时通讯有无UI集成的区别介绍-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草Alex
【11】flutter进行了聊天页面的开发-增加了即时通讯聊天的整体页面和组件-切换-朋友-陌生人-vip开通详细页面-即时通讯sdk准备-直播sdk准备-即时通讯有无UI集成的区别介绍-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草Alex
478 90
【11】flutter进行了聊天页面的开发-增加了即时通讯聊天的整体页面和组件-切换-朋友-陌生人-vip开通详细页面-即时通讯sdk准备-直播sdk准备-即时通讯有无UI集成的区别介绍-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草Alex
|
5月前
|
人工智能 自然语言处理 开发工具
HarmonyOS NEXT~鸿蒙开发能力:HarmonyOS SDK AI 全解析
本文深入解析HarmonyOS SDK中的AI功能集,涵盖分布式AI引擎、核心组件(NLP、计算机视觉等)及智能决策能力。通过代码示例与开发实践指南,帮助开发者掌握环境配置、性能调优及多场景应用(智能家居、移动办公等)。同时探讨性能优化策略与未来演进方向,助力构建高效分布式智能应用。
497 9
|
7月前
|
存储 开发工具 开发者
揭秘 Microsoft.Docker.SDK:让容器开发更轻松的强大工具揭秘
随着云计算和容器技术的快速发展,`Docker` 已经成为容器化技术的事实标准。`Microsoft` 作为 `Docker` 的主要支持者和参与者,推出了 `Microsoft.Docker.SDK`,旨在帮助开发者更轻松地进行容器开发。本文将深入揭秘 Microsoft.Docker.SDK 的功能、使用方法以及它在容器开发中的应用。
207 12
|
8月前
|
前端开发 JavaScript 开发工具
【04】鸿蒙实战应用开发-华为鸿蒙纯血操作系统Harmony OS NEXT-正确安装鸿蒙SDK-结构目录介绍-路由介绍-帧动画(ohos.animator)书写介绍-能够正常使用依赖库等-ArkUI基础组件介绍-全过程实战项目分享-从零开发到上线-优雅草卓伊凡
【04】鸿蒙实战应用开发-华为鸿蒙纯血操作系统Harmony OS NEXT-正确安装鸿蒙SDK-结构目录介绍-路由介绍-帧动画(ohos.animator)书写介绍-能够正常使用依赖库等-ArkUI基础组件介绍-全过程实战项目分享-从零开发到上线-优雅草卓伊凡
494 5
【04】鸿蒙实战应用开发-华为鸿蒙纯血操作系统Harmony OS NEXT-正确安装鸿蒙SDK-结构目录介绍-路由介绍-帧动画(ohos.animator)书写介绍-能够正常使用依赖库等-ArkUI基础组件介绍-全过程实战项目分享-从零开发到上线-优雅草卓伊凡
|
8月前
|
前端开发 Java Shell
【08】flutter完成屏幕适配-重建Android,增加GetX路由,屏幕适配,基础导航栏-多版本SDK以及gradle造成的关于fvm的使用(flutter version manage)-卓伊凡换人优雅草Alex-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草Alex
【08】flutter完成屏幕适配-重建Android,增加GetX路由,屏幕适配,基础导航栏-多版本SDK以及gradle造成的关于fvm的使用(flutter version manage)-卓伊凡换人优雅草Alex-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草Alex
540 20
【08】flutter完成屏幕适配-重建Android,增加GetX路由,屏幕适配,基础导航栏-多版本SDK以及gradle造成的关于fvm的使用(flutter version manage)-卓伊凡换人优雅草Alex-开发完整的社交APP-前端客户端开发+数据联调|以优雅草商业项目为例做开发-flutter开发-全流程-商业应用级实战开发-优雅草Alex
|
8月前
|
JavaScript 编译器 开发工具
【02】鸿蒙实战应用开发-华为鸿蒙纯血操作系统Harmony OS NEXT-项目开发实战-准备工具安装-编译器DevEco Studio安装-arkts编程语言认识-编译器devco-鸿蒙SDK安装-模拟器环境调试-hyper虚拟化开启-全过程实战项目分享-从零开发到上线-优雅草卓伊凡
【02】鸿蒙实战应用开发-华为鸿蒙纯血操作系统Harmony OS NEXT-项目开发实战-准备工具安装-编译器DevEco Studio安装-arkts编程语言认识-编译器devco-鸿蒙SDK安装-模拟器环境调试-hyper虚拟化开启-全过程实战项目分享-从零开发到上线-优雅草卓伊凡
405 2
【02】鸿蒙实战应用开发-华为鸿蒙纯血操作系统Harmony OS NEXT-项目开发实战-准备工具安装-编译器DevEco Studio安装-arkts编程语言认识-编译器devco-鸿蒙SDK安装-模拟器环境调试-hyper虚拟化开启-全过程实战项目分享-从零开发到上线-优雅草卓伊凡
|
9月前
|
API 开发工具 Android开发
【01】完整开发即构美颜sdk的uni官方uts插件—让所有开发者可以直接使用即构美颜sdk的能力-优雅草卓伊凡
【01】完整开发即构美颜sdk的uni官方uts插件—让所有开发者可以直接使用即构美颜sdk的能力-优雅草卓伊凡
296 23
【01】完整开发即构美颜sdk的uni官方uts插件—让所有开发者可以直接使用即构美颜sdk的能力-优雅草卓伊凡