# Elasticsearch 到 MySQL 的数据同步示例

本示例主要介绍 Elasticsearch 到 MySQL 的数据同步示例场景开发，该场景根据 Elasticsearch 接收到的数据内容向 MySQL 数据源的表 userinfo 插入、更新数据。主要步骤如下：

准备数据
新建实时作业
画布中拖拽图元
配置"Elasticsearch数据源"组件属性
配置"关系型数据库目标"组件属性
通用配置
保存草稿
运行
提交版本

# 准备数据

在 MySQL数据源中创建一个表 userinfo，用于写入ES数据

CREATE TABLE userinfo (
  usercode varchar(64) NOT NULL,
  username varchar(64) DEFAULT NULL,
  sex varchar(64) DEFAULT NULL,
  age int(11) DEFAULT NULL,
  unitcode varchar(64) DEFAULT NULL,
  deptcode varchar(64) DEFAULT NULL,
  telephone varchar(64) DEFAULT NULL,
  createtime datetime DEFAULT NULL,
  updatetime datetime DEFAULT NULL,
  PRIMARY KEY (usercode)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

INSERT INTO `dws_front_dev`.`userinfo` (`usercode`, `username`, `sex`, `age`, `unitcode`, `deptcode`, `telephone`, `createtime`, `updatetime`) VALUES ('001', '张聪', '男', 20, 'test', 'test', '15091345789', '2018-12-13 00:00:00', '2018-12-13 00:00:00');

在 Elasticsearch数据源中插入数据。具体如下：

curl -H "Content-Type: application/json" \
-X POST 'https://elastic:primeton000000@192.168.16.211:9200/user/_bulk' -d '
{ "index": { "_index":"user","_id": "1" }} 
{ "usercode": "001", "username": "张聪", "sex": "男", "age": 35, "unitcode": "普元信息", "deptcode": "技术部", "telephone": "15091345789", "createtime": "2018-12-13 00:00:00" , "updatetime": "2023-12-18 12:00:10"} 
{ "index": { "_index":"user","_id": "2" }} 
{ "usercode": "002", "username": "王强", "sex": "男", "age": 25, "unitcode": "普元信息", "deptcode": "售后", "telephone": "15309872351", "createtime": "2018-12-13 23:59:59" , "updatetime": "2024-01-18 12:30:00"}
' -k