OceanBase客户端使用指南

OceanBase客户端使用指南

ID:38260125

大小:24.16 KB

页数:6页

时间:2019-06-07

OceanBase客户端使用指南_第1页
OceanBase客户端使用指南_第2页
OceanBase客户端使用指南_第3页
OceanBase客户端使用指南_第4页
OceanBase客户端使用指南_第5页
资源描述:

《OceanBase客户端使用指南》由会员上传分享,免费在线阅读,更多相关内容在教育资源-天天文库

1、OceanBase客户端使用指南1OceanBase客户端工作原理32客户端常用数据结构说明32.1rowkey32.2RowData32.3QueryInfo32.4InsertMutator和UpdateMutator43接口使用说明43.1初始化OceanBasejava客户端43.1.1配置项43.1.2创建客户端实例43.2接口使用说明53.2.1ResultCode定义53.2.2get53.2.3query53.2.4insert63.2.5update63.2.6delete6本文档描述OceanBase客

2、户端的使用方法,由于当前仅提供Java客户端,所以暂时只包含Java客户端的使用方法。文档主要包括以下几个部分:1.客户端的工作原理2.客户端常用数据结构说明3.客户端的初始化和接口使用说明1OceanBase客户端工作原理OceanBase是一个分布式表格存储系统,主要包括以下模块:1.rootserver2.updateserver3.chunkserver4.mergeserverrootserver负责维护系统数据的分布信息,客户端根据用户请求的rowkey,从rootserver查询负责该rowkey对应数据的m

3、ergeserver。updateserver负责整个系统的数据更新,更新的数据会定期合并到chunkserver。chunkserver负责静态数据的存储。mergeserver提供系统的查询服务,当接收到查询时,mergeserver会根据相应的rowkey(或者范围)请求chunkserver上存储的静态数据,以及updateserver上更新的数据,然后做合并,返回结果数据。mergeserver还支持对数据的过滤,排序等操作。2客户端常用数据结构说明2.1rowkeyOceanBase中所有的数据都需要有一个ro

4、wkey,数据在存储时按照rowkey排序。RowKey为字节流,rowkey的结构在系统的schema中指定。2.2RowDataOceanBase客户端使用RowData来表示一行数据,该数据结构通常用在查询返回时。数据结构包括:1.表名2.rowkey3.各列数据,列的数据由列名和值组成,提供按照列名取值的接口2.3QueryInfoOceanBase提供查询功能,查询的参数使用QueryInfo对象封装,QueryInfo主要包含以下信息:字段名含义startKey查询范围的开始rowKeyendKey查询范围的结

5、束rowKeyFlag查询的标识位:INCLUSIVE_START(结果包含startKey);INCLUSIVE_END(结果包含endKey);MIN_VALUE(startKey是最小值,即比任何用户数据小);MAX_VALUE(endKey是最大值,即比任何用户数据大)orderBy排序字段列表,支持多个排序字段,每个字段包括字段名和排序规则(升序/降序)columns查询换回的列名列表pageSize分页的单页大小pageNum分页时当前的页码Limit单次查询返回的最大条目数filter过滤条件,比如price

6、>1.0等groupbyParamgroupBy的条件参数1.1InsertMutator和UpdateMutatorMutator封装了对一条记录的修改操作,客户端把要修改的数据填充在Mutator中,作为请求参数发送到updateserver,updateserver执行相应的操作。Mutator的主要数据结构包括:字段名含义Table更新的表名rowKey待更新的数据的rowKeyColumns待更新的数据列表,结构为List,其中Tupe为一个name/value对2接口使用说明2.1初始化Ocean

7、Basejava客户端2.1.1配置项OceanBase客户端支持3个配置项名称类型默认值含义IPString无Rootserver的地址PortInt无Rootserver的端口TimeoutInt1000客户端请求的超时时间,单位为毫秒(ms)2.1.2创建客户端实例Clientobclient=null;//创建一个客户端实例ClientImplclientInstance=newClientImpl();clientInstance.setIp("192.168.0.1");//设置rootserver地址clie

8、ntInstance.setPort(1234);//设置rootserver端口clientInstance.setTimeout(2000);//设置超时时间obclient=clientInstance;1.1接口使用说明OceanBase的客户端只要提供读取、查询和更新的接口。1.1.1Resu

当前文档最多预览五页,下载文档查看全文

此文档下载收益归作者所有

当前文档最多预览五页,下载文档查看全文
温馨提示:
1. 部分包含数学公式或PPT动画的文件,查看预览时可能会显示错乱或异常,文件下载后无此问题,请放心下载。
2. 本文档由用户上传,版权归属用户,天天文库负责整理代发布。如果您对本文档版权有争议请及时联系客服。
3. 下载前请仔细阅读文档内容,确认文档内容符合您的需求后进行下载,若出现内容与标题不符可向本站投诉处理。
4. 下载文档时可能由于网络波动等原因无法下载或下载错误,付费完成后未能成功下载的用户请联系客服处理。