feat(tablestore): add knowledge base API

Author: zhanghaochenFCB

README.md

@@ -9,19 +9,19 @@
  - 阿里云表格存储是阿里云自主研发的NoSQL数据存储服务，提供海量结构化数据的存储和实时访问。
 
 ## 版本
- - 当前版本：5.17.9
+ - 当前版本：5.17.10
 
 ## 运行环境
  - JDK 6及其以上
 
 ## 安装
 #### Maven方式
-下载[最新版JAR包](https://search.maven.org/remotecontent?filepath=com/aliyun/openservices/tablestore/5.17.8/tablestore-5.17.8.jar)或者通过Maven：
+下载[最新版JAR包](https://search.maven.org/remotecontent?filepath=com/aliyun/openservices/tablestore/5.17.10/tablestore-5.17.10.jar)或者通过Maven：
 ```xml
 <dependency>
   <groupId>com.aliyun.openservices</groupId>
   <artifactId>tablestore</artifactId>
-  <version>5.17.8</version>
+  <version>5.17.10</version>
 </dependency>
 ```
 

tablestore/pom.xml

@@ -3,7 +3,7 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>com.aliyun.openservices</groupId>
   <artifactId>tablestore</artifactId>
-  <version>5.17.9</version>
+  <version>5.17.10</version>
   <packaging>jar</packaging>
   <name>AliCloud TableStore SDK for Java</name>
   <parent>
@@ -105,7 +105,7 @@
     <dependency>
       <groupId>com.google.code.gson</groupId>
       <artifactId>gson</artifactId>
-      <version>2.8.5</version>
+      <version>2.9.0</version>
     </dependency>
     <dependency>
       <groupId>com.google.guava</groupId>

tablestore/protoc.sh

@@ -0,0 +1,63 @@
+#!/bin/bash
+# Usage: ./protoc.sh [protoc_path]
+# Need to specify the path to the protoc executable file
+# Protocol buffer version requirement: 4.28.2
+
+DIR=$(cd $(dirname $0); pwd)
+cd ${DIR}
+
+
+# Define the default protoc executable file path
+DEFAULT_PROTOC_PATH="protoc"
+
+# Check if the parameter is provided, if not, use the default value.
+if [ -z "$1" ]; then
+    PROTOC_PATH="$DEFAULT_PROTOC_PATH"
+else
+    PROTOC_PATH="$1"
+fi
+
+# Check if this path is valid
+if [ ! -x "$PROTOC_PATH" ]; then
+    echo "Error: '$PROTOC_PATH' is not a valid executable file."
+    exit 1
+fi
+
+# Output the version information of protoc
+echo "Running protoc from: $PROTOC_PATH"
+"$PROTOC_PATH" --version
+
+# List of proto files
+proto_files=($(find ./src/main/java -type f -name "*.proto"))
+
+build_folder='build-protoc'
+mkdir -p "$build_folder"
+
+for proto_file in "${proto_files[@]}"; do
+    cp "$proto_file" "$build_folder"
+done
+
+cd "$build_folder"
+
+gen_folder='gen'
+mkdir -p "$gen_folder"
+for proto_file in "${proto_files[@]}"; do
+    proto_base=$(basename "$proto_file")
+
+    command="$PROTOC_PATH $proto_base --java_out=./$gen_folder"
+    echo "run: $command"
+    $command
+    if [ $? -ne 0 ]; then
+        echo "run command failed: $command"
+        exit 1
+    fi
+done
+
+find . -type f -name "*.java" -exec sed -i '' 's/com\.google\.protobuf/com.aliyun.ots.thirdparty.com.google.protobuf/g' {} \;
+
+rsync -av $gen_folder/ ../src/main/java/
+
+cd ..
+rm -r "$build_folder"
+
+echo "all commands done."

tablestore/src/main/java/com/alicloud/openservices/tablestore/AsyncClient.java

@@ -11,6 +11,7 @@
 import com.alicloud.openservices.tablestore.model.search.*;
 import com.alicloud.openservices.tablestore.model.sql.SQLQueryRequest;
 import com.alicloud.openservices.tablestore.model.sql.SQLQueryResponse;
+import com.alicloud.openservices.tablestore.model.knowledgebase.*;
 
 public class AsyncClient implements AsyncClientInterface {
 
@@ -409,4 +410,74 @@ public void switchCredentialsProvider(CredentialsProvider newCrdsProvider) {
     public Future<SQLQueryResponse> sqlQuery(SQLQueryRequest request, TableStoreCallback<SQLQueryRequest, SQLQueryResponse> callback) {
         return internalClient.sqlQuery(request, callback);
     }
+
+    // KnowledgeBase operations
+    @Override
+    public Future<CreateKnowledgeBaseResponse> createKnowledgeBase(CreateKnowledgeBaseRequest request, TableStoreCallback<CreateKnowledgeBaseRequest, CreateKnowledgeBaseResponse> callback) {
+        return internalClient.createKnowledgeBase(request, callback);
+    }
+
+    @Override
+    public Future<DescribeKnowledgeBaseResponse> describeKnowledgeBase(DescribeKnowledgeBaseRequest request, TableStoreCallback<DescribeKnowledgeBaseRequest, DescribeKnowledgeBaseResponse> callback) {
+        return internalClient.describeKnowledgeBase(request, callback);
+    }
+
+    @Override
+    public Future<ListKnowledgeBaseResponse> listKnowledgeBase(ListKnowledgeBaseRequest request, TableStoreCallback<ListKnowledgeBaseRequest, ListKnowledgeBaseResponse> callback) {
+        return internalClient.listKnowledgeBase(request, callback);
+    }
+
+    @Override
+    public Future<DeleteKnowledgeBaseResponse> deleteKnowledgeBase(DeleteKnowledgeBaseRequest request, TableStoreCallback<DeleteKnowledgeBaseRequest, DeleteKnowledgeBaseResponse> callback) {
+        return internalClient.deleteKnowledgeBase(request, callback);
+    }
+
+    @Override
+    public Future<UpdateKnowledgeBaseResponse> updateKnowledgeBase(UpdateKnowledgeBaseRequest request, TableStoreCallback<UpdateKnowledgeBaseRequest, UpdateKnowledgeBaseResponse> callback) {
+        return internalClient.updateKnowledgeBase(request, callback);
+    }
+
+    // Document operations
+    @Override
+    public Future<AddDocumentsResponse> addDocuments(AddDocumentsRequest request, TableStoreCallback<AddDocumentsRequest, AddDocumentsResponse> callback) {
+        return internalClient.addDocuments(request, callback);
+    }
+
+    @Override
+    public Future<GetDocumentResponse> getDocument(GetDocumentRequest request, TableStoreCallback<GetDocumentRequest, GetDocumentResponse> callback) {
+        return internalClient.getDocument(request, callback);
+    }
+
+    @Override
+    public Future<ListDocumentsResponse> listDocuments(ListDocumentsRequest request, TableStoreCallback<ListDocumentsRequest, ListDocumentsResponse> callback) {
+        return internalClient.listDocuments(request, callback);
+    }
+
+    @Override
+    public Future<DeleteDocumentsResponse> deleteDocuments(DeleteDocumentsRequest request, TableStoreCallback<DeleteDocumentsRequest, DeleteDocumentsResponse> callback) {
+        return internalClient.deleteDocuments(request, callback);
+    }
+
+    @Override
+    public Future<UpdateDocumentResponse> updateDocument(UpdateDocumentRequest request, TableStoreCallback<UpdateDocumentRequest, UpdateDocumentResponse> callback) {
+        return internalClient.updateDocument(request, callback);
+    }
+
+    // Chunk operations
+    @Override
+    public Future<ListChunksResponse> listChunks(ListChunksRequest request, TableStoreCallback<ListChunksRequest, ListChunksResponse> callback) {
+        return internalClient.listChunks(request, callback);
+    }
+
+    @Override
+    public Future<UpdateChunksResponse> updateChunks(UpdateChunksRequest request, TableStoreCallback<UpdateChunksRequest, UpdateChunksResponse> callback) {
+        return internalClient.updateChunks(request, callback);
+    }
+
+    // Retrieval operations
+    @Override
+    public Future<RetrieveResponse> retrieve(RetrieveRequest request, TableStoreCallback<RetrieveRequest, RetrieveResponse> callback) {
+        return internalClient.retrieve(request, callback);
+    }
+
 }

tablestore/src/main/java/com/alicloud/openservices/tablestore/AsyncClientInterface.java

@@ -8,6 +8,7 @@
 import com.alicloud.openservices.tablestore.model.search.*;
 import com.alicloud.openservices.tablestore.model.sql.SQLQueryRequest;
 import com.alicloud.openservices.tablestore.model.sql.SQLQueryResponse;
+import com.alicloud.openservices.tablestore.model.knowledgebase.*;
 
 public interface AsyncClientInterface {
 
@@ -493,4 +494,48 @@ public Future<SearchResponse> search(
     public void switchCredentialsProvider(CredentialsProvider newCrdsProvider);
 
     public Future<SQLQueryResponse> sqlQuery(SQLQueryRequest request, TableStoreCallback<SQLQueryRequest, SQLQueryResponse> callback);
+
+    // KnowledgeBase operations
+    public Future<CreateKnowledgeBaseResponse> createKnowledgeBase(
+            CreateKnowledgeBaseRequest request, TableStoreCallback<CreateKnowledgeBaseRequest, CreateKnowledgeBaseResponse> callback);
+
+    public Future<DescribeKnowledgeBaseResponse> describeKnowledgeBase(
+            DescribeKnowledgeBaseRequest request, TableStoreCallback<DescribeKnowledgeBaseRequest, DescribeKnowledgeBaseResponse> callback);
+
+    public Future<ListKnowledgeBaseResponse> listKnowledgeBase(
+            ListKnowledgeBaseRequest request, TableStoreCallback<ListKnowledgeBaseRequest, ListKnowledgeBaseResponse> callback);
+
+    public Future<DeleteKnowledgeBaseResponse> deleteKnowledgeBase(
+            DeleteKnowledgeBaseRequest request, TableStoreCallback<DeleteKnowledgeBaseRequest, DeleteKnowledgeBaseResponse> callback);
+
+    public Future<UpdateKnowledgeBaseResponse> updateKnowledgeBase(
+            UpdateKnowledgeBaseRequest request, TableStoreCallback<UpdateKnowledgeBaseRequest, UpdateKnowledgeBaseResponse> callback);
+
+    // Document operations
+    public Future<AddDocumentsResponse> addDocuments(
+            AddDocumentsRequest request, TableStoreCallback<AddDocumentsRequest, AddDocumentsResponse> callback);
+
+    public Future<GetDocumentResponse> getDocument(
+            GetDocumentRequest request, TableStoreCallback<GetDocumentRequest, GetDocumentResponse> callback);
+
+    public Future<ListDocumentsResponse> listDocuments(
+            ListDocumentsRequest request, TableStoreCallback<ListDocumentsRequest, ListDocumentsResponse> callback);
+
+    public Future<DeleteDocumentsResponse> deleteDocuments(
+            DeleteDocumentsRequest request, TableStoreCallback<DeleteDocumentsRequest, DeleteDocumentsResponse> callback);
+
+    public Future<UpdateDocumentResponse> updateDocument(
+            UpdateDocumentRequest request, TableStoreCallback<UpdateDocumentRequest, UpdateDocumentResponse> callback);
+
+    // Chunk operations
+    public Future<ListChunksResponse> listChunks(
+            ListChunksRequest request, TableStoreCallback<ListChunksRequest, ListChunksResponse> callback);
+
+    public Future<UpdateChunksResponse> updateChunks(
+            UpdateChunksRequest request, TableStoreCallback<UpdateChunksRequest, UpdateChunksResponse> callback);
+
+    // Retrieval operations
+    public Future<RetrieveResponse> retrieve(
+            RetrieveRequest request, TableStoreCallback<RetrieveRequest, RetrieveResponse> callback);
+
 }