fix(ksql-driver): Escape quotes in column names

mcheshkov · KSDaemon · commit 7947087546eb · 2025-05-30T15:42:06.000+03:00
diff --git a/packages/cubejs-ksql-driver/src/KsqlQuery.ts b/packages/cubejs-ksql-driver/src/KsqlQuery.ts
@@ -52,7 +52,9 @@ export class KsqlQuery extends BaseQuery {
   }
 
   public escapeColumnName(name: string) {
-    return `\`${name}\``;
+    // https://docs.confluent.io/platform/current/ksqldb/reference/sql/lexical-structure.html#ksqldb-lexical-structure-identifiers
+    // https://github.com/confluentinc/ksql/blob/84afdf1c2504844a15e02643f796288b8b069073/ksqldb-parser/src/main/antlr4/io/confluent/ksql/parser/SqlBase.g4#L378
+    return `\`${name.replaceAll('`', '``')}\``;
   }
 
   public castToString(sql: string) {

Original file line number	Diff line number	Diff line change
`@@ -52,7 +52,9 @@ export class KsqlQuery extends BaseQuery {`
`52`	`52`	`}`
`53`	`53`
`54`	`54`	`public escapeColumnName(name: string) {`
`55`		- return `\`${name}\``;
	`55`	`+ // https://docs.confluent.io/platform/current/ksqldb/reference/sql/lexical-structure.html#ksqldb-lexical-structure-identifiers`
	`56`	`+ // https://github.com/confluentinc/ksql/blob/84afdf1c2504844a15e02643f796288b8b069073/ksqldb-parser/src/main/antlr4/io/confluent/ksql/parser/SqlBase.g4#L378`
	`57`	+ return `\`${name.replaceAll('`', '``')}\``;
`56`	`58`	`}`
`57`	`59`
`58`	`60`	`public castToString(sql: string) {`