Fixed prepared statements validations

Author: alex268

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

@@ -95,16 +95,9 @@ public void clearBatch() {
 
     protected StructValue getCurrentValues() throws SQLException {
         for (ParamDescription prm: params) {
-            if (currentValues.containsKey(prm.name())) {
-                continue;
+            if (!currentValues.containsKey(prm.name())) {
+                throw new SQLDataException(YdbConst.MISSING_VALUE_FOR_PARAMETER + prm.displayName());
             }
-
-            if (prm.type().isOptional()) {
-                currentValues.put(prm.name(), prm.type().nullValue());
-                continue;
-            }
-
-            throw new SQLDataException(YdbConst.MISSING_VALUE_FOR_PARAMETER + prm.displayName());
         }
         return StructValue.of(currentValues);
     }

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

@@ -57,6 +57,9 @@ public static BulkUpsertQuery build(String tablePath, List<String> columns, Tabl
 
         Map<String, Type> structTypes = new HashMap<>();
         for (String column: columns) {
+            if (!columnTypes.containsKey(column)) {
+                throw new SQLException("Cannot parse BULK upsert: column " + column + " not found");
+            }
             structTypes.put(column, columnTypes.get(column));
         }
 

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

@@ -2,6 +2,7 @@
 
 
 
+import java.sql.SQLDataException;
 import java.sql.SQLException;
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -109,15 +110,15 @@ public Params getCurrentParams() throws SQLException {
     @Override
     public String getNameByIndex(int index) throws SQLException {
         if (index <= 0 || index > parameters.size()) {
-            throw new SQLException(YdbConst.PARAMETER_NUMBER_NOT_FOUND + index);
+            throw new SQLDataException(YdbConst.PARAMETER_NUMBER_NOT_FOUND + index);
         }
         return parameters.get(index - 1).getName();
     }
 
     @Override
     public TypeDescription getDescription(int index) throws SQLException {
         if (index <= 0 || index > parameters.size()) {
-            throw new SQLException(YdbConst.PARAMETER_NUMBER_NOT_FOUND + index);
+            throw new SQLDataException(YdbConst.PARAMETER_NUMBER_NOT_FOUND + index);
         }
 
         JdbcPrm p = parameters.get(index - 1);
@@ -127,7 +128,7 @@ public TypeDescription getDescription(int index) throws SQLException {
     @Override
     public void setParam(int index, Object obj, int sqlType) throws SQLException {
         if (index <= 0 || index > parameters.size()) {
-            throw new SQLException(YdbConst.PARAMETER_NUMBER_NOT_FOUND + index);
+            throw new SQLDataException(YdbConst.PARAMETER_NUMBER_NOT_FOUND + index);
         }
 
         parameters.get(index - 1).setValue(obj, sqlType);
@@ -137,7 +138,7 @@ public void setParam(int index, Object obj, int sqlType) throws SQLException {
     public void setParam(String name, Object obj, int sqlType) throws SQLException {
         JdbcPrm param = parametersByName.get(name);
         if (param == null) {
-            throw new SQLException(YdbConst.PARAMETER_NUMBER_NOT_FOUND + name);
+            throw new SQLDataException(YdbConst.PARAMETER_NUMBER_NOT_FOUND + name);
         }
         param.setValue(obj, sqlType);
     }

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

@@ -1,5 +1,6 @@
 package tech.ydb.jdbc.query.params;
 
+import java.sql.SQLDataException;
 import java.sql.SQLException;
 
 import tech.ydb.jdbc.YdbConst;
@@ -34,7 +35,7 @@ public void reset() {
     @Override
     public void copyToParams(Params params) throws SQLException {
         if (value == null) {
-            throw new SQLException(YdbConst.MISSING_VALUE_FOR_PARAMETER + name);
+            throw new SQLDataException(YdbConst.MISSING_VALUE_FOR_PARAMETER + name);
         }
         params.put(name, value);
     }
@@ -56,7 +57,7 @@ public void setValue(Object obj, int sqlType) throws SQLException {
 
         Type type = YdbTypes.findType(obj, sqlType);
         if (type == null) {
-            throw new SQLException(String.format(YdbConst.PARAMETER_TYPE_UNKNOWN, sqlType, obj));
+            throw new SQLDataException(String.format(YdbConst.PARAMETER_TYPE_UNKNOWN, sqlType, obj));
         }
 
         if (obj == null) {