| # |
| # Licensed to the Apache Software Foundation (ASF) under one or more |
| # contributor license agreements. See the NOTICE file distributed with |
| # this work for additional information regarding copyright ownership. |
| # The ASF licenses this file to You under the Apache License, Version 2.0 |
| # (the "License"); you may not use this file except in compliance with |
| # the License. You may obtain a copy of the License at |
| # |
| # http://www.apache.org/licenses/LICENSE-2.0 |
| # |
| # Unless required by applicable law or agreed to in writing, software |
| # distributed under the License is distributed on an "AS IS" BASIS, |
| # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| # See the License for the specific language governing permissions and |
| # limitations under the License. |
| # |
| |
| dm_table_source = """ |
| create table if not exists "SYSDBA".e2e_table_source |
| ( |
| DM_BIT BIT, |
| DM_INT INT, |
| DM_INTEGER INTEGER, |
| DM_PLS_INTEGER PLS_INTEGER, |
| DM_TINYINT TINYINT, |
| |
| DM_BYTE BYTE, |
| DM_SMALLINT SMALLINT, |
| DM_BIGINT BIGINT, |
| |
| DM_NUMERIC NUMERIC, |
| DM_NUMBER NUMBER, |
| DM_DECIMAL DECIMAL, |
| DM_DEC DEC, |
| |
| DM_REAL REAL, |
| DM_FLOAT FLOAT, |
| DM_DOUBLE_PRECISION DOUBLE PRECISION, |
| DM_DOUBLE DOUBLE, |
| |
| DM_CHAR CHAR, |
| DM_CHARACTER CHARACTER, |
| DM_VARCHAR VARCHAR, |
| DM_VARCHAR2 VARCHAR2, |
| DM_TEXT TEXT, |
| DM_LONG LONG, |
| DM_LONGVARCHAR LONGVARCHAR, |
| DM_CLOB CLOB, |
| |
| DM_TIMESTAMP TIMESTAMP, |
| DM_DATETIME DATETIME, |
| DM_TIME TIME, |
| DM_DATE DATE, |
| |
| DM_BLOB BLOB, |
| DM_BINARY BINARY, |
| DM_VARBINARY VARBINARY, |
| DM_LONGVARBINARY LONGVARBINARY, |
| DM_IMAGE IMAGE, |
| DM_BFILE BFILE |
| ) |
| """ |
| |
| dm_table_sink = """ |
| create table if not exists "SYSDBA".e2e_table_sink |
| ( |
| DM_BIT BIT, |
| DM_INT INT, |
| DM_INTEGER INTEGER, |
| DM_PLS_INTEGER PLS_INTEGER, |
| DM_TINYINT TINYINT, |
| |
| DM_BYTE BYTE, |
| DM_SMALLINT SMALLINT, |
| DM_BIGINT BIGINT, |
| |
| DM_NUMERIC NUMERIC, |
| DM_NUMBER NUMBER, |
| DM_DECIMAL DECIMAL, |
| DM_DEC DEC, |
| |
| DM_REAL REAL, |
| DM_FLOAT FLOAT, |
| DM_DOUBLE_PRECISION DOUBLE PRECISION, |
| DM_DOUBLE DOUBLE, |
| |
| DM_CHAR CHAR, |
| DM_CHARACTER CHARACTER, |
| DM_VARCHAR VARCHAR, |
| DM_VARCHAR2 VARCHAR2, |
| DM_TEXT TEXT, |
| DM_LONG LONG, |
| DM_LONGVARCHAR LONGVARCHAR, |
| DM_CLOB CLOB, |
| |
| DM_TIMESTAMP TIMESTAMP, |
| DM_DATETIME DATETIME, |
| DM_TIME TIME, |
| DM_DATE DATE, |
| |
| DM_BLOB BLOB, |
| DM_BINARY BINARY, |
| DM_VARBINARY VARBINARY, |
| DM_LONGVARBINARY LONGVARBINARY, |
| DM_IMAGE IMAGE, |
| DM_BFILE BFILE |
| ) |
| """ |
| // only need for source |
| DML = """ |
| INSERT INTO "SYSDBA".e2e_table_source ( |
| DM_BIT, DM_INT, DM_INTEGER, DM_PLS_INTEGER, DM_TINYINT, DM_BYTE, DM_SMALLINT, DM_BIGINT, |
| DM_NUMERIC, DM_NUMBER, DM_DECIMAL, DM_DEC, DM_REAL, DM_FLOAT, DM_DOUBLE_PRECISION, DM_DOUBLE, |
| DM_CHAR, DM_CHARACTER, DM_VARCHAR, DM_VARCHAR2, DM_TEXT, DM_LONG, DM_LONGVARCHAR, DM_CLOB, |
| DM_TIMESTAMP, DM_DATETIME, DM_TIME, DM_DATE, |
| DM_BLOB, DM_BINARY, DM_VARBINARY, DM_LONGVARBINARY, DM_IMAGE, DM_BFILE) |
| VALUES |
| (0, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, '1', |
| 'a', 'a', 'a', 'a', 'a', 'a', 'a', |
| '2022-08-13 17:35:59.000000', '2022-08-13 17:36:11.000000', '15:45:00', '2022-08-13', |
| null, null, null, null, null, null) |
| """ |
