Quote union branch names in INSERT stmt

rayokota · Jul 21, 2024 · dad329f · dad329f
1 parent 456111d
commit dad329f
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/pom.xml b/pom.xml
@@ -3,7 +3,7 @@
 
     <groupId>io.kcache</groupId>
     <artifactId>kwack</artifactId>
-    <version>0.4.0</version>
+    <version>0.5.0</version>
     <packaging>jar</packaging>
 
     <name>kwack</name>

diff --git a/src/main/java/io/kcache/kwack/KwackEngine.java b/src/main/java/io/kcache/kwack/KwackEngine.java
@@ -820,8 +820,8 @@ public void handleUpdate(Headers headers,
                     for (ColumnDef columnDef : structColumnDef.getColumnDefs().values()) {
                         if (columnDef.getColumnType() == DuckDBColumnType.UNION) {
                             UnionColumnDef unionColumnDef = (UnionColumnDef) columnDef;
-                            paramMarkers.add("union_value("
-                                + valueObj._1.getUnionBranch(unionColumnDef) + " := ?)");
+                            paramMarkers.add("union_value(\""
+                                + valueObj._1.getUnionBranch(unionColumnDef) + "\" := ?)");
                         } else {
                             paramMarkers.add("?");
                         }
@@ -830,8 +830,8 @@ public void handleUpdate(Headers headers,
                 } else {
                     if (valueColDef.getColumnType() == DuckDBColumnType.UNION) {
                         UnionColumnDef unionColumnDef = (UnionColumnDef) valueColDef;
-                        paramMarkers.add("union_value("
-                            + valueObj._1.getUnionBranch(unionColumnDef) + " := ?)");
+                        paramMarkers.add("union_value(\""
+                            + valueObj._1.getUnionBranch(unionColumnDef) + "\" := ?)");
                     } else {
                         paramMarkers.add("?");
                     }