|
|
@@ -2,8 +2,8 @@ package cc.smtweb.system.canal.file.impl; |
|
|
|
|
|
|
|
import cc.smtweb.framework.core.common.CanalVO; |
|
|
|
import cc.smtweb.framework.core.common.SwEnum; |
|
|
|
import cc.smtweb.framework.core.util.StringUtil; |
|
|
|
import cc.smtweb.system.canal.file.common.AbstractFileWork; |
|
|
|
import org.apache.commons.lang.StringUtils; |
|
|
|
|
|
|
|
import java.util.ArrayList; |
|
|
|
import java.util.List; |
|
|
@@ -47,7 +47,7 @@ public class MySqlFileWork extends AbstractFileWork { |
|
|
|
for (String field : fields) { |
|
|
|
sql.append("?").append(","); |
|
|
|
String value = data.get(field); |
|
|
|
if (StringUtils.isEmpty(value)) { |
|
|
|
if (StringUtil.isEmpty(value)) { |
|
|
|
args.add(null); |
|
|
|
} else { |
|
|
|
args.add(value); |
|
|
@@ -69,7 +69,7 @@ public class MySqlFileWork extends AbstractFileWork { |
|
|
|
if (field.equals(canalVO.getIdField())) continue; |
|
|
|
sql.append(field).append("=").append("?").append(","); |
|
|
|
String value = data.get(field); |
|
|
|
if (StringUtils.isEmpty(value)) { |
|
|
|
if (StringUtil.isEmpty(value)) { |
|
|
|
args.add(null); |
|
|
|
} else { |
|
|
|
args.add(value); |
|
|
|