fix bug: sqoop mysql import params error (#2896) (b5eb9fe4) · Commits · SUMMER2020 / students / proj-2002251

dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/sqoop/generator/sources/MysqlSourceGenerator.java

+9 −9

Original line number	Diff line number	Diff line
		@@ -77,19 +77,19 @@ public class MysqlSourceGenerator implements ISourceGenerator {
		}else{
		srcQuery += " WHERE $CONDITIONS";
		}
		result.append(" --query \'"+srcQuery+"\'");
		result.append(" --query \'").append(srcQuery).append("\'");

		}

		List<Property> mapColumnHive = sourceMysqlParameter.getMapColumnHive();

		if(mapColumnHive != null && !mapColumnHive.isEmpty()){
		String columnMap = "";
		StringBuilder columnMap = new StringBuilder();
		for(Property item:mapColumnHive){
		columnMap = item.getProp()+"="+ item.getValue()+",";
		columnMap.append(item.getProp()).append("=").append(item.getValue()).append(",");
		}

		if(StringUtils.isNotEmpty(columnMap)){
		if(StringUtils.isNotEmpty(columnMap.toString())){
		result.append(" --map-column-hive ")
		.append(columnMap.substring(0,columnMap.length() - 1));
		}
		@@ -98,12 +98,12 @@ public class MysqlSourceGenerator implements ISourceGenerator {
		List<Property> mapColumnJava = sourceMysqlParameter.getMapColumnJava();

		if(mapColumnJava != null && !mapColumnJava.isEmpty()){
		String columnMap = "";
		StringBuilder columnMap = new StringBuilder();
		for(Property item:mapColumnJava){
		columnMap = item.getProp()+"="+ item.getValue()+",";
		columnMap.append(item.getProp()).append("=").append(item.getValue()).append(",");
		}

		if(StringUtils.isNotEmpty(columnMap)){
		if(StringUtils.isNotEmpty(columnMap.toString())){
		result.append(" --map-column-java ")
		.append(columnMap.substring(0,columnMap.length() - 1));
		}