diff --git a/pom.xml b/pom.xml
index cb5ed70..449ce43 100644
--- a/pom.xml
+++ b/pom.xml
@@ -12,6 +12,7 @@
influx-data
manufact_influx_data
filesync
+ relational_migration
pom
diff --git a/relational_migration/pom.xml b/relational_migration/pom.xml
new file mode 100644
index 0000000..b552b38
--- /dev/null
+++ b/relational_migration/pom.xml
@@ -0,0 +1,40 @@
+
+
+ 4.0.0
+
+
+ com.njcn
+ data-migration
+ 1.0.0
+
+
+ relational_migration
+ pom
+
+
+
+ 8
+ 8
+ UTF-8
+
+
+
+ relational_comm
+ relational_target
+
+
+
+
+
+
+ net.bytebuddy
+ byte-buddy
+ 1.12.10
+
+
+
+
+
+
+
diff --git a/relational_migration/relational_comm/pom.xml b/relational_migration/relational_comm/pom.xml
new file mode 100644
index 0000000..2064aa7
--- /dev/null
+++ b/relational_migration/relational_comm/pom.xml
@@ -0,0 +1,127 @@
+
+
+ 4.0.0
+
+
+ com.njcn
+ relational_migration
+ 1.0.0
+
+
+ relational_comm
+
+
+ 1.8
+ UTF-8
+ UTF-8
+
+
+
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+
+ cn.hutool
+ hutool-all
+
+
+
+ commons-io
+ commons-io
+
+
+
+ org.bouncycastle
+ bcprov-jdk15on
+
+
+
+ org.apache.commons
+ commons-compress
+ 1.21
+
+
+
+ org.projectlombok
+ lombok
+ ${lombok.version}
+
+
+
+
+ org.mybatis.spring.boot
+ mybatis-spring-boot-starter
+ ${mybatis.version}
+
+
+
+ com.alibaba
+ druid-spring-boot-starter
+ ${druid.version}
+
+
+
+ mysql
+ mysql-connector-java
+ ${mysql.version}
+
+
+
+
+ com.dameng
+ DmJdbcDriver18
+ 8.1.1.193
+
+
+
+ com.baomidou
+ mybatis-plus-generator
+ ${mybatis-plus-generator.version}
+
+
+
+ com.baomidou
+ mybatis-plus-boot-starter
+ ${mybatis-plus.version}
+
+
+ com.github.jeffreyning
+ mybatisplus-plus
+ ${mybatis-plus.jeffreyning.version}
+
+
+
+ com.github.xiaoymin
+ knife4j-spring-boot-starter
+ ${knife4j.version}
+
+
+
+
+
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 3.8.1
+
+ 1.8
+ 1.8
+ UTF-8
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+
+
+
+
diff --git a/relational_migration/relational_comm/src/main/java/com/njcn/relational/exception/GlobalBusinessExceptionHandler.java b/relational_migration/relational_comm/src/main/java/com/njcn/relational/exception/GlobalBusinessExceptionHandler.java
new file mode 100644
index 0000000..6d50b30
--- /dev/null
+++ b/relational_migration/relational_comm/src/main/java/com/njcn/relational/exception/GlobalBusinessExceptionHandler.java
@@ -0,0 +1,29 @@
+package com.njcn.relational.exception;
+
+
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+
+/**
+ * 全局通用业务异常处理器
+ *
+ * @author hongawen
+ * @version 1.0.0
+ * @date 2021年04月20日 18:04
+ */
+@Slf4j
+@AllArgsConstructor
+@RestControllerAdvice
+public class GlobalBusinessExceptionHandler {
+
+
+
+ @ExceptionHandler(Exception.class)
+ public void handleException(Exception e) {
+ log.error("系统异常--------------------", e);
+ e.printStackTrace();
+ }
+
+}
diff --git a/relational_migration/relational_comm/src/main/java/com/njcn/relational/mapper/DynamicSyncMapper.java b/relational_migration/relational_comm/src/main/java/com/njcn/relational/mapper/DynamicSyncMapper.java
new file mode 100644
index 0000000..97d16fd
--- /dev/null
+++ b/relational_migration/relational_comm/src/main/java/com/njcn/relational/mapper/DynamicSyncMapper.java
@@ -0,0 +1,59 @@
+package com.njcn.relational.mapper;
+
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.Update;
+
+import java.util.List;
+import java.util.Map;
+
+@Mapper
+public interface DynamicSyncMapper {
+
+ /**
+ * 获取表所有列名(指定Schema)
+ */
+ @Select("SELECT COLUMN_NAME FROM ALL_TAB_COLUMNS " +
+ "WHERE TABLE_NAME = #{tableName} " +
+ "AND OWNER = #{schema} " +
+ "ORDER BY COLUMN_ID")
+ List getTableColumns(@Param("tableName") String tableName,
+ @Param("schema") String schema);
+
+ /**
+ * 获取当前用户/Schema
+ */
+ @Select("SELECT USER FROM DUAL")
+ String getCurrentUser();
+
+ /**
+ * 分页查询
+ */
+ @Select("SELECT * FROM ${tableName} LIMIT #{limit} OFFSET #{offset}")
+ List