Skip to content

Commit 269824f

Browse files
committed
Send VARCHAR type code instead of STRING
1 parent 77dbd53 commit 269824f

3 files changed

Lines changed: 3 additions & 3 deletions

File tree

core/src/main/java/io/questdb/client/cutlass/qwp/client/QwpUdpSender.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1305,7 +1305,7 @@ private void stageNullArrayColumnValue(CharSequence name, byte type) {
13051305
}
13061306

13071307
private void stageStringColumnValue(CharSequence name, CharSequence value) {
1308-
QwpTableBuffer.ColumnBuffer col = acquireColumn(name, TYPE_STRING, true);
1308+
QwpTableBuffer.ColumnBuffer col = acquireColumn(name, TYPE_VARCHAR, true);
13091309
beginColumnWrite(col, name);
13101310
col.addString(value);
13111311
completeColumnWrite();

core/src/main/java/io/questdb/client/cutlass/qwp/client/QwpWebSocketSender.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1015,7 +1015,7 @@ public QwpWebSocketSender stringColumn(CharSequence columnName, CharSequence val
10151015
checkNotClosed();
10161016
checkTableSelected();
10171017
try {
1018-
QwpTableBuffer.ColumnBuffer col = currentTableBuffer.getOrCreateColumn(columnName, QwpConstants.TYPE_STRING, true);
1018+
QwpTableBuffer.ColumnBuffer col = currentTableBuffer.getOrCreateColumn(columnName, QwpConstants.TYPE_VARCHAR, true);
10191019
if (col != null) {
10201020
col.addString(value);
10211021
}

core/src/test/java/io/questdb/client/test/cutlass/qwp/client/QwpUdpSenderTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1101,7 +1101,7 @@ public void testNullableStringPrefixFlushKeepsNullStateWithoutReflection() throw
11011101
Assert.assertNotNull(tableBuffer);
11021102
Assert.assertEquals(0, tableBuffer.getRowCount());
11031103

1104-
QwpTableBuffer.ColumnBuffer stringColumn = tableBuffer.getExistingColumn("s", TYPE_STRING);
1104+
QwpTableBuffer.ColumnBuffer stringColumn = tableBuffer.getExistingColumn("s", TYPE_VARCHAR);
11051105
assertNullableStringNullState(stringColumn);
11061106

11071107
QwpTableBuffer.ColumnBuffer longColumn = tableBuffer.getExistingColumn("x", TYPE_LONG);

0 commit comments

Comments
 (0)