Fixed InToList converter

Author: alex268

jdbc/src/main/java/tech/ydb/jdbc/query/params/InListJdbcPrm.java

@@ -9,6 +9,7 @@
 import tech.ydb.jdbc.impl.YdbTypes;
 import tech.ydb.table.query.Params;
 import tech.ydb.table.values.ListType;
+import tech.ydb.table.values.OptionalType;
 import tech.ydb.table.values.Type;
 import tech.ydb.table.values.Value;
 import tech.ydb.table.values.VoidValue;
@@ -55,15 +56,16 @@ private Value<?> buildList() throws SQLException {
             return ListType.of(type.ydbType()).newValue(values);
         }
 
+        OptionalType optional = type.ydbType().makeOptional();
         for (Item item: items) {
             if (item.value == NULL) {
-                values.add(type.nullValue());
+                values.add(optional.emptyValue());
             } else {
                 values.add(item.value.makeOptional());
             }
         }
 
-        return ListType.of(type.ydbType().makeOptional()).newValue(values);
+        return ListType.of(optional).newValue(values);
 
     }
 
@@ -103,6 +105,11 @@ public void setValue(Object obj, int sqlType) throws SQLException {
                 type = TypeDescription.of(ydbType);
             }
 
+            if (obj == null) {
+                value = NULL;
+                return;
+            }
+
             value = type.setters().toValue(obj);
         }
 

jdbc/src/test/java/tech/ydb/jdbc/impl/YdbPreparedStatementTest.java

@@ -551,6 +551,10 @@ public void inListTest(boolean convertInToList) throws SQLException {
                 ps.setString(2, "3");
                 ps.addBatch();
 
+                ps.setInt(1, 4);
+                ps.setString(2, "null");
+                ps.addBatch();
+
                 ps.executeBatch();
             }
 
@@ -563,7 +567,7 @@ public void inListTest(boolean convertInToList) throws SQLException {
                 assertResultSetCount(ps.executeQuery(), 2);
 
                 ps.setInt(1, 1);
-                ps.setInt(2, 4);
+                ps.setInt(2, 5);
                 assertResultSetCount(ps.executeQuery(), 1);
 
                 ps.setInt(1, 1);
@@ -591,6 +595,10 @@ public void inListTest(boolean convertInToList) throws SQLException {
                 ps.setString(2, null);
                 assertResultSetCount(ps.executeQuery(), 1);
 
+                ps.setString(1, null);
+                ps.setString(2, "2");
+                assertResultSetCount(ps.executeQuery(), 0);
+
                 ps.setString(1, "1");
                 ps.setString(2, "1");
                 assertResultSetCount(ps.executeQuery(), 1);