dromara/dbswitch
1
0
Fork 0
mirror of https://gitee.com/dromara/dbswitch.git synced 2025-10-16 14:43:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

version for 2.0.0

Browse Source
This commit is contained in:
inrgihc
2024-12-05 22:33:43 +08:00
parent 34274ec1ab
commit 88955ac6e5
815 changed files with 1829 additions and 1890 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
dbswitch-data/pom.xml
View File

@@ -3,9 +3,9 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.gitee.dbswitch</groupId>
<groupId>org.dromara.dbswitch</groupId>
<artifactId>dbswitch-parent</artifactId>
<version>1.9.10</version>
<version>2.0.0</version>
</parent>
<artifactId>dbswitch-data</artifactId>
@@ -13,19 +13,19 @@
<dependencies>
<dependency>
<groupId>com.gitee.dbswitch</groupId>
<groupId>org.dromara.dbswitch</groupId>
<artifactId>dbswitch-common</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>com.gitee.dbswitch</groupId>
<groupId>org.dromara.dbswitch</groupId>
<artifactId>dbswitch-core</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>com.gitee.dbswitch</groupId>
<groupId>org.dromara.dbswitch</groupId>
<artifactId>dbswitch-register-product</artifactId>
<version>${project.version}</version>
</dependency>

4
dbswitch-data/src/main/java/com/gitee/dbswitch/data/DataSyncApplication.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/DataSyncApplication.java
View File

@@ -7,9 +7,9 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data;
package org.dromara.dbswitch.data;
import com.gitee.dbswitch.data.service.MigrationService;
import org.dromara.dbswitch.data.service.MigrationService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.Banner;
import org.springframework.boot.SpringApplication;

8
dbswitch-data/src/main/java/com/gitee/dbswitch/data/config/DbswichPropertiesConfiguration.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/config/DbswichPropertiesConfiguration.java
View File

@@ -7,11 +7,11 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.config;
package org.dromara.dbswitch.data.config;
import com.gitee.dbswitch.data.entity.GlobalParamConfigProperties;
import com.gitee.dbswitch.data.entity.SourceDataSourceProperties;
import com.gitee.dbswitch.data.entity.TargetDataSourceProperties;
import org.dromara.dbswitch.data.entity.GlobalParamConfigProperties;
import org.dromara.dbswitch.data.entity.SourceDataSourceProperties;
import org.dromara.dbswitch.data.entity.TargetDataSourceProperties;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;

2
dbswitch-data/src/main/java/com/gitee/dbswitch/data/config/DbswitchPropertySourceFactory.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/config/DbswitchPropertySourceFactory.java
View File

@@ -7,7 +7,7 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.config;
package org.dromara.dbswitch.data.config;
import java.io.IOException;
import java.util.Properties;

4
dbswitch-data/src/main/java/com/gitee/dbswitch/data/config/DbswitchTaskExecutorConfig.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/config/DbswitchTaskExecutorConfig.java
View File

@@ -7,9 +7,9 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.config;
package org.dromara.dbswitch.data.config;
import com.gitee.dbswitch.data.util.DataSourceUtils;
import org.dromara.dbswitch.data.util.DataSourceUtils;
import java.util.concurrent.ThreadPoolExecutor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

4
dbswitch-data/src/main/java/com/gitee/dbswitch/data/domain/ComparePerfStat.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/domain/ComparePerfStat.java
View File

@@ -7,9 +7,9 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.domain;
package org.dromara.dbswitch.data.domain;
import com.gitee.dbswitch.common.entity.PrintablePerfStat;
import org.dromara.dbswitch.common.entity.PrintablePerfStat;
import java.util.Map;
import lombok.AllArgsConstructor;
import lombok.Data;

4
dbswitch-data/src/main/java/com/gitee/dbswitch/data/domain/ExceptPerfStat.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/domain/ExceptPerfStat.java
View File

@@ -1,7 +1,7 @@
package com.gitee.dbswitch.data.domain;
package org.dromara.dbswitch.data.domain;
import cn.hutool.core.exceptions.ExceptionUtil;
import com.gitee.dbswitch.common.entity.PrintablePerfStat;
import org.dromara.dbswitch.common.entity.PrintablePerfStat;
import com.google.common.collect.Sets;
import java.util.Map;
import java.util.Set;

4
dbswitch-data/src/main/java/com/gitee/dbswitch/data/domain/ReaderPerfStat.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/domain/ReaderPerfStat.java
View File

@@ -7,10 +7,10 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.domain;
package org.dromara.dbswitch.data.domain;
import cn.hutool.core.io.unit.DataSizeUtil;
import com.gitee.dbswitch.common.entity.PrintablePerfStat;
import org.dromara.dbswitch.common.entity.PrintablePerfStat;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

12
dbswitch-data/src/main/java/com/gitee/dbswitch/data/domain/ReaderTaskParam.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/domain/ReaderTaskParam.java
View File

@@ -7,13 +7,13 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.domain;
package org.dromara.dbswitch.data.domain;
import com.gitee.dbswitch.common.entity.CloseableDataSource;
import com.gitee.dbswitch.core.exchange.MemChannel;
import com.gitee.dbswitch.core.task.TaskParam;
import com.gitee.dbswitch.data.config.DbswichPropertiesConfiguration;
import com.gitee.dbswitch.schema.TableDescription;
import org.dromara.dbswitch.common.entity.CloseableDataSource;
import org.dromara.dbswitch.core.core.exchange.MemChannel;
import org.dromara.dbswitch.core.core.task.TaskParam;
import org.dromara.dbswitch.data.config.DbswichPropertiesConfiguration;
import org.dromara.dbswitch.core.schema.TableDescription;
import java.util.Set;
import java.util.concurrent.CountDownLatch;
import lombok.AllArgsConstructor;

4
dbswitch-data/src/main/java/com/gitee/dbswitch/data/domain/ReaderTaskResult.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/domain/ReaderTaskResult.java
View File

@@ -7,9 +7,9 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.domain;
package org.dromara.dbswitch.data.domain;
import com.gitee.dbswitch.core.task.TaskResult;
import org.dromara.dbswitch.core.core.task.TaskResult;
import java.util.HashMap;
import java.util.Map;
import lombok.AllArgsConstructor;

7
dbswitch-data/src/main/java/com/gitee/dbswitch/data/domain/WrapCommonDataSource.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/domain/WrapCommonDataSource.java
View File

@@ -7,11 +7,10 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.domain;
package org.dromara.dbswitch.data.domain;
import com.gitee.dbswitch.common.entity.CloseableDataSource;
import com.gitee.dbswitch.common.entity.InvisibleDataSource;
import java.io.IOException;
import org.dromara.dbswitch.common.entity.CloseableDataSource;
import org.dromara.dbswitch.common.entity.InvisibleDataSource;
import java.io.PrintWriter;
import java.net.URLClassLoader;
import java.sql.Connection;

7
dbswitch-data/src/main/java/com/gitee/dbswitch/data/domain/WrapHikariDataSource.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/domain/WrapHikariDataSource.java
View File

@@ -7,12 +7,11 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.domain;
package org.dromara.dbswitch.data.domain;
import com.gitee.dbswitch.common.entity.CloseableDataSource;
import com.gitee.dbswitch.common.entity.InvisibleDataSource;
import org.dromara.dbswitch.common.entity.CloseableDataSource;
import org.dromara.dbswitch.common.entity.InvisibleDataSource;
import com.zaxxer.hikari.HikariDataSource;
import java.io.IOException;
import java.io.PrintWriter;
import java.net.URLClassLoader;
import java.sql.Connection;

4
dbswitch-data/src/main/java/com/gitee/dbswitch/data/domain/WriterPerfStat.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/domain/WriterPerfStat.java
View File

@@ -7,9 +7,9 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.domain;
package org.dromara.dbswitch.data.domain;
import com.gitee.dbswitch.common.entity.PrintablePerfStat;
import org.dromara.dbswitch.common.entity.PrintablePerfStat;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

8
dbswitch-data/src/main/java/com/gitee/dbswitch/data/domain/WriterTaskParam.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/domain/WriterTaskParam.java
View File

@@ -7,11 +7,11 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.domain;
package org.dromara.dbswitch.data.domain;
import com.gitee.dbswitch.core.exchange.MemChannel;
import com.gitee.dbswitch.core.robot.RobotReader;
import com.gitee.dbswitch.core.task.TaskParam;
import org.dromara.dbswitch.core.core.exchange.MemChannel;
import org.dromara.dbswitch.core.core.robot.RobotReader;
import org.dromara.dbswitch.core.core.task.TaskParam;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;

4
dbswitch-data/src/main/java/com/gitee/dbswitch/data/domain/WriterTaskResult.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/domain/WriterTaskResult.java
View File

@@ -7,9 +7,9 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.domain;
package org.dromara.dbswitch.data.domain;
import com.gitee.dbswitch.core.task.TaskResult;
import org.dromara.dbswitch.core.core.task.TaskResult;
import java.util.HashMap;
import java.util.Map;
import lombok.AllArgsConstructor;

2
dbswitch-data/src/main/java/com/gitee/dbswitch/data/entity/GlobalParamConfigProperties.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/entity/GlobalParamConfigProperties.java
View File

@@ -7,7 +7,7 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.entity;
package org.dromara.dbswitch.data.entity;
import lombok.Data;

6
dbswitch-data/src/main/java/com/gitee/dbswitch/data/entity/SourceDataSourceProperties.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/entity/SourceDataSourceProperties.java
View File

@@ -7,12 +7,12 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.entity;
package org.dromara.dbswitch.data.entity;
import com.gitee.dbswitch.common.entity.PatternMapper;
import org.dromara.dbswitch.common.entity.PatternMapper;
import java.util.List;
import java.util.concurrent.TimeUnit;
import com.gitee.dbswitch.common.type.ProductTypeEnum;
import org.dromara.dbswitch.common.type.ProductTypeEnum;
import lombok.Data;
/**

8
dbswitch-data/src/main/java/com/gitee/dbswitch/data/entity/TargetDataSourceProperties.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/entity/TargetDataSourceProperties.java
View File

@@ -7,11 +7,11 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.entity;
package org.dromara.dbswitch.data.entity;
import com.gitee.dbswitch.common.type.CaseConvertEnum;
import com.gitee.dbswitch.common.type.ProductTypeEnum;
import com.gitee.dbswitch.common.type.SyncOptionEnum;
import org.dromara.dbswitch.common.type.CaseConvertEnum;
import org.dromara.dbswitch.common.type.ProductTypeEnum;
import org.dromara.dbswitch.common.type.SyncOptionEnum;
import java.util.concurrent.TimeUnit;
import lombok.Data;

70
dbswitch-data/src/main/java/com/gitee/dbswitch/data/handler/ReaderTaskThread.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/handler/ReaderTaskThread.java
View File

@@ -7,43 +7,43 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.handler;
package org.dromara.dbswitch.data.handler;
import cn.hutool.core.io.unit.DataSizeUtil;
import com.gitee.dbswitch.calculate.DefaultChangeCalculatorService;
import com.gitee.dbswitch.calculate.RecordRowChangeCalculator;
import com.gitee.dbswitch.calculate.RecordRowHandler;
import com.gitee.dbswitch.calculate.RowChangeTypeEnum;
import com.gitee.dbswitch.calculate.TaskParamEntity;
import com.gitee.dbswitch.common.consts.Constants;
import com.gitee.dbswitch.common.entity.CloseableDataSource;
import com.gitee.dbswitch.common.entity.ResultSetWrapper;
import com.gitee.dbswitch.common.type.CaseConvertEnum;
import com.gitee.dbswitch.common.type.ProductTypeEnum;
import com.gitee.dbswitch.common.util.DatabaseAwareUtils;
import com.gitee.dbswitch.common.util.JdbcTypesUtils;
import com.gitee.dbswitch.common.util.PatterNameUtils;
import com.gitee.dbswitch.core.exchange.BatchElement;
import com.gitee.dbswitch.core.exchange.MemChannel;
import com.gitee.dbswitch.core.task.TaskProcessor;
import com.gitee.dbswitch.data.config.DbswichPropertiesConfiguration;
import com.gitee.dbswitch.data.domain.ReaderTaskParam;
import com.gitee.dbswitch.data.domain.ReaderTaskResult;
import com.gitee.dbswitch.data.entity.SourceDataSourceProperties;
import com.gitee.dbswitch.data.entity.TargetDataSourceProperties;
import com.gitee.dbswitch.provider.ProductFactoryProvider;
import com.gitee.dbswitch.provider.ProductProviderFactory;
import com.gitee.dbswitch.provider.manage.TableManageProvider;
import com.gitee.dbswitch.provider.meta.MetadataProvider;
import com.gitee.dbswitch.provider.query.TableDataQueryProvider;
import com.gitee.dbswitch.provider.sync.TableDataSynchronizeProvider;
import com.gitee.dbswitch.provider.transform.RecordTransformProvider;
import com.gitee.dbswitch.provider.write.TableDataWriteProvider;
import com.gitee.dbswitch.schema.ColumnDescription;
import com.gitee.dbswitch.schema.TableDescription;
import com.gitee.dbswitch.schema.SourceProperties;
import com.gitee.dbswitch.service.DefaultMetadataService;
import com.gitee.dbswitch.service.MetadataService;
import org.dromara.dbswitch.core.calculate.DefaultChangeCalculatorService;
import org.dromara.dbswitch.core.calculate.RecordRowChangeCalculator;
import org.dromara.dbswitch.core.calculate.RecordRowHandler;
import org.dromara.dbswitch.core.calculate.RowChangeTypeEnum;
import org.dromara.dbswitch.core.calculate.TaskParamEntity;
import org.dromara.dbswitch.common.consts.Constants;
import org.dromara.dbswitch.common.entity.CloseableDataSource;
import org.dromara.dbswitch.common.entity.ResultSetWrapper;
import org.dromara.dbswitch.common.type.CaseConvertEnum;
import org.dromara.dbswitch.common.type.ProductTypeEnum;
import org.dromara.dbswitch.common.util.DatabaseAwareUtils;
import org.dromara.dbswitch.common.util.JdbcTypesUtils;
import org.dromara.dbswitch.common.util.PatterNameUtils;
import org.dromara.dbswitch.core.core.exchange.BatchElement;
import org.dromara.dbswitch.core.core.exchange.MemChannel;
import org.dromara.dbswitch.core.core.task.TaskProcessor;
import org.dromara.dbswitch.data.config.DbswichPropertiesConfiguration;
import org.dromara.dbswitch.data.domain.ReaderTaskParam;
import org.dromara.dbswitch.data.domain.ReaderTaskResult;
import org.dromara.dbswitch.data.entity.SourceDataSourceProperties;
import org.dromara.dbswitch.data.entity.TargetDataSourceProperties;
import org.dromara.dbswitch.core.provider.ProductFactoryProvider;
import org.dromara.dbswitch.core.provider.ProductProviderFactory;
import org.dromara.dbswitch.core.provider.manage.TableManageProvider;
import org.dromara.dbswitch.core.provider.meta.MetadataProvider;
import org.dromara.dbswitch.core.provider.query.TableDataQueryProvider;
import org.dromara.dbswitch.core.provider.sync.TableDataSynchronizeProvider;
import org.dromara.dbswitch.core.provider.transform.RecordTransformProvider;
import org.dromara.dbswitch.core.provider.write.TableDataWriteProvider;
import org.dromara.dbswitch.core.schema.ColumnDescription;
import org.dromara.dbswitch.core.schema.TableDescription;
import org.dromara.dbswitch.core.schema.SourceProperties;
import org.dromara.dbswitch.core.service.DefaultMetadataService;
import org.dromara.dbswitch.core.service.MetadataService;
import com.google.common.collect.Lists;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;

14
dbswitch-data/src/main/java/com/gitee/dbswitch/data/handler/WriterTaskThread.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/handler/WriterTaskThread.java
View File

@@ -7,15 +7,15 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.handler;
package org.dromara.dbswitch.data.handler;
import cn.hutool.core.date.StopWatch;
import com.gitee.dbswitch.core.exchange.BatchElement;
import com.gitee.dbswitch.core.exchange.MemChannel;
import com.gitee.dbswitch.core.robot.RobotReader;
import com.gitee.dbswitch.core.task.TaskProcessor;
import com.gitee.dbswitch.data.domain.WriterTaskParam;
import com.gitee.dbswitch.data.domain.WriterTaskResult;
import org.dromara.dbswitch.core.core.exchange.BatchElement;
import org.dromara.dbswitch.core.core.exchange.MemChannel;
import org.dromara.dbswitch.core.core.robot.RobotReader;
import org.dromara.dbswitch.core.core.task.TaskProcessor;
import org.dromara.dbswitch.data.domain.WriterTaskParam;
import org.dromara.dbswitch.data.domain.WriterTaskResult;
import java.util.Optional;
import lombok.extern.slf4j.Slf4j;

22
dbswitch-data/src/main/java/com/gitee/dbswitch/data/service/DefaultBatchExchanger.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/service/DefaultBatchExchanger.java
View File

@@ -7,18 +7,18 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.service;
package org.dromara.dbswitch.data.service;
import com.gitee.dbswitch.common.entity.PrintablePerfStat;
import com.gitee.dbswitch.core.exchange.AbstractBatchExchanger;
import com.gitee.dbswitch.core.robot.RobotReader;
import com.gitee.dbswitch.core.robot.RobotWriter;
import com.gitee.dbswitch.data.domain.ComparePerfStat;
import com.gitee.dbswitch.data.domain.ExceptPerfStat;
import com.gitee.dbswitch.data.domain.ReaderPerfStat;
import com.gitee.dbswitch.data.domain.ReaderTaskResult;
import com.gitee.dbswitch.data.domain.WriterPerfStat;
import com.gitee.dbswitch.data.domain.WriterTaskResult;
import org.dromara.dbswitch.common.entity.PrintablePerfStat;
import org.dromara.dbswitch.core.core.exchange.AbstractBatchExchanger;
import org.dromara.dbswitch.core.core.robot.RobotReader;
import org.dromara.dbswitch.core.core.robot.RobotWriter;
import org.dromara.dbswitch.data.domain.ComparePerfStat;
import org.dromara.dbswitch.data.domain.ExceptPerfStat;
import org.dromara.dbswitch.data.domain.ReaderPerfStat;
import org.dromara.dbswitch.data.domain.ReaderTaskResult;
import org.dromara.dbswitch.data.domain.WriterPerfStat;
import org.dromara.dbswitch.data.domain.WriterTaskResult;
import com.google.common.collect.Sets;
import java.util.List;
import java.util.Optional;

28
dbswitch-data/src/main/java/com/gitee/dbswitch/data/service/DefaultReaderRobot.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/service/DefaultReaderRobot.java
View File

@@ -7,24 +7,24 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.service;
package org.dromara.dbswitch.data.service;
import cn.hutool.core.stream.StreamUtil;
import cn.hutool.core.text.StrPool;
import cn.hutool.core.util.StrUtil;
import com.gitee.dbswitch.common.entity.CloseableDataSource;
import com.gitee.dbswitch.common.entity.LoggingSupplier;
import com.gitee.dbswitch.common.entity.MdcKeyValue;
import com.gitee.dbswitch.core.robot.RobotReader;
import com.gitee.dbswitch.data.config.DbswichPropertiesConfiguration;
import com.gitee.dbswitch.data.domain.ReaderTaskParam;
import com.gitee.dbswitch.data.domain.ReaderTaskResult;
import com.gitee.dbswitch.data.entity.SourceDataSourceProperties;
import com.gitee.dbswitch.data.handler.ReaderTaskThread;
import com.gitee.dbswitch.data.util.JsonUtils;
import com.gitee.dbswitch.schema.TableDescription;
import com.gitee.dbswitch.service.DefaultMetadataService;
import com.gitee.dbswitch.service.MetadataService;
import org.dromara.dbswitch.common.entity.CloseableDataSource;
import org.dromara.dbswitch.common.entity.LoggingSupplier;
import org.dromara.dbswitch.common.entity.MdcKeyValue;
import org.dromara.dbswitch.core.core.robot.RobotReader;
import org.dromara.dbswitch.data.config.DbswichPropertiesConfiguration;
import org.dromara.dbswitch.data.domain.ReaderTaskParam;
import org.dromara.dbswitch.data.domain.ReaderTaskResult;
import org.dromara.dbswitch.data.entity.SourceDataSourceProperties;
import org.dromara.dbswitch.data.handler.ReaderTaskThread;
import org.dromara.dbswitch.data.util.JsonUtils;
import org.dromara.dbswitch.core.schema.TableDescription;
import org.dromara.dbswitch.core.service.DefaultMetadataService;
import org.dromara.dbswitch.core.service.MetadataService;
import com.google.common.collect.Maps;
import java.util.ArrayList;
import java.util.List;

18
dbswitch-data/src/main/java/com/gitee/dbswitch/data/service/DefaultWriterRobot.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/service/DefaultWriterRobot.java
View File

@@ -7,16 +7,16 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.service;
package org.dromara.dbswitch.data.service;
import com.gitee.dbswitch.common.entity.LoggingSupplier;
import com.gitee.dbswitch.common.entity.MdcKeyValue;
import com.gitee.dbswitch.common.util.ExamineUtils;
import com.gitee.dbswitch.core.robot.RobotReader;
import com.gitee.dbswitch.core.robot.RobotWriter;
import com.gitee.dbswitch.data.domain.WriterTaskParam;
import com.gitee.dbswitch.data.domain.WriterTaskResult;
import com.gitee.dbswitch.data.handler.WriterTaskThread;
import org.dromara.dbswitch.common.entity.LoggingSupplier;
import org.dromara.dbswitch.common.entity.MdcKeyValue;
import org.dromara.dbswitch.common.util.ExamineUtils;
import org.dromara.dbswitch.core.core.robot.RobotReader;
import org.dromara.dbswitch.core.core.robot.RobotWriter;
import org.dromara.dbswitch.data.domain.WriterTaskParam;
import org.dromara.dbswitch.data.domain.WriterTaskResult;
import org.dromara.dbswitch.data.handler.WriterTaskThread;
import com.google.common.collect.Maps;
import java.util.ArrayList;
import java.util.List;

24
dbswitch-data/src/main/java/com/gitee/dbswitch/data/service/MigrationService.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/service/MigrationService.java
View File

@@ -7,19 +7,19 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.service;
package org.dromara.dbswitch.data.service;
import com.gitee.dbswitch.common.entity.CloseableDataSource;
import com.gitee.dbswitch.common.entity.LoggingRunnable;
import com.gitee.dbswitch.common.entity.MdcKeyValue;
import com.gitee.dbswitch.common.entity.PrintablePerfStat;
import com.gitee.dbswitch.core.exchange.AbstractBatchExchanger;
import com.gitee.dbswitch.core.robot.RobotReader;
import com.gitee.dbswitch.core.robot.RobotWriter;
import com.gitee.dbswitch.data.config.DbswichPropertiesConfiguration;
import com.gitee.dbswitch.data.entity.GlobalParamConfigProperties;
import com.gitee.dbswitch.data.util.DataSourceUtils;
import com.gitee.dbswitch.data.util.MachineUtils;
import org.dromara.dbswitch.common.entity.CloseableDataSource;
import org.dromara.dbswitch.common.entity.LoggingRunnable;
import org.dromara.dbswitch.common.entity.MdcKeyValue;
import org.dromara.dbswitch.common.entity.PrintablePerfStat;
import org.dromara.dbswitch.core.core.exchange.AbstractBatchExchanger;
import org.dromara.dbswitch.core.core.robot.RobotReader;
import org.dromara.dbswitch.core.core.robot.RobotWriter;
import org.dromara.dbswitch.data.config.DbswichPropertiesConfiguration;
import org.dromara.dbswitch.data.entity.GlobalParamConfigProperties;
import org.dromara.dbswitch.data.util.DataSourceUtils;
import org.dromara.dbswitch.data.util.MachineUtils;
import java.sql.Connection;
import java.sql.Statement;
import java.util.ArrayList;

20
dbswitch-data/src/main/java/com/gitee/dbswitch/data/util/DataSourceUtils.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/util/DataSourceUtils.java
View File

@@ -7,18 +7,18 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.util;
package org.dromara.dbswitch.data.util;
import cn.hutool.core.util.ClassLoaderUtil;
import com.gitee.dbswitch.common.entity.CloseableDataSource;
import com.gitee.dbswitch.common.entity.InvisibleDataSource;
import com.gitee.dbswitch.common.entity.JarClassLoader;
import com.gitee.dbswitch.common.type.ProductTypeEnum;
import com.gitee.dbswitch.common.util.ExamineUtils;
import com.gitee.dbswitch.data.domain.WrapCommonDataSource;
import com.gitee.dbswitch.data.domain.WrapHikariDataSource;
import com.gitee.dbswitch.data.entity.SourceDataSourceProperties;
import com.gitee.dbswitch.data.entity.TargetDataSourceProperties;
import org.dromara.dbswitch.common.entity.CloseableDataSource;
import org.dromara.dbswitch.common.entity.InvisibleDataSource;
import org.dromara.dbswitch.common.entity.JarClassLoader;
import org.dromara.dbswitch.common.type.ProductTypeEnum;
import org.dromara.dbswitch.common.util.ExamineUtils;
import org.dromara.dbswitch.data.domain.WrapCommonDataSource;
import org.dromara.dbswitch.data.domain.WrapHikariDataSource;
import org.dromara.dbswitch.data.entity.SourceDataSourceProperties;
import org.dromara.dbswitch.data.entity.TargetDataSourceProperties;
import com.zaxxer.hikari.HikariDataSource;
import java.net.URLClassLoader;
import java.util.Map;

2
dbswitch-data/src/main/java/com/gitee/dbswitch/data/util/JsonUtils.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/util/JsonUtils.java
View File

@@ -7,7 +7,7 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.util;
package org.dromara.dbswitch.data.util;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.JavaType;

4
dbswitch-data/src/main/java/com/gitee/dbswitch/data/util/MachineUtils.java → dbswitch-data/src/main/java/org/dromara/dbswitch/data/util/MachineUtils.java
View File

@@ -7,14 +7,14 @@
// Date : 2020/1/2
// Location: beijing , china
/////////////////////////////////////////////////////////////
package com.gitee.dbswitch.data.util;
package org.dromara.dbswitch.data.util;
import cn.hutool.core.io.FileUtil;
import cn.hutool.system.JvmInfo;
import cn.hutool.system.OsInfo;
import cn.hutool.system.RuntimeInfo;
import cn.hutool.system.SystemUtil;
import com.gitee.dbswitch.common.util.PomVersionUtils;
import org.dromara.dbswitch.common.util.PomVersionUtils;
import lombok.experimental.UtilityClass;
import lombok.extern.slf4j.Slf4j;

2
dbswitch-data/src/main/resources/config.yml
View File

@@ -50,5 +50,5 @@ dbswitch:
writer-engine-insert: false
## whether use change data synchronize to target database table
change-data-sync: true
## data sync option for increment synchronize, see: com.gitee.dbswitch.common.type.SyncOptionEnum
## data sync option for increment synchronize, see: org.dromara.dbswitch.common.type.SyncOptionEnum
target-sync-option: INSERT_UPDATE_DELETE