fix(sql): Fix database not preserving column alias casing in SQL (#5948)

RaphDal · web-flow · commit 2b00422b67ce · 2025-07-15T20:33:10.000+01:00
diff --git a/core/src/main/java/io/questdb/griffin/SqlCodeGenerator.java b/core/src/main/java/io/questdb/griffin/SqlCodeGenerator.java
@@ -231,7 +231,6 @@
 import io.questdb.griffin.engine.table.FilterOnSubQueryRecordCursorFactory;
 import io.questdb.griffin.engine.table.FilterOnValuesRecordCursorFactory;
 import io.questdb.griffin.engine.table.FilteredRecordCursorFactory;
-import io.questdb.griffin.engine.table.PageFrameRowCursorFactory;
 import io.questdb.griffin.engine.table.LatestByAllFilteredRecordCursorFactory;
 import io.questdb.griffin.engine.table.LatestByAllIndexedRecordCursorFactory;
 import io.questdb.griffin.engine.table.LatestByAllSymbolsFilteredRecordCursorFactory;
@@ -247,6 +246,7 @@
 import io.questdb.griffin.engine.table.LatestByValueIndexedRowCursorFactory;
 import io.questdb.griffin.engine.table.LatestByValuesIndexedFilteredRecordCursorFactory;
 import io.questdb.griffin.engine.table.PageFrameRecordCursorFactory;
+import io.questdb.griffin.engine.table.PageFrameRowCursorFactory;
 import io.questdb.griffin.engine.table.SelectedRecordCursorFactory;
 import io.questdb.griffin.engine.table.SortedSymbolIndexRecordCursorFactory;
 import io.questdb.griffin.engine.table.SymbolIndexFilteredRowCursorFactory;
@@ -4216,8 +4216,8 @@ private RecordCursorFactory generateSelectChoose(QueryModel model, SqlExecutionC
             for (int i = 0; i < selectColumnCount; i++) {
                 QueryColumn qc = columns.getQuick(i);
                 if (
-                        !Chars.equalsIgnoreCase(metadata.getColumnName(i), qc.getAst().token) ||
-                                (qc.getAlias() != null && !Chars.equalsIgnoreCase(qc.getAlias(), qc.getAst().token))
+                        !Chars.equals(metadata.getColumnName(i), qc.getAst().token) ||
+                                (qc.getAlias() != null && !Chars.equals(qc.getAlias(), qc.getAst().token))
                 ) {
                     entity = false;
                     break;
diff --git a/core/src/test/java/io/questdb/test/griffin/SqlCodeGeneratorTest.java b/core/src/test/java/io/questdb/test/griffin/SqlCodeGeneratorTest.java
@@ -518,6 +518,18 @@ public void testCg() throws Exception {
         );
     }
 
+    @Test
+    public void testColumnAliasCaseSensitivity() throws Exception {
+        assertMemoryLeak(() -> {
+            execute("create table trades (symbol SYMBOL)");
+            execute("insert into trades values ('USD'), ('EUR')");
+            assertSql(
+                    "SYMBOL\nUSD\nEUR\n",
+                    "SELECT symbol AS SYMBOL FROM trades"
+            );
+        });
+    }
+
     @Test
     public void testCreateTableAsSelectUsesQueryTimestamp() throws Exception {
         assertQuery(
