根据主键在指定的 Collection 中查询单条或多条数据,单次最多可查询100条数据。
Collection 数据写入/删除后,可以实时查询数据。
public DataApiResponse<FetchDataInCollectionResult> fetchDataInCollection(FetchDataInCollectionRequest request) throws ApiClientException, VectorApiException
参数名 | 类型 | 必选 | 默认值 | 备注 |
|---|---|---|---|---|
resourceId | String | 2选1 | 资源id | |
collectionName | String | collection名称 | ||
ids | List | 是 |
| |
名称 | 类型 | 说明 |
|---|---|---|
fetch | List | 查询到的数据列表,FetchResult结构见下。 |
idsNotExist | List | 不存在的主键列表 |
名称 | 类型 |
|---|---|
id | Object |
fields | Map<String, Object> |
package org.example.newsubproduct.data.data; import com.volcengine.vikingdb.runtime.core.ClientConfig; import com.volcengine.vikingdb.runtime.core.auth.AuthWithAkSk; import com.volcengine.vikingdb.runtime.enums.Scheme; import com.volcengine.vikingdb.runtime.exception.VectorApiException; import com.volcengine.vikingdb.runtime.vector.model.request.*; import com.volcengine.vikingdb.runtime.vector.model.response.*; import com.volcengine.vikingdb.runtime.vector.service.VectorService; import java.util.Arrays; public class FetchDataInCollection { public static void main(String[] args) { VectorService vectorService = null; try { vectorService = new VectorService( Scheme.HTTPS, "api-vikingdb.vikingdb.cn-beijing.volces.com", // 填写向量库数据面v2的域名 https://www.volcengine.com/docs/84313/1792715 "cn-beijing", new AuthWithAkSk(System.getenv("AK"), System.getenv("SK")), ClientConfig.builder().build() ); } catch (Exception e) { System.err.println("Client initialization failed: " + e.getMessage()); e.printStackTrace(); return; } FetchDataInCollectionRequest request = FetchDataInCollectionRequest.builder() .collectionName("your_collection_name") // 替换为您的集合名称 .ids(Arrays.asList(1, 2, 3, -99)) .build(); try { DataApiResponse<FetchDataInCollectionResult> response = vectorService.fetchDataInCollection(request); System.out.println("request success:"); System.out.println(response); } catch (VectorApiException vectorApiException) { System.err.println("request vectorApiException:"); System.out.println("apiName: " + vectorApiException.getApiName()); System.out.println("httpStatusCode: " + vectorApiException.getHttpStatusCode()); System.out.println("code: " + vectorApiException.getCode()); System.out.println("message: " + vectorApiException.getMessage()); System.out.println("requestId: " + vectorApiException.getRequestId()); System.out.println("responseContext: " + vectorApiException.getResponseContext().getBody()); } catch (Exception e) { System.err.println("request exception, message : " + e.getMessage()); e.printStackTrace(); } } }