# StarRocks数据库同步

本示例主要演示从StarRocks读取数据，写入StarRocks库中。

主要步骤如下：

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

# 准备数据

1、在StarRocks数据库中创建源表和目标表。

⚠️提示：StarRocks Sink 在执行中不会自动创建表，需要用户提前创建目标表。

源表：
CREATE TABLE `Employees` (
  `EmployeeID` int(11) NOT NULL COMMENT "",
  `Name` varchar(50) NOT NULL COMMENT "",
  `Salary` decimal64(10, 2) NULL COMMENT ""
) ENGINE=OLAP 
PRIMARY KEY(`EmployeeID`, `Name`)
DISTRIBUTED BY HASH(`EmployeeID`) BUCKETS 1 
PROPERTIES (
"replication_num" = "3",
"in_memory" = "false",
"storage_format" = "DEFAULT",
"enable_persistent_index" = "false",
"replicated_storage" = "true",
"compression" = "LZ4"
);

INSERT INTO test.Employees(EmployeeID, Name, Salary) VALUES(1, 'mmmm', 1234.00);
INSERT INTO test.Employees(EmployeeID, Name, Salary) VALUES(2, 'aaaamijia', 3333.00);
INSERT INTO test.Employees(EmployeeID, Name, Salary) VALUES(3, 'Robert Johnson', 5500.00);
INSERT INTO test.Employees(EmployeeID, Name, Salary) VALUES(4, 'Emily Williams', 4500.00);
INSERT INTO test.Employees(EmployeeID, Name, Salary) VALUES(5, 'aaaa,bbbb', 7000.00);


目标表：
CREATE TABLE `Employees2` (
  `EmployeeID` int(11) NOT NULL COMMENT "",
  `Name` varchar(50) NOT NULL COMMENT "",
  `Salary` decimal64(10, 2) NULL COMMENT ""
) ENGINE=OLAP 
PRIMARY KEY(`EmployeeID`, `Name`)
DISTRIBUTED BY HASH(`EmployeeID`) BUCKETS 1 
PROPERTIES (
"replication_num" = "3",
"in_memory" = "false",
"storage_format" = "DEFAULT",
"enable_persistent_index" = "false",
"replicated_storage" = "true",
"compression" = "LZ4"
);