package com.product.data.entity;
|
|
import com.product.core.entity.DataTableEntity;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.data.config.CmnConst;
|
import com.product.data.config.DatabaseType;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @Author cheng
|
* @Date 2022/2/10 13:49
|
* @Desc 同步配置
|
*/
|
public class SyncFieldConfigEntity {
|
/**
|
* 来源表名
|
*/
|
private String sourceTable;
|
/**
|
* 目标表名
|
*/
|
private String targetTable;
|
/**
|
* 同步类型 0 增量同步 1 覆盖同步
|
*/
|
private int syncType;
|
/**
|
* 查询条件
|
*/
|
private String queryFilter;
|
/**
|
* 同步任务名称
|
*/
|
private String syncTaskName;
|
|
private List<SyncFieldEntity> syncFieldEntityList = new ArrayList<>();
|
/**
|
* 唯一标识字段
|
*/
|
private List<SyncFieldEntity> uniqueFields;
|
/**
|
* 增量标识字段
|
*/
|
private SyncFieldEntity incrementField;
|
/**
|
* 增量更新标识字段
|
*/
|
private SyncFieldEntity updateField;
|
/**
|
* 保存前调用方法
|
*/
|
private String saveBeforeMethod;
|
|
private String taskUuid;
|
|
private String targetTablePkField;
|
|
private Map<String, SyncFieldEntity> sourceFieldMap = new HashMap<>();
|
private Map<String, SyncFieldEntity> targetFieldMap = new HashMap<>();
|
|
|
@Override
|
public String toString() {
|
return "SyncFieldConfigEntity{" +
|
"sourceTable='" + sourceTable + '\'' +
|
", targetTable='" + targetTable + '\'' +
|
", syncType=" + syncType +
|
", queryFilter='" + queryFilter + '\'' +
|
", syncTaskName='" + syncTaskName + '\'' +
|
", syncFieldEntityList=" + syncFieldEntityList +
|
", uniqueField=" + uniqueFields +
|
", incrementField=" + incrementField +
|
", saveBeforeMethod='" + saveBeforeMethod + '\'' +
|
", taskUuid='" + taskUuid + '\'' +
|
", targetTablePkField='" + targetTablePkField + '\'' +
|
'}';
|
}
|
|
public SyncFieldConfigEntity(FieldSetEntity fse, String targetTablePkField, DatabaseType dbType) {
|
this.sourceTable = fse.getString("source_table");
|
this.targetTable = fse.getString("target_table");
|
this.syncType = fse.getInteger("sync_type");
|
this.queryFilter = fse.getString("query_filter");
|
this.syncTaskName = fse.getString("sync_task_name");
|
this.saveBeforeMethod = fse.getString("save_before");
|
this.taskUuid = fse.getString("uuid");
|
this.targetTablePkField = targetTablePkField;
|
addFields(fse.getSubDataTable(CmnConst.TABLE_SYNC_MANAGER_FIELD), dbType);
|
}
|
|
public String getTargetTablePkField() {
|
return targetTablePkField;
|
}
|
|
public String getTaskUuid() {
|
return taskUuid;
|
}
|
|
|
public boolean getUniqueFieldExists() {
|
if (this.uniqueFields == null || this.uniqueFields.size() < 0) {
|
return false;
|
}
|
return true;
|
}
|
|
public List<SyncFieldEntity> getUniqueFields() {
|
return uniqueFields;
|
}
|
|
// public SyncFieldEntity getUniqueField() {
|
// return uniqueField;
|
// }
|
|
public SyncFieldEntity getIncrementField() {
|
return incrementField;
|
}
|
|
private void addFields(DataTableEntity dt, DatabaseType dbType) {
|
for (int i = 0; i < dt.getRows(); i++) {
|
SyncFieldEntity syncFieldEntity = new SyncFieldEntity(dt.getFieldSetEntity(i), dbType);
|
syncFieldEntityList.add(syncFieldEntity);
|
if (syncFieldEntity.isIncrement()) {
|
incrementField = syncFieldEntity;
|
}
|
if (syncFieldEntity.isUnique()) {
|
if (this.uniqueFields == null) {
|
uniqueFields = new ArrayList<>();
|
}
|
uniqueFields.add(syncFieldEntity);
|
}
|
if (syncFieldEntity.isUpdate()) {
|
updateField = syncFieldEntity;
|
}
|
this.sourceFieldMap.put(syncFieldEntity.getSourceFieldName(), syncFieldEntity);
|
this.targetFieldMap.put(syncFieldEntity.getTargetFieldName(), syncFieldEntity);
|
}
|
}
|
|
public SyncFieldEntity getSourceFieldEntity(String fieldName) {
|
return this.sourceFieldMap.get(fieldName);
|
}
|
|
public SyncFieldEntity getTargetFieldEntity(String fieldName) {
|
return this.targetFieldMap.get(fieldName);
|
}
|
|
public SyncFieldEntity getUpdateField() {
|
return updateField;
|
}
|
|
public String getSaveBeforeMethod() {
|
return saveBeforeMethod;
|
}
|
|
public List<SyncFieldEntity> getSyncFieldEntityList() {
|
return syncFieldEntityList;
|
}
|
|
public String getSourceTable() {
|
return sourceTable;
|
}
|
|
public void setSourceTable(String sourceTable) {
|
this.sourceTable = sourceTable;
|
}
|
|
public String getTargetTable() {
|
return targetTable;
|
}
|
|
public void setTargetTable(String targetTable) {
|
this.targetTable = targetTable;
|
}
|
|
public int getSyncType() {
|
return syncType;
|
}
|
|
public void setSyncType(int syncType) {
|
this.syncType = syncType;
|
}
|
|
public String getQueryFilter() {
|
return queryFilter;
|
}
|
|
public void setQueryFilter(String queryFilter) {
|
this.queryFilter = queryFilter;
|
}
|
|
public String getSyncTaskName() {
|
return syncTaskName;
|
}
|
|
public void setSyncTaskName(String syncTaskName) {
|
this.syncTaskName = syncTaskName;
|
}
|
}
|
