fix: when index name length is too long

Author: jarad0628

connectors-common/connector-core/src/main/java/io/tapdata/kit/DbKit.java

@@ -163,6 +163,9 @@ public static String buildIndexName(String table) {
     }
 
     public static String buildIndexName(String table, TapIndex index, int maxLength) {
+        if (EmptyKit.isNotBlank(index.getName()) && index.getName().length() <= maxLength) {
+            return index.getName();
+        }
         String indexName = table + "_" + index.getIndexFields().stream().map(TapIndexField::getName).collect(Collectors.joining("_"));
         if (indexName.length() + 4 <= maxLength) {
             return "IDX_" + indexName;

connectors-common/mysql-core/src/main/java/io/tapdata/connector/mysql/config/MysqlConfig.java

@@ -16,6 +16,7 @@ public MysqlConfig() {
         setDbType("mysql");
         setEscapeChar('`');
         setJdbcDriver("com.mysql.cj.jdbc.Driver");
+        setMaxIndexNameLength(64);
     }
 
     private static final Map<String, String> DEFAULT_PROPERTIES = new HashMap<String, String>() {{

connectors-common/postgres-core/src/main/java/io/tapdata/connector/postgres/config/PostgresConfig.java

@@ -32,6 +32,7 @@ public class PostgresConfig extends CommonDbConfig implements Serializable {
     public PostgresConfig() {
         setDbType("postgresql");
         setJdbcDriver("org.postgresql.Driver");
+        setMaxIndexNameLength(63);
     }
 
     @Override

connectors-common/sql-core/src/main/java/io/tapdata/common/CommonDbConfig.java

@@ -65,6 +65,8 @@ public class CommonDbConfig implements Serializable {
     private String sslKeyPassword;
     protected String sslRandomPath;
 
+    private int maxIndexNameLength = 30;
+
     //pattern for jdbc-url
     public String getDatabaseUrlPattern() {
         // last %s reserved for extend params
@@ -435,4 +437,12 @@ public String getSslRandomPath() {
     public void setSslRandomPath(String sslRandomPath) {
         this.sslRandomPath = sslRandomPath;
     }
+
+    public int getMaxIndexNameLength() {
+        return maxIndexNameLength;
+    }
+
+    public void setMaxIndexNameLength(int maxIndexNameLength) {
+        this.maxIndexNameLength = maxIndexNameLength;
+    }
 }

connectors-common/sql-core/src/main/java/io/tapdata/common/CommonDbConnector.java

@@ -646,13 +646,9 @@ protected String getCreateIndexSql(TapTable tapTable, TapIndex tapIndex) {
             sb.append("unique ");
         }
         sb.append("index ");
-        if (EmptyKit.isNotBlank(tapIndex.getName())) {
-            sb.append(escapeChar).append(tapIndex.getName()).append(escapeChar);
-        } else {
-            String indexName = DbKit.buildIndexName(tapTable.getId(), tapIndex, 32);
-            tapIndex.setName(indexName);
-            sb.append(escapeChar).append(indexName).append(escapeChar);
-        }
+        String indexName = DbKit.buildIndexName(tapTable.getId(), tapIndex, commonDbConfig.getMaxIndexNameLength());
+        tapIndex.setName(indexName);
+        sb.append(escapeChar).append(indexName).append(escapeChar);
         sb.append(" on ").append(getSchemaAndTable(tapTable.getId())).append('(')
                 .append(tapIndex.getIndexFields().stream().map(f -> escapeChar + f.getName() + escapeChar + " " + (f.getFieldAsc() ? "asc" : "desc"))
                         .collect(Collectors.joining(","))).append(')');

connectors/mysql-connector/src/main/java/io/tapdata/connector/mysql/MysqlConnector.java

@@ -1017,13 +1017,9 @@ protected String getCreateIndexSql(TapTable tapTable, TapIndex tapIndex) {
             sb.append("unique ");
         }
         sb.append("index ");
-        if (EmptyKit.isNotBlank(tapIndex.getName())) {
-            sb.append(escapeChar).append(tapIndex.getName()).append(escapeChar);
-        } else {
-            String indexName = DbKit.buildIndexName(tapTable.getId(), tapIndex, 64);
-            tapIndex.setName(indexName);
-            sb.append(escapeChar).append(indexName).append(escapeChar);
-        }
+        String indexName = DbKit.buildIndexName(tapTable.getId(), tapIndex, commonDbConfig.getMaxIndexNameLength());
+        tapIndex.setName(indexName);
+        sb.append(escapeChar).append(indexName).append(escapeChar);
         sb.append(" on ").append(getSchemaAndTable(tapTable.getId())).append('(')
                 .append(tapIndex.getIndexFields().stream().map(f -> escapeChar + f.getName() + escapeChar + (EmptyKit.isNotNull(f.getSubPosition()) ? "(" + f.getSubPosition() + ")" : " ") + (f.getFieldAsc() ? "asc" : "desc"))
                         .collect(Collectors.joining(","))).append(')');