From cff9d5c5d0cb4d07bee3befdb73bfdf9eaa6cf03 Mon Sep 17 00:00:00 2001
From: qianbao <qianbaoqianbao>
Date: Wed, 25 Mar 2026 15:50:06 +0800
Subject: [PATCH] 添加向量库

---
 src/main/java/com/xly/milvus/config/MilvusStartupValidator.java  |  4 ++--
 src/main/java/com/xly/milvus/service/impl/MilvusServiceImpl.java | 23 +++++++++++++++++++----
 2 files changed, 21 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/xly/milvus/config/MilvusStartupValidator.java b/src/main/java/com/xly/milvus/config/MilvusStartupValidator.java
index e3e1f3a..586e151 100644
--- a/src/main/java/com/xly/milvus/config/MilvusStartupValidator.java
+++ b/src/main/java/com/xly/milvus/config/MilvusStartupValidator.java
@@ -68,10 +68,10 @@ public class MilvusStartupValidator implements ApplicationRunner {
                 }
             }
 
-            log.info("✅ Milvus启动验证完成");
+            log.info("Milvus启动验证完成");
 
         } catch (Exception e) {
-            log.error("❌ Milvus启动验证失败: {}", e.getMessage(), e);
+            log.error("Milvus启动验证失败: {}", e.getMessage(), e);
             // 可以根据配置决定是否抛出异常
             // throw new RuntimeException("Milvus验证失败", e);
         }
diff --git a/src/main/java/com/xly/milvus/service/impl/MilvusServiceImpl.java b/src/main/java/com/xly/milvus/service/impl/MilvusServiceImpl.java
index 3204d0e..ec2bbb9 100644
--- a/src/main/java/com/xly/milvus/service/impl/MilvusServiceImpl.java
+++ b/src/main/java/com/xly/milvus/service/impl/MilvusServiceImpl.java
@@ -144,16 +144,30 @@ public class MilvusServiceImpl implements MilvusService {
      **/
     public void addAiMilvusVectorRecord(String sInputTabelName,String tUpdateDate,String tUpdateDateUp) {
         //获取需要同步地数据
+        delAiMilvusVectorRecord(sInputTabelName);
         Map<String,Object> dMap = new HashMap<>();
         dMap.put("sInputTabelName",sInputTabelName);
-        String sSql = "DELETE FROM ai_milvus_vector_record WHERE sInputTabelName = #{sInputTabelName}";
-        dynamicExeDbService.delSql(dMap,sSql);
         dMap.put("tUpdateDate",tUpdateDate);
         dMap.put("tUpdateDateUp",tUpdateDateUp);
-        sSql = String.format("INSERT INTO ai_milvus_vector_record(sId,sInputTabelName,tUpdateDate,tUpdateDateUp)VALUES(newId(),#{sInputTabelName},#{tUpdateDate},#{tUpdateDateUp})");
+        String sSql = String.format("INSERT INTO ai_milvus_vector_record(sId,sInputTabelName,tUpdateDate,tUpdateDateUp)VALUES(newId(),#{sInputTabelName},#{tUpdateDate},#{tUpdateDateUp})");
         dynamicExeDbService.addSql(dMap,sSql);
     }
 
+    /***
+     * @Author 钱豹
+     * @Date 22:32 2026/3/24
+     * @Param [sInputTabelName, tUpdateDate]
+     * @return java.util.List<java.util.Map<java.lang.String,java.lang.Object>>
+     * @Description 获取更新地数据
+     **/
+    public void delAiMilvusVectorRecord(String sInputTabelName) {
+        //获取需要同步地数据
+        Map<String,Object> dMap = new HashMap<>();
+        dMap.put("sInputTabelName",sInputTabelName);
+        String sSql = "DELETE FROM ai_milvus_vector_record WHERE sInputTabelName = #{sInputTabelName}";
+        dynamicExeDbService.delSql(dMap,sSql);
+    }
+
 
     /***
      * @Author 钱豹
@@ -595,7 +609,8 @@ public class MilvusServiceImpl implements MilvusService {
             milvusClient.dropCollection(DropCollectionReq.builder()
                     .collectionName(collectionName)
                     .build());
-
+            //删除对应的记录表
+            delAiMilvusVectorRecord(collectionName);
         }
         // 检查集合是否存在
         HasCollectionReq hasCollectionReq = HasCollectionReq.builder()
--
libgit2 0.22.2