Added integration test to validate GEOMETRY data type

Altinity · subkanthi · Oct 16, 2024 · Oct 2, 2024 · Oct 2, 2024 · Oct 2, 2024
commit 65e0bad8a705c2591918c87ccc2d41e88ed14b9c
diff --git a/...est/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/CreateTableDataTypesIT.java b/...est/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/CreateTableDataTypesIT.java
@@ -287,8 +287,19 @@
             Assert.assertTrue(c3b.equalsIgnoreCase("(3.0,4.0)"));
         }
         Assert.assertTrue(pointResultValidated);
+        String createTableWithGeometry = "CREATE TABLE employee.locations ( id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(100), location GEOMETRY)";
+        ITCommon.connectToMySQL(mySqlContainer).createStatement().execute(createTableWithGeometry);
 
+        // Sleep for 10 seconds to allow the table to be replicated
+        Thread.sleep(10000);
+
+        // Insert a new row into the table
+        ITCommon.connectToMySQL(mySqlContainer).createStatement().execute("INSERT INTO locations (name, location)\n" +
+                "VALUES ('Route', ST_GeomFromText('LINESTRING(0 0, 1 1, 2 2)'));\n");
+
+        Thread.sleep(10000);
 
+        // Validate GEOMETRY data type
 
         Thread.sleep(5000);
 

diff --git a/...rc/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/MultipleDatabaseIT.java b/...rc/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/MultipleDatabaseIT.java
        // query clickhouse connection and get data for test_table1 and test_table2


        ResultSet rs = writer.executeQueryWithResultSet("SELECT * FROM test_db.test_table");
        // Validate the data
        boolean recordFound = false;
        while(rs.next()) {
	// query clickhouse connection and get data for test_table1 and test_table2


	ResultSet rs = writer.executeQueryWithResultSet("SELECT * FROM test_db.test_table");
Check failure on line 133 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/MultipleDatabaseIT.java GitHub Actions / JUnit Test Report MultipleDatabaseIT.testMultipleDatabases `Code: 81. DB::Exception: Database test_db does not exist. (UNKNOWN_DATABASE) (version 24.9.2.42 (official build)) , server ClickHouseNode [uri=http://localhost:32802/system, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@-1854434933` Raw output `java.sql.BatchUpdateException: Code: 81. DB::Exception: Database test_db does not exist. (UNKNOWN_DATABASE) (version 24.9.2.42 (official build)) , server ClickHouseNode [uri=http://localhost:32802/system, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@-1854434933 at com.altinity.clickhouse.debezium.embedded.ddl.parser.MultipleDatabaseIT.testMultipleDatabases(MultipleDatabaseIT.java:133)`
	// Validate the data
	boolean recordFound = false;
	while(rs.next()) {