[fix][dingo-store-proxy] Resolve IndexMapper.toIndex mapping errors

dingodb · Nov 20, 2024 · b195bf3 · b195bf3
1 parent 2e59936
commit b195bf3
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 14 deletions.
diff --git a/dingo-calcite/src/main/codegen/includes/AlterTable.ftl b/dingo-calcite/src/main/codegen/includes/AlterTable.ftl
@@ -184,11 +184,7 @@ SqlAlterTable addUniqueIndex(Span s, String scope, SqlIdentifier id): {
 } {
  <UNIQUE><INDEX> { s.add(this); }
     { index = getNextToken().image; }
-    (
-        <VECTOR> { indexType = "vector"; } columnList = ParenthesizedSimpleIdentifierList()
-    |
-        [<SCALAR>] columnList = ParenthesizedSimpleIdentifierList()
-    )
+    [<SCALAR>] columnList = ParenthesizedSimpleIdentifierList()
     (
        <WITH> withColumnList = ParenthesizedSimpleIdentifierList()
      |

diff --git a/dingo-meta-api/src/main/java/io/dingodb/meta/MetaService.java b/dingo-meta-api/src/main/java/io/dingodb/meta/MetaService.java
@@ -119,13 +119,6 @@ default long createTables(
         return 0;
     }
 
-    default void rollbackCreateTable(
-        @NonNull TableDefinition tableDefinition,
-        @NonNull List<IndexDefinition> indexTableDefinitions
-    ) {
-
-    }
-
     default void rollbackCreateTable(
         long schemaId,
         @NonNull TableDefinition tableDefinition,
@@ -151,7 +144,6 @@ default void updateTable(CommonId tableId, @NonNull Table table) {
 
     long truncateTable(@NonNull String tableName, long tableEntityId);
 
-//    boolean dropTables(@NonNull Collection<CommonId> tableIds);
 
     /**
      * Get table by table name.

diff --git a/dingo-store-proxy/src/main/java/io/dingodb/store/proxy/mapper/IndexMapper.java b/dingo-store-proxy/src/main/java/io/dingodb/store/proxy/mapper/IndexMapper.java
@@ -101,7 +101,11 @@ default Properties toMap(Object target) {
         if (target == null) {
             return new Properties();
         }
-        return JSON.convertValue(target, Properties.class);
+        try {
+            return JSON.convertValue(target, Properties.class);
+        } catch (Exception e) {
+            return new Properties();
+        }
     }
 
     default void resetIndexParameter(TableDefinition indexDefinition, io.dingodb.common.table.IndexDefinition indexDef) {