表格存储 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
目录
相关文章
|
8天前
|
Java
java入门代码示例
本文介绍Java入门基础,包含Hello World、变量类型、条件判断、循环及方法定义等核心语法示例,帮助初学者快速掌握Java编程基本结构与逻辑。
141 0
|
2月前
|
安全 Java 数据库连接
2025 年最新 Java 学习路线图含实操指南助你高效入门 Java 编程掌握核心技能
2025年最新Java学习路线图,涵盖基础环境搭建、核心特性(如密封类、虚拟线程)、模块化开发、响应式编程、主流框架(Spring Boot 3、Spring Security 6)、数据库操作(JPA + Hibernate 6)及微服务实战,助你掌握企业级开发技能。
262 3
|
13天前
|
开发工具 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)-优雅草卓伊凡
176 11
X Android SDK file not found: adb.安卓开发常见问题-Android SDK 缺少 `adb`(Android Debug Bridge)-优雅草卓伊凡
|
25天前
|
前端开发 Java 数据库连接
帮助新手快速上手的 JAVA 学习路线最详细版涵盖从入门到进阶的 JAVA 学习路线
本Java学习路线涵盖从基础语法、面向对象、异常处理到高级框架、微服务、JVM调优等内容,适合新手入门到进阶,助力掌握企业级开发技能,快速成为合格Java开发者。
278 3
|
2月前
|
NoSQL Java 关系型数据库
Java 从入门到进阶完整学习路线图规划与实战开发最佳实践指南
本文为Java开发者提供从入门到进阶的完整学习路线图,涵盖基础语法、面向对象、数据结构与算法、并发编程、JVM调优、主流框架(如Spring Boot)、数据库操作(MySQL、Redis)、微服务架构及云原生开发等内容,并结合实战案例与最佳实践,助力高效掌握Java核心技术。
219 1
|
2月前
|
Java 测试技术 API
Java IO流(二):文件操作与NIO入门
本文详解Java NIO与传统IO的区别与优势,涵盖Path、Files类、Channel、Buffer、Selector等核心概念,深入讲解文件操作、目录遍历、NIO实战及性能优化技巧,适合处理大文件与高并发场景,助力高效IO编程与面试准备。
|
2月前
|
Java 编译器 API
Java Lambda表达式与函数式编程入门
Lambda表达式是Java 8引入的重要特性,简化了函数式编程的实现方式。它通过简洁的语法替代传统的匿名内部类,使代码更清晰、易读。本文深入讲解Lambda表达式的基本语法、函数式接口、方法引用等核心概念,并结合集合操作、线程处理、事件回调等实战案例,帮助开发者掌握现代Java编程技巧。同时,还解析了面试中高频出现的相关问题,助你深入理解其原理与应用场景。
|
16天前
|
Java API 数据库
2025 年最新 Java 实操学习路线,从入门到高级应用详细指南
2025年Java最新实操学习路线,涵盖从环境搭建到微服务、容器化部署的全流程实战内容,助你掌握Java 21核心特性、Spring Boot 3.2开发、云原生与微服务架构,提升企业级项目开发能力,适合从入门到高级应用的学习需求。
254 0
|
26天前
|
监控 Java API
2025 年全新出炉的 Java 学习路线:从入门起步到实操精通的详细指南
2025年Java学习路线与实操指南,涵盖Java 21核心特性、虚拟线程、Spring Boot 3、微服务、Spring Security、容器化部署等前沿技术,助你从入门到企业级开发进阶。
214 0
|
2月前
|
前端开发 Java 数据库
Java 项目实战从入门到精通 :Java Web 在线商城项目开发指南
本文介绍了一个基于Java Web的在线商城项目,涵盖技术方案与应用实例。项目采用Spring、Spring MVC和MyBatis框架,结合MySQL数据库,实现商品展示、购物车、用户注册登录等核心功能。通过Spring Boot快速搭建项目结构,使用JPA进行数据持久化,并通过Thymeleaf模板展示页面。项目结构清晰,适合Java Web初学者学习与拓展。
186 1

热门文章

最新文章