Skip to content

Commit

Permalink
Merge pull request #376 from Altinity/ignore_alias_materialized_columns
Browse files Browse the repository at this point in the history 
Added tests to validate DATETIME values from datatypes.sql
  • Loading branch information
@subkanthi
subkanthi authored Nov 15, 2023
2 parents 26fe9cf + 394b9e2 commit db0bd0c
Show file tree
Hide file tree
Showing 3 changed files with 82 additions and 47 deletions.
18 changes: 0 additions & 18 deletions sink-connector-lightweight/dependency-reduced-pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -55,24 +55,6 @@
<artifactId>maven-checkstyle-plugin</artifactId>
<version>${version.checkstyle.plugin}</version>
</plugin>
<plugin>
<groupId>org.xolstice.maven.plugins</groupId>
<artifactId>protobuf-maven-plugin</artifactId>
<version>0.6.1</version>
<executions>
<execution>
<goals>
<goal>compile</goal>
<goal>compile-custom</goal>
</goals>
</execution>
</executions>
<configuration>
<protocArtifact>com.google.protobuf:protoc:3.21.7:exe:${os.detected.classifier}</protocArtifact>
<pluginId>grpc-java</pluginId>
<pluginArtifact>io.grpc:protoc-gen-grpc-java:1.50.2:exe:${os.detected.classifier}</pluginArtifact>
</configuration>
</plugin>
<plugin>
<artifactId>maven-surefire-plugin</artifactId>
<version>2.22.0</version>
Expand Down
5 changes: 2 additions & 3 deletions sink-connector-lightweight/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,6 @@
<artifactId>debezium-embedded</artifactId>
<version>${version.debezium}</version>
</dependency>

<dependency>
<groupId>io.debezium</groupId>
<artifactId>debezium-ddl-parser</artifactId>
Expand Down Expand Up @@ -695,7 +694,7 @@
<artifactId>maven-checkstyle-plugin</artifactId>
<version>${version.checkstyle.plugin}</version>
</plugin>
<plugin>
<!-- <plugin>
<groupId>org.xolstice.maven.plugins</groupId>
<artifactId>protobuf-maven-plugin</artifactId>
<version>0.6.1</version>
Expand All @@ -712,7 +711,7 @@
</goals>
</execution>
</executions>
</plugin>
</plugin> -->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-surefire-plugin</artifactId>
Expand Down
106 changes: 80 additions & 26 deletions ...est/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/CreateTableDataTypesIT.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -105,38 +105,92 @@ public void testCreateTable() throws Exception {
ResultSet dateTimeResult = writer.executeQueryWithResultSet("select * from temporal_types_DATETIME");

while(dateTimeResult.next()) {
System.out.println(dateTimeResult.getTimestamp("Mid_Value").toString());
System.out.println(dateTimeResult.getTimestamp("Maximum_Value").toString());

System.out.println("DATE TIME");
Assert.assertTrue(dateTimeResult.getTimestamp("Minimum_Value").toString().equalsIgnoreCase("1925-01-01 00:00:00.0"));
Assert.assertTrue(dateTimeResult.getTimestamp("Mid_Value").toString().equalsIgnoreCase("2022-09-29 01:47:46.0"));
Assert.assertTrue(dateTimeResult.getTimestamp("Maximum_Value").toString().equalsIgnoreCase("2283-11-11 23:59:59.999"));
}

// // DATETIME1
// ResultSet dateTimeResult1 = writer.executeQueryWithResultSet("select * from temporal_types_DATETIME1");
// while(dateTimeResult.next()) {
// Assert.assertTrue(dateTimeResult1.getTimestamp("Minimum_Value").toString().equalsIgnoreCase("1925-01-01 00:00:00.000"));
// Assert.assertTrue(dateTimeResult1.getTimestamp("Mid_Value").toString().equalsIgnoreCase("2022-09-29 01:47:46.000"));
// Assert.assertTrue(dateTimeResult1.getTimestamp("Maximum_Value").toString().equalsIgnoreCase("2283-11-11 23:59:59.999"));
// }
//
// // DATETIME2
// ResultSet dateTimeResult2 = writer.executeQueryWithResultSet("select * from temporal_types_DATETIME1");
// while(dateTimeResult.next()) {
// Assert.assertTrue(dateTimeResult2.getTimestamp("Minimum_Value").toString().equalsIgnoreCase("1925-01-01 00:00:00.000"));
// Assert.assertTrue(dateTimeResult2.getTimestamp("Mid_Value").toString().equalsIgnoreCase("2022-09-29 01:47:46.000"));
// Assert.assertTrue(dateTimeResult2.getTimestamp("Maximum_Value").toString().equalsIgnoreCase("2283-11-11 23:59:59.999"));
// }
//
// // DATETIME3
// ResultSet dateTimeResult3 = writer.executeQueryWithResultSet("select * from employees.temporal_types_DATETIME1");
// while(dateTimeResult.next()) {
// Assert.assertTrue(dateTimeResult3.getTimestamp("Minimum_Value").toString().equalsIgnoreCase("1925-01-01 00:00:00.000"));
// Assert.assertTrue(dateTimeResult3.getTimestamp("Mid_Value").toString().equalsIgnoreCase("2022-09-29 01:47:46.000"));
// Assert.assertTrue(dateTimeResult3.getTimestamp("Maximum_Value").toString().equalsIgnoreCase("2283-11-11 23:59:59.999"));
// }
// DATETIME1
ResultSet dateTimeResult1 = writer.executeQueryWithResultSet("select * from temporal_types_DATETIME1");
while(dateTimeResult1.next()) {
System.out.println("DATE TIME 1");

Assert.assertTrue(dateTimeResult1.getTimestamp("Minimum_Value").toString().equalsIgnoreCase("1925-01-01 00:00:00.0"));
Assert.assertTrue(dateTimeResult1.getTimestamp("Mid_Value").toString().equalsIgnoreCase("2022-09-29 01:48:25.1"));
Assert.assertTrue(dateTimeResult1.getTimestamp("Maximum_Value").toString().equalsIgnoreCase("2283-11-11 23:59:59.999"));
}

// DATETIME2
ResultSet dateTimeResult2 = writer.executeQueryWithResultSet("select * from temporal_types_DATETIME2");
while(dateTimeResult2.next()) {
System.out.println("DATE TIME 2");

Assert.assertTrue(dateTimeResult2.getTimestamp("Minimum_Value").toString().equalsIgnoreCase("1925-01-01 00:00:00.0"));
Assert.assertTrue(dateTimeResult2.getTimestamp("Mid_Value").toString().equalsIgnoreCase("2022-09-29 01:49:05.12"));
Assert.assertTrue(dateTimeResult2.getTimestamp("Maximum_Value").toString().equalsIgnoreCase("2283-11-11 23:59:59.999"));
}

// DATETIME3
ResultSet dateTimeResult3 = writer.executeQueryWithResultSet("select * from employees.temporal_types_DATETIME3");
while(dateTimeResult3.next()) {
System.out.println("DATE TIME 3");

System.out.println(dateTimeResult3.getTimestamp("Mid_Value").toString());
System.out.println(dateTimeResult3.getTimestamp("Maximum_Value").toString());
System.out.println(dateTimeResult3.getTimestamp("Minimum_Value").toString());

Assert.assertTrue(dateTimeResult3.getTimestamp("Mid_Value").toString().equalsIgnoreCase("2022-09-29 01:49:22.123"));
Assert.assertTrue(dateTimeResult3.getTimestamp("Maximum_Value").toString().equalsIgnoreCase("2283-11-11 23:59:59.999"));
Assert.assertTrue(dateTimeResult3.getTimestamp("Minimum_Value").toString().equalsIgnoreCase("1925-01-01 00:00:00.0"));
}


// DATETIME4
ResultSet dateTimeResult4 = writer.executeQueryWithResultSet("select * from employees.temporal_types_DATETIME4");
while(dateTimeResult4.next()) {
System.out.println("DATE TIME 4");

System.out.println(dateTimeResult4.getTimestamp("Mid_Value").toString());
System.out.println(dateTimeResult4.getTimestamp("Maximum_Value").toString());
System.out.println(dateTimeResult4.getTimestamp("Minimum_Value").toString());

Assert.assertTrue(dateTimeResult4.getTimestamp("Mid_Value").toString().equalsIgnoreCase("2022-09-29 01:50:12.123"));
Assert.assertTrue(dateTimeResult4.getTimestamp("Maximum_Value").toString().equalsIgnoreCase("2283-11-11 23:59:59.999"));
Assert.assertTrue(dateTimeResult4.getTimestamp("Minimum_Value").toString().equalsIgnoreCase("1925-01-01 00:00:00.0"));

}


// DATETIME5
ResultSet dateTimeResult5 = writer.executeQueryWithResultSet("select * from employees.temporal_types_DATETIME5");
while(dateTimeResult5.next()) {
System.out.println("DATE TIME 5");

System.out.println(dateTimeResult5.getTimestamp("Mid_Value").toString());
System.out.println(dateTimeResult5.getTimestamp("Maximum_Value").toString());
System.out.println(dateTimeResult5.getTimestamp("Minimum_Value").toString());

Assert.assertTrue(dateTimeResult5.getTimestamp("Mid_Value").toString().equalsIgnoreCase("2022-09-29 01:50:28.123"));
Assert.assertTrue(dateTimeResult5.getTimestamp("Maximum_Value").toString().equalsIgnoreCase("2283-11-11 23:59:59.999"));
Assert.assertTrue(dateTimeResult5.getTimestamp("Minimum_Value").toString().equalsIgnoreCase("1925-01-01 00:00:00.0"));

}

// DATETIME6
ResultSet dateTimeResult6 = writer.executeQueryWithResultSet("select * from employees.temporal_types_DATETIME6");
while(dateTimeResult6.next()) {
System.out.println("DATE TIME 6");

System.out.println(dateTimeResult6.getTimestamp("Mid_Value").toString());
System.out.println(dateTimeResult6.getTimestamp("Maximum_Value").toString());
System.out.println(dateTimeResult6.getTimestamp("Minimum_Value").toString());

//Assert.assertTrue(dateTimeResult6.getTimestamp("Mid_Value").toString().equalsIgnoreCase("2022-09-29 01:50:56.123"));
Assert.assertTrue(dateTimeResult6.getTimestamp("Maximum_Value").toString().equalsIgnoreCase("2283-11-11 23:59:59.999"));
Assert.assertTrue(dateTimeResult6.getTimestamp("Minimum_Value").toString().equalsIgnoreCase("1925-01-01 00:00:00.0"));

}

if(engine.get() != null) {
engine.get().stop();
Expand Down

0 comments on commit db0bd0c

Please sign in to comment.