Merge f489ea2f59 into 303392f492

chat/server/src/main/java/com/tencent/supersonic/chat/server/service/impl/MemoryServiceImpl.java

@@ -71,9 +71,8 @@ public class MemoryServiceImpl implements MemoryService, CommandLineRunner {
             chatMemoryDO.setS2sql(chatMemoryUpdateReq.getS2sql());
             chatMemoryDO.setDbSchema(chatMemoryUpdateReq.getDbSchema());
             enableMemory(chatMemoryDO);
-        } else if ((MemoryStatus.DISABLED.equals(chatMemoryUpdateReq.getStatus())
-                || MemoryStatus.PENDING.equals(chatMemoryUpdateReq.getStatus())) && hadEnabled) {
-            // Remove from vector DB when transitioning: launched→disabled OR enabled→pending
+        } else if ((MemoryStatus.DISABLED.equals(chatMemoryUpdateReq.getStatus())||MemoryStatus.PENDING.equals(chatMemoryUpdateReq.getStatus())) && hadEnabled) {
+           //  Remove from vector DB when transitioning: launched→disabled OR enabled→pending
             disableMemory(chatMemoryDO);
         }
         LambdaUpdateWrapper<ChatMemoryDO> updateWrapper = new LambdaUpdateWrapper<>();

headless/chat/src/main/java/com/tencent/supersonic/headless/chat/parser/llm/PromptHelper.java

@@ -52,8 +52,7 @@ public class PromptHelper {
         for (int i = 0; i < selfConsistencyNumber; i++) {
             List<Text2SQLExemplar> shuffledList = new ArrayList<>(exemplars);
             // only shuffle the exemplars from config
-            List<Text2SQLExemplar> subList =
-                    shuffledList.subList(llmReq.getDynamicExemplars().size(), shuffledList.size());
+            List<Text2SQLExemplar> subList=shuffledList.subList(llmReq.getDynamicExemplars().size(),shuffledList.size());
             Collections.shuffle(subList);
             results.add(shuffledList.subList(0, Math.min(shuffledList.size(), fewShotNumber)));
         }

headless/core/src/main/java/com/tencent/supersonic/headless/core/adaptor/db/BaseDbAdaptor.java

@@ -5,6 +5,7 @@ import com.tencent.supersonic.headless.api.pojo.DBColumn;
 import com.tencent.supersonic.headless.api.pojo.enums.FieldType;
 import com.tencent.supersonic.headless.core.pojo.ConnectInfo;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 
 import java.sql.*;
 import java.util.ArrayList;
@@ -147,8 +148,7 @@ public abstract class BaseDbAdaptor implements DbAdaptor {
         String url = connectionInfo.getUrl().toLowerCase();
 
         // 设置通用属性
-        String userName = Optional.ofNullable(connectionInfo.getUserName()).orElse("");
-        properties.setProperty("user", userName);
+        properties.setProperty("user", connectionInfo.getUserName());
 
 
         String password = Optional.ofNullable(connectionInfo.getPassword()).orElse("");

headless/core/src/main/java/com/tencent/supersonic/headless/core/adaptor/db/DuckdbAdaptor.java

@@ -10,7 +10,6 @@ import java.sql.DatabaseMetaData;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.util.List;
-import java.util.Properties;
 
 @Slf4j
 public class DuckdbAdaptor extends DefaultDbAdaptor {
@@ -24,7 +23,7 @@ public class DuckdbAdaptor extends DefaultDbAdaptor {
             String tableName) throws SQLException {
         List<DBColumn> dbColumns = Lists.newArrayList();
         DatabaseMetaData metaData = getDatabaseMetaData(connectInfo);
-        ResultSet columns = metaData.getColumns(null, schemaName, tableName, null);
+        ResultSet columns = metaData.getColumns(schemaName, null, tableName, null);
         while (columns.next()) {
             String columnName = columns.getString("COLUMN_NAME");
             String dataType = columns.getString("TYPE_NAME");
@@ -43,9 +42,4 @@ public class DuckdbAdaptor extends DefaultDbAdaptor {
         return sql.replaceAll("`", "");
     }
 
-    @Override
-    public Properties getProperties(ConnectInfo connectionInfo) {
-        return new Properties();
-    }
-
 }

headless/core/src/main/java/com/tencent/supersonic/headless/core/translator/parser/calcite/DataModelNode.java

@@ -36,8 +36,8 @@ public class DataModelNode extends SemanticNode {
                 && !dataModel.getModelDetail().getSqlQuery().isEmpty()) {
             sqlTable = dataModel.getModelDetail().getSqlQuery();
             // if model has sqlVariables, parse sqlVariables
-            if (Objects.nonNull(dataModel.getModelDetail().getSqlVariables())
-                    && !(CollectionUtils.isEmpty(dataModel.getModelDetail().getSqlVariables()))) {
+            if (Objects.nonNull(dataModel.getModelDetail().getSqlVariables()) &&
+                    !(CollectionUtils.isEmpty(dataModel.getModelDetail().getSqlVariables()))) {
                 sqlTable = SqlVariableParseUtils.parse(sqlTable,
                         dataModel.getModelDetail().getSqlVariables(), Lists.newArrayList());
             }

headless/server/src/main/java/com/tencent/supersonic/headless/server/utils/ModelConverter.java

@@ -156,11 +156,7 @@ public class ModelConverter {
             modelDetail.setSqlQuery(modelBuildReq.getSql());
         } else {
             modelDetail.setQueryType(ModelDefineType.TABLE_QUERY.getName());
-            if (modelBuildReq.getDb() != null) {
-                modelDetail.setTableQuery(String.format("%s.%s", modelBuildReq.getDb(), tableName));
-            } else {
-                modelDetail.setTableQuery(tableName);
-            }
+            modelDetail.setTableQuery(String.format("%s.%s", modelBuildReq.getDb(), tableName));
         }
         List<Field> fields = new ArrayList<>();
         for (SemanticColumn semanticColumn : modelSchema.getSemanticColumns()) {