Skip to content

Commit 0ef6249

Browse files
committed
[CALCITE-5409] Implement BatchNestedLoopJoin for JDBC
1 parent b6eaaaf commit 0ef6249

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

core/src/main/java/org/apache/calcite/runtime/ResultSetEnumerable.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717
package org.apache.calcite.runtime;
1818

1919
import org.apache.calcite.DataContext;
20-
import org.apache.calcite.avatica.SqlType;
2120
import org.apache.calcite.linq4j.AbstractEnumerable;
2221
import org.apache.calcite.linq4j.Enumerable;
2322
import org.apache.calcite.linq4j.Enumerator;
@@ -203,8 +202,7 @@ public static PreparedStatementEnricher createEnricher(Integer[] indexes,
203202
private static void setDynamicParam(PreparedStatement preparedStatement,
204203
int i, @Nullable Object value) throws SQLException {
205204
if (value == null) {
206-
// TODO: use proper type instead of ANY
207-
preparedStatement.setObject(i, null, SqlType.ANY.id);
205+
preparedStatement.setNull(i, Types.NULL);
208206
} else if (value instanceof Timestamp) {
209207
preparedStatement.setTimestamp(i, (Timestamp) value);
210208
} else if (value instanceof Time) {

0 commit comments

Comments
 (0)