[FLINK-27439] Add an e2e test for all supported value data types
This closes #106
diff --git a/flink-table-store-e2e-tests/src/test/java/org/apache/flink/table/store/tests/TypeE2eTest.java b/flink-table-store-e2e-tests/src/test/java/org/apache/flink/table/store/tests/TypeE2eTest.java
index 77b0fee..81fd14b 100644
--- a/flink-table-store-e2e-tests/src/test/java/org/apache/flink/table/store/tests/TypeE2eTest.java
+++ b/flink-table-store-e2e-tests/src/test/java/org/apache/flink/table/store/tests/TypeE2eTest.java
@@ -27,7 +27,7 @@
public class TypeE2eTest extends E2eTestBase {
@Test
- public void testAllTypes() throws Exception {
+ public void testAllTypesAsKey() throws Exception {
String schema =
String.join(
"\n",
@@ -87,8 +87,85 @@
tableStoreDdl,
createResultSink("result1", schema));
checkResult(
- "true, 1, 10, 100, 1000, 1.1, 1.11, 12.456, 123456789123456789.12345678, hi, hello, table桌子store商店, [116], 2022-04-28, 2022-04-28T15:35:45.123, [hi, hello, null, test], +I[1, 10, 测试]",
- "null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null");
+ "true, 1, 10, 100, 1000, 1.1, 1.11, 12.456, "
+ + "123456789123456789.12345678, hi, hello, table桌子store商店, [116], "
+ + "2022-04-28, 2022-04-28T15:35:45.123, [hi, hello, null, test], +I[1, 10, 测试]",
+ "null, null, null, null, null, null, null, null, null, "
+ + "null, null, null, null, null, null, null, null");
+ }
+
+ @Test
+ public void testAllTypesAsValue() throws Exception {
+ String schema =
+ String.join(
+ "\n",
+ Arrays.asList(
+ "pk INT,",
+ "f0 BOOLEAN,",
+ "f1 TINYINT,",
+ "f2 SMALLINT,",
+ "f3 INT,",
+ "f4 BIGINT,",
+ "f5 FLOAT,",
+ "f6 DOUBLE,",
+ "f7 DECIMAL(5, 3),",
+ "f8 DECIMAL(26, 8),",
+ "f9 CHAR(10),",
+ "f10 VARCHAR(10),",
+ "f11 STRING,",
+ "f12 BYTES,",
+ "f13 DATE,",
+ "f14 TIMESTAMP(3),",
+ "f15 ARRAY<STRING>,",
+ "f16 ROW<a INT, b BIGINT, c STRING>,",
+ "f17 MAP<STRING, BIGINT>"));
+ String tableStoreDdl =
+ String.join(
+ "\n",
+ Arrays.asList(
+ "CREATE TABLE IF NOT EXISTS table_store(",
+ schema + ",",
+ "PRIMARY KEY (pk) NOT ENFORCED",
+ ") WITH (",
+ " 'bucket' = '1',",
+ " 'path' = '%s'",
+ ");"));
+ tableStoreDdl =
+ String.format(
+ tableStoreDdl,
+ TEST_DATA_DIR + "/" + UUID.randomUUID().toString() + ".store");
+
+ runSql(
+ "INSERT INTO table_store VALUES (1,"
+ + "true, cast(1 as tinyint), cast(10 as smallint), "
+ + "100, 1000, cast(1.1 as float), 1.11, 12.456, "
+ + "cast('123456789123456789.12345678' as decimal(26, 8)), "
+ + "cast('hi' as char(10)), 'hello', 'table桌子store商店', "
+ + "ENCODE('table桌子store商店', 'UTF-8'), "
+ + "DATE '2022-04-28', TIMESTAMP '2022-04-28 15:35:45.123', "
+ + "ARRAY['hi', 'hello', cast(null as string), 'test'], (1, 10, '测试'), "
+ + "MAP['hi', 1, 'hello', cast(null as bigint), 'test', 3]"
+ + "), (2,"
+ + "cast(null as boolean), cast(null as tinyint), cast(null as smallint), "
+ + "cast(null as int), cast(null as bigint), cast(null as float), "
+ + "cast(null as double), cast(null as decimal(5, 3)), cast(null as decimal(26, 8)), "
+ + "cast(null as char(10)), cast(null as varchar(10)), cast(null as string), "
+ + "cast(null as bytes), cast(null as date), cast(null as timestamp(3)), "
+ + "cast(null as array<string>), cast(null as row<a int, b bigint, c string>), "
+ + "cast(null as map<string, bigint>)"
+ + ");",
+ tableStoreDdl);
+ runSql(
+ "INSERT INTO result1 SELECT * FROM table_store;",
+ tableStoreDdl,
+ createResultSink("result1", schema));
+ checkResult(
+ "1, true, 1, 10, 100, 1000, 1.1, 1.11, 12.456, "
+ + "123456789123456789.12345678, hi, hello, table桌子store商店, [116], "
+ + "2022-04-28, 2022-04-28T15:35:45.123, [hi, hello, null, test], +I[1, 10, 测试], "
+ + "{hi=1, test=3, hello=null}",
+ "2, null, null, null, null, null, null, null, null, null, "
+ + "null, null, null, null, null, null, null, null, null");
}
private void runSql(String sql, String... ddls) throws Exception {
