Skip to content

Commit 265e786

Browse files
committed
fix
1 parent da17d06 commit 265e786

1 file changed

Lines changed: 1 addition & 7 deletions

File tree

waddler/src/clickhouse-core/dialect.ts

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,3 @@
1-
import { TupleParam } from '@clickhouse/client';
21
import type { ClickHouseSQLTemplate } from '../clickhouse/session.ts';
32
import {
43
Dialect,
@@ -105,7 +104,6 @@ export class ClickHouseDialect extends Dialect {
105104

106105
if (typeof value === 'bigint') {
107106
this.pushParams(params, `${value}`, lastParamIdx + paramsCount + 1, 'single');
108-
// params.push([`param${lastParamIdx + params.length + 1}`, `${value}`] as any);
109107
return { sql: this.escapeParam(lastParamIdx + paramsCount + 1, types[colIdx]), addParamsCount: 1 };
110108
}
111109

@@ -119,7 +117,6 @@ export class ClickHouseDialect extends Dialect {
119117
}
120118

121119
this.pushParams(params, mappedValue, lastParamIdx + paramsCount + 1, 'single');
122-
// params.push([`param${lastParamIdx + params.length + 1}`, mappedValue] as any);
123120
return {
124121
sql: this.escapeParam(lastParamIdx + paramsCount + 1, types[colIdx] ?? arrayTypeToCast),
125122
addParamsCount: 1,
@@ -134,21 +131,18 @@ export class ClickHouseDialect extends Dialect {
134131
|| value instanceof Date
135132
) {
136133
this.pushParams(params, value, lastParamIdx + paramsCount + 1, 'single');
137-
// params.push([`param${lastParamIdx + params.length + 1}`, value] as any);
138134
return { sql: this.escapeParam(lastParamIdx + paramsCount + 1, types[colIdx]), addParamsCount: 1 };
139135
}
140136

141-
if (value instanceof Map || value instanceof TupleParam) {
137+
if (value instanceof Map || (typeof value === 'object' && value.constructor?.name === 'TupleParam')) {
142138
// Map, Tuple type
143139
this.pushParams(params, value, lastParamIdx + paramsCount + 1, 'single');
144-
// params.push([`param${lastParamIdx + params.length + 1}`, value] as any);
145140
return { sql: this.escapeParam(lastParamIdx + paramsCount + 1, types[colIdx]), addParamsCount: 1 };
146141
}
147142

148143
if (typeof value === 'object') {
149144
// should be JSON type
150145
this.pushParams(params, JSON.stringify(value), lastParamIdx + paramsCount + 1, 'single');
151-
// params.push([`param${lastParamIdx + params.length + 1}`, JSON.stringify(value)] as any);
152146
return { sql: this.escapeParam(lastParamIdx + paramsCount + 1, types[colIdx] ?? 'JSON'), addParamsCount: 1 };
153147
}
154148

0 commit comments

Comments
 (0)