|
|
|
@ -796,7 +796,8 @@ public class IdcServiceImpl implements IdcService {
|
|
|
|
|
private boolean analyToDB(String host, String tableName, String uniqueColumn, String
|
|
|
|
|
filePathColumn, List<Map<String, Object>> list, boolean isUpload) {
|
|
|
|
|
|
|
|
|
|
String tName = DBAUtils.tableRealName(tableName);
|
|
|
|
|
|
|
|
|
|
String tName = DBAUtils.tableRealName(tableName);
|
|
|
|
|
String sql = "replace " + tName + "(";
|
|
|
|
|
String del = "delete from " + tName + " where ";
|
|
|
|
|
String upd = "update " + tName + " set ";
|
|
|
|
@ -810,7 +811,7 @@ public class IdcServiceImpl implements IdcService {
|
|
|
|
|
if (col > 0)
|
|
|
|
|
sql += ",";
|
|
|
|
|
columnList.get(i).put("attrName", columnList.get(i).get("columnName"));
|
|
|
|
|
sql += columnList.get(i).get("columnName").toString();
|
|
|
|
|
sql += "`"+columnList.get(i).get("columnName").toString()+"`";
|
|
|
|
|
col++;
|
|
|
|
|
if (uniqueColumn != null && columnList.get(i).get("columnKey") != null && ("," + uniqueColumn + ",").contains("," + columnList.get(i).get("columnName") + ",")) {
|
|
|
|
|
keyColumn[key] = columnList.get(i).get("columnName").toString();
|
|
|
|
|