Spilt sharding-scaling to sharding-scaling-core module and sharding-scaling-bootstrap module

pom.xml

@@ -209,20 +209,6 @@
                     <groupId>org.apache.maven.plugins</groupId>
                     <artifactId>maven-assembly-plugin</artifactId>
                     <version>${maven-assembly-plugin.version}</version>
-                    <configuration>
-                        <descriptors>
-                            <descriptor>package.xml</descriptor>
-                        </descriptors>
-                    </configuration>
-                    <executions>
-                        <execution>
-                            <id>make-assembly</id>
-                            <phase>package</phase>
-                            <goals>
-                                <goal>single</goal>
-                            </goals>
-                        </execution>
-                    </executions>
                 </plugin>
             </plugins>
         </pluginManagement>

sharding-scaling-bootstrap/pom.xml

@@ -36,4 +36,26 @@
         </dependency>
     </dependencies>
 
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-assembly-plugin</artifactId>
+                <configuration>
+                    <descriptors>
+                        <descriptor>package.xml</descriptor>
+                    </descriptors>
+                </configuration>
+                <executions>
+                    <execution>
+                        <id>make-assembly</id>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>single</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
 </project>
\ No newline at end of file

src/main/java/info/avalon566/shardingscaling/Bootstrap.java → sharding-scaling-bootstrap/src/main/java/info/avalon566/shardingscaling/Bootstrap.java

@@ -17,14 +17,14 @@
 
 package info.avalon566.shardingscaling;
 
-import info.avalon566.shardingscaling.job.ScalingJob;
-import info.avalon566.shardingscaling.job.config.RuleConfiguration;
-import info.avalon566.shardingscaling.job.config.SyncConfiguration;
-import info.avalon566.shardingscaling.job.config.SyncType;
-import info.avalon566.shardingscaling.job.schedule.standalone.InProcessScheduler;
-import info.avalon566.shardingscaling.sync.core.DataSourceConfiguration;
-import info.avalon566.shardingscaling.sync.core.JdbcDataSourceConfiguration;
-import info.avalon566.shardingscaling.sync.core.RdbmsConfiguration;
+import info.avalon566.shardingscaling.core.job.ScalingJob;
+import info.avalon566.shardingscaling.config.RuleConfiguration;
+import info.avalon566.shardingscaling.core.config.SyncConfiguration;
+import info.avalon566.shardingscaling.core.config.SyncType;
+import info.avalon566.shardingscaling.core.job.schedule.standalone.InProcessScheduler;
+import info.avalon566.shardingscaling.core.config.DataSourceConfiguration;
+import info.avalon566.shardingscaling.core.config.JdbcDataSourceConfiguration;
+import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
 import info.avalon566.shardingscaling.utils.RuntimeUtil;
 import info.avalon566.shardingscaling.utils.YamlUtil;
 import lombok.extern.slf4j.Slf4j;

src/main/java/info/avalon566/shardingscaling/job/config/RuleConfiguration.java → sharding-scaling-bootstrap/src/main/java/info/avalon566/shardingscaling/config/RuleConfiguration.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.job.config;
+package info.avalon566.shardingscaling.config;
 
 import lombok.Data;
 

src/main/java/info/avalon566/shardingscaling/sync/core/DataSourceConfiguration.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/config/DataSourceConfiguration.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.core;
+package info.avalon566.shardingscaling.core.config;
 
 /**
  * Data source configuration.

src/main/java/info/avalon566/shardingscaling/sync/core/JdbcDataSourceConfiguration.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/config/JdbcDataSourceConfiguration.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.core;
+package info.avalon566.shardingscaling.core.config;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

src/main/java/info/avalon566/shardingscaling/sync/core/RdbmsConfiguration.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/config/RdbmsConfiguration.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.core;
+package info.avalon566.shardingscaling.core.config;
 
 import lombok.Data;
 import lombok.SneakyThrows;

src/main/java/info/avalon566/shardingscaling/job/config/SyncConfiguration.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/config/SyncConfiguration.java

@@ -15,9 +15,8 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.job.config;
+package info.avalon566.shardingscaling.core.config;
 
-import info.avalon566.shardingscaling.sync.core.RdbmsConfiguration;
 import lombok.AllArgsConstructor;
 import lombok.Data;
 

src/main/java/info/avalon566/shardingscaling/job/config/SyncType.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/config/SyncType.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.job.config;
+package info.avalon566.shardingscaling.core.config;
 
 /**
  * Sync type.
@@ -23,5 +23,6 @@ package info.avalon566.shardingscaling.job.config;
  */
 
 public enum SyncType {
+    
     Database, Table, TableSlice
 }

src/main/java/info/avalon566/shardingscaling/exception/SyncExecuteException.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/exception/SyncExecuteException.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.exception;
+package info.avalon566.shardingscaling.core.exception;
 
 /**
  * Synchronize task execute exception.

src/main/java/info/avalon566/shardingscaling/job/DatabaseSyncJob.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/DatabaseSyncJob.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.job;
+package info.avalon566.shardingscaling.core.job;
 
-import info.avalon566.shardingscaling.job.config.SyncConfiguration;
-import info.avalon566.shardingscaling.job.schedule.Reporter;
+import info.avalon566.shardingscaling.core.config.SyncConfiguration;
+import info.avalon566.shardingscaling.core.job.schedule.Reporter;
 import lombok.extern.slf4j.Slf4j;
 
 /**

src/main/java/info/avalon566/shardingscaling/job/HistoryDataSyncer.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/HistoryDataSyncer.java

@@ -15,18 +15,18 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.job;
+package info.avalon566.shardingscaling.core.job;
 
-import info.avalon566.shardingscaling.job.config.SyncConfiguration;
-import info.avalon566.shardingscaling.job.config.SyncType;
-import info.avalon566.shardingscaling.job.schedule.Event;
-import info.avalon566.shardingscaling.job.schedule.EventType;
-import info.avalon566.shardingscaling.job.schedule.Reporter;
-import info.avalon566.shardingscaling.job.schedule.standalone.InProcessScheduler;
-import info.avalon566.shardingscaling.sync.core.DataSourceFactory;
-import info.avalon566.shardingscaling.sync.core.RdbmsConfiguration;
-import info.avalon566.shardingscaling.sync.jdbc.DbMetaDataUtil;
-import info.avalon566.shardingscaling.sync.mysql.MySQLJdbcReader;
+import info.avalon566.shardingscaling.core.config.SyncConfiguration;
+import info.avalon566.shardingscaling.core.config.SyncType;
+import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
+import info.avalon566.shardingscaling.core.job.schedule.Event;
+import info.avalon566.shardingscaling.core.job.schedule.EventType;
+import info.avalon566.shardingscaling.core.job.schedule.Reporter;
+import info.avalon566.shardingscaling.core.job.schedule.standalone.InProcessScheduler;
+import info.avalon566.shardingscaling.core.sync.util.DataSourceFactory;
+import info.avalon566.shardingscaling.core.sync.util.DbMetaDataUtil;
+import info.avalon566.shardingscaling.core.sync.mysql.MySQLJdbcReader;
 import lombok.extern.slf4j.Slf4j;
 
 import javax.sql.DataSource;

src/main/java/info/avalon566/shardingscaling/job/RealtimeDataSyncer.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/RealtimeDataSyncer.java

@@ -15,17 +15,17 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.job;
+package info.avalon566.shardingscaling.core.job;
 
-import info.avalon566.shardingscaling.exception.SyncExecuteException;
-import info.avalon566.shardingscaling.job.config.SyncConfiguration;
-import info.avalon566.shardingscaling.job.schedule.Event;
-import info.avalon566.shardingscaling.job.schedule.EventType;
-import info.avalon566.shardingscaling.job.schedule.Reporter;
-import info.avalon566.shardingscaling.sync.core.SyncExecutor;
-import info.avalon566.shardingscaling.sync.core.Writer;
-import info.avalon566.shardingscaling.sync.mysql.MySQLBinlogReader;
-import info.avalon566.shardingscaling.sync.mysql.MySQLWriter;
+import info.avalon566.shardingscaling.core.exception.SyncExecuteException;
+import info.avalon566.shardingscaling.core.config.SyncConfiguration;
+import info.avalon566.shardingscaling.core.job.schedule.Event;
+import info.avalon566.shardingscaling.core.job.schedule.EventType;
+import info.avalon566.shardingscaling.core.job.schedule.Reporter;
+import info.avalon566.shardingscaling.core.sync.SyncExecutor;
+import info.avalon566.shardingscaling.core.sync.writer.Writer;
+import info.avalon566.shardingscaling.core.sync.mysql.MySQLBinlogReader;
+import info.avalon566.shardingscaling.core.sync.mysql.MySQLWriter;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.ArrayList;

src/main/java/info/avalon566/shardingscaling/job/ScalingJob.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/ScalingJob.java

@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.job;
+package info.avalon566.shardingscaling.core.job;
 
-import info.avalon566.shardingscaling.job.config.SyncConfiguration;
-import info.avalon566.shardingscaling.job.schedule.Reporter;
-import info.avalon566.shardingscaling.job.schedule.Scheduler;
+import info.avalon566.shardingscaling.core.config.SyncConfiguration;
+import info.avalon566.shardingscaling.core.job.schedule.Reporter;
+import info.avalon566.shardingscaling.core.job.schedule.Scheduler;
 
 import java.util.List;
 

src/main/java/info/avalon566/shardingscaling/job/TableSliceSyncJob.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/TableSliceSyncJob.java

@@ -15,17 +15,17 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.job;
+package info.avalon566.shardingscaling.core.job;
 
-import info.avalon566.shardingscaling.exception.SyncExecuteException;
-import info.avalon566.shardingscaling.job.config.SyncConfiguration;
-import info.avalon566.shardingscaling.job.schedule.Event;
-import info.avalon566.shardingscaling.job.schedule.EventType;
-import info.avalon566.shardingscaling.job.schedule.Reporter;
-import info.avalon566.shardingscaling.sync.core.SyncExecutor;
-import info.avalon566.shardingscaling.sync.core.Writer;
-import info.avalon566.shardingscaling.sync.mysql.MySQLJdbcReader;
-import info.avalon566.shardingscaling.sync.mysql.MySQLWriter;
+import info.avalon566.shardingscaling.core.exception.SyncExecuteException;
+import info.avalon566.shardingscaling.core.config.SyncConfiguration;
+import info.avalon566.shardingscaling.core.job.schedule.Event;
+import info.avalon566.shardingscaling.core.job.schedule.EventType;
+import info.avalon566.shardingscaling.core.job.schedule.Reporter;
+import info.avalon566.shardingscaling.core.sync.SyncExecutor;
+import info.avalon566.shardingscaling.core.sync.writer.Writer;
+import info.avalon566.shardingscaling.core.sync.mysql.MySQLJdbcReader;
+import info.avalon566.shardingscaling.core.sync.mysql.MySQLWriter;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.Collections;

src/main/java/info/avalon566/shardingscaling/job/schedule/Event.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/schedule/Event.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.job.schedule;
+package info.avalon566.shardingscaling.core.job.schedule;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

src/main/java/info/avalon566/shardingscaling/job/schedule/EventType.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/schedule/EventType.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.job.schedule;
+package info.avalon566.shardingscaling.core.job.schedule;
 
 /**
  * Event type.

src/main/java/info/avalon566/shardingscaling/job/schedule/Reporter.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/schedule/Reporter.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.job.schedule;
+package info.avalon566.shardingscaling.core.job.schedule;
 
 /**
  * Job Running reporter.

src/main/java/info/avalon566/shardingscaling/job/schedule/Scheduler.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/schedule/Scheduler.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.job.schedule;
+package info.avalon566.shardingscaling.core.job.schedule;
 
-import info.avalon566.shardingscaling.job.config.SyncConfiguration;
+import info.avalon566.shardingscaling.core.config.SyncConfiguration;
 
 import java.util.List;
 

src/main/java/info/avalon566/shardingscaling/job/schedule/standalone/InProcessReporter.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/schedule/standalone/InProcessReporter.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.job.schedule.standalone;
+package info.avalon566.shardingscaling.core.job.schedule.standalone;
 
-import info.avalon566.shardingscaling.job.schedule.Event;
-import info.avalon566.shardingscaling.job.schedule.Reporter;
+import info.avalon566.shardingscaling.core.job.schedule.Event;
+import info.avalon566.shardingscaling.core.job.schedule.Reporter;
 
 import java.util.concurrent.ConcurrentLinkedQueue;
 

src/main/java/info/avalon566/shardingscaling/job/schedule/standalone/InProcessScheduler.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/job/schedule/standalone/InProcessScheduler.java

@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.job.schedule.standalone;
+package info.avalon566.shardingscaling.core.job.schedule.standalone;
 
-import info.avalon566.shardingscaling.job.DatabaseSyncJob;
-import info.avalon566.shardingscaling.job.TableSliceSyncJob;
-import info.avalon566.shardingscaling.job.config.SyncConfiguration;
-import info.avalon566.shardingscaling.job.config.SyncType;
-import info.avalon566.shardingscaling.job.schedule.Reporter;
-import info.avalon566.shardingscaling.job.schedule.Scheduler;
+import info.avalon566.shardingscaling.core.job.TableSliceSyncJob;
+import info.avalon566.shardingscaling.core.job.DatabaseSyncJob;
+import info.avalon566.shardingscaling.core.config.SyncConfiguration;
+import info.avalon566.shardingscaling.core.config.SyncType;
+import info.avalon566.shardingscaling.core.job.schedule.Reporter;
+import info.avalon566.shardingscaling.core.job.schedule.Scheduler;
 
 import java.util.List;
 

src/main/java/info/avalon566/shardingscaling/sync/core/AbstractRunner.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/AbstractRunner.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.core;
+package info.avalon566.shardingscaling.core.sync;
 
 import lombok.AccessLevel;
 import lombok.Getter;

src/main/java/info/avalon566/shardingscaling/sync/core/Runner.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/Runner.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.core;
+package info.avalon566.shardingscaling.core.sync;
 
 /**
  * Job runner.

src/main/java/info/avalon566/shardingscaling/sync/core/SyncExecutor.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/SyncExecutor.java

@@ -15,9 +15,14 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.core;
+package info.avalon566.shardingscaling.core.sync;
 
-import info.avalon566.shardingscaling.exception.SyncExecuteException;
+import info.avalon566.shardingscaling.core.exception.SyncExecuteException;
+import info.avalon566.shardingscaling.core.sync.channel.Channel;
+import info.avalon566.shardingscaling.core.sync.channel.DispatcherChannel;
+import info.avalon566.shardingscaling.core.sync.channel.MemoryChannel;
+import info.avalon566.shardingscaling.core.sync.reader.Reader;
+import info.avalon566.shardingscaling.core.sync.writer.Writer;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 

src/main/java/info/avalon566/shardingscaling/sync/core/Channel.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/channel/Channel.java

@@ -15,7 +15,9 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.core;
+package info.avalon566.shardingscaling.core.sync.channel;
+
+import info.avalon566.shardingscaling.core.sync.record.Record;
 
 /**
  * Channel.

src/main/java/info/avalon566/shardingscaling/sync/core/DispatcherChannel.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/channel/DispatcherChannel.java

@@ -15,9 +15,11 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.core;
+package info.avalon566.shardingscaling.core.sync.channel;
 
-import info.avalon566.shardingscaling.sync.jdbc.DataRecord;
+import info.avalon566.shardingscaling.core.sync.record.FinishedRecord;
+import info.avalon566.shardingscaling.core.sync.record.Record;
+import info.avalon566.shardingscaling.core.sync.record.DataRecord;
 
 import java.util.HashMap;
 import java.util.Map;

src/main/java/info/avalon566/shardingscaling/sync/core/MemoryChannel.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/channel/MemoryChannel.java

@@ -15,12 +15,14 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.core;
+package info.avalon566.shardingscaling.core.sync.channel;
 
 import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.TimeUnit;
 
+import info.avalon566.shardingscaling.core.sync.record.Record;
+
 /**
  * Memory channel.
  * @author avalon566

src/main/java/info/avalon566/shardingscaling/sync/jdbc/ColumnMetaData.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/metadata/ColumnMetaData.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.jdbc;
+package info.avalon566.shardingscaling.core.sync.metadata;
 
 import lombok.Data;
 

src/main/java/info/avalon566/shardingscaling/sync/jdbc/JdbcUri.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/metadata/JdbcUri.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.jdbc;
+package info.avalon566.shardingscaling.core.sync.metadata;
 
 import com.google.common.base.Strings;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/BinlogPosition.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/BinlogPosition.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql;
+package info.avalon566.shardingscaling.core.sync.mysql;
 
 import lombok.Data;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/MySQLBinlogReader.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/MySQLBinlogReader.java

@@ -15,22 +15,22 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql;
-
-import info.avalon566.shardingscaling.sync.core.AbstractRunner;
-import info.avalon566.shardingscaling.sync.core.Channel;
-import info.avalon566.shardingscaling.sync.core.DataSourceFactory;
-import info.avalon566.shardingscaling.sync.core.JdbcDataSourceConfiguration;
-import info.avalon566.shardingscaling.sync.core.RdbmsConfiguration;
-import info.avalon566.shardingscaling.sync.core.Reader;
-import info.avalon566.shardingscaling.sync.jdbc.Column;
-import info.avalon566.shardingscaling.sync.jdbc.DataRecord;
-import info.avalon566.shardingscaling.sync.jdbc.JdbcUri;
-import info.avalon566.shardingscaling.sync.mysql.binlog.MySQLConnector;
-import info.avalon566.shardingscaling.sync.mysql.binlog.event.AbstractBinlogEvent;
-import info.avalon566.shardingscaling.sync.mysql.binlog.event.DeleteRowsEvent;
-import info.avalon566.shardingscaling.sync.mysql.binlog.event.UpdateRowsEvent;
-import info.avalon566.shardingscaling.sync.mysql.binlog.event.WriteRowsEvent;
+package info.avalon566.shardingscaling.core.sync.mysql;
+
+import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
+import info.avalon566.shardingscaling.core.sync.AbstractRunner;
+import info.avalon566.shardingscaling.core.sync.channel.Channel;
+import info.avalon566.shardingscaling.core.sync.reader.Reader;
+import info.avalon566.shardingscaling.core.sync.record.Column;
+import info.avalon566.shardingscaling.core.sync.record.DataRecord;
+import info.avalon566.shardingscaling.core.sync.metadata.JdbcUri;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.event.AbstractBinlogEvent;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.event.DeleteRowsEvent;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.event.UpdateRowsEvent;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.event.WriteRowsEvent;
+import info.avalon566.shardingscaling.core.sync.util.DataSourceFactory;
+import info.avalon566.shardingscaling.core.config.JdbcDataSourceConfiguration;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.MySQLConnector;
 import lombok.Setter;
 import lombok.extern.slf4j.Slf4j;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/MySQLJdbcReader.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/MySQLJdbcReader.java

@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql;
+package info.avalon566.shardingscaling.core.sync.mysql;
 
-import info.avalon566.shardingscaling.sync.core.JdbcDataSourceConfiguration;
-import info.avalon566.shardingscaling.sync.core.RdbmsConfiguration;
-import info.avalon566.shardingscaling.sync.jdbc.AbstractJdbcReader;
-import info.avalon566.shardingscaling.sync.jdbc.JdbcUri;
+import info.avalon566.shardingscaling.core.config.JdbcDataSourceConfiguration;
+import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
+import info.avalon566.shardingscaling.core.sync.reader.AbstractJdbcReader;
+import info.avalon566.shardingscaling.core.sync.metadata.JdbcUri;
 
 import java.util.List;
 import java.util.Map;

src/main/java/info/avalon566/shardingscaling/sync/mysql/MySQLWriter.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/MySQLWriter.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql;
+package info.avalon566.shardingscaling.core.sync.mysql;
 
-import info.avalon566.shardingscaling.sync.core.RdbmsConfiguration;
-import info.avalon566.shardingscaling.sync.jdbc.AbstractJdbcWriter;
+import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
+import info.avalon566.shardingscaling.core.sync.writer.AbstractJdbcWriter;
 
 /**
  * MySQL writer.

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/BinlogContext.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/BinlogContext.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.binlog.ColumnDef;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.binlog.TableMapEvent;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.binlog.ColumnDef;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.binlog.TableMapEvent;
 import lombok.Data;
 import java.util.HashMap;
 import java.util.Map;

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/MySQLConnector.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/MySQLConnector.java

@@ -15,18 +15,18 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.MySQLBinlogEventPacketDecoder;
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.MySQLCommandPacketDecoder;
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.MySQLLengthFieldBasedFrameEncoder;
-import info.avalon566.shardingscaling.sync.mysql.binlog.event.AbstractBinlogEvent;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.command.BinlogDumpCommandPacket;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.command.QueryCommandPacket;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.command.RegisterSlaveCommandPacket;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.response.ErrorPacket;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.response.OkPacket;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.response.InternalResultSet;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.MySQLBinlogEventPacketDecoder;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.MySQLCommandPacketDecoder;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.MySQLLengthFieldBasedFrameEncoder;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.event.AbstractBinlogEvent;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.command.BinlogDumpCommandPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.command.QueryCommandPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.command.RegisterSlaveCommandPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response.ErrorPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response.InternalResultSet;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response.OkPacket;
 import io.netty.bootstrap.Bootstrap;
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelHandlerContext;

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/MySQLNegotiateHandler.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/MySQLNegotiateHandler.java

@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.auth.ClientAuthenticationPacket;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.auth.HandshakeInitializationPacket;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.response.ErrorPacket;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.response.OkPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.auth.ClientAuthenticationPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.auth.HandshakeInitializationPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response.ErrorPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response.OkPacket;
 import lombok.RequiredArgsConstructor;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/MySQLPasswordEncryptor.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/MySQLPasswordEncryptor.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog;
 
 import java.security.MessageDigest;
 import java.security.NoSuchAlgorithmException;

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/ServerInfo.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/ServerInfo.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog;
 
 import lombok.Data;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/ServerVersion.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/ServerVersion.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog;
 
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
@@ -28,7 +28,7 @@ import lombok.Getter;
  * @author yangyi
  */
 @Getter
-public class ServerVersion {
+public final class ServerVersion {
     
     private static final Pattern VERSION_PATTERN = Pattern.compile("^(\\d+)\\.(\\d+)\\.(\\d+).*");
     

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/codec/AuthenticationMethod.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/codec/AuthenticationMethod.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.codec;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.codec;
 
 /**
  * MySQL client/server protocol Authentication Method.

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/codec/BlobValueDecoder.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/codec/BlobValueDecoder.java

@@ -15,17 +15,26 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.codec;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.codec;
 
 import io.netty.buffer.ByteBuf;
 
 import java.io.Serializable;
 
 /**
+ * Blob value decoder.
+ *
  * @author avalon566
  */
-public class BlobValueDecoder {
-
+public final class BlobValueDecoder {
+    
+    /**
+     * decode blob value.
+     *
+     * @param meta meta data
+     * @param in input byte buffur
+     * @return blob value
+     */
     public static Serializable decodeBlob(final int meta, final ByteBuf in) {
         switch (meta) {
             case 1:

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/codec/CapabilityFlags.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/codec/CapabilityFlags.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.codec;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.codec;
 
 /**
  * MySQL capability flags.

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/codec/DataTypesCodec.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/codec/DataTypesCodec.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.codec;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.codec;
 
 import io.netty.buffer.ByteBuf;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/codec/DateAndTimeValueDecoder.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/codec/DateAndTimeValueDecoder.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.codec;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.codec;
 
 import io.netty.buffer.ByteBuf;
 import lombok.AllArgsConstructor;

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/codec/DecimalValueDecoder.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/codec/DecimalValueDecoder.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.codec;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.codec;
 
 import io.netty.buffer.ByteBuf;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/codec/JsonValueDecoder.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/codec/JsonValueDecoder.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.codec;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.codec;
 
 import io.netty.buffer.ByteBuf;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/codec/MySQLBinlogEventPacketDecoder.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/codec/MySQLBinlogEventPacketDecoder.java

@@ -15,21 +15,21 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.codec;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.codec;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.BinlogContext;
-import info.avalon566.shardingscaling.sync.mysql.binlog.event.DeleteRowsEvent;
-import info.avalon566.shardingscaling.sync.mysql.binlog.event.UpdateRowsEvent;
-import info.avalon566.shardingscaling.sync.mysql.binlog.event.WriteRowsEvent;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.BinlogContext;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.event.DeleteRowsEvent;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.event.UpdateRowsEvent;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.event.WriteRowsEvent;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.binlog.EventTypes;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.binlog.FormatDescriptionEvent;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.binlog.RotateEvent;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.binlog.RowsEvent;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.binlog.TableMapEvent;
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.codec.ByteToMessageDecoder;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.binlog.BinlogEventHeader;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.binlog.EventTypes;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.binlog.FormatDescriptionEvent;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.binlog.RotateEvent;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.binlog.RowsEvent;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.binlog.TableMapEvent;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.binlog.BinlogEventHeader;
 import lombok.extern.slf4j.Slf4j;
 import java.util.List;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/codec/MySQLCommandPacketDecoder.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/codec/MySQLCommandPacketDecoder.java

@@ -15,19 +15,19 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.codec;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.codec;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.auth.HandshakeInitializationPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.auth.HandshakeInitializationPacket;
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.codec.ByteToMessageDecoder;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.response.EofPacket;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.response.ErrorPacket;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.response.FieldPacket;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.response.InternalResultSet;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.response.OkPacket;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.response.ResultSetHeaderPacket;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.response.RowDataPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response.EofPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response.ErrorPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response.FieldPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response.InternalResultSet;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response.OkPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response.ResultSetHeaderPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response.RowDataPacket;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.List;

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/codec/MySQLLengthFieldBasedFrameEncoder.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/codec/MySQLLengthFieldBasedFrameEncoder.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.codec;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.codec;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.AbstractPacket;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.HeaderPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.AbstractPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.HeaderPacket;
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.codec.MessageToByteEncoder;

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/codec/PacketConstants.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/codec/PacketConstants.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.codec;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.codec;
 
 /**
  * MySQL protocol constants.

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/event/AbstractBinlogEvent.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/event/AbstractBinlogEvent.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.event;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.event;
 
 import lombok.Data;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/event/DeleteRowsEvent.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/event/DeleteRowsEvent.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.event;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.event;
 
 import lombok.Data;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/event/UpdateRowsEvent.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/event/UpdateRowsEvent.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.event;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.event;
 
 import lombok.Data;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/event/WriteRowsEvent.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/event/WriteRowsEvent.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.event;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.event;
 
 import lombok.Data;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/AbstractPacket.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/AbstractPacket.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet;
 
 import io.netty.buffer.ByteBuf;
 import lombok.Data;

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/HeaderPacket.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/HeaderPacket.java

@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet;
 
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufAllocator;
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DataTypesCodec;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DataTypesCodec;
 import lombok.Data;
 
 /**

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/Packet.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/Packet.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet;
 
 import io.netty.buffer.ByteBuf;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/auth/ClientAuthenticationPacket.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/auth/ClientAuthenticationPacket.java

@@ -15,13 +15,14 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.auth;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.auth;
 
 import com.google.common.base.Strings;
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.CapabilityFlags;
-import info.avalon566.shardingscaling.sync.mysql.binlog.MySQLPasswordEncryptor;
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DataTypesCodec;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.AbstractPacket;
+
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DataTypesCodec;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.AbstractPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.CapabilityFlags;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.MySQLPasswordEncryptor;
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufAllocator;
 import lombok.AccessLevel;

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/auth/HandshakeInitializationPacket.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/auth/HandshakeInitializationPacket.java

@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.auth;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.auth;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.CapabilityFlags;
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DataTypesCodec;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.AbstractPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DataTypesCodec;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.AbstractPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.CapabilityFlags;
 import io.netty.buffer.ByteBuf;
 import lombok.Data;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/binlog/BinlogEventHeader.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/binlog/BinlogEventHeader.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.binlog;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.binlog;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DataTypesCodec;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DataTypesCodec;
 import io.netty.buffer.ByteBuf;
 import lombok.Data;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/binlog/ColumnDef.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/binlog/ColumnDef.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.binlog;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.binlog;
 
 import lombok.Data;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/binlog/ColumnTypes.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/binlog/ColumnTypes.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.binlog;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.binlog;
 
 /**
  * Mysql column types.

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/binlog/EventTypes.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/binlog/EventTypes.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.binlog;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.binlog;
 
 /**
  * Mysql event types.

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/binlog/FormatDescriptionEvent.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/binlog/FormatDescriptionEvent.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.binlog;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.binlog;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DataTypesCodec;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DataTypesCodec;
 import io.netty.buffer.ByteBuf;
 import lombok.Getter;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/binlog/RotateEvent.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/binlog/RotateEvent.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.binlog;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.binlog;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DataTypesCodec;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DataTypesCodec;
 import io.netty.buffer.ByteBuf;
 import lombok.Getter;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/binlog/RowsEvent.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/binlog/RowsEvent.java

@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.binlog;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.binlog;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.BinlogContext;
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.BlobValueDecoder;
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DataTypesCodec;
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DateAndTimeValueDecoder;
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DecimalValueDecoder;
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.JsonValueDecoder;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DateAndTimeValueDecoder;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.BinlogContext;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.BlobValueDecoder;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DataTypesCodec;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DecimalValueDecoder;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.JsonValueDecoder;
 import io.netty.buffer.ByteBuf;
 import lombok.Data;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/binlog/TableMapEvent.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/binlog/TableMapEvent.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.binlog;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.binlog;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DataTypesCodec;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DataTypesCodec;
 import io.netty.buffer.ByteBuf;
 import lombok.Getter;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/command/AbstractCommandPacket.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/command/AbstractCommandPacket.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.command;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.command;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.AbstractPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.AbstractPacket;
 import lombok.Data;
 
 /**

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/command/BinlogDumpCommandPacket.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/command/BinlogDumpCommandPacket.java

@@ -15,10 +15,11 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.command;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.command;
 
 import com.google.common.base.Strings;
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DataTypesCodec;
+
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DataTypesCodec;
 import lombok.Setter;
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufAllocator;

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/command/QueryCommandPacket.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/command/QueryCommandPacket.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.command;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.command;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DataTypesCodec;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DataTypesCodec;
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufAllocator;
 import lombok.Setter;

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/command/RegisterSlaveCommandPacket.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/command/RegisterSlaveCommandPacket.java

@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.command;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.command;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DataTypesCodec;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DataTypesCodec;
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufAllocator;
 import lombok.Setter;

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/response/EofPacket.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/response/EofPacket.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.response;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DataTypesCodec;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.AbstractPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DataTypesCodec;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.AbstractPacket;
 import lombok.Getter;
 import io.netty.buffer.ByteBuf;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/response/ErrorPacket.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/response/ErrorPacket.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.response;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DataTypesCodec;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.AbstractPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DataTypesCodec;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.AbstractPacket;
 import io.netty.buffer.ByteBuf;
 import lombok.Getter;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/response/FieldPacket.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/response/FieldPacket.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.response;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DataTypesCodec;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.AbstractPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DataTypesCodec;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.AbstractPacket;
 import io.netty.buffer.ByteBuf;
 import lombok.Getter;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/response/InternalResultSet.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/response/InternalResultSet.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.response;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/response/OkPacket.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/response/OkPacket.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.response;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DataTypesCodec;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.AbstractPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DataTypesCodec;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.AbstractPacket;
 import io.netty.buffer.ByteBuf;
 import lombok.Getter;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/response/ResultSetHeaderPacket.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/response/ResultSetHeaderPacket.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.response;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DataTypesCodec;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.AbstractPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DataTypesCodec;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.AbstractPacket;
 import io.netty.buffer.ByteBuf;
 import lombok.Getter;
 

src/main/java/info/avalon566/shardingscaling/sync/mysql/binlog/packet/response/RowDataPacket.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/packet/response/RowDataPacket.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog.packet.response;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response;
 
-import info.avalon566.shardingscaling.sync.mysql.binlog.codec.DataTypesCodec;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.AbstractPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.codec.DataTypesCodec;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.AbstractPacket;
 import io.netty.buffer.ByteBuf;
 import lombok.Getter;
 

src/main/java/info/avalon566/shardingscaling/sync/postgresql/PostgreSQLJdbcReader.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/postgresql/PostgreSQLJdbcReader.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.postgresql;
+package info.avalon566.shardingscaling.core.sync.postgresql;
 
-import info.avalon566.shardingscaling.sync.core.RdbmsConfiguration;
-import info.avalon566.shardingscaling.sync.jdbc.AbstractJdbcReader;
+import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
+import info.avalon566.shardingscaling.core.sync.reader.AbstractJdbcReader;
 
 /**
  * PostgreSQL JDBC reader.

src/main/java/info/avalon566/shardingscaling/sync/postgresql/PostgreSQLWalReader.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/postgresql/PostgreSQLWalReader.java

@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.postgresql;
+package info.avalon566.shardingscaling.core.sync.postgresql;
 
-import info.avalon566.shardingscaling.sync.core.AbstractRunner;
-import info.avalon566.shardingscaling.sync.core.Channel;
-import info.avalon566.shardingscaling.sync.core.RdbmsConfiguration;
-import info.avalon566.shardingscaling.sync.core.Reader;
+import info.avalon566.shardingscaling.core.sync.AbstractRunner;
+import info.avalon566.shardingscaling.core.sync.channel.Channel;
+import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
+import info.avalon566.shardingscaling.core.sync.reader.Reader;
 import lombok.Setter;
 
 import java.util.List;

src/main/java/info/avalon566/shardingscaling/sync/postgresql/PostgreSQLWriter.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/postgresql/PostgreSQLWriter.java

@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.postgresql;
+package info.avalon566.shardingscaling.core.sync.postgresql;
 
-import info.avalon566.shardingscaling.sync.core.RdbmsConfiguration;
-import info.avalon566.shardingscaling.sync.jdbc.AbstractJdbcWriter;
+import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
+import info.avalon566.shardingscaling.core.sync.writer.AbstractJdbcWriter;
 
 /**
  * postgreSQL writer.

src/main/java/info/avalon566/shardingscaling/sync/jdbc/AbstractJdbcReader.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/reader/AbstractJdbcReader.java

@@ -15,16 +15,19 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.jdbc;
+package info.avalon566.shardingscaling.core.sync.reader;
 
-import info.avalon566.shardingscaling.exception.SyncExecuteException;
-import info.avalon566.shardingscaling.sync.core.AbstractRunner;
-import info.avalon566.shardingscaling.sync.core.Channel;
-import info.avalon566.shardingscaling.sync.core.DataSourceFactory;
-import info.avalon566.shardingscaling.sync.core.FinishedRecord;
-import info.avalon566.shardingscaling.sync.core.JdbcDataSourceConfiguration;
-import info.avalon566.shardingscaling.sync.core.RdbmsConfiguration;
-import info.avalon566.shardingscaling.sync.core.Reader;
+import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
+import info.avalon566.shardingscaling.core.sync.AbstractRunner;
+import info.avalon566.shardingscaling.core.sync.channel.Channel;
+import info.avalon566.shardingscaling.core.sync.record.FinishedRecord;
+import info.avalon566.shardingscaling.core.sync.record.Column;
+import info.avalon566.shardingscaling.core.sync.metadata.ColumnMetaData;
+import info.avalon566.shardingscaling.core.sync.record.DataRecord;
+import info.avalon566.shardingscaling.core.sync.util.DbMetaDataUtil;
+import info.avalon566.shardingscaling.core.exception.SyncExecuteException;
+import info.avalon566.shardingscaling.core.sync.util.DataSourceFactory;
+import info.avalon566.shardingscaling.core.config.JdbcDataSourceConfiguration;
 import lombok.AccessLevel;
 import lombok.Getter;
 import lombok.Setter;

src/main/java/info/avalon566/shardingscaling/sync/core/Reader.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/reader/Reader.java

@@ -15,10 +15,14 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.core;
+package info.avalon566.shardingscaling.core.sync.reader;
 
 import java.util.List;
 
+import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
+import info.avalon566.shardingscaling.core.sync.channel.Channel;
+import info.avalon566.shardingscaling.core.sync.Runner;
+
 /**
  * Reader interface.
  * @author avalon566

src/main/java/info/avalon566/shardingscaling/sync/jdbc/Column.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/record/Column.java

@@ -15,18 +15,20 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.jdbc;
+package info.avalon566.shardingscaling.core.sync.record;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;
 
 /**
  * Column.
+ *
  * @author avalon566
  */
 @Data
 @AllArgsConstructor
 public class Column {
+    
     private Object value;
 
     private boolean updated;

src/main/java/info/avalon566/shardingscaling/sync/jdbc/DataRecord.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/record/DataRecord.java

@@ -15,9 +15,8 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.jdbc;
+package info.avalon566.shardingscaling.core.sync.record;
 
-import info.avalon566.shardingscaling.sync.core.Record;
 import lombok.Data;
 
 import java.util.ArrayList;

src/main/java/info/avalon566/shardingscaling/sync/core/FinishedRecord.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/record/FinishedRecord.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.core;
+package info.avalon566.shardingscaling.core.sync.record;
 
 /**
  * Finished record.

src/main/java/info/avalon566/shardingscaling/sync/core/Record.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/record/Record.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.core;
+package info.avalon566.shardingscaling.core.sync.record;
 
 /**
  * Record interface.

src/main/java/info/avalon566/shardingscaling/sync/core/DataSourceFactory.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/util/DataSourceFactory.java

@@ -15,9 +15,11 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.core;
+package info.avalon566.shardingscaling.core.sync.util;
 
 import org.apache.commons.dbcp2.BasicDataSource;
+import info.avalon566.shardingscaling.core.config.DataSourceConfiguration;
+import info.avalon566.shardingscaling.core.config.JdbcDataSourceConfiguration;
 
 import javax.sql.DataSource;
 

src/main/java/info/avalon566/shardingscaling/sync/jdbc/DbMetaDataUtil.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/util/DbMetaDataUtil.java

@@ -15,11 +15,13 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.jdbc;
+package info.avalon566.shardingscaling.core.sync.util;
 
 import com.google.common.cache.CacheBuilder;
 import com.google.common.cache.CacheLoader;
 import com.google.common.cache.LoadingCache;
+
+import info.avalon566.shardingscaling.core.sync.metadata.ColumnMetaData;
 import lombok.extern.slf4j.Slf4j;
 
 import javax.sql.DataSource;

src/main/java/info/avalon566/shardingscaling/sync/jdbc/AbstractJdbcWriter.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/writer/AbstractJdbcWriter.java

@@ -15,16 +15,19 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.jdbc;
+package info.avalon566.shardingscaling.core.sync.writer;
 
-import info.avalon566.shardingscaling.exception.SyncExecuteException;
-import info.avalon566.shardingscaling.sync.core.AbstractRunner;
-import info.avalon566.shardingscaling.sync.core.Channel;
-import info.avalon566.shardingscaling.sync.core.DataSourceFactory;
-import info.avalon566.shardingscaling.sync.core.FinishedRecord;
-import info.avalon566.shardingscaling.sync.core.RdbmsConfiguration;
-import info.avalon566.shardingscaling.sync.core.Record;
-import info.avalon566.shardingscaling.sync.core.Writer;
+import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
+import info.avalon566.shardingscaling.core.sync.AbstractRunner;
+import info.avalon566.shardingscaling.core.sync.channel.Channel;
+import info.avalon566.shardingscaling.core.sync.record.FinishedRecord;
+import info.avalon566.shardingscaling.core.sync.record.Column;
+import info.avalon566.shardingscaling.core.sync.metadata.ColumnMetaData;
+import info.avalon566.shardingscaling.core.sync.record.DataRecord;
+import info.avalon566.shardingscaling.core.sync.util.DbMetaDataUtil;
+import info.avalon566.shardingscaling.core.exception.SyncExecuteException;
+import info.avalon566.shardingscaling.core.sync.util.DataSourceFactory;
+import info.avalon566.shardingscaling.core.sync.record.Record;
 import lombok.Setter;
 import lombok.extern.slf4j.Slf4j;
 
@@ -46,11 +49,11 @@ import java.util.List;
 public abstract class AbstractJdbcWriter extends AbstractRunner implements Writer {
 
     private final RdbmsConfiguration rdbmsConfiguration;
+    
+    private final SqlBuilder sqlBuilder;
 
     private DbMetaDataUtil dbMetaDataUtil;
 
-    private final SqlBuilder sqlBuilder;
-
     @Setter
     private Channel channel;
 

src/main/java/info/avalon566/shardingscaling/sync/jdbc/SqlBuilder.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/writer/SqlBuilder.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.jdbc;
+package info.avalon566.shardingscaling.core.sync.writer;
 
 import com.google.common.cache.CacheBuilder;
 import com.google.common.cache.CacheLoader;
@@ -25,6 +25,9 @@ import javax.sql.DataSource;
 import java.util.List;
 import java.util.concurrent.ExecutionException;
 
+import info.avalon566.shardingscaling.core.sync.metadata.ColumnMetaData;
+import info.avalon566.shardingscaling.core.sync.util.DbMetaDataUtil;
+
 /**
  * Sql builder.
  *

src/main/java/info/avalon566/shardingscaling/sync/core/Writer.java → sharding-scaling-core/src/main/java/info/avalon566/shardingscaling/core/sync/writer/Writer.java

@@ -15,7 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.core;
+package info.avalon566.shardingscaling.core.sync.writer;
+
+import info.avalon566.shardingscaling.core.sync.channel.Channel;
+import info.avalon566.shardingscaling.core.sync.Runner;
 
 /**
  * Writer.

src/test/java/info/avalon566/shardingscaling/sync/core/RdbmsConfigurationTest.java → sharding-scaling-core/src/test/java/info/avalon566/shardingscaling/core/config/RdbmsConfigurationTest.java

@@ -15,9 +15,10 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.core;
+package info.avalon566.shardingscaling.core.config;
 
 import org.junit.Test;
+import info.avalon566.shardingscaling.core.config.RdbmsConfiguration;
 
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertTrue;

src/test/java/info/avalon566/shardingscaling/sync/mysql/binlog/MySQLConnectorTest.java → sharding-scaling-core/src/test/java/info/avalon566/shardingscaling/core/sync/mysql/binlog/MySQLConnectorTest.java

@@ -15,17 +15,17 @@
  * limitations under the License.
  */
 
-package info.avalon566.shardingscaling.sync.mysql.binlog;
+package info.avalon566.shardingscaling.core.sync.mysql.binlog;
 
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelPipeline;
 import io.netty.util.concurrent.Promise;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.command.BinlogDumpCommandPacket;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.command.QueryCommandPacket;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.command.RegisterSlaveCommandPacket;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.response.InternalResultSet;
-import info.avalon566.shardingscaling.sync.mysql.binlog.packet.response.OkPacket;
-import info.avalon566.shardingscaling.utils.ReflectionUtil;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.command.BinlogDumpCommandPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.command.QueryCommandPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.command.RegisterSlaveCommandPacket;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response.InternalResultSet;
+import info.avalon566.shardingscaling.core.sync.mysql.binlog.packet.response.OkPacket;
+import info.avalon566.shardingscaling.core.utils.ReflectionUtil;
 import lombok.SneakyThrows;
 
 import org.junit.Before;