1- ## 1.格式:
2-
3- 通过建表语句中的` PERIOD FOR SYSTEM_TIME ` 将表标识为维表,其中` PRIMARY KEY(keyInfo) ` 中的keyInfo,表示用来和源表进行关联的字段,
4- 维表JOIN的条件必须与` keyInfo ` 字段一致。
51
6- ``` sql
2+ ## 1.格式:
73 通过建表语句中的` PERIOD FOR SYSTEM_TIME ` 将表标识为维表,其中` PRIMARY KEY(keyInfo) ` 中的keyInfo,表示用来和源表进行关联的字段,
84 维表JOIN的条件必须与` keyInfo ` 字段一致。
95```
2622 );
2723```
2824
29- ## 2.支持版本
30-
25+ # 2.支持版本
3126 db2 9.X
32-
27+
3328## 3.表结构定义
34-
35- [维表参数信息](docs/plugin/sideParams.md)
36-
37- db2独有的参数
38-
39- | 参数名称 | 含义 | 是否必填 | 默认值 |
40- | -------- | ------------------ | -------- | ------ |
41- | type | 维表类型, db2 | 是 | |
42- | url | 连接数据库 jdbcUrl | 是 | |
43- | userName | 连接用户名 | 是 | |
44- | password | 连接密码 | 是 | |
45-
46- ## 4.参数
4729
4830
4931 [ 维表参数信息] ( docs/plugin/sideParams.md )
@@ -58,35 +40,9 @@ db2独有的参数
5840| schema | 表所属scheam| 否||
5941
6042
61- ### ALL全量维表定义
62-
63- ```sql
64- // 定义全量维表
65- CREATE TABLE sideTable(
66- id INT,
67- name VARCHAR,
68- PRIMARY KEY(id) ,
69- PERIOD FOR SYSTEM_TIME
70- )WITH(
71- type ='db2',
72- url ='jdbc:db2://172.16.8.104:50000/test?charset=utf8',
73- userName ='dtstack',
74- password ='abc123',
75- tableName ='all_test_db2',
76- cache ='ALL',
77- cacheTTLMs ='60000',
78- parallelism ='1'
79- );
80- ```
81- ### LRU异步维表定义
8243
8344## 4.样例
8445
85- ``` sql
86- create table sideTable (
87- channel varchar ,
88- xccount int ,
89- PRIMARY KEY (channel),
9046### ALL全量维表定义
9147```
9248 // 定义全量维表
@@ -100,7 +56,6 @@ CREATE TABLE sideTable(
10056 url='jdbc:db2://172.16.10.251:50000/mqTest',
10157 userName='DB2INST1',
10258 password='abc123',
103- tableName='lru_test_db2',
10459 tableName='USER_INFO2',
10560 schema = 'DTSTACK'
10661 cache ='ALL',
@@ -131,7 +86,6 @@ CREATE TABLE sideTable(
13186 asyncPoolSize ='3',
13287 parallelism ='2'
13388 );
134- ```
13589
13690```
13791
@@ -168,57 +122,7 @@ CREATE TABLE source2(
168122 batchSize = '1'
169123);
170124
171- ### Db2异步维表关联
172-
173- ```sql
174- CREATE TABLE MyTable(
175- id int,
176- name varchar
177- )WITH(
178- type ='kafka11',
179- bootstrapServers ='172.16.8.107:9092',
180- zookeeperQuorum ='172.16.8.107:2181/kafka',
181- offsetReset ='latest',
182- topic ='cannan_yctest01',
183- timezone='Asia/Shanghai',
184- enableKeyPartitions ='false',
185- topicIsPattern ='false',
186- parallelism ='1'
187- );
188-
189- CREATE TABLE MyResult(
190- id INT,
191- name VARCHAR
192- )WITH(
193- type='db2',
194- url='jdbc:db2://172.16.8.104:50000/test?charset=utf8',
195- userName='dtstack',
196- password='abc123',
197- tableName ='test_db2_zf',
198- updateMode ='append',
199- parallelism ='1',
200- batchSize ='100',
201- batchWaitInterval ='1000'
202- );
203125
204- CREATE TABLE sideTable(
205- id INT,
206- name VARCHAR,
207- PRIMARY KEY(id) ,
208- PERIOD FOR SYSTEM_TIME
209- )WITH(
210- type='db2',
211- url='jdbc:db2://172.16.8.104:50000/test?charset=utf8',
212- userName='dtstack',
213- password='abc123',
214- tableName ='test_db2_10',
215- partitionedJoin ='false',
216- cache ='LRU',
217- cacheSize ='10000',
218- cacheTTLMs ='60000',
219- asyncPoolSize ='3',
220- parallelism ='1'
221- );
222126CREATE TABLE MyResult(
223127 id int,
224128 name VARCHAR,
@@ -259,19 +163,6 @@ GRANT CONTROL ON TABLE "DTSTACK "."USER_INFO2" TO USER "DB2INST1"
259163;
260164```
261165
262- insert
263- into
264- MyResult
265- select
266- m.id,
267- s.name
268- from
269- MyTable m
270- join
271- sideTable s
272- on m.id=s.id;
273-
274- ```
275166维表数据:(1001,maqi,hz)
276167
277168源表数据:{"name":"maqi","id":1001}
0 commit comments