aliyun / aliyun-tablestore-java-sdk Goto Github PK

View Code? Open in Web Editor NEW

53.0 21.0 25.0 2.57 MB

Aliyun TableStore(原OTS) JAVA SDK

Home Page: https://www.aliyun.com/product/ots/

License: Apache License 2.0

Java 100.00%

aliyun tablestore ots nosql distributed-database java-sdk

aliyun-tablestore-java-sdk's People

Contributors

Stargazers

Watchers

aliyun-tablestore-java-sdk's Issues

BatchGetRowResponse中RowResult isSuccess==true，但Row为null

现象

使用BatchGetRow功能查询批量数据，查询一条不存在的数据，BatchGetRowResponse正常返回，取RowResult值的时候发现：isSuccess为true，但Row为null。

期望

public class BatchGetRowResponse extends Response implements Jsonizable {
    /**
     * BatchGetRow批量操作中单行查询的结果。
     * 若isSucceed为true，则代表该行查询操作成功，可以通过getRow获取单行查询的结果。
     * 若isSucceed为false，则代表该行查询操作失败，可以通过getError获取失败的错误信息。
     */
    public static class RowResult {}
}

代码

  private <T> void getBatchRow(Class<T> clazz, String table, List<PrimaryKey> pks) throws Exception {
    //读取一行数据，设置数据表名称。
    MultiRowQueryCriteria criteria = new MultiRowQueryCriteria(table);
    //设置读取最新版本。
    criteria.setMaxVersions(1);
    // 添加主键
    for(PrimaryKey pk : pks){
      criteria.addRow(pk);
    }
    // 执行查询
    BatchGetRowRequest request = new BatchGetRowRequest();
    request.addMultiRowQueryCriteria(criteria);
    BatchGetRowResponse response = client.batchGetRow(request);
    List<RowResult> rowRsts = response.getBatchGetRowResult(table);
    if (rowRsts.isEmpty()) {
      return Collections.emptyList();
    }

    for(RowResult rowRst : rowRsts){
      if(!rowRst.isSucceed()){
        continue;
      }
      Row row = rowRst.getRow();
      if(row.isEmpty()){
        continue;
      }
      System.out.println(row);
    }
  }

GetRange方法不能正确的完成功能

OTSMultiDataSample.java中演示了getRange方法的调用，demo程序中，插入了GID=1， UID范围1-5的5条数据。

getRange设定了GID范围从1-4，但是返回的结果是所有1-5的条目，这里demo是有些问题的，返回1-5是正常的。

但是我把查询程序改成GID范围INF_MIN-INF_MAX，UID范围设置成1-4时仍然返回所有结果，这里是不是存在一些bug？

TimestreamMetaIterator分页会取出所有数据

参考该地址实现：https://help.aliyun.com/document_detail/114347.html?spm=a2c4g.11186623.6.615.17132345T3bKeQ

TimestreamMetaIterator iter1 = db.metaTable()
                .filter(filter)
                .identifierOnly()       // 只返回identifer
                .fetchAll();
        System.out.print(iterator.getTotalCount());   //获取命中的时间线条数
        while (iter1.hasNext()) {
            System.out.print(iterator.next().toString());
        }
    public boolean hasNext() {
        if (isBufferHasData()) {
            return true;
        }
        byte[] token = response.getNextToken();

        while (token != null) {
            request.getSearchQuery().setToken(response.getNextToken());
            request.getSearchQuery().setOffset(0);
            fetchData(request);
            if (isBufferHasData()) {
                return true;
            }
            token = response.getNextToken();
        }
        return false;
    }

上述实现会取出所有数据，是否需要把isBufferHasData提出公共方法出来。目前实现分页，不能用这个方法，只能自己写实现

STS Token过期之后，OTS Client对象无法更新Token，希望提供一个接口，可以更新Token

如题所示

未对[ErrorCode]:OTSFlowControl错误进行处理

系统对[ErrorCode]:OTSFlowControl进行处理

OTSConditionalUpdateSample bug, the external 'cond' is not set in 'updateRow' function

https://github.com/aliyun/aliyun-tablestore-java-sdk/blob/master/src/test/java/examples/OTSConditionalUpdateSample.java

line 64 and 162

对 protobuf-java 2.5.0 支持不好

tablestore 5.3.0 对 protobuf-java 2.5.0 支持不好

没有结合spring spirngboot用例

没有集合spring 用例
没有结合springboot 用例
每一次创建连接需要时间较长，大约1分钟
长连接好像不能保持

Table Store 写入迟延

Table Store sdk 有大概两秒钟的写入迟延。写入table后，马上读取，无数据。请提供方案。

请问如何使用 PrepareCallback ?

目前该接口无任何入参, 而且在 Client 执行大部分操作时都会回调一次.
暂时无法理解这个回调接口的应用场景..

java.lang.IllegalStateException: Request cannot be executed; I/O reactor status: STOPPED
at org.apache.http.util.Asserts.check(Asserts.java:46)
at org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase.ensureRunning(CloseableHttpAsyncClientBase.java:90)
at org.apache.http.impl.nio.client.InternalHttpAsyncClient.execute(InternalHttpAsyncClient.java:123)
at org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute(CloseableHttpAsyncClient.java:68)
at com.alicloud.openservices.tablestore.core.http.AsyncServiceClient.asyncSendRequest(AsyncServiceClient.java:150)
at com.alicloud.openservices.tablestore.core.OperationLauncher.asyncInvokePost(OperationLauncher.java:152)
at com.alicloud.openservices.tablestore.core.BatchGetRowLauncher.fire(BatchGetRowLauncher.java:63)
at com.alicloud.openservices.tablestore.InternalClient.batchGetRow(InternalClient.java:586)
at com.alicloud.openservices.tablestore.SyncClient.batchGetRow(SyncClient.java:273)

怎么检查otsclient是否处于shutdown状态？？？

Issue submit test.

This is just a test.

把完整的ERROR CODE列表放到代码里面，并定义常量字符串

在处理ERROR CODE的时候，要到API文档里面查询，而找API文档的错误码又要花很长时间，希望这些错误码能跟代码放在一起，方便查询。
另外，每个函数能将典型的抛出的错误码在注释里面说明一下，也会有利于处理。

aliyun / aliyun-tablestore-java-sdk Goto Github PK

aliyun-tablestore-java-sdk's People

Contributors

Stargazers

Watchers

Forkers

aliyun-tablestore-java-sdk's Issues

现象

期望

代码

Recommend Projects

Recommend Topics

Recommend Org