# StarRocks多表数据同步到Oracle数据库

本示例主要演示从StarRocks源库中读取两张表userinfo、orderinfo的数据，通过转换组件FieldMapper组件配置转换规则，指定源表和目标表之间的字段映射关系，将数据写入Oracle目标库表中。

主要步骤如下：

准备数据
新建同步作业
拖拽图元
运行
查看数据
提交版本

# 准备数据

创建数据库dws_source作为源库


CREATE DATABASE IF NOT EXISTS dws_source;

创建表 userinfo 和 userinfo 作为源表，并给源表 INSERT 一些数据。


-- ---------------------------------------
-- Table structure for orderinfo
-- ---------------------------------------

DROP TABLE IF EXISTS `dws_source`.`orderinfo`;

CREATE TABLE `dws_source`.`orderinfo` (
  `ordercode` varchar(32) NOT NULL COMMENT '订单号',
  `amount` int DEFAULT NULL COMMENT '数量',
  `price` varchar(32) DEFAULT NULL COMMENT '价格',
  `manufacturer` varchar(32) DEFAULT NULL COMMENT '制造商',
  `createtime` datetime  COMMENT '创建时间',
  `createuser` varchar(32) DEFAULT NULL COMMENT '创建人',
  `updatetime` datetime  COMMENT '更新时间'
) ENGINE=OLAP 
PRIMARY KEY(`ordercode`)
COMMENT "订单信息表"
DISTRIBUTED BY HASH(`ordercode`)
PROPERTIES (
"replication_num" = "3"
);

-- ----------------------------
-- Records of orderinfo
-- ----------------------------

INSERT INTO `dws_source`.`orderinfo`
(ordercode, amount, price, manufacturer, createtime, createuser, updatetime)
VALUES('001', 1800, '5900', '天威科技11', '2018-12-13 08:00:00', '魏雨', '2018-12-13 08:00:00');
INSERT INTO `dws_source`.`orderinfo`
(ordercode, amount, price, manufacturer, createtime, createuser, updatetime)
VALUES('002', 1800, '9000', '天威科技11', '2018-12-13 08:00:00', '魏雨', '2018-12-13 08:00:00');
INSERT INTO `dws_source`.`orderinfo`
(ordercode, amount, price, manufacturer, createtime, createuser, updatetime)
VALUES('003', 1800, '5900', '天威科技', '2018-12-13 08:00:00', '魏雨', '2018-12-13 08:00:00');
INSERT INTO `dws_source`.`orderinfo`
(ordercode, amount, price, manufacturer, createtime, createuser, updatetime)
VALUES('004', 2000, '5000', '微云科技', '2018-12-13 08:00:00', '王林', '2019-12-01 08:20:11');
INSERT INTO `dws_source`.`orderinfo`
(ordercode, amount, price, manufacturer, createtime, createuser, updatetime)
VALUES('005', 3000, '666', '西安金属', '2018-12-13 08:00:00', '王强', '2022-12-13 08:00:00');


-- ---------------------------------------
-- Table structure for userinfo
-- ---------------------------------------
DROP TABLE IF EXISTS `dws_source`.`userinfo`;

CREATE TABLE `dws_source`.`userinfo` (
    `usercode` varchar(32) NOT NULL COMMENT '用户编码',
    `username` varchar(20) COMMENT '用户姓名',
    `sex` char(3) COMMENT '性别',
    `age` INT COMMENT '年龄',
    `unitcode` varchar(32) COMMENT '所属单位',
    `deptcode` varchar(32) COMMENT '所属部门',
    `telephone` varchar(32) COMMENT '联系方式',
    `createtime` Date COMMENT '创建时间',
    `updatetime` Date COMMENT '更新时间'
)ENGINE=OLAP 
PRIMARY KEY(`usercode`)
COMMENT "用户信息表"
DISTRIBUTED BY HASH(`usercode`)
PROPERTIES (
"replication_num" = "3"
);

-- ----------------------------
-- Records of userinfo
-- ----------------------------

INSERT INTO `dws_source`.`userinfo`
(usercode, username, sex, age, unitcode, deptcode, telephone, createtime, updatetime)
VALUES('2', '王建国', '男', 20, '普元信息', '售后', '18977889900', '2024-07-03', '2024-07-04');
INSERT INTO `dws_source`.`userinfo`
(usercode, username, sex, age, unitcode, deptcode, telephone, createtime, updatetime)
VALUES('5', '刘飞', '男', 25, '普元信息', '事业部', '15091345789', '2018-12-13', '2018-12-13');
INSERT INTO `dws_source`.`userinfo`
(usercode, username, sex, age, unitcode, deptcode, telephone, createtime, updatetime)
VALUES('3', '王强', '男', 25, '普元信息', '售后', '15389012334', '2018-12-13', '2018-12-13');
INSERT INTO `dws_source`.`userinfo`
(usercode, username, sex, age, unitcode, deptcode, telephone, createtime, updatetime)
VALUES('4', '魏雨', '女', 26, '普元信息', '售后', '15309872351', '2018-12-13', '2018-12-13');
INSERT INTO `dws_source`.`userinfo`
(usercode, username, sex, age, unitcode, deptcode, telephone, createtime, updatetime)
VALUES('1', '张聪', '男', 80, '普元信息', '技术部', '18091256632', '2018-12-13', '2018-12-13');