Update tests

Author: alex268

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

@@ -534,9 +534,10 @@ public void abort() {
 
     @Test
     public void testDDLInsideTransaction() throws SQLException {
-        String createTempTable = QUERIES.withTableName("--jdbc:SCHEME\n"
-                + "create table temp_#tableName(id Int32, value Int32, primary key(id))");
-        String dropTempTable = QUERIES.withTableName("--jdbc:SCHEME\ndrop table temp_#tableName");
+        String createTempTable = QUERIES.withTableName(
+                "create table temp_#tableName(id Int32, value Int32, primary key(id))"
+        );
+        String dropTempTable = QUERIES.withTableName("drop table temp_#tableName");
 
         try (Statement statement = jdbc.connection().createStatement()) {
             statement.execute(SIMPLE_UPSERT);
@@ -555,7 +556,7 @@ public void testDDLInsideTransaction() throws SQLException {
     @Test
     public void testWarningInIndexUsage() throws SQLException {
         try (Statement statement = jdbc.connection().createStatement()) {
-            statement.execute("--jdbc:SCHEME\n" +
+            statement.execute("" +
                     "create table unit_0_indexed (" +
                     "id Int32, value Int32, " +
                     "primary key (id), " +
@@ -632,8 +633,7 @@ public void testAnsiLexerForIdea() throws SQLException {
     })
     public void testUnsupportedByStorageTableTypes(String type) throws SQLException {
         String tableName = "unsupported_" + type;
-        String sql = "--jdbc:SCHEME\n"
-                + "create table " + tableName + " (key Int32, payload " + type + ", primary key(key))";
+        String sql = "create table " + tableName + " (key Int32, payload " + type + ", primary key(key))";
 
         try (Statement statement = jdbc.connection().createStatement()) {
             ExceptionAssert.ydbNonRetryable("is not supported by storage", () -> statement.execute(sql));
@@ -649,8 +649,7 @@ public void testUnsupportedByStorageTableTypes(String type) throws SQLException
     })
     public void testUnsupportedComplexTypes(String type) throws SQLException {
         String tableName = "unsupported_" + type.replaceAll("[^a-zA-Z0-9]", "");
-        String sql = "--jdbc:SCHEME\n"
-                + "create table " + tableName + " (key Int32, payload " + type + ", primary key(key))";
+        String sql = "create table " + tableName + " (key Int32, payload " + type + ", primary key(key))";
 
         try (Statement statement = jdbc.connection().createStatement()) {
             ExceptionAssert.ydbNonRetryable("Invalid type for column: payload.",

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

@@ -277,7 +277,7 @@ public void executeSchemeQueryExplicitly() throws SQLException {
 
     @Test
     public void executeDataQuery() throws SQLException {
-        try (ResultSet rs = statement.executeQuery("--jdbc:DATA\nselect 2 + 2")) {
+        try (ResultSet rs = statement.executeQuery("select 2 + 2")) {
             Assertions.assertFalse(rs.isClosed());
             TableAssert.assertSelectInt(4, rs);
         }
@@ -297,15 +297,15 @@ public void executeDataQueryInTx() throws SQLException {
 
     @Test
     public void executeScanQuery() throws SQLException {
-        try (ResultSet rs = statement.executeQuery("--jdbc:SCAN\n" + "select 2 + 2")) {
+        try (ResultSet rs = statement.executeQuery("scan select 2 + 2")) {
             Assertions.assertFalse(rs.isClosed());
             TableAssert.assertSelectInt(4, rs);
         }
     }
 
     @Test
     public void executeScanQueryOnSystemTable() throws SQLException {
-        try (ResultSet rs = statement.executeQuery("--jdbc:SCAN\n" + "select * from `.sys/partition_stats`")) {
+        try (ResultSet rs = statement.executeQuery("scan select * from `.sys/partition_stats`")) {
             Assertions.assertFalse(rs.isClosed());
         }
     }