code optimization

WeDataSphere · Jan 13, 2025 · e0a7ced · e0a7ced
1 parent 01642b0
commit e0a7ced
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...c/src/main/scala/org/apache/linkis/manager/engineplugin/jdbc/conf/JDBCConfiguration.scala b/...c/src/main/scala/org/apache/linkis/manager/engineplugin/jdbc/conf/JDBCConfiguration.scala
@@ -32,7 +32,7 @@ object JDBCConfiguration {
 
   val JDBC_KERBEROS_ENABLE = CommonVars[Boolean]("wds.linkis.keytab.enable", false)
 
-  val CHANGE_DS_TYPE_TO_MYSQL = CommonVars[Boolean]("linkis.change.ds.type.to.mysql", true).getValue
+  val CHANGE_DS_TYPE_TO_MYSQL = CommonVars[String]("linkis.change.ds.type.to.mysql", "starrocks").getValue
 
   val DS_TYPES_TO_EXECUTE_TASK_BY_JDBC =
     CommonVars[String]("linkis.can.execute.task.ds.types.by.jdbc", "starrocks").getValue

diff --git a/.../jdbc/src/main/scala/org/apache/linkis/manager/engineplugin/jdbc/executor/JDBCHelper.java b/.../jdbc/src/main/scala/org/apache/linkis/manager/engineplugin/jdbc/executor/JDBCHelper.java
@@ -146,7 +146,7 @@ public static String getTypeStr(int type) {
                 retVal = BinaryType.typeName();
                 break;
             case Types.DECIMAL:
-                retVal =  new DecimalType("decimal", 3).typeName();
+                retVal = StringType.typeName();
                 break;
             case Types.ARRAY:
                 retVal = ArrayType.typeName();

diff --git a/...cala/org/apache/linkis/manager/engineplugin/jdbc/executor/JDBCMultiDatasourceParser.scala b/...cala/org/apache/linkis/manager/engineplugin/jdbc/executor/JDBCMultiDatasourceParser.scala
@@ -137,7 +137,7 @@ object JDBCMultiDatasourceParser extends Logging {
         MessageFormat.format(UNSUPPORTED_DS_TYPE.getErrorDesc, dbType)
       )
     }
-    if (CHANGE_DS_TYPE_TO_MYSQL) {
+    if (CHANGE_DS_TYPE_TO_MYSQL.contains(dbType)) {
       dbType = "mysql"
     }