@@ -37,19 +37,67 @@ CREATE TABLE tableName(
37
37
| tableName | oracle表名称| 是||
38
38
| schema | oracle 的schema| 否| 当前登录用户|
39
39
| parallelism | 并行度设置| 否| 1|
40
+ | batchSize | flush的大小| 否| 100|
41
+ | batchWaitInterval | flush的时间间隔,单位ms| 否| 1000|
42
+ | allReplace | true:新值替换旧值| 否| false|
43
+ | updateMode | APPEND:不回撤数据,只下发增量数据,UPSERT:先删除回撤数据,然后更新| 否| 结果表设置主键则为UPSERT|
44
+
40
45
41
46
## 5.样例:
42
47
```
43
- CREATE TABLE MyResult(
44
- channel VARCHAR,
45
- pv VARCHAR
48
+ CREATE TABLE MyTable(
49
+ name varchar,
50
+ channel varchar,
51
+ id int
46
52
)WITH(
47
- type ='oracle',
48
- url ='jdbc:oracle:thin:@xx.xx.xx.xx:1521:orcl',
49
- userName ='dtstack',
50
- password ='abc123',
51
- tableName ='pv2',
52
- schema = 'MQTEST',
53
+ type ='kafka10',
54
+ bootstrapServers ='172.16.8.107:9092',
55
+ zookeeperQuorum ='172.16.8.107:2181/kafka',
56
+ offsetReset ='latest',
57
+ topic ='mqTest01',
58
+ timezone='Asia/Shanghai',
59
+ updateMode ='append',
60
+ enableKeyPartitions ='false',
61
+ topicIsPattern ='false',
53
62
parallelism ='1'
54
- )
55
- ```
63
+ );
64
+
65
+ CREATE TABLE MyResult(
66
+ primarykey_id int ,
67
+ name VARCHAR,
68
+ address VARCHAR
69
+ )WITH(
70
+ type ='oracle',
71
+ url ='jdbc:oracle:thin:@172.16.8.178',
72
+ userName ='system',
73
+ password ='oracle',
74
+ tableName ='YELUO_TEST_ORACLE_01',
75
+ updateMode ='append',
76
+ parallelism ='1',
77
+ batchSize ='100',
78
+ batchWaitInterval ='1000'
79
+ );
80
+
81
+ insert
82
+ into
83
+ MyResult
84
+ select
85
+ id as primarykey_id,
86
+ channel as address,
87
+ name
88
+ from
89
+ MyTable a
90
+ ```
91
+
92
+ ## 6.数据示例
93
+ ### 输入数据
94
+ ```
95
+ {"name":"roc","id":11,"channel":"daishuyun"}
96
+ ```
97
+ ### 结果数据
98
+ ```
99
+ +---------+------+------+-----------+
100
+ | primarykey_id | name | address |
101
+ +---------+------+------+----------+
102
+ | 11 | roc | daishuyun |
103
+ ```
0 commit comments