[Fix-340][Engine] Local engine, mysql supports fields whose names are…

… mysql keywords
datavane · Jan 23, 2024 · 3e83118 · 3e83118
1 parent bcc5b1c
commit 3e83118
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/...s/datavines-connector-mysql/src/main/java/io/datavines/connector/plugin/MysqlDialect.java b/...s/datavines-connector-mysql/src/main/java/io/datavines/connector/plugin/MysqlDialect.java
@@ -43,4 +43,9 @@ public boolean invalidateItemCanOutputToSelf() {
     public boolean supportToBeErrorDataStorage() {
         return true;
     }
+
+    @Override
+    public String quoteIdentifier(String entity) {
+        return "`" + entity + "`";
+    }
 }
diff --git a/...-config/src/main/java/io/datavines/engine/local/config/BaseLocalConfigurationBuilder.java b/...-config/src/main/java/io/datavines/engine/local/config/BaseLocalConfigurationBuilder.java
@@ -98,6 +98,8 @@ protected List<SourceConfig> getSourceConfigs() throws DataVinesException {
                     metricInputParameter.put(SRC_CONNECTOR_TYPE, connectorParameter.getType());
                     metricInputParameter.put(TABLE, table);
 
+                    metricInputParameter.put(COLUMN, connectorFactory.getDialect().quoteIdentifier(metricInputParameter.get(COLUMN)));
+
                     boolean invalidateItemCanOutput = Boolean.parseBoolean(metricInputParameter.get(INVALIDATE_ITEM_CAN_OUTPUT));
                     invalidateItemCanOutput &= connectorFactory.getDialect().invalidateItemCanOutput();
                     metricInputParameter.put(INVALIDATE_ITEM_CAN_OUTPUT, String.valueOf(invalidateItemCanOutput));