Add end-to-end tests to verify data type support when migrating from PostgreSQL (#1251)

* Add end-to-end tests to check that table interleave limits are adhered to when migrating from Postgres

* Add end-to-end tests for verify data type support when migrating from PostgreSQL

---------

Co-authored-by: Vardhan Vinay Thigle <39047439+VardhanThigle@users.noreply.github.com>

Author: nmemond

.github/workflows/integration-tests-against-emulator.yaml

@@ -108,6 +108,8 @@ jobs:
           sudo apt-get -yq install postgresql-client
       - run: psql --version
       - run: psql -f test_data/pg_dump.test.out
+      - run: psql -c 'CREATE DATABASE test_pg_data_types;'
+      - run: psql -d test_pg_data_types -f test_data/postgres_data_types_dump.test.out
 
       # init a MySQL database from the test_data
       - run: mysql --version

test_data/postgres_data_types_dump.test.out

@@ -0,0 +1,134 @@
+DROP TABLE IF EXISTS all_data_types;
+CREATE TABLE all_data_types (
+  row_id BIGINT PRIMARY KEY,
+  bit_to_bytes BIT,
+  bit_to_bool_array BIT,
+  bit_to_string BIT,
+  bit_n_to_bytes BIT(32),
+  bit_n_to_bool_array BIT(32),
+  bit_n_to_string BIT(32),
+  bit_varying_to_bytes BIT VARYING,
+  bit_varying_to_bool_array BIT VARYING,
+  bit_varying_to_string BIT VARYING,
+  bit_varying_n_to_bytes BIT VARYING(32),
+  bit_varying_n_to_bool_array BIT VARYING(32),
+  bit_varying_n_to_string BIT VARYING(32),
+  varbit_to_bytes VARBIT,
+  varbit_to_bool_array VARBIT,
+  varbit_to_string VARBIT,
+  varbit_n_to_bytes VARBIT(32),
+  varbit_n_to_bool_array VARBIT(32),
+  varbit_n_to_string VARBIT(32),
+  bool_to_bool BOOL,
+  bool_to_string BOOL,
+  bool_array_to_bool_array BOOL[],
+  bool_array_to_string BOOL[],
+  boolean_to_bool BOOLEAN,
+  boolean_to_string BOOLEAN,
+  smallint_to_int64 SMALLINT,
+  smallint_to_string SMALLINT,
+  smallint_array_to_int64_array SMALLINT[],
+  smallint_array_to_string SMALLINT[],
+  int2_to_int64 INT2,
+  int2_to_string INT2,
+  int_to_int64 INT,
+  int_to_string INT,
+  int_array_to_int64_array INT[],
+  int_array_to_string INT[],
+  int4_to_int64 INT4,
+  int4_to_string INT4,
+  integer_to_int64 INTEGER,
+  integer_to_string INTEGER,
+  bigint_to_int64 BIGINT,
+  bigint_to_string BIGINT,
+  bigint_array_to_int64_array BIGINT[],
+  bigint_array_to_string BIGINT[],
+  int8_to_int64 INT8,
+  int8_to_string INT8,
+  smallserial_to_int64 SMALLSERIAL,
+  smallserial_to_string SMALLSERIAL,
+  serial2_to_int64 SERIAL2,
+  serial2_to_string SERIAL2,
+  serial_to_int64 SERIAL,
+  serial_to_string SERIAL,
+  serial4_to_int64 SERIAL4,
+  serial4_to_string SERIAL4,
+  bigserial_to_int64 BIGSERIAL,
+  bigserial_to_string BIGSERIAL,
+  serial8_to_int64 SERIAL8,
+  serial8_to_string SERIAL8,
+  decimal_to_numeric DECIMAL(20, 5),
+  decimal_to_string DECIMAL(20, 5),
+  numeric_to_numeric NUMERIC(20, 5),
+  numeric_to_string NUMERIC(20, 5),
+  large_decimal_to_numeric DECIMAL(40, 10),
+  large_decimal_to_string DECIMAL(40, 10),
+  large_numeric_to_numeric NUMERIC(40, 10),
+  large_numeric_to_string NUMERIC(40, 10),
+  float4_to_float32 FLOAT4,
+  float4_to_float64 FLOAT4,
+  float4_to_string FLOAT4,
+  real_to_float32 REAL,
+  real_to_float64 REAL,
+  real_to_string REAL,
+  real_array_to_float32_array REAL[],
+  real_array_to_string REAL[],
+  double_precision_to_float64 DOUBLE PRECISION,
+  double_precision_to_string DOUBLE PRECISION,
+  float_to_float64 FLOAT,
+  float_to_string FLOAT,
+  float_array_to_float64_array FLOAT[],
+  float_array_to_string FLOAT[],
+  float8_to_float64 FLOAT8,
+  float8_to_string FLOAT8,
+  date_to_date DATE,
+  date_to_string DATE,
+  timestamp_to_timestamp TIMESTAMP,
+  timestamp_to_string TIMESTAMP,
+  timestamp_with_timezone_to_timestamp TIMESTAMP WITH TIME ZONE,
+  timestamp_with_timezone_to_string TIMESTAMP WITH TIME ZONE,
+  timestamptz_to_timestamp TIMESTAMPTZ,
+  timestamptz_to_string TIMESTAMPTZ,
+  time_to_string TIME,
+  time_with_timezone_to_string TIME WITH TIME ZONE,
+  timetz_to_string TIMETZ,
+  char_to_string CHAR,
+  char_n_to_string CHAR(255),
+  character_to_string CHARACTER,
+  character_n_to_string CHARACTER(255),
+  varchar_to_string VARCHAR,
+  varchar_n_to_string VARCHAR(255),
+  character_varying_to_string CHARACTER VARYING,
+  character_varying_n_to_string CHARACTER VARYING(255),
+  text_to_string TEXT,
+  bytea_to_bytes BYTEA,
+  bytea_to_string BYTEA,
+  json_to_json JSON,
+  json_to_string JSON,
+  jsonb_to_json JSONB,
+  jsonb_to_string JSONB,
+  interval_to_int64 INTERVAL,
+  interval_to_string INTERVAL,
+  box_to_string BOX,
+  box_to_float64_array BOX,
+  circle_to_string CIRCLE,
+  circle_to_float64_array CIRCLE,
+  line_to_string LINE,
+  line_to_float64_array LINE,
+  lseg_to_string LSEG,
+  lseg_to_float64_array LSEG,
+  path_to_string PATH,
+  path_to_float64_array PATH,
+  point_to_string POINT,
+  point_to_float64_array POINT,
+  polygon_to_string POLYGON,
+  polygon_to_float64_array POLYGON,
+  money_to_int64 MONEY,
+  money_to_string MONEY,
+  uuid_to_bytes UUID,
+  uuid_to_string UUID,
+  xml_to_string XML,
+  cidr_to_string CIDR,
+  inet_to_string INET,
+  macaddr_to_string MACADDR
+);