update tests

Author: ferenc-csaky

flink-sql-runner/src/test/java/com/datasqrl/flinkrunner/AbstractITSupport.java

@@ -45,7 +45,6 @@
 import org.testcontainers.junit.jupiter.Testcontainers;
 import org.testcontainers.postgresql.PostgreSQLContainer;
 import org.testcontainers.utility.DockerImageName;
-import org.testcontainers.utility.MountableFile;
 
 @Slf4j
 @Testcontainers
@@ -60,15 +59,12 @@ public class AbstractITSupport {
 
   @Container
   protected static final GenericContainer<?> postgresContainer =
-      new PostgreSQLContainer(DockerImageName.parse("postgres:17"))
+      new PostgreSQLContainer(DockerImageName.parse("postgres:18"))
           .withNetwork(sharedNetwork)
           .withNetworkAliases("postgres")
           .withDatabaseName("datasqrl")
           .withUsername("postgres")
-          .withPassword("postgres")
-          .withCopyFileToContainer(
-              MountableFile.forClasspathResource("sqrl/postgres-schema.sql"),
-              "/docker-entrypoint-initdb.d/init.sql");
+          .withPassword("postgres");
 
   @Container
   protected static final GenericContainer<?> redpandaContainer =

flink-sql-runner/src/test/java/com/datasqrl/flinkrunner/SqlUtilsTest.java

@@ -19,16 +19,29 @@
 
 import com.google.common.base.Charsets;
 import com.google.common.io.Resources;
+import java.util.stream.Stream;
 import org.junit.jupiter.params.ParameterizedTest;
-import org.junit.jupiter.params.provider.CsvSource;
+import org.junit.jupiter.params.provider.Arguments;
+import org.junit.jupiter.params.provider.MethodSource;
 
 class SqlUtilsTest {
 
+  static Stream<Arguments> testArgs() {
+    return Stream.of(
+        Arguments.of("flink.sql", 12),
+        Arguments.of("test_sql.sql", 6),
+        Arguments.of("test_udf_sql.sql", 6));
+  }
+
   @ParameterizedTest(name = "{0}")
-  @CsvSource({"flink.sql,18", "test_sql.sql,6", "test_udf_sql.sql,6"})
+  @MethodSource("testArgs")
   void givenSource_when_thenSplitCorrectly(String filename, int numberOfStatements)
       throws Exception {
-    var script = Resources.toString(getClass().getResource("/sql/" + filename), Charsets.UTF_8);
+
+    var scriptUrl = getClass().getResource("/sql/" + filename);
+    assertThat(scriptUrl).isNotNull();
+
+    var script = Resources.toString(scriptUrl, Charsets.UTF_8);
     var stmts = SqlUtils.parseStatements(script);
     assertThat(stmts).isNotNull().isNotEmpty().hasSize(numberOfStatements);
   }