diff --git a/spring-ai-alibaba-core/src/main/java/com/alibaba/cloud/ai/document/DocumentParser.java b/spring-ai-alibaba-core/src/main/java/com/alibaba/cloud/ai/document/DocumentParser.java
new file mode 100644
index 00000000..c93e49e3
--- /dev/null
+++ b/spring-ai-alibaba-core/src/main/java/com/alibaba/cloud/ai/document/DocumentParser.java
@@ -0,0 +1,27 @@
+package com.alibaba.cloud.ai.document;
+
+import org.springframework.ai.document.Document;
+
+import java.io.InputStream;
+import java.util.List;
+
+/**
+ * @author HeYQ
+ * @since 2024-12-02 11:25
+ */
+
+public interface DocumentParser {
+
+ /**
+ * Parses a given {@link InputStream} into a {@link Document}. The specific
+ * implementation of this method will depend on the type of the document being parsed.
+ *
+ * Note: This method does not close the provided {@link InputStream} - it is the
+ * caller's responsibility to manage the lifecycle of the stream.
+ * @param inputStream The {@link InputStream} that contains the content of the
+ * {@link Document}.
+ * @return The parsed {@link Document}.
+ */
+ List parse(InputStream inputStream);
+
+}
diff --git a/spring-ai-alibaba-core/src/main/java/com/alibaba/cloud/ai/document/JsonDocumentParser.java b/spring-ai-alibaba-core/src/main/java/com/alibaba/cloud/ai/document/JsonDocumentParser.java
new file mode 100644
index 00000000..2cdc8dfe
--- /dev/null
+++ b/spring-ai-alibaba-core/src/main/java/com/alibaba/cloud/ai/document/JsonDocumentParser.java
@@ -0,0 +1,112 @@
+package com.alibaba.cloud.ai.document;
+
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.springframework.ai.document.Document;
+import org.springframework.ai.reader.EmptyJsonMetadataGenerator;
+import org.springframework.ai.reader.JsonMetadataGenerator;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.stream.StreamSupport;
+
+/**
+ * @author HeYQ
+ * @since 2024-12-08 21:13
+ */
+
+public class JsonDocumentParser implements DocumentParser {
+
+ private final JsonMetadataGenerator jsonMetadataGenerator;
+
+ private final ObjectMapper objectMapper = new ObjectMapper();
+
+ /**
+ * The key from the JSON that we will use as the text to parse into the Document text
+ */
+ private final List jsonKeysToUse;
+
+ public JsonDocumentParser(String... jsonKeysToUse) {
+ this(new EmptyJsonMetadataGenerator(), jsonKeysToUse);
+ }
+
+ public JsonDocumentParser(JsonMetadataGenerator jsonMetadataGenerator, String... jsonKeysToUse) {
+ Objects.requireNonNull(jsonKeysToUse, "keys must not be null");
+ Objects.requireNonNull(jsonMetadataGenerator, "jsonMetadataGenerator must not be null");
+ this.jsonMetadataGenerator = jsonMetadataGenerator;
+ this.jsonKeysToUse = List.of(jsonKeysToUse);
+ }
+
+ @Override
+ public List parse(InputStream inputStream) {
+ try {
+ JsonNode rootNode = this.objectMapper.readTree(inputStream);
+
+ if (rootNode.isArray()) {
+ return StreamSupport.stream(rootNode.spliterator(), true)
+ .map(jsonNode -> parseJsonNode(jsonNode, this.objectMapper))
+ .toList();
+ }
+ else {
+ return Collections.singletonList(parseJsonNode(rootNode, this.objectMapper));
+ }
+ }
+ catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ private Document parseJsonNode(JsonNode jsonNode, ObjectMapper objectMapper) {
+ Map item = objectMapper.convertValue(jsonNode, new TypeReference>() {
+
+ });
+ var sb = new StringBuilder();
+
+ this.jsonKeysToUse.stream()
+ .filter(item::containsKey)
+ .forEach(key -> sb.append(key).append(": ").append(item.get(key)).append(System.lineSeparator()));
+
+ Map metadata = this.jsonMetadataGenerator.generate(item);
+ String content = sb.isEmpty() ? item.toString() : sb.toString();
+ return new Document(content, metadata);
+ }
+
+ protected List get(JsonNode rootNode) {
+ if (rootNode.isArray()) {
+ return StreamSupport.stream(rootNode.spliterator(), true)
+ .map(jsonNode -> parseJsonNode(jsonNode, this.objectMapper))
+ .toList();
+ }
+ else {
+ return Collections.singletonList(parseJsonNode(rootNode, this.objectMapper));
+ }
+ }
+
+ /**
+ * Retrieves documents from the JSON resource using a JSON Pointer.
+ * @param pointer A JSON Pointer string (RFC 6901) to locate the desired element
+ * @return A list of Documents parsed from the located JSON element
+ * @throws RuntimeException if the JSON cannot be parsed or the pointer is invalid
+ */
+ public List get(String pointer, InputStream inputStream) {
+ try {
+ JsonNode rootNode = this.objectMapper.readTree(inputStream);
+ JsonNode targetNode = rootNode.at(pointer);
+
+ if (targetNode.isMissingNode()) {
+ throw new IllegalArgumentException("Invalid JSON Pointer: " + pointer);
+ }
+
+ return get(targetNode);
+ }
+ catch (IOException e) {
+ throw new RuntimeException("Error reading JSON resource", e);
+ }
+ }
+
+}
diff --git a/spring-ai-alibaba-core/src/main/java/com/alibaba/cloud/ai/document/TextDocumentParser.java b/spring-ai-alibaba-core/src/main/java/com/alibaba/cloud/ai/document/TextDocumentParser.java
new file mode 100644
index 00000000..9a895a00
--- /dev/null
+++ b/spring-ai-alibaba-core/src/main/java/com/alibaba/cloud/ai/document/TextDocumentParser.java
@@ -0,0 +1,44 @@
+package com.alibaba.cloud.ai.document;
+
+import org.springframework.ai.document.Document;
+import org.springframework.util.Assert;
+
+import java.io.InputStream;
+import java.nio.charset.Charset;
+import java.util.Collections;
+import java.util.List;
+
+import static java.nio.charset.StandardCharsets.UTF_8;
+
+/**
+ * @author HeYQ
+ * @since 2024-12-08 21:13
+ */
+public class TextDocumentParser implements DocumentParser {
+
+ private final Charset charset;
+
+ public TextDocumentParser() {
+ this(UTF_8);
+ }
+
+ public TextDocumentParser(Charset charset) {
+ Assert.notNull(charset, "charset");
+ this.charset = charset;
+ }
+
+ @Override
+ public List parse(InputStream inputStream) {
+ try {
+ String text = new String(inputStream.readAllBytes(), charset);
+ if (text.isBlank()) {
+ throw new Exception();
+ }
+ return Collections.singletonList(new Document(text));
+ }
+ catch (Exception e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+}
diff --git a/spring-ai-alibaba-core/src/test/java/com/alibaba/cloud/ai/dashscope/rag/AnalyticdbVectorTest.java b/spring-ai-alibaba-core/src/test/java/com/alibaba/cloud/ai/dashscope/rag/AnalyticdbVectorTest.java
new file mode 100644
index 00000000..1e2d00f5
--- /dev/null
+++ b/spring-ai-alibaba-core/src/test/java/com/alibaba/cloud/ai/dashscope/rag/AnalyticdbVectorTest.java
@@ -0,0 +1,92 @@
+package com.alibaba.cloud.ai.dashscope.rag;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.condition.EnabledIfEnvironmentVariable;
+import org.springframework.ai.document.Document;
+import org.springframework.ai.vectorstore.SearchRequest;
+import org.springframework.boot.test.context.SpringBootTest;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Random;
+
+@SpringBootTest
+@EnabledIfEnvironmentVariable(named = "ANALYTICDB_SECRET_KEY", matches = ".+")
+class AnalyticdbVectorTest {
+
+ AnalyticdbVector analyticdbVector;
+
+ @BeforeEach
+ public void init() throws Exception {
+ AnalyticdbConfig config = new AnalyticdbConfig();
+ config.setRegionId("cn-beijing");
+ config.setDBInstanceId("gp-2ze41j8y0ry4spfev");
+ config.setAccessKeyId(System.getenv("ANALYTICDB_SECRET_ID"));
+ config.setAccessKeySecret(System.getenv("ANALYTICDB_SECRET_KEY"));
+ config.setManagerAccount("hyq"); // admin0
+ config.setManagerAccountPassword("hdcHDC1997@@@"); // 123456
+ config.setNamespace("llama");
+ config.setNamespacePassword("llamapassword");
+ config.setEmbeddingDimension(3L);
+ analyticdbVector = new AnalyticdbVector("test_llama", config);
+ }
+
+ @Test
+ void testGetInstance() throws Exception {
+ List list = new ArrayList<>(10);
+ Map metadata = new HashMap<>();
+ metadata.put("docId", "1"); // 123 //12344
+ Document document = new Document("hello1234you arewomen12334444", metadata);
+ int length = 1536; // Array length
+ float min = 0f; // smallest value
+ float max = 1f; // the largest value
+ float[] em = new float[length]; // create float array
+ Random random = new Random();
+ for (int i = 0; i < length; i++) {
+ em[i] = min + (max - min) * random.nextFloat();
+ }
+ document.setEmbedding(em);
+ list.add(document);
+ analyticdbVector.add(list);
+ SearchRequest searchRequest = SearchRequest.query("hello");
+ List documents = analyticdbVector.similaritySearch(searchRequest);
+ System.out.println(documents.get(0).getContent());
+
+ // analyticdbVector.delete(List.of("1"));
+
+ }
+
+ @Test
+ void testSearchByVector() {
+ // Suppose we have a known vector and some preset parameters.
+ // List queryVector = Arrays.asList(0.1f, 0.2f, 0.3f);
+ // Map kwargs = new HashMap<>();
+ // kwargs.put("score_threshold", 0.5f);
+ SearchRequest searchRequest = SearchRequest.query("hello");
+ searchRequest.withTopK(5);
+ searchRequest.withSimilarityThreshold(0.5f);
+
+ // Call the method and verify the return result.
+ List results = analyticdbVector.similaritySearch(searchRequest);
+
+ // There should be some assertions here to verify that the results meet
+ // expectations.
+ Assertions.assertNotNull(results);
+ // The more specific assertions can be added based on your needs.
+ }
+
+ @Test
+ void testDelete() {
+ // Call the delete method.
+ analyticdbVector.delete(List.of("1"));
+
+ // Based on your actual situation, you can add logic here to verify
+ // whether the delete operation was successful.
+ // For example, check whether the collection exists in the database.
+ }
+
+}