ba3cceb061
* fix(TDI-34905):add stream support for tFileinputJason JSONpath * fix(TDI-34905):change filename to filemnameOrStream.
55 lines
2.2 KiB
Plaintext
55 lines
2.2 KiB
Plaintext
<%@ jet
|
|
imports="
|
|
org.talend.core.model.process.INode
|
|
org.talend.core.model.process.ElementParameterParser
|
|
org.talend.core.model.metadata.IMetadataTable
|
|
org.talend.core.model.metadata.IMetadataColumn
|
|
org.talend.core.model.process.IConnection
|
|
org.talend.core.model.process.IConnectionCategory
|
|
org.talend.designer.codegen.config.CodeGeneratorArgument
|
|
java.util.Map
|
|
java.util.List
|
|
org.talend.core.model.metadata.types.JavaTypesManager
|
|
org.talend.core.model.metadata.types.JavaType
|
|
org.talend.core.model.utils.NodeUtil
|
|
"
|
|
%>
|
|
<%@ include file="../templates/Log4j/Log4jFileUtil.javajet"%>
|
|
<%
|
|
CodeGeneratorArgument codeGenArgument = (CodeGeneratorArgument) argument;
|
|
INode node = (INode)codeGenArgument.getArgument();
|
|
boolean isLog4jEnabled = ("true").equals(ElementParameterParser.getValue(node.getProcess(), "__LOG4J_ACTIVATE__"));
|
|
|
|
String cid = node.getUniqueName();
|
|
|
|
String dieOnErrorStr = ElementParameterParser.getValue(node, "__DIE_ON_ERROR__");
|
|
boolean dieOnError = (dieOnErrorStr!=null&&!("").equals(dieOnErrorStr))?("true").equals(dieOnErrorStr):false;
|
|
|
|
String encoding = ElementParameterParser.getValue(node, "__ENCODING__");
|
|
String advancedSeparatorStr = ElementParameterParser.getValue(node, "__ADVANCED_SEPARATOR__");
|
|
boolean advancedSeparator = (advancedSeparatorStr!=null&&!("").equals(advancedSeparatorStr))?("true").equals(advancedSeparatorStr):false;
|
|
String thousandsSeparator = ElementParameterParser.getValueWithJavaType(node, "__THOUSANDS_SEPARATOR__", JavaTypesManager.CHARACTER);
|
|
String decimalSeparator = ElementParameterParser.getValueWithJavaType(node, "__DECIMAL_SEPARATOR__", JavaTypesManager.CHARACTER);
|
|
|
|
String filenameOrStream = ElementParameterParser.getValue(node, "__FILENAME__");
|
|
String useUrl = ElementParameterParser.getValue(node, "__USEURL__");
|
|
boolean isUseUrl = "true".equals(useUrl);
|
|
String urlpath = ElementParameterParser.getValue(node, "__URLPATH__");
|
|
|
|
String readBy = ElementParameterParser.getValue(node, "__READ_BY__");
|
|
|
|
if("XPATH".equals(readBy)){
|
|
%>
|
|
<%@ include file="./xpath.javajet"%>
|
|
<%
|
|
}else if("JSONPATH".equals(readBy)) {
|
|
%>
|
|
<%@ include file="./jsonpath.javajet"%>
|
|
<%
|
|
} else {
|
|
%>
|
|
<%@ include file="./jsonpath_javascript_api.javajet"%>
|
|
<%
|
|
}
|
|
%>
|