From 492700bbbf062725f9e78221d6adc25a916e0290 Mon Sep 17 00:00:00 2001 From: paul8263 Date: Fri, 19 Nov 2021 09:20:20 +0800 Subject: [PATCH] [docs] Improve column name note in oracle cdc document (#633) --- docs/content/connectors/oracle-cdc.md | 18 ++++++++++-------- 1 file changed, 10 insertions(+), 8 deletions(-) diff --git a/docs/content/connectors/oracle-cdc.md b/docs/content/connectors/oracle-cdc.md index 6898a9827..05be2f5e4 100644 --- a/docs/content/connectors/oracle-cdc.md +++ b/docs/content/connectors/oracle-cdc.md @@ -120,10 +120,10 @@ The Oracle CDC table can be defined as following: ```sql -- register an Oracle table 'products' in Flink SQL Flink SQL> CREATE TABLE products ( - id INT NOT NULL, - name STRING, - description STRING, - weight DECIMAL(10, 3), + ID INT NOT NULL, + NAME STRING, + DESCRIPTION STRING, + WEIGHT DECIMAL(10, 3), PRIMARY KEY(id) NOT ENFORCED ) WITH ( 'connector' = 'oracle-cdc', @@ -288,10 +288,10 @@ CREATE TABLE products ( schema_name STRING METADATA FROM 'schema_name' VIRTUAL, table_name STRING METADATA FROM 'table_name' VIRTUAL, operation_ts TIMESTAMP_LTZ(3) METADATA FROM 'op_ts' VIRTUAL, - id INT NOT NULL, - name STRING, - description STRING, - weight DECIMAL(10, 3), + ID INT NOT NULL, + NAME STRING, + DESCRIPTION STRING, + WEIGHT DECIMAL(10, 3), PRIMARY KEY(id) NOT ENFORCED ) WITH ( 'connector' = 'oracle-cdc', @@ -305,6 +305,8 @@ CREATE TABLE products ( ); ``` +** Note ** : The Oracle dialect is case-sensitive, it converts field name to uppercase if the field name is not quoted, Flink SQL doesn't convert the field name. Thus for physical columns from oracle database, we should use its converted field name in Oracle when define an `oracle-cdc` table in Flink SQL. + Features --------