Compare commits

...

1 Commits

5 changed files with 18 additions and 1 deletions

View File

@@ -22,6 +22,9 @@ skeleton="../templates/db_output_bulk.skeleton"
CodeGeneratorArgument codeGenArgument = (CodeGeneratorArgument) argument;
INode node = (INode)codeGenArgument.getArgument();
String cid = node.getUniqueName();
if(cid.matches("^.*?tOracleOutputBulkExec_\\d+_tOBE$")){
cid = cid.substring(0,cid.length()-5);// 5 ==> "_tOBE".length();
}
String host = ElementParameterParser.getValue(node, "__HOST__");
String port = ElementParameterParser.getValue(node, "__PORT__");
String dbname = ElementParameterParser.getValue(node, "__DBNAME__");

View File

@@ -18,6 +18,9 @@
CodeGeneratorArgument codeGenArgument = (CodeGeneratorArgument) argument;
INode node = (INode)codeGenArgument.getArgument();
String cid = node.getUniqueName();
if(cid.matches("^.*?tOracleOutputBulkExec_\\d+_tOBE$")){
cid = cid.substring(0,cid.length()-5);// 5 ==> "_tOBE".length();
}
String dataAction = ElementParameterParser.getValue(node,"__DATA_ACTION__");
String dbmsId = ElementParameterParser.getValue(node,"__MAPPING__");
boolean useExistingConn = ("true").equals(ElementParameterParser.getValue(node,"__USE_EXISTING_CONNECTION__"));

View File

@@ -753,5 +753,10 @@
<IMPORT NAME="ORACLE_8" MODULE="ojdbc12.jar" MVN="mvn:org.talend.libraries/ojdbc12/6.0.0" REQUIRED_IF="(DB_VERSION == 'ORACLE_8') AND (USE_EXISTING_CONNECTION == 'false')" />
</IMPORTS>
</CODEGENERATION>
<RETURNS/>
<RETURNS>
<RETURN NAME="NB_LINE_DATA" TYPE="id_Integer" AVAILABILITY="AFTER"/>
<RETURN NAME="NB_LINE_BAD" TYPE="id_Integer" AVAILABILITY="AFTER"/>
<RETURN NAME="NB_LINE_INSERTED" TYPE="id_Integer" AVAILABILITY="AFTER"/>
<RETURN NAME="RETURN_CODE" TYPE="id_Integer" AVAILABILITY="AFTER"/>
</RETURNS>
</COMPONENT>

View File

@@ -27,6 +27,9 @@ INTO_TABLE_CLAUSE.NAME=INTO TABLE clause
LOCAL_SERVICE_NAME.NAME=Local Service Name
LONG_NAME=Loads efficiently data from a flow
NB_LINE.NAME=Number of line
NB_LINE_BAD.NAME=Number of bad lines
NB_LINE_DATA.NAME=Number of input lines
NB_LINE_INSERTED.NAME=Number of inserted lines
NULL_CHAR.NAME=Null Char
OPTIONS.ITEM.KEY=Parameter
OPTIONS.ITEM.KEY.ITEM.BINDSIZE=BINDSIZE(Max bing array size)\:integer value

View File

@@ -36,6 +36,9 @@ imports="
return;
}
this.cid = node.getUniqueName();
if(cid.matches("^.*?tOracleOutputBulkExec_\\d+_tOBE$")){
cid = cid.substring(0,cid.length()-5);// 5 ==> "_tOBE".length();
}
this.isLog4jEnabled = ("true").equals(ElementParameterParser.getValue(node.getProcess(), "__LOG4J_ACTIVATE__"));
String useConn = ElementParameterParser.getValue(node,"__USE_EXISTING_CONNECTION__");
if(useConn == null || "".equals(useConn) || "true".equals(useConn)){