日本被黑人强伦姧人妻完整版 2条经过责罚数据同步到寰宇部署的N个数据库

1、数据同步需求日本被黑人强伦姧人妻完整版

自动识别源表中数据所包摄的分公司进行自动同步,行将源表中A分公司的数据同步到A公司数据库表,源表中B分公司的数据同步到B公司数据库表,依此类推。

2、兑现思绪

l 一般ETL器具兑现思绪:诞生同步到A分公司经过,抽取源表数据->过滤出A分公司->将过滤后的数据加载到A公司数据库表。再诞生同步到B分公司经过,有若干个分公司就诞生若干条经过。

时弊:开荒责任量随分公司数目成正比,当统共表存在变更时需要对统共经过进行修改,普遍运转监控、惊羡繁难。

优点:当某个分公司数据库表有变更时,只需要惊羡对应的经过,不影响其他经过。

l Restcloud ETL器具兑现思绪:创建1个主经过、1个子经过,主经过用于取得需要同步的分公司并手脚变量参数,并逐一输出给子经过。子经过取得主经过的变量参数手脚数据过滤条款及动态取得对应筹办数据源。

主经过责任旨趣:通过践诺SQL剧本做Groupby分组盘算出要同步的分公司并手脚变量参数,诈欺【逐行拆分输出组件】阻挡轮回调用子经过,逐一将变量参数传送给子经过。

创建1个子经过,取得主经过输出数据手脚参数条款抽取需要同步的数据,及需要调取的数据源。

时弊:存在一定范围,如要求统共分公司的表称号、表结构换取。

优点:责任量小,普遍运转监控、惊羡方便。

3、示例

3.1 诞生主经过

3.1.1设立【践诺SQL剧本】组件

设立基本属性:指定读取源表的数据源

设立过滤条款:此处无需过滤数据,下一步跳过该项设立

设立SQL语句:编写SQL还是做Groupby分组盘算出要同步的分公司并手脚变量参数。

若是有存储分公司名单与数据源对应代码表,此处不错径直用【表输入】组件取得

日本被黑人强伦姧人妻完整版

保存退出,18禁止观看强奷免费国产大片完成【践诺SQL剧本】设立。

3.1.2设立【逐行拆分输出】组件

3.1.2设立【子任务】组件

聘任已设立后的子经过,聘任数据流入(继承主经过输出数据)

3.2 诞生子经过

3.2.1 设立【库表输入】

设立基本属性:指定读取源表的数据源

设立SQL语句:增多数据过滤条款参数

设立输入字段:系统自动读取,无需设立。径直点击保存退出完成【库表输入】组件设立。

3.2.2 设立【践诺Java剧本】

设立基本属性:无需修改设立,径直下一步。

设立Java代码:代码逻辑(通过判断输入的参数值取得对应同步的筹办数据源)

如输入参数A,对应同步到数据源“Stephen_MySql01”, Stephen_MySql01为设立A公司的的数据源称号。

径直点击编译并保存,退出完成【践诺Java剧本】组件设立

山西名醋缘生物科技;位于晋商故里、三晋腹地,山西老陈醋原产地保护区—晋中市榆次区,是一家集生物科技产品开发、销售、技术咨询于一体的创新型企业。专业提供山西老陈醋、山西陈醋的酿造技术服务与咨询,食用菌菌种生产、销售。研究开发出“名醋缘”、“人民小醋”系列产品:山西老陈醋、山西陈醋、红曲醋、苦荞醋、燕麦醋、小米醋、红枣醋、养颜口服液、私人高端定制醋等。

3.2.3 设立【库表输出】

设立基本属性:指定读取源表的数据源(此处字据参数动态取得指定输出数据源)

设立输出字段:字据筹办表的字段情况,手工点击新增列完成输出字段设立。

由于数据源是动态原因,经过在不运转情况下无法取得到对应表,因此无法自动取得表结构。

输出字段设立完成后,点击保存完成【库表输出】设立。

3.3 测试

3.3.1用例数据

源表数据如下:

3.3.2后果要求:

address 为“广州”的数据同步到mysql数据库

address 为“上海”的数据同步到SQL serve数据库

address 为“北京”的数据同步到Postgres数据库

3.3.3运转斥逐

数据库斥逐

象征为“广州”的,就将该条数据插入到mysql数据库

象征为“上海”的,就将该条数据插入到SQL server数据库

象征为“北京”的,就将该条数据插入到postgres数据库

日本被黑人强伦姧人妻完整版

数据源表数据源分公司数据库发布于:广东省声明:该文视力仅代表作家本身,搜狐号系信息发布平台,搜狐仅提供信息存储空间办事。