mirror of
https://github.com/alibaba/canal.git
synced 2026-11-04 00:30:15 +08:00
fix
This commit is contained in:
@@ -6,7 +6,6 @@ import java.util.Map;
|
|||||||
|
|
||||||
import com.alibaba.otter.canal.client.adapter.rdb.config.MappingConfig;
|
import com.alibaba.otter.canal.client.adapter.rdb.config.MappingConfig;
|
||||||
import com.alibaba.otter.canal.client.adapter.support.Dml;
|
import com.alibaba.otter.canal.client.adapter.support.Dml;
|
||||||
import org.apache.commons.lang.StringUtils;
|
|
||||||
|
|
||||||
public class SimpleDml {
|
public class SimpleDml {
|
||||||
|
|
||||||
@@ -79,10 +78,6 @@ public class SimpleDml {
|
|||||||
List<SimpleDml> simpleDmlList = new ArrayList<>();
|
List<SimpleDml> simpleDmlList = new ArrayList<>();
|
||||||
int len = dml.getData().size();
|
int len = dml.getData().size();
|
||||||
|
|
||||||
String destination = StringUtils.trimToEmpty(dml.getDestination());
|
|
||||||
String database = dml.getDatabase();
|
|
||||||
String table = dml.getTable();
|
|
||||||
|
|
||||||
for (int i = 0; i < len; i++) {
|
for (int i = 0; i < len; i++) {
|
||||||
SimpleDml simpleDml = new SimpleDml();
|
SimpleDml simpleDml = new SimpleDml();
|
||||||
simpleDml.setDestination(dml.getDestination());
|
simpleDml.setDestination(dml.getDestination());
|
||||||
|
|||||||
Reference in New Issue
Block a user