Fix(TDI-32477):Dynamic column includes the part of columns

table

main/plugins/org.talend.designer.components.localprovider/components/tPostgresqlOutput/tPostgresqlOutput_begin.javajet

@@ -70,6 +70,8 @@ skeleton="../templates/db_output_bulk.skeleton"
 
 	String dieOnError = ElementParameterParser.getValue(node, "__DIE_ON_ERROR__");
 	
+	boolean convertToLowercase = ("true").equals(ElementParameterParser.getValue(node, "__CONVERT_COLUMN_TABLE_TO_LOWERCASE__"));
+
     String rejectConnName = null;
     List<? extends IConnection> rejectConns = node.getOutgoingConnections("REJECT");
     if(rejectConns != null && rejectConns.size() > 0) {
@@ -98,6 +100,18 @@ List<Column> stmtStructure = null;
 if(columnList != null && columnList.size() > 0) {
     stmtStructure = getManager(dbmsId, cid).createColumnList(columnList, useFieldOptions, fieldOptions, addCols);
     isDynamic = isDynamic && !getManager(dbmsId, cid).isDynamicColumnReplaced();
+    
+    if(convertToLowercase){
+    	for(Column column : stmtStructure) {
+    		if(column.isReplaced()) {
+    			for (Column replacedColumn : column.getReplacement()) {
+    				replacedColumn.setColumnName(replacedColumn.getColumnName().toLowerCase());
+    			}
+    		} else if(!column.isDynamic()){
+    			column.setColumnName(column.getColumnName().toLowerCase());
+    		}
+    	}
+    }
 }
 %>
 
@@ -116,9 +130,9 @@ if(("true").equals(useExistingConn)) {
 
 String tableName_<%=cid%> = null;
 if(dbschema_<%=cid%> == null || dbschema_<%=cid%>.trim().length() == 0) {
-	tableName_<%=cid%> = <%=table%>;
+	tableName_<%=cid%> = (<%=table%>)<%=convertToLowercase ? ".toLowerCase()" : ""%>;
 } else {
-	tableName_<%=cid%> = dbschema_<%=cid%> + "\".\"" + <%=table%>;
+	tableName_<%=cid%> = dbschema_<%=cid%> + "\".\"" + (<%=table%>)<%=convertToLowercase ? ".toLowerCase()" : ""%>;
 }
 
 <%

main/plugins/org.talend.designer.components.localprovider/components/tPostgresqlOutput/tPostgresqlOutput_java.xml

@@ -393,6 +393,14 @@
 			<DEFAULT>false</DEFAULT>
 		</PARAMETER>
 
+		<PARAMETER
+	      NAME="CONVERT_COLUMN_TABLE_TO_LOWERCASE"
+	      FIELD="CHECK"
+	      NUM_ROW="25"
+	    >
+	      <DEFAULT>false</DEFAULT>
+	    </PARAMETER>
+
 		<PARAMETER
 			NAME="USE_BATCH_SIZE"
 			FIELD="CHECK"

main/plugins/org.talend.designer.components.localprovider/components/tPostgresqlOutput/tPostgresqlOutput_main.javajet

@@ -50,6 +50,8 @@ skeleton="../templates/db_output_bulk.skeleton"
 	boolean useBatchSize = ("true").equals(ElementParameterParser.getValue(node,"__USE_BATCH_SIZE__"));
 	String batchSize=ElementParameterParser.getValue(node,"__BATCH_SIZE__");
 	
+	boolean convertToLowercase = ("true").equals(ElementParameterParser.getValue(node, "__CONVERT_COLUMN_TABLE_TO_LOWERCASE__"));
+
 	//feature:22704
 	boolean savePoint = ("true").equals(ElementParameterParser.getValue(node,"__SAVE_POINT__"));
 	boolean showSavePoint = false;
@@ -156,11 +158,16 @@ skeleton="../templates/db_output_bulk.skeleton"
 		if(conns_dynamic!=null && conns_dynamic.size()>0){
 			IConnection conn = conns_dynamic.get(0);
 			if(!("".equals(insertColName.toString()))) {
+				String insertColNameStr = null;
+				if(convertToLowercase)
+					insertColNameStr = insertColName.toString().toLowerCase();
+				else
+					insertColNameStr = insertColName.toString();
 %>
-				String insert_<%=cid%> = "INSERT INTO \"" + tableName_<%=cid%> + "\" (<%=insertColName.toString()%>, "+DynamicUtils.getInsertIntoStmtColumnsList(<%=conn.getName()%>.<%=getDynamicColumn()%>, "<%=dbmsId %>")+") VALUES (<%=insertValueStmt.toString()%>, "+DynamicUtils.getInsertIntoStmtValuesList(<%=conn.getName()%>.<%=getDynamicColumn()%>)+")";
+				String insert_<%=cid%> = "INSERT INTO \"" + tableName_<%=cid%> + "\" (<%=insertColNameStr%>, "+DynamicUtils.getInsertIntoStmtColumnsList(<%=conn.getName()%>.<%=getDynamicColumn()%>, "<%=dbmsId %>")<%if(convertToLowercase){%>.toLowerCase()<%}%>+") VALUES (<%=insertValueStmt.toString()%>, "+DynamicUtils.getInsertIntoStmtValuesList(<%=conn.getName()%>.<%=getDynamicColumn()%>)+")";
 <%			} else {
 %>
-				String insert_<%=cid%> = "INSERT INTO \"" + tableName_<%=cid%> + "\" ("+DynamicUtils.getInsertIntoStmtColumnsList(<%=conn.getName()%>.<%=getDynamicColumn()%>, "<%=dbmsId %>")+") VALUES ("+DynamicUtils.getInsertIntoStmtValuesList(<%=conn.getName()%>.<%=getDynamicColumn()%>)+")";
+				String insert_<%=cid%> = "INSERT INTO \"" + tableName_<%=cid%> + "\" ("+DynamicUtils.getInsertIntoStmtColumnsList(<%=conn.getName()%>.<%=getDynamicColumn()%>, "<%=dbmsId %>")<%if(convertToLowercase){%>.toLowerCase()<%}%>+") VALUES ("+DynamicUtils.getInsertIntoStmtValuesList(<%=conn.getName()%>.<%=getDynamicColumn()%>)+")";
 <%
 			}
 		}

main/plugins/org.talend.designer.components.localprovider/components/tPostgresqlOutput/tPostgresqlOutput_messages.properties

@@ -99,3 +99,5 @@ SPECIFY_DATASOURCE_ALIAS.NAME=Specify a data source alias
 DATASOURCE.NAME=Data source
 DATASOURCE_ALIAS.NAME=Data source alias
 PROPERTIES.NAME=Additional JDBC Parameters
+
+CONVERT_COLUMN_TABLE_TO_LOWERCASE.NAME=Convert columns and table to lowercase

main/plugins/org.talend.designer.components.localprovider/components/templates/_tableActionForOutput.javajet

@@ -5,6 +5,7 @@
 Boolean isParallelize ="true".equalsIgnoreCase(ElementParameterParser.getValue(node, "__PARALLELIZE__"));
 String dbms=ElementParameterParser.getValue(node, "__MAPPING__");
 boolean convertToUppercase_tableAction = "true".equalsIgnoreCase(ElementParameterParser.getValue(node, "__CONVERT_COLUMN_TABLE_TO_UPPERCASE__"));
+boolean convertToLowercase_tableAction = "true".equalsIgnoreCase(ElementParameterParser.getValue(node, "__CONVERT_COLUMN_TABLE_TO_LOWERCASE__"));
 if (!isParallelize) {
 //end issue 0010346 Parallelization crash with "Drop table if exists and create"
 
@@ -222,7 +223,7 @@ if (!isParallelize) {
                                     while(rsTable_<%=cid%>.next()) {
                                         String table_<%=cid%> = rsTable_<%=cid%>.getString("TABLE_NAME");
                                         String schema_<%=cid%> = rsTable_<%=cid%>.getString("TABLE_SCHEM");
-                                        if(table_<%=cid%>.equals<%if(!tableNameCaseSensitive){%>IgnoreCase<%}%>(<%=table%>)
+                                        if(table_<%=cid%>.equals<%if(!tableNameCaseSensitive){%>IgnoreCase<%}%>(<%=table%><%if(convertToLowercase_tableAction){%>.toLowerCase()<%}%>)
                                             && (schema_<%=cid%>.equals<%if(!tableNameCaseSensitive){%>IgnoreCase<%}%>(dbschema_<%=cid%>) || ((dbschema_<%=cid%> ==null || dbschema_<%=cid%>.trim().length() ==0) && defaultSchema_<%=cid%>.equals<%if(!tableNameCaseSensitive){%>IgnoreCase<%}%>(schema_<%=cid%>)))) {
                                             whetherExist_<%=cid%> = true;
                                             break;
@@ -377,7 +378,7 @@ if (!isParallelize) {
                                     if(conns_dynamic!=null && conns_dynamic.size()>0){
                                         String query=manager.getCreateTableSQL(stmtStructure);
                                         %>
-                                        stmtCreate_<%=cid%>.execute((("<%=query%>").replace("{TALEND_DYNAMIC_COLUMN}",DynamicUtils.getCreateTableSQL(<%=conns_dynamic.get(0).getName()%>.<%=getDynamicColumn()%>, "<%=dbms==null?"":dbms.toLowerCase()%>")<%if(convertToUppercase_tableAction){%>.toUpperCase()<%}%>)+")<%=ending%>"));
+                                        stmtCreate_<%=cid%>.execute((("<%=query%>").replace("{TALEND_DYNAMIC_COLUMN}",DynamicUtils.getCreateTableSQL(<%=conns_dynamic.get(0).getName()%>.<%=getDynamicColumn()%>, "<%=dbms==null?"":dbms.toLowerCase()%>"))+")<%=ending%>")<%if(convertToUppercase_tableAction){%>.toUpperCase()<%}else if(convertToLowercase_tableAction){%>.toLowerCase()<%}%>);
                                     <%
                                     }
                                 } else {