Compare commits

...

1 Commits

Author SHA1 Message Date
wang wei
603544b051 fix(TDI-37914): Need to update the javajet to use the real column name
for the DiIncomingSchemaEnforcer
2016-11-30 16:46:04 +08:00

View File

@@ -110,13 +110,15 @@ if(hasInput){
for (int i = 0; i < input_columnList.size(); i++) { // column
IMetadataColumn column = input_columnList.get(i);
if (dynamicPos != i) {
String realName = column.getOriginalDbColumnName();
%>
current_<%=cid%>.put("<%=column.getLabel()%>", <%=inputConn.getName()%>.<%=column.getLabel()%>);
current_<%=cid%>.put("<%=column.getLabel()%>", <%if(realName!=null && !realName.isEmpty()){%>"<%=realName%>"<%} else {%>null<%}%>, <%=inputConn.getName()%>.<%=column.getLabel()%>);
<%
} else {
%>
for (int i = 0; i < <%=inputConn.getName()%>.<%=column.getLabel()%>.getColumnCount(); i++) {
current_<%=cid%>.put(<%=inputConn.getName()%>.<%=column.getLabel()%>.getColumnMetadata(i).getName(),
routines.system.DynamicMetadata metadata_<%=cid%> = <%=inputConn.getName()%>.<%=column.getLabel()%>.getColumnMetadata(i);
current_<%=cid%>.put(metadata_<%=cid%>.getName(), metadata_<%=cid%>.getDbName(),
<%=inputConn.getName()%>.<%=column.getLabel()%>.getColumnValue(i));
}
<%