# 关系型数据库同步Hive数据示例

本示例主要演示从Mysql empsinfo表中读取数据，通过Replace组件进行字段配置，将Name中含KING的值替换为RANK，插入Hive empsinfo表中。

主要步骤如下：

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

# 准备数据

在Mysql中创建表empsinfo，在Hive中创建表empsinfo

Mysql表创建：
-- ---------------------------------------
-- Table structure for empsinfo_miggration
-- ---------------------------------------
DROP TABLE IF EXISTS `empsinfo`;
CREATE TABLE `empsinfo_miggration` (
  `ID` int NOT NULL,
  `NAME` varchar(10) DEFAULT NULL,
  `AGE` decimal(3,0) DEFAULT NULL,
  `EMPNO` int DEFAULT NULL,
  PRIMARY KEY (`ID`)
);

-- ----------------------------
-- Records of empsinfo
-- ----------------------------
BEGIN;
INSERT INTO `empsinfo` (`ID`, `NAME`, `AGE`, `EMPNO`) VALUES (10001, 'WARD', 25, 7521);
INSERT INTO `empsinfo` (`ID`, `NAME`, `AGE`, `EMPNO`) VALUES (10002, 'JONES', 32, 7566);
INSERT INTO `empsinfo` (`ID`, `NAME`, `AGE`, `EMPNO`) VALUES (10003, 'BLAKE', 15, 7698);
INSERT INTO `empsinfo` (`ID`, `NAME`, `AGE`, `EMPNO`) VALUES (10004, 'SCOTT', 53, 7788);
INSERT INTO `empsinfo` (`ID`, `NAME`, `AGE`, `EMPNO`) VALUES (10005, 'KING', 22, 7839);
COMMIT;

Hive表创建：
-- ---------------------------------------
-- Table structure for empsinfo
-- ---------------------------------------
DROP TABLE IF EXISTS `empsinfo`;
CREATE TABLE `empsinfo` (
  `ID` int ,
  `NAME` String ,
  `AGE` int,
  `EMPNO` int 
)ROW FORMAT DELIMITED FIELDS TERMINATED BY ',' 
STORED AS ORC;


INSERT INTO `empsinfo`  VALUES (10001, 'WARD', 25, 7521);
INSERT INTO `empsinfo`  VALUES (10002, 'JONES', 32, 7566);
INSERT INTO `empsinfo`  VALUES (10003, 'BLAKE', 15, 7698);
INSERT INTO `empsinfo`  VALUES (10004, 'SCOTT', 53, 7788);
INSERT INTO `empsinfo`  VALUES (10005, 'KING', 22, 7839);