Compare commits

...

3 Commits

Author SHA1 Message Date
jzhao-talend
9cef13b946 fix(TDI-46297):FCB 'EnableRegionalDisco' is disabled error when using
tMicrosoftCrmInput
2021-06-23 12:05:06 +08:00
pyzhou
d040c3b781 fix(TDI-44917):error message compile error (#6337) 2021-06-16 11:00:16 +08:00
Dmytro Grygorenko
e0e744bfd7 fix(TDI-46065): Redshift - add "Credential Provider" option to XML layout. (#6207) (#6326) 2021-06-11 11:43:14 +03:00
19 changed files with 315 additions and 201 deletions

View File

@@ -83,7 +83,6 @@ if (useSpatialOptions) {
targetSRID = Integer.parseInt(ElementParameterParser.getValue(node,"__SRID__"));
}
catch (NumberFormatException e) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
%>
// TODO unable to parse integer: <%=ElementParameterParser.getValue(node,"__SRID__")%>
// TODO error: <%=e.getMessage()%>
@@ -456,12 +455,12 @@ if (xmlTypeExist || clobTypeExist) {
// Close the temporary CLOB
tempClob.close();
} catch( java.sql.SQLException sqlexp){
globalMap.put("<%=cid%>_ERROR_MESSAGE",sqlexp.getMessage());
globalMap.put("<%=cid%>_ERROR_MESSAGE",sqlexp.getMessage());
<%dbLog.logPrintedException("sqlexp.getMessage()");%>
tempClob.freeTemporary();
sqlexp.printStackTrace();
} catch(java.lang.Exception exp){
globalMap.put("<%=cid%>_ERROR_MESSAGE",exp.getMessage());
globalMap.put("<%=cid%>_ERROR_MESSAGE",exp.getMessage());
<%dbLog.logPrintedException("exp.getMessage()");%>
tempClob.freeTemporary();
exp.printStackTrace();

View File

@@ -78,7 +78,6 @@ imports="
targetSRID = Integer.parseInt(ElementParameterParser.getValue(node,"__SRID__"));
}
catch (NumberFormatException e) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
%>
// TODO unable to parse integer: <%=ElementParameterParser.getValue(node,"__SRID__")%>
// TODO error: <%=e.getMessage()%>
@@ -129,7 +128,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
stmtCreateIndex_<%=cid%>.execute(dropIndex_<%=cid %>);
<%dbLog.data().sqlExecuteDone(dbLog.var("dropIndex"));%>
} catch (java.sql.SQLException e) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
<%dbLog.logIgnoredException("e.getMessage()");%>
}
@@ -184,7 +183,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
<%dbLog.batch().executeDone(dbLog.str(dataAction));%>
}
}catch (java.sql.BatchUpdateException e){
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
<%if(("true").equals(dieOnError)) {
%>
throw(e);

View File

@@ -375,7 +375,6 @@ IMetadataColumn talendDynCol = null;
targetSRID = Integer.parseInt(ElementParameterParser.getValue(node,"__SRID__"));
}
catch (NumberFormatException e) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
%>
// TODO unable to parse integer: <%=ElementParameterParser.getValue(node,"__SRID__")%>
// TODO error: <%=e.getMessage()%>
@@ -458,7 +457,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
insertedCount_<%=cid%> = insertedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
<%dbLog.data().inserting(dbLog.var("nb_line"));%>
} catch(java.lang.Exception e) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
whetherReject_<%=cid%> = true;
<%
if (("true").equals(dieOnError)) {
@@ -601,7 +600,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
updatedCount_<%=cid%> = updatedCount_<%=cid%> + pstmt_<%=cid %>.executeUpdate();
<%dbLog.data().updating(dbLog.var("nb_line"));%>
} catch(java.lang.Exception e) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
whetherReject_<%=cid%> = true;
<%
if (("true").equals(dieOnError)) {
@@ -768,7 +767,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
nb_line_<%=cid%>++;
<%dbLog.data().updating(dbLog.var("nb_line"));%>
} catch(java.lang.Exception e) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
whetherReject_<%=cid%> = true;
<%
if (("true").equals(dieOnError)) {
@@ -850,7 +849,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
nb_line_<%=cid%>++;
<%dbLog.data().inserting(dbLog.var("nb_line"));%>
} catch(java.lang.Exception e) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
whetherReject_<%=cid%> = true;
<%
if (("true").equals(dieOnError)) {
@@ -1042,7 +1041,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
<%dbLog.data().updating(dbLog.var("nb_line"));%>
}
} catch(java.lang.Exception e) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
whetherReject_<%=cid%> = true;
<%
if (("true").equals(dieOnError)) {
@@ -1133,7 +1132,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
nb_line_<%=cid%>++;
<%dbLog.data().deleting(dbLog.var("nb_line"));%>
} catch(java.lang.Exception e) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
whetherReject_<%=cid%> = true;
<%
if (("true").equals(dieOnError)) {
@@ -1203,7 +1202,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
pstmt_<%=cid %>.executeBatch();
<%dbLog.batch().executeDone(dbLog.str(dataAction));%>
}catch (java.sql.BatchUpdateException e){
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
<%if(("true").equals(dieOnError)) {
%>
throw(e);
@@ -1252,7 +1251,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
pstmt_<%=cid %>.executeBatch();
<%dbLog.batch().executeDone(dbLog.str(dataAction));%>
}catch (java.sql.BatchUpdateException e){
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
<%if(("true").equals(dieOnError)) {
%>
throw(e);

View File

@@ -50,7 +50,6 @@
try {
instanceCount = Integer.parseInt(ElementParameterParser.getValue(node, "__INSTANCE_COUNT__"));
} catch (Exception e) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
%>
if(true) {
@@ -107,7 +106,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
client_<%=cid%>.resumeNode(instanceId);
hasToCreateNode_<%=cid%> = false;
} catch(com.google.common.util.concurrent.UncheckedExecutionException e_<%=cid%>) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",e_<%=cid%>.getMessage());
globalMap.put("<%=cid%>_ERROR_MESSAGE",e_<%=cid%>.getMessage());
boolean ignoreException_<%=cid%> = false;
if(e_<%=cid%>.getCause()!=null && (e_<%=cid%>.getCause() instanceof java.lang.NullPointerException)) {
if("name".equals(e_<%=cid%>.getCause().getMessage())) {
@@ -184,7 +183,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e_<%=cid%>.getMessage());
try {
nodes_<%=cid%> = context_<%=cid%>.getComputeService().createNodesInGroup(<%=instanceName%>.toLowerCase(), <%=instanceCount%>, template_<%=cid%>);
} catch(com.google.common.util.concurrent.UncheckedExecutionException e_<%=cid%>) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",e_<%=cid%>.getMessage());
globalMap.put("<%=cid%>_ERROR_MESSAGE",e_<%=cid%>.getMessage());
boolean ignoreException_<%=cid%> = false;
if(e_<%=cid%>.getCause()!=null && (e_<%=cid%>.getCause() instanceof java.lang.NullPointerException)) {
if("name".equals(e_<%=cid%>.getCause().getMessage())) {

View File

@@ -200,8 +200,7 @@
// to 1 (lesser values do not make sense).
sqlBuffer_<%=cid %>.append(",\n ERROR_COUNT=" + <%=errorInt%>);
<%
} catch (NumberFormatException nfe) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",nfe.getMessage());
} catch (NumberFormatException nfe) {
System.err.println(nfe.getStackTrace());
}
}
@@ -331,7 +330,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",nfe.getMessage());
log.debug("<%=cid%> - Generate command into file:"+executableFilePath_<%=cid %>+".");
<%}%>
} catch (java.lang.Exception e) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
<%log4jCodeGenerateUtil.logError(node,"error");%>
e.printStackTrace();
}
@@ -368,7 +367,6 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
reader.close();
}
} catch(java.io.IOException ioe) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",ioe.getMessage());
<%log4jCodeGenerateUtil.logError(node,"error","ioe");%>
ioe.printStackTrace();
}
@@ -400,7 +398,6 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",ioe.getMessage());
reader.close();
}
} catch(java.io.IOException ioe) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",ioe.getMessage());
<%log4jCodeGenerateUtil.logError(node,"error","ioe");%>
ioe.printStackTrace();
}
@@ -447,8 +444,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",ioe.getMessage());
} finally {
reader.close();
}
} catch(java.io.IOException ioe) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",ioe.getMessage());
} catch(java.io.IOException ioe) {
<%log4jCodeGenerateUtil.logError(node,"error","ioe");%>
ioe.printStackTrace();
}
@@ -479,8 +475,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",ioe.getMessage());
} finally {
reader.close();
}
} catch(java.io.IOException ioe) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",ioe.getMessage());
} catch(java.io.IOException ioe) {
<%log4jCodeGenerateUtil.logError(node,"error","ioe");%>
ioe.printStackTrace();
}
@@ -534,7 +529,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",ioe.getMessage());
}
%>
} catch (java.lang.Exception e) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
<%log4jCodeGenerateUtil.logError(node,"error");%>
e.printStackTrace();
}

View File

@@ -40,6 +40,8 @@ if ((metadatas != null) && (metadatas.size() > 0)) {
boolean debug = ("true").equals(ElementParameterParser.getValue(node,"__DEBUG__"));
boolean isAPI2011 = ("API_2011").equals(ElementParameterParser.getValue(node,"__API_VERSION__"));
String discWSDL = ElementParameterParser.getValue(node, "__DISC_WSDL__");
String applicationId = ElementParameterParser.getValue(node, "__APPLICATION_ID__");
String authority = ElementParameterParser.getValue(node, "__AUTHORITY__");
if(debug){%>
System.setProperty("org.apache.commons.logging.Log", "org.apache.commons.logging.impl.SimpleLog");
System.setProperty("org.apache.commons.logging.simplelog.showdatetime", "true");
@@ -351,12 +353,14 @@ if ((metadatas != null) && (metadatas.size() > 0)) {
}else{//api 2011
%>
org.talend.ms.crm.MSCRMClient client_<%=cid%> = new org.talend.ms.crm.MSCRMClient(<%=username%>, decryptedPassword_<%=cid%>, <%=orgName%>);
client_<%=cid%>.setTimeout(<%=timeout%>);
client_<%=cid%>.setReuseHttpClient(<%=reuseHttpClient%>);
client_<%=cid%>.setMaxConnectionRetries(reConnMaxNum_<%=cid%>);
client_<%=cid%>.setAttemptsInterval(<%=attemptsInterval%>);
com.microsoft.schemas.xrm._2011.contracts.OrganizationServiceStub serviceStub_<%=cid%> = client_<%=cid%>.getOnlineConnection(<%=discWSDL%>);
org.talend.ms.crm.odata.ClientConfiguration clientConfig_<%=cid%> = org.talend.ms.crm.odata.ClientConfigurationFactory
.buildOAuthNativeClientConfiguration(<%=applicationId%>, <%=username%>, decryptedPassword_<%=cid%>, <%=authority%>);
clientConfig_<%=cid%>.setTimeout(<%=timeout%>);
clientConfig_<%=cid%>.setReuseHttpClient(<%=reuseHttpClient%>);
clientConfig_<%=cid%>.setMaxRetry(reConnMaxNum_<%=cid%>,<%=attemptsInterval%>);
org.talend.ms.crm.MSCRMClient client_<%=cid%> = new org.talend.ms.crm.MSCRMClient(clientConfig_<%=cid%>, <%=orgName%>,<%=discWSDL%> );
com.microsoft.schemas.xrm._2011.contracts.OrganizationServiceStub serviceStub_<%=cid%> = client_<%=cid%>.getOnlineConnection();
<%
String entityname = ElementParameterParser.getValue(node, "__ENTITYNAME__").trim();
String customEntityname = ElementParameterParser.getValue(node, "__CUSTOM_ENTITY_NAME__");

View File

@@ -104,7 +104,7 @@
<PARAMETER NAME="DISC_WSDL" FIELD="TEXT" NUM_ROW="20" REQUIRED="true"
SHOW_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')">
<DEFAULT>"https://disco.crm.dynamics.com/XRMServices/2011/Discovery.svc"</DEFAULT>
<DEFAULT>"https://globaldisco.crm.dynamics.com/api/discovery/v2.0/Instances"</DEFAULT>
</PARAMETER>
<PARAMETER NAME="SERVICE_ROOT_URL" FIELD="TEXT" NUM_ROW="22" REQUIRED="true"
@@ -133,15 +133,15 @@
<DEFAULT>""</DEFAULT>
</PARAMETER>
<PARAMETER NAME="APPLICATION_ID" FIELD="TEXT" NUM_ROW="30" REQUIRED="true" SHOW_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR (AUTH_TYPE=='ON_PREMISE' AND MS_CRM_VERSION=='CRM_2016' AND PREMISE_AUTH=='OAUTH')">
<DEFAULT>""</DEFAULT>
<PARAMETER NAME="APPLICATION_ID" FIELD="TEXT" NUM_ROW="30" REQUIRED="true" SHOW_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR (AUTH_TYPE=='ON_PREMISE' AND MS_CRM_VERSION=='CRM_2016' AND PREMISE_AUTH=='OAUTH')">
<DEFAULT>"51f81489-12ee-4a9e-aaae-a2591f45987d"</DEFAULT>
</PARAMETER>
<PARAMETER NAME="CLIENT_SECRET" FIELD="TEXT" NUM_ROW="30" REQUIRED="true" SHOW_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA') AND (ONLINE_REGISTERED_APP != 'NATIVE')">
<DEFAULT>""</DEFAULT>
</PARAMETER>
<PARAMETER NAME="AUTHORITY" FIELD="TEXT" NUM_ROW="35" REQUIRED="true" SHOW_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR (AUTH_TYPE=='ON_PREMISE' AND MS_CRM_VERSION=='CRM_2016' AND PREMISE_AUTH=='OAUTH')">
<PARAMETER NAME="AUTHORITY" FIELD="TEXT" NUM_ROW="35" REQUIRED="true" SHOW_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR (AUTH_TYPE=='ON_PREMISE' AND MS_CRM_VERSION=='CRM_2016' AND PREMISE_AUTH=='OAUTH')">
<DEFAULT>"https://login.windows.net/common/oauth2/authorize"</DEFAULT>
</PARAMETER>
@@ -27552,7 +27552,7 @@
<IMPORT NAME="jcifs" MODULE="jcifs-1.3.0.jar" MVN="mvn:org.talend.libraries/jcifs-1.3.0/6.0.0" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')" />
<!-- 2011 -->
<!-- crm client -->
<IMPORT NAME="talend-mscrm" MODULE="talend-mscrm-3.5-20210518.jar" MVN="mvn:org.talend.components/talend-mscrm/3.5-20210518" REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION =='API_2016_ODATA' OR API_VERSION =='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT NAME="talend-mscrm" MODULE="talend-mscrm-3.6-20210618.jar" MVN="mvn:org.talend.components/talend-mscrm/3.6-20210618" REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION =='API_2016_ODATA' OR API_VERSION =='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<!-- axis2 1.7.4 -->
<IMPORT NAME="activation-1.1" MODULE="activation-1.1.jar" MVN="mvn:org.talend.libraries/activation-1.1/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/activation-1.1.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="axiom-api-1.2.20" MODULE="axiom-api-1.2.20.jar" MVN="mvn:org.talend.libraries/axiom-api-1.2.20/6.0.0" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
@@ -27565,7 +27565,6 @@
<IMPORT NAME="commons-cli-1.2" MODULE="commons-cli-1.2.jar" MVN="mvn:commons-cli/commons-cli/1.2" UrlPath="platform:/plugin/org.talend.libraries.apache.common/lib/commons-cli-1.2.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="geronimo-stax-api_1.0_spec-1.0.1" MODULE="geronimo-stax-api_1.0_spec-1.0.1.jar" MVN="mvn:org.talend.libraries/geronimo-stax-api_1.0_spec-1.0.1/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/geronimo-stax-api_1.0_spec-1.0.1.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="jaxen-1.1.6" MODULE="jaxen-1.1.6.jar" MVN="mvn:jaxen/jaxen/1.1.6" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" BundleID="" />
<IMPORT NAME="mail-1.4.7" MODULE="mail-1.4.7.jar" MVN="mvn:javax.mail/mail/1.4.7" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="neethi-3.0.3" MODULE="neethi-3.0.3.jar" MVN="mvn:org.apache.neethi/neethi/3.0.3" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="WSDL4J-1_6_3" MODULE="wsdl4j-1.6.3.jar" MVN="mvn:wsdl4j/wsdl4j/1.6.3" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="wstx-asl-3.2.9" MODULE="wstx-asl-3.2.9.jar" MVN="mvn:org.talend.libraries/wstx-asl-3.2.9/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/wstx-asl-3.2.9.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
@@ -27578,11 +27577,6 @@
<IMPORT NAME="woden-api-1.0M9" MODULE="woden-api-1.0M9.jar" MVN="mvn:org.talend.libraries/woden-api-1.0M9/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/woden-api-1.0M9.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="woden-impl-commons-1.0M9" MODULE="woden-impl-commons-1.0M9.jar" MVN="mvn:org.talend.libraries/woden-impl-commons-1.0M9/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/woden-impl-commons-1.0M9.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="woden-impl-dom-1.0M9" MODULE="woden-impl-dom-1.0M9.jar" MVN="mvn:org.talend.libraries/woden-impl-dom-1.0M9/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/woden-impl-dom-1.0M9.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<!-- httpclient 4.2.1 -->
<IMPORT NAME="commons-codec-1.14" MODULE="commons-codec-1.14.jar" MVN="mvn:commons-codec/commons-codec/1.14" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="commons-logging" MODULE="commons-logging-1.2.jar" MVN="mvn:commons-logging/commons-logging/1.2" UrlPath="platform:/base/plugins/org.apache.commons.logging_1.2.0.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')"/>
<IMPORT NAME="httpcore-4.4.13" MODULE="httpcore-4.4.13.jar" MVN="mvn:org.apache.httpcomponents/httpcore/4.4.13" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="httpclient-4.5.13" MODULE="httpclient-4.5.13.jar" MVN="mvn:org.apache.httpcomponents/httpclient/4.5.13" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<!-- log4j -->
<IMPORT NAME="Driver-Commons-log4j-1.2.17" MODULE="log4j-1.2.17.jar" MVN="mvn:log4j/log4j/1.2.17" UrlPath="platform:/plugin/org.talend.libraries.apache/lib/log4j-1.2.17.jar" REQUIRED="true" BundleID="" />
<!-- Jars for CRM 2015 CXF begin -->
@@ -27802,126 +27796,126 @@
NAME="aalto-xml-0.9.10"
MODULE="aalto-xml-0.9.10.jar"
MVN="mvn:org.talend.libraries/aalto-xml-0.9.10/6.4.0"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="adal4j-1.1.1-20191012"
MODULE="adal4j-1.1.1-20191012.jar"
MVN="mvn:com.microsoft.azure/adal4j/1.1.1-20191012"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="commons-codec-1.14"
MODULE="commons-codec-1.14.jar"
MVN="mvn:commons-codec/commons-codec/1.14"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="apache-commons-io"
MODULE="commons-io-2.4.jar"
MVN="mvn:commons-io/commons-io/2.4"
UrlPath="platform:/plugin/org.talend.libraries.apache.common/lib/commons-io-2.4.jar"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="commons-lang3-3.8.1.jar"
MODULE="commons-lang3-3.8.1.jar"
MVN="mvn:org.apache.commons/commons-lang3/3.8.1"
UrlPath="platform:/plugin/org.talend.libraries.apache.common/lib/commons-lang3-3.8.1.jar"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="gson-2.3.1"
MODULE="gson-2.3.1.jar"
MVN="mvn:org.talend.libraries/gson-2.3.1/6.1.0"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="commons-logging"
MODULE="commons-logging-1.2.jar"
MVN="mvn:commons-logging/commons-logging/1.2"
UrlPath="platform:/base/plugins/org.apache.commons.logging_1.2.0.jar"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="httpcore-4.4.13"
MODULE="httpcore-4.4.13.jar"
MVN="mvn:org.apache.httpcomponents/httpcore/4.4.13"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="httpclient-4.5.13"
MODULE="httpclient-4.5.13.jar"
MVN="mvn:org.apache.httpcomponents/httpclient/4.5.13"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="jackson-core-2.11.4.jar"
MODULE="jackson-core-2.11.4.jar"
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.11.4"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="jackson-databind-2.11.4.jar"
MODULE="jackson-databind-2.11.4.jar"
MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.11.4"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="jackson-annotations-2.11.4.jar"
MODULE="jackson-annotations-2.11.4.jar"
MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.11.4"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="json-smart-2.4.2.jar"
MODULE="json-smart-2.4.2.jar"
MVN="mvn:net.minidev/json-smart/2.4.2"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="accessors-smart-1.1"
MODULE="accessors-smart-1.1.jar"
MVN="mvn:net.minidev/accessors-smart/1.1"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="mail-1.4.7"
MODULE="mail-1.4.7.jar"
MVN="mvn:javax.mail/mail/1.4.7"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="nimbus-jose-jwt-3.1.2"
MODULE="nimbus-jose-jwt-3.1.2.jar"
MVN="mvn:org.talend.libraries/nimbus-jose-jwt-3.1.2/6.4.0"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="oauth2-oidc-sdk-4.5"
MODULE="oauth2-oidc-sdk-4.5.jar"
MVN="mvn:org.talend.libraries/oauth2-oidc-sdk-4.5/6.4.0"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="odata-client-core-4.7.1"
MODULE="odata-client-core-4.7.1.jar"
MVN="mvn:org.apache.olingo/odata-client-core/4.7.1"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="odata-client-api-4.7.1"
MODULE="odata-client-api-4.7.1.jar"
MVN="mvn:org.apache.olingo/odata-client-api/4.7.1"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="odata-commons-api-4.7.1"
MODULE="odata-commons-api-4.7.1.jar"
MVN="mvn:org.apache.olingo/odata-commons-api/4.7.1"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="odata-commons-core-4.7.1"
MODULE="odata-commons-core-4.7.1.jar"
MVN="mvn:org.apache.olingo/odata-commons-core/4.7.1"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="slf4j-api-1.7.12"
MODULE="slf4j-api-1.7.12.jar"
MVN="mvn:org.talend.libraries/slf4j-api-1.7.12/6.0.0"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="slf4j-simple-1.7.2"
MODULE="slf4j-simple-1.7.2.jar"
MVN="mvn:org.talend.libraries/slf4j-simple-1.7.2/6.0.0"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<IMPORT
NAME="stax2-api-3.1.4"
MODULE="stax2-api-3.1.4.jar"
MVN="mvn:org.talend.libraries/stax2-api-3.1.4/6.0.0"
UrlPath="platform:/plugin/org.talend.libraries.apache.cxf/lib/stax2-api-3.1.4.jar"
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
REQUIRED_IF="(((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE=='ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018')))" />
<!-- CRM 2016 odata end -->
</IMPORTS>

View File

@@ -21,6 +21,8 @@ imports="
boolean debug = ("true").equals(ElementParameterParser.getValue(node,"__DEBUG__"));
boolean isAPI2011 = ("API_2011").equals(ElementParameterParser.getValue(node,"__API_VERSION__"));
String discWSDL = ElementParameterParser.getValue(node, "__DISC_WSDL__");
String applicationId = ElementParameterParser.getValue(node, "__APPLICATION_ID__");
String authority = ElementParameterParser.getValue(node, "__AUTHORITY__");
%>
int nb_line_<%=cid%> = 0;
<%if(debug){%>
@@ -94,11 +96,13 @@ imports="
<%}
}else{
%>
org.talend.ms.crm.MSCRMClient client_<%=cid%> = new org.talend.ms.crm.MSCRMClient(<%=username%>, decryptedPassword_<%=cid%>, <%=orgName%>);
client_<%=cid%>.setTimeout(<%=timeout%>);
client_<%=cid%>.setReuseHttpClient(<%=reuseHttpClient%>);
client_<%=cid%>.setMaxConnectionRetries(reConnMaxNum_<%=cid%>);
client_<%=cid%>.setAttemptsInterval(<%=attemptsInterval%>);
com.microsoft.schemas.xrm._2011.contracts.OrganizationServiceStub serviceStub_<%=cid%> = client_<%=cid%>.getOnlineConnection(<%=discWSDL%>);
org.talend.ms.crm.odata.ClientConfiguration clientConfig_<%=cid%> = org.talend.ms.crm.odata.ClientConfigurationFactory
.buildOAuthNativeClientConfiguration(<%=applicationId%>, <%=username%>, decryptedPassword_<%=cid%>, <%=authority%>);
clientConfig_<%=cid%>.setTimeout(<%=timeout%>);
clientConfig_<%=cid%>.setReuseHttpClient(<%=reuseHttpClient%>);
clientConfig_<%=cid%>.setMaxRetry(reConnMaxNum_<%=cid%>,<%=attemptsInterval%>);
org.talend.ms.crm.MSCRMClient client_<%=cid%> = new org.talend.ms.crm.MSCRMClient(clientConfig_<%=cid%>, <%=orgName%>,<%=discWSDL%> );
com.microsoft.schemas.xrm._2011.contracts.OrganizationServiceStub serviceStub_<%=cid%> = client_<%=cid%>.getOnlineConnection();
<%
}%>

View File

@@ -104,7 +104,7 @@
<PARAMETER NAME="DISC_WSDL" FIELD="TEXT" NUM_ROW="30" REQUIRED="true"
SHOW_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')">
<DEFAULT>"https://disco.crm.dynamics.com/XRMServices/2011/Discovery.svc"</DEFAULT>
<DEFAULT>"https://globaldisco.crm.dynamics.com/api/discovery/v2.0/Instances"</DEFAULT>
</PARAMETER>
<PARAMETER NAME="SERVICE_ROOT_URL" FIELD="TEXT" NUM_ROW="31" REQUIRED="true"
@@ -133,15 +133,15 @@
<DEFAULT>""</DEFAULT>
</PARAMETER>
<PARAMETER NAME="APPLICATION_ID" FIELD="TEXT" NUM_ROW="40" REQUIRED="true" SHOW_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR (AUTH_TYPE=='ON_PREMISE' AND MS_CRM_VERSION=='CRM_2016' AND PREMISE_AUTH=='OAUTH')">
<DEFAULT>""</DEFAULT>
<PARAMETER NAME="APPLICATION_ID" FIELD="TEXT" NUM_ROW="40" REQUIRED="true" SHOW_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR (AUTH_TYPE=='ON_PREMISE' AND MS_CRM_VERSION=='CRM_2016' AND PREMISE_AUTH=='OAUTH')">
<DEFAULT>"51f81489-12ee-4a9e-aaae-a2591f45987d"</DEFAULT>
</PARAMETER>
<PARAMETER NAME="CLIENT_SECRET" FIELD="TEXT" NUM_ROW="40" REQUIRED="true" SHOW_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA') AND (ONLINE_REGISTERED_APP != 'NATIVE')">
<DEFAULT>""</DEFAULT>
</PARAMETER>
<PARAMETER NAME="AUTHORITY" FIELD="TEXT" NUM_ROW="42" REQUIRED="true" SHOW_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR (AUTH_TYPE=='ON_PREMISE' AND MS_CRM_VERSION=='CRM_2016' AND PREMISE_AUTH=='OAUTH')">
<PARAMETER NAME="AUTHORITY" FIELD="TEXT" NUM_ROW="42" REQUIRED="true" SHOW_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR (AUTH_TYPE=='ON_PREMISE' AND MS_CRM_VERSION=='CRM_2016' AND PREMISE_AUTH=='OAUTH')">
<DEFAULT>"https://login.windows.net/common/oauth2/authorize"</DEFAULT>
</PARAMETER>
@@ -38308,7 +38308,7 @@
<IMPORT NAME="jcifs" MODULE="jcifs-1.3.0.jar" MVN="mvn:org.talend.libraries/jcifs-1.3.0/6.0.0" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')" />
<!-- 2011 -->
<!-- crm client -->
<IMPORT NAME="talend-mscrm" MODULE="talend-mscrm-3.5-20210518.jar" MVN="mvn:org.talend.components/talend-mscrm/3.5-20210518" REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION =='API_2016_ODATA' OR API_VERSION =='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT NAME="talend-mscrm" MODULE="talend-mscrm-3.6-20210618.jar" MVN="mvn:org.talend.components/talend-mscrm/3.6-20210618" REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION =='API_2016_ODATA' OR API_VERSION =='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<!-- axis2 1.7.4 -->
<IMPORT NAME="activation-1.1" MODULE="activation-1.1.jar" MVN="mvn:org.talend.libraries/activation-1.1/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/activation-1.1.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="axiom-api-1.2.20" MODULE="axiom-api-1.2.20.jar" MVN="mvn:org.talend.libraries/axiom-api-1.2.20/6.0.0" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
@@ -38321,7 +38321,6 @@
<IMPORT NAME="commons-cli-1.2" MODULE="commons-cli-1.2.jar" MVN="mvn:commons-cli/commons-cli/1.2" UrlPath="platform:/plugin/org.talend.libraries.apache.common/lib/commons-cli-1.2.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="geronimo-stax-api_1.0_spec-1.0.1" MODULE="geronimo-stax-api_1.0_spec-1.0.1.jar" MVN="mvn:org.talend.libraries/geronimo-stax-api_1.0_spec-1.0.1/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/geronimo-stax-api_1.0_spec-1.0.1.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="jaxen-1.1.6" MODULE="jaxen-1.1.6.jar" MVN="mvn:jaxen/jaxen/1.1.6" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" BundleID="" />
<IMPORT NAME="mail-1.4.7" MODULE="mail-1.4.7.jar" MVN="mvn:javax.mail/mail/1.4.7" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="neethi-3.0.3" MODULE="neethi-3.0.3.jar" MVN="mvn:org.apache.neethi/neethi/3.0.3" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="WSDL4J-1_6_3" MODULE="wsdl4j-1.6.3.jar" MVN="mvn:wsdl4j/wsdl4j/1.6.3" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="wstx-asl-3.2.9" MODULE="wstx-asl-3.2.9.jar" MVN="mvn:org.talend.libraries/wstx-asl-3.2.9/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/wstx-asl-3.2.9.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
@@ -38334,11 +38333,6 @@
<IMPORT NAME="woden-api-1.0M9" MODULE="woden-api-1.0M9.jar" MVN="mvn:org.talend.libraries/woden-api-1.0M9/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/woden-api-1.0M9.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="woden-impl-commons-1.0M9" MODULE="woden-impl-commons-1.0M9.jar" MVN="mvn:org.talend.libraries/woden-impl-commons-1.0M9/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/woden-impl-commons-1.0M9.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="woden-impl-dom-1.0M9" MODULE="woden-impl-dom-1.0M9.jar" MVN="mvn:org.talend.libraries/woden-impl-dom-1.0M9/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/woden-impl-dom-1.0M9.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<!-- httpclient 4.2.1 -->
<IMPORT NAME="commons-codec-1.14.jar" MODULE="commons-codec-1.14.jar" MVN="mvn:commons-codec/commons-codec/1.14" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="commons-logging" MODULE="commons-logging-1.2.jar" MVN="mvn:commons-logging/commons-logging/1.2" UrlPath="platform:/base/plugins/org.apache.commons.logging_1.2.0.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')"/>
<IMPORT NAME="httpcore-4.4.13" MODULE="httpcore-4.4.13.jar" MVN="mvn:org.apache.httpcomponents/httpcore/4.4.13" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="httpclient-4.5.13" MODULE="httpclient-4.5.13.jar" MVN="mvn:org.apache.httpcomponents/httpclient/4.5.13" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<!-- log4j -->
<IMPORT NAME="Driver-Commons-log4j-1.2.17" MODULE="log4j-1.2.17.jar" MVN="mvn:log4j/log4j/1.2.17" UrlPath="platform:/plugin/org.talend.libraries.apache/lib/log4j-1.2.17.jar" REQUIRED="true" BundleID="" />
<!-- Jars for CRM 2015 CXF begin -->
@@ -38564,126 +38558,126 @@
NAME="aalto-xml-0.9.10"
MODULE="aalto-xml-0.9.10.jar"
MVN="mvn:org.talend.libraries/aalto-xml-0.9.10/6.4.0"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="adal4j-1.1.1-20191012"
MODULE="adal4j-1.1.1-20191012.jar"
MVN="mvn:com.microsoft.azure/adal4j/1.1.1-20191012"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="commons-codec-1.14.jar"
MODULE="commons-codec-1.14.jar"
MVN="mvn:commons-codec/commons-codec/1.14"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="apache-commons-io"
MODULE="commons-io-2.4.jar"
MVN="mvn:commons-io/commons-io/2.4"
UrlPath="platform:/plugin/org.talend.libraries.apache.common/lib/commons-io-2.4.jar"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="commons-lang3-3.8.1.jar"
MODULE="commons-lang3-3.8.1.jar"
MVN="mvn:org.apache.commons/commons-lang3/3.8.1"
UrlPath="platform:/plugin/org.talend.libraries.apache.common/lib/commons-lang3-3.8.1.jar"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="gson-2.3.1"
MODULE="gson-2.3.1.jar"
MVN="mvn:org.talend.libraries/gson-2.3.1/6.1.0"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="commons-logging"
MODULE="commons-logging-1.2.jar"
MVN="mvn:commons-logging/commons-logging/1.2"
UrlPath="platform:/base/plugins/org.apache.commons.logging_1.2.0.jar"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="httpcore-4.4.13"
MODULE="httpcore-4.4.13.jar"
MVN="mvn:org.apache.httpcomponents/httpcore/4.4.13"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="httpclient-4.5.13"
MODULE="httpclient-4.5.13.jar"
MVN="mvn:org.apache.httpcomponents/httpclient/4.5.13"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="jackson-core-2.11.4.jar"
MODULE="jackson-core-2.11.4.jar"
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.11.4"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="jackson-databind-2.11.4.jar"
MODULE="jackson-databind-2.11.4.jar"
MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.11.4"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="jackson-annotations-2.11.4.jar"
MODULE="jackson-annotations-2.11.4.jar"
MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.11.4"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="json-smart-2.4.2.jar"
MODULE="json-smart-2.4.2.jar"
MVN="mvn:net.minidev/json-smart/2.4.2"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="accessors-smart-1.1"
MODULE="accessors-smart-1.1.jar"
MVN="mvn:net.minidev/accessors-smart/1.1"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="mail-1.4.7"
MODULE="mail-1.4.7.jar"
MVN="mvn:javax.mail/mail/1.4.7"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="nimbus-jose-jwt-3.1.2"
MODULE="nimbus-jose-jwt-3.1.2.jar"
MVN="mvn:org.talend.libraries/nimbus-jose-jwt-3.1.2/6.4.0"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="oauth2-oidc-sdk-4.5"
MODULE="oauth2-oidc-sdk-4.5.jar"
MVN="mvn:org.talend.libraries/oauth2-oidc-sdk-4.5/6.4.0"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="odata-client-core-4.7.1"
MODULE="odata-client-core-4.7.1.jar"
MVN="mvn:org.apache.olingo/odata-client-core/4.7.1"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="odata-client-api-4.7.1"
MODULE="odata-client-api-4.7.1.jar"
MVN="mvn:org.apache.olingo/odata-client-api/4.7.1"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="odata-commons-api-4.7.1"
MODULE="odata-commons-api-4.7.1.jar"
MVN="mvn:org.apache.olingo/odata-commons-api/4.7.1"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="odata-commons-core-4.7.1"
MODULE="odata-commons-core-4.7.1.jar"
MVN="mvn:org.apache.olingo/odata-commons-core/4.7.1"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="slf4j-api-1.7.12"
MODULE="slf4j-api-1.7.12.jar"
MVN="mvn:org.talend.libraries/slf4j-api-1.7.12/6.0.0"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="slf4j-simple-1.7.2"
MODULE="slf4j-simple-1.7.2.jar"
MVN="mvn:org.talend.libraries/slf4j-simple-1.7.2/6.0.0"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<IMPORT
NAME="stax2-api-3.1.4"
MODULE="stax2-api-3.1.4.jar"
MVN="mvn:org.talend.libraries/stax2-api-3.1.4/6.0.0"
UrlPath="platform:/plugin/org.talend.libraries.apache.cxf/lib/stax2-api-3.1.4.jar"
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
REQUIRED_IF="((AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011' OR API_VERSION=='API_2016_ODATA' OR API_VERSION=='API_2018_ODATA')) OR ((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2016' OR MS_CRM_VERSION == 'CRM_2018'))" />
<!-- CRM 2016 odata end -->
</IMPORTS>
</CODEGENERATION>

View File

@@ -159,7 +159,6 @@ if(notNullCols != null && notNullCols.size() > 0) {
}
}
catch (java.lang.Exception e) {
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
}
*/
if (!(("").equals(maxErrors) || ("\"\"").equals(maxErrors) || ("\"0\"").equals(maxErrors))) {

View File

@@ -37,7 +37,7 @@ skeleton="../templates/db_output_bulk.skeleton"
if(useExistingS3Connection){
current_node = NodeUtil.getNodeByUniqueName(node.getProcess(),s3ConnectionCid,true);
}
boolean inheritRole = "true".equalsIgnoreCase(ElementParameterParser.getValue(current_node, "__INHERIT_CREDENTIALS__"));
boolean inheritRole = "INHERIT_CREDENTIALS".equalsIgnoreCase(ElementParameterParser.getValue(current_node, "__CREDENTIAL_PROVIDER__"));
List<IMetadataColumn> columnList = getColumnList(node);
%>
String dbschema_<%=cid%> = null;

View File

@@ -142,23 +142,27 @@
NUM_ROW="46" SHOW_IF="(USE_EXISTING_CONNECTION_S3 == 'true') AND (DATA_SOURCE_TYPE == 'S3') AND (ASSUME_ROLE == 'false')" GROUP="S3_CONFIG"/>
<PARAMETER
NAME="INHERIT_CREDENTIALS"
FIELD="CHECK"
NUM_ROW="55"
NAME="CREDENTIAL_PROVIDER"
FIELD="CLOSED_LIST"
NUM_ROW="48"
REQUIRED="true"
GROUP="S3_CONFIG"
SHOW="false"
>
<DEFAULT>false</DEFAULT>
<ITEMS DEFAULT="STATIC_CREDENTIALS"> <!-- It's just a basic one -->
<ITEM NAME="STATIC_CREDENTIALS" VALUE="STATIC_CREDENTIALS" SHOW_IF="true" />
<ITEM NAME="INHERIT_CREDENTIALS" VALUE="INHERIT_CREDENTIALS" SHOW_IF="true" />
<ITEM NAME="WEB_TOKEN" VALUE="WEB_TOKEN" SHOW_IF="false" />
</ITEMS>
</PARAMETER>
<PARAMETER NAME="ACCESS_KEY" FIELD="TEXT" NUM_ROW="50"
REQUIRED="true" GROUP="S3_CONFIG" SHOW_IF="(USE_EXISTING_CONNECTION_S3 == 'false') AND (DATA_SOURCE_TYPE == 'S3') AND (ASSUME_ROLE == 'false') AND (INHERIT_CREDENTIALS == 'false')">
REQUIRED="true" GROUP="S3_CONFIG" SHOW_IF="(USE_EXISTING_CONNECTION_S3 == 'false') AND (DATA_SOURCE_TYPE == 'S3') AND (ASSUME_ROLE == 'false') AND (CREDENTIAL_PROVIDER == 'STATIC_CREDENTIALS')">
<DEFAULT>""</DEFAULT>
</PARAMETER>
<PARAMETER NAME="SECRET_KEY" FIELD="PASSWORD" NUM_ROW="50"
REQUIRED="true" GROUP="S3_CONFIG" SHOW_IF="(USE_EXISTING_CONNECTION_S3 == 'false') AND (DATA_SOURCE_TYPE == 'S3') AND (ASSUME_ROLE == 'false') AND (INHERIT_CREDENTIALS == 'false')">
REQUIRED="true" GROUP="S3_CONFIG" SHOW_IF="(USE_EXISTING_CONNECTION_S3 == 'false') AND (DATA_SOURCE_TYPE == 'S3') AND (ASSUME_ROLE == 'false') AND (CREDENTIAL_PROVIDER == 'STATIC_CREDENTIALS')">
<DEFAULT>""</DEFAULT>
</PARAMETER>

View File

@@ -71,36 +71,40 @@
NUM_ROW="46" SHOW_IF="USE_EXISTING_CONNECTION == 'true'" GROUP="S3_CONFIG"/>
<PARAMETER
NAME="ACCESS_KEY"
FIELD="TEXT"
NAME="CREDENTIAL_PROVIDER"
FIELD="CLOSED_LIST"
NUM_ROW="50"
REQUIRED="true"
SHOW_IF="(USE_EXISTING_CONNECTION == 'false') AND (INHERIT_CREDENTIALS == 'false')"
SHOW_IF="USE_EXISTING_CONNECTION == 'false'"
GROUP="S3_CONFIG"
>
<DEFAULT>""</DEFAULT>
<ITEMS DEFAULT="STATIC_CREDENTIALS"> <!-- It's just a basic one -->
<ITEM NAME="STATIC_CREDENTIALS" VALUE="STATIC_CREDENTIALS" SHOW_IF="true" />
<ITEM NAME="INHERIT_CREDENTIALS" VALUE="INHERIT_CREDENTIALS" SHOW_IF="true" />
<ITEM NAME="WEB_TOKEN" VALUE="WEB_TOKEN" SHOW_IF="false" />
</ITEMS>
</PARAMETER>
<PARAMETER
NAME="SECRET_KEY"
FIELD="PASSWORD"
NUM_ROW="50"
NAME="ACCESS_KEY"
FIELD="TEXT"
NUM_ROW="51"
REQUIRED="true"
SHOW_IF="(USE_EXISTING_CONNECTION == 'false') AND (INHERIT_CREDENTIALS == 'false')"
SHOW_IF="(USE_EXISTING_CONNECTION == 'false') AND (CREDENTIAL_PROVIDER == 'STATIC_CREDENTIALS')"
GROUP="S3_CONFIG"
>
<DEFAULT>""</DEFAULT>
</PARAMETER>
<PARAMETER
NAME="INHERIT_CREDENTIALS"
FIELD="CHECK"
NUM_ROW="55"
NAME="SECRET_KEY"
FIELD="PASSWORD"
NUM_ROW="51"
REQUIRED="true"
GROUP="S3_CONFIG"
SHOW_IF="USE_EXISTING_CONNECTION == 'false'"
SHOW_IF="(USE_EXISTING_CONNECTION == 'false') AND (CREDENTIAL_PROVIDER == 'STATIC_CREDENTIALS')"
>
<DEFAULT>false</DEFAULT>
<DEFAULT>""</DEFAULT>
</PARAMETER>
<PARAMETER
@@ -232,9 +236,40 @@
</ITEMS>
</PARAMETER>
<PARAMETER NAME="CONFIG_CLIENT" FIELD="CHECK" NUM_ROW="40"
GROUP="S3_CONFIG" NB_LINES="5">
</PARAMETER>
<PARAMETER
NAME="WEB_IDENTITY_TOKEN_FILE"
FIELD="FILE"
NUM_ROW="40"
REQUIRED="false"
GROUP="WEB_IDENTITY_TOKEN"
SHOW_IF="isShow[CREDENTIAL_PROVIDER] AND (CREDENTIAL_PROVIDER == 'WEB_TOKEN')"
/>
<PARAMETER
NAME="WEB_TOKEN_ARN"
FIELD="TEXT"
NUM_ROW="42"
REQUIRED="false"
GROUP="WEB_IDENTITY_TOKEN"
SHOW_IF="isShow[CREDENTIAL_PROVIDER] AND (CREDENTIAL_PROVIDER == 'WEB_TOKEN')"
/>
<PARAMETER
NAME="WEB_TOKEN_ROLE_SESSION_NAME"
FIELD="TEXT"
NUM_ROW="44"
REQUIRED="false"
GROUP="WEB_IDENTITY_TOKEN"
SHOW_IF="isShow[CREDENTIAL_PROVIDER] AND (CREDENTIAL_PROVIDER == 'WEB_TOKEN')"
/>
<PARAMETER
NAME="CONFIG_CLIENT"
FIELD="CHECK"
NUM_ROW="46"
NB_LINES="5"
GROUP="S3_CONFIG"
/>
<PARAMETER NAME="CLIENT_CONFIGURATION" FIELD="TABLE" GROUP="S3_CONFIG"
NUM_ROW="50" NB_LINES="5" REQUIRED="true" SHOW_IF="CONFIG_CLIENT =='true'">

View File

@@ -85,7 +85,14 @@ REGION.ITEM.AP_NORTHEAST_2=Asia Pacific (Seoul)
REGION.ITEM.AP_SOUTH_1=Asia Pacific (Mumbai)
REGION.ITEM.CA_CENTRAL_1=Canada (Central)
INHERIT_CREDENTIALS.NAME=Inherit credentials from AWS role
CREDENTIAL_PROVIDER.NAME=Credential provider
CREDENTIAL_PROVIDER.ITEM.STATIC_CREDENTIALS=Static credentials
CREDENTIAL_PROVIDER.ITEM.WEB_TOKEN=Web identity token
CREDENTIAL_PROVIDER.ITEM.INHERIT_CREDENTIALS=Inherit credentials from AWS role
WEB_IDENTITY_TOKEN.NAME=Web identity token
WEB_IDENTITY_TOKEN_FILE.NAME=Token file
WEB_TOKEN_ARN.NAME=Role ARN
WEB_TOKEN_ROLE_SESSION_NAME.NAME=Role session name
ASSUME_ROLE.NAME=Assume Role
ARN.NAME=Role ARN

View File

@@ -133,36 +133,40 @@
NUM_ROW="46" SHOW_IF="USE_EXISTING_CONNECTION_S3 == 'true'" GROUP="S3_CONFIG"/>
<PARAMETER
NAME="ACCESS_KEY"
FIELD="TEXT"
NAME="CREDENTIAL_PROVIDER"
FIELD="CLOSED_LIST"
NUM_ROW="50"
REQUIRED="true"
SHOW_IF="(USE_EXISTING_CONNECTION_S3 == 'false') AND (INHERIT_CREDENTIALS == 'false')"
SHOW_IF="USE_EXISTING_CONNECTION_S3 == 'false'"
GROUP="S3_CONFIG"
>
<DEFAULT>""</DEFAULT>
<ITEMS DEFAULT="STATIC_CREDENTIALS"> <!-- It's just a basic one -->
<ITEM NAME="STATIC_CREDENTIALS" VALUE="STATIC_CREDENTIALS" SHOW_IF="true" />
<ITEM NAME="INHERIT_CREDENTIALS" VALUE="INHERIT_CREDENTIALS" SHOW_IF="true" />
<ITEM NAME="WEB_TOKEN" VALUE="WEB_TOKEN" SHOW_IF="false" />
</ITEMS>
</PARAMETER>
<PARAMETER
NAME="SECRET_KEY"
FIELD="PASSWORD"
NUM_ROW="50"
NAME="ACCESS_KEY"
FIELD="TEXT"
NUM_ROW="51"
REQUIRED="true"
SHOW_IF="(USE_EXISTING_CONNECTION_S3 == 'false') AND (INHERIT_CREDENTIALS == 'false')"
SHOW_IF="(USE_EXISTING_CONNECTION_S3 == 'false') AND (CREDENTIAL_PROVIDER == 'STATIC_CREDENTIALS')"
GROUP="S3_CONFIG"
>
<DEFAULT>""</DEFAULT>
</PARAMETER>
<PARAMETER
NAME="INHERIT_CREDENTIALS"
FIELD="CHECK"
NUM_ROW="55"
NAME="SECRET_KEY"
FIELD="PASSWORD"
NUM_ROW="51"
REQUIRED="true"
GROUP="S3_CONFIG"
SHOW_IF="USE_EXISTING_CONNECTION_S3 == 'false'"
SHOW_IF="(USE_EXISTING_CONNECTION_S3 == 'false') AND (CREDENTIAL_PROVIDER == 'STATIC_CREDENTIALS')"
>
<DEFAULT>false</DEFAULT>
<DEFAULT>""</DEFAULT>
</PARAMETER>
<PARAMETER
@@ -384,6 +388,33 @@
</ITEMS>
</PARAMETER>
<PARAMETER
NAME="WEB_IDENTITY_TOKEN_FILE"
FIELD="FILE"
NUM_ROW="62"
REQUIRED="false"
GROUP="WEB_IDENTITY_TOKEN"
SHOW_IF="isShow[CREDENTIAL_PROVIDER] AND (CREDENTIAL_PROVIDER == 'WEB_TOKEN')"
/>
<PARAMETER
NAME="WEB_TOKEN_ARN"
FIELD="TEXT"
NUM_ROW="63"
REQUIRED="false"
GROUP="WEB_IDENTITY_TOKEN"
SHOW_IF="isShow[CREDENTIAL_PROVIDER] AND (CREDENTIAL_PROVIDER == 'WEB_TOKEN')"
/>
<PARAMETER
NAME="WEB_TOKEN_ROLE_SESSION_NAME"
FIELD="TEXT"
NUM_ROW="64"
REQUIRED="false"
GROUP="WEB_IDENTITY_TOKEN"
SHOW_IF="isShow[CREDENTIAL_PROVIDER] AND (CREDENTIAL_PROVIDER == 'WEB_TOKEN')"
/>
<PARAMETER NAME="CONFIG_CLIENT" FIELD="CHECK" NUM_ROW="70"
GROUP="S3_CONFIG" NB_LINES="5">
</PARAMETER>
@@ -593,8 +624,13 @@
<TEMPLATE_PARAM SOURCE="self.SECRET_KEY" TARGET="tROB.SECRET_KEY" />
<TEMPLATE_PARAM SOURCE="self.REGION" TARGET="tROB.REGION" />
<TEMPLATE_PARAM SOURCE="self.INHERIT_CREDENTIALS" TARGET="tROB.INHERIT_CREDENTIALS" />
<TEMPLATE_PARAM SOURCE="self.INHERIT_CREDENTIALS" TARGET="tRBE.INHERIT_CREDENTIALS" />
<TEMPLATE_PARAM SOURCE="self.CREDENTIAL_PROVIDER" TARGET="tROB.CREDENTIAL_PROVIDER" />
<TEMPLATE_PARAM SOURCE="self.CREDENTIAL_PROVIDER" TARGET="tRBE.CREDENTIAL_PROVIDER" />
<TEMPLATE_PARAM SOURCE="self.WEB_IDENTITY_TOKEN_FILE" TARGET="tROB.WEB_IDENTITY_TOKEN_FILE" />
<TEMPLATE_PARAM SOURCE="self.WEB_TOKEN_ARN" TARGET="tROB.WEB_TOKEN_ARN" />
<TEMPLATE_PARAM SOURCE="self.WEB_TOKEN_ROLE_SESSION_NAME" TARGET="tROB.WEB_TOKEN_ROLE_SESSION_NAME" />
<!-- Need to transfer the same three params (WEB_IDENTITY_TOKEN_FILE, WEB_TOKEN_ARN and WEB_TOKEN_ROLE_SESSION_NAME)
to the tRedshiftBulkExec component once it supports them (after Credential Provider list is made visible) -->
<TEMPLATE_PARAM SOURCE="self.ASSUME_ROLE_S3" TARGET="tROB.ASSUME_ROLE" />
<TEMPLATE_PARAM SOURCE="self.ARN" TARGET="tROB.ARN" />
<TEMPLATE_PARAM SOURCE="self.ROLE_SESSION_NAME" TARGET="tROB.ROLE_SESSION_NAME" />

View File

@@ -154,7 +154,14 @@ REGION.ITEM.AP_NORTHEAST_2=Asia Pacific (Seoul)
REGION.ITEM.AP_SOUTH_1=Asia Pacific (Mumbai)
REGION.ITEM.CA_CENTRAL_1=Canada (Central)
INHERIT_CREDENTIALS.NAME=Inherit credentials from AWS role
CREDENTIAL_PROVIDER.NAME=Credential provider
CREDENTIAL_PROVIDER.ITEM.STATIC_CREDENTIALS=Static credentials
CREDENTIAL_PROVIDER.ITEM.WEB_TOKEN=Web identity token
CREDENTIAL_PROVIDER.ITEM.INHERIT_CREDENTIALS=Inherit credentials from AWS role
WEB_IDENTITY_TOKEN.NAME=Web identity token
WEB_IDENTITY_TOKEN_FILE.NAME=Token file
WEB_TOKEN_ARN.NAME=Role ARN
WEB_TOKEN_ROLE_SESSION_NAME.NAME=Role session name
ASSUME_ROLE_S3.NAME=S3 Assume Role
ASSUME_ROLE_REDSHIFT.NAME=Redshift Assume Role

View File

@@ -10,54 +10,4 @@
<artifactId>org.talend.libraries.crm</artifactId>
<packaging>eclipse-plugin</packaging>
<properties>
<libs.dir>${project.basedir}/lib</libs.dir>
</properties>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-clean-plugin</artifactId>
<version>3.0.0</version>
<configuration>
<filesets>
<fileset>
<directory>${libs.dir}</directory>
<includes>
<include>talend-mscrm-*.jar</include>
</includes>
</fileset>
</filesets>
</configuration>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-dependency-plugin</artifactId>
<version>2.8</version>
<executions>
<execution>
<id>copy-jars</id>
<phase>generate-sources</phase>
<goals>
<goal>copy</goal>
</goals>
<configuration>
<artifactItems>
<artifactItem>
<groupId>org.talend.components</groupId>
<artifactId>talend-mscrm</artifactId>
<version>3.4-20210428</version>
<type>jar</type>
<overWrite>true</overWrite>
<outputDirectory>${libs.dir}</outputDirectory>
</artifactItem>
</artifactItems>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>

View File

@@ -3646,6 +3646,15 @@
id="org.talend.repository.model.migration.AddEncodingToPostParametersFortFileFetchMigrationTask"
name="AddEncodingToPostParametersFortFileFetchMigrationTask"
version="7.3.1">
</projecttask>
<projecttask
beforeLogon="false"
breaks="7.3.0"
class="org.talend.repository.model.migration.ReplaceInheritCredentialCheckBoxWithDropDownListTaskForRedshift"
description="Replace 'inherit credentials' checkbox for drop down list for Redshift components"
id="org.talend.repository.model.migration.ReplaceInheritCredentialCheckBoxWithDropDownListTaskForRedshift"
name="ReplaceInheritCredentialCheckBoxWithDropDownListTaskForRedshift"
version="7.3.1">
</projecttask>
<projecttask
beforeLogon="false"

View File

@@ -0,0 +1,80 @@
package org.talend.repository.model.migration;
import java.util.Collections;
import java.util.Calendar;
import java.util.Date;
import java.util.GregorianCalendar;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import org.talend.commons.exception.ExceptionHandler;
import org.talend.core.language.ECodeLanguage;
import org.talend.core.model.components.ComponentUtilities;
import org.talend.core.model.components.ModifyComponentsAction;
import org.talend.core.model.components.conversions.IComponentConversion;
import org.talend.core.model.components.conversions.RemovePropertyComponentConversion;
import org.talend.core.model.components.filters.IComponentFilter;
import org.talend.core.model.components.filters.NameComponentFilter;
import org.talend.core.model.migration.AbstractJobMigrationTask;
import org.talend.core.model.properties.Item;
import org.talend.designer.core.model.utils.emf.talendfile.ElementParameterType;
import org.talend.designer.core.model.utils.emf.talendfile.ProcessType;
import org.talend.designer.core.model.utils.emf.talendfile.NodeType;
/**
* https://jira.talendforge.org/browse/TDI-46065
*/
public class ReplaceInheritCredentialCheckBoxWithDropDownListTaskForRedshift extends AbstractJobMigrationTask {
public ExecutionResult execute(Item item) {
ProcessType processType = getProcessType(item);
if (getProject().getLanguage() != ECodeLanguage.JAVA || processType == null) {
return ExecutionResult.NOTHING_TO_DO;
}
String[] componentsName = new String[] {"tRedshiftBulkExec", "tRedshiftOutputBulk", "tRedshiftOutputBulkExec"};
try {
for (int i = 0; i < componentsName.length; i++) {
IComponentFilter filter = new NameComponentFilter(componentsName[i]);
ModifyComponentsAction.searchAndModify(item, processType, filter,
Collections.singletonList(new IComponentConversion() {
public void transform(NodeType node) {
if (ComponentUtilities.getNodeProperty(node, "CREDENTIAL_PROVIDER") == null) {
ComponentUtilities.addNodeProperty(node, "CREDENTIAL_PROVIDER", "CLOSED_LIST");
ElementParameterType prevCredProperty = ComponentUtilities.getNodeProperty(node, "INHERIT_CREDENTIALS");
if (prevCredProperty != null && Boolean.TRUE.toString().equalsIgnoreCase(prevCredProperty.getValue())) {
ComponentUtilities.getNodeProperty(node, "CREDENTIAL_PROVIDER").setValue("INHERIT_CREDENTIALS");
} else {
ComponentUtilities.getNodeProperty(node, "CREDENTIAL_PROVIDER").setValue("STATIC_CREDENTIALS");
}
}
}
}));
if(componentsName[i].equals("tRedshiftBulkExec")) {
ModifyComponentsAction.searchAndModify(item, processType, filter,
Collections.singletonList(new IComponentConversion() {
public void transform(NodeType node) {
ComponentUtilities.getNodeProperty(node, "CREDENTIAL_PROVIDER").setShow(false);
}
}));
}
ModifyComponentsAction.searchAndModify(item, processType, filter,
Collections.singletonList(new RemovePropertyComponentConversion("INHERIT_CREDENTIALS")));
}
return ExecutionResult.SUCCESS_NO_ALERT;
} catch (Exception e) {
ExceptionHandler.process(e);
return ExecutionResult.FAILURE;
}
}
public Date getOrder() {
GregorianCalendar gc = new GregorianCalendar(2021, 05, 14, 12, 0, 0);
return gc.getTime();
}
}