Wrap names with double quotes

mzumi · mzumi · commit 7fc9db4adf53 · 2024-06-11T09:48:23.000Z
diff --git a/src/main/java/org/embulk/output/SnowflakeOutputPlugin.java b/src/main/java/org/embulk/output/SnowflakeOutputPlugin.java
@@ -167,8 +167,12 @@ protected JdbcOutputConnector getConnector(PluginTask task, boolean retryableMet
         throw new ConfigException(e);
       }
     }
+    if (t.getWarehouse().startsWith("\"") && t.getWarehouse().endsWith("\"")) {
+      props.setProperty("warehouse", t.getWarehouse());
+    } else {
+      props.setProperty("warehouse", "\"" + t.getWarehouse() + "\"");
+    }
 
-    props.setProperty("warehouse", t.getWarehouse());
     props.setProperty("db", t.getDatabase());
     props.setProperty("schema", t.getSchema());
     if (!t.getRole().isEmpty()) {

Original file line number	Diff line number	Diff line change
`@@ -167,8 +167,12 @@ protected JdbcOutputConnector getConnector(PluginTask task, boolean retryableMet`
`167`	`167`	`throw new ConfigException(e);`
`168`	`168`	`}`
`169`	`169`	`}`
	`170`	`+ if (t.getWarehouse().startsWith("\"") && t.getWarehouse().endsWith("\"")) {`
	`171`	`+ props.setProperty("warehouse", t.getWarehouse());`
	`172`	`+ } else {`
	`173`	`+ props.setProperty("warehouse", "\"" + t.getWarehouse() + "\"");`
	`174`	`+ }`
`170`	`175`
`171`		`- props.setProperty("warehouse", t.getWarehouse());`
`172`	`176`	`props.setProperty("db", t.getDatabase());`
`173`	`177`	`props.setProperty("schema", t.getSchema());`
`174`	`178`	`if (!t.getRole().isEmpty()) {`