Compare commits
183 Commits
cmeng/tmp/
...
cmeng/stig
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
163e0d70ec | ||
|
|
6800625fe9 | ||
|
|
a6190d6896 | ||
|
|
1f5a3f62d8 | ||
|
|
56577d508b | ||
|
|
a5ad384e46 | ||
|
|
4e9e4e0290 | ||
|
|
021574267c | ||
|
|
761e336111 | ||
|
|
edb39550e6 | ||
|
|
245bd37ca8 | ||
|
|
54c00306d9 | ||
|
|
2c7248ef83 | ||
|
|
01cd9c232b | ||
|
|
fea8d4065a | ||
|
|
d143d33850 | ||
|
|
8e3ec1f574 | ||
|
|
17742a2c68 | ||
|
|
8ea780dc4d | ||
|
|
b63ce620eb | ||
|
|
19e68c1694 | ||
|
|
64b10e61a9 | ||
|
|
7d7e4398ac | ||
|
|
f5b4f882ff | ||
|
|
20b460ddc3 | ||
|
|
125870fea8 | ||
|
|
ac916cbc57 | ||
|
|
e180852f07 | ||
|
|
c05c6f3c7f | ||
|
|
50db6d0d8a | ||
|
|
d09be2efef | ||
|
|
2b69024fee | ||
|
|
2c97652a74 | ||
|
|
f6d32e4ac1 | ||
|
|
b03481e60e | ||
|
|
4455d61521 | ||
|
|
c9c84e121c | ||
|
|
4905cfd090 | ||
|
|
30c0b563b1 | ||
|
|
710bf29d2f | ||
|
|
e6c614bbc2 | ||
|
|
4782532dca | ||
|
|
2f3bdc3e0b | ||
|
|
b2250689e9 | ||
|
|
ac2245fb06 | ||
|
|
32dcb2e020 | ||
|
|
e29fa80408 | ||
|
|
f1967f2645 | ||
|
|
2c2f8e884e | ||
|
|
74d5f20345 | ||
|
|
db8732247a | ||
|
|
a91a2f6e71 | ||
|
|
e6f036a519 | ||
|
|
6c5527d6e9 | ||
|
|
532c950982 | ||
|
|
f26d262975 | ||
|
|
d3800d42ea | ||
|
|
4a2583f672 | ||
|
|
4fde7f3df4 | ||
|
|
5c962b4b9c | ||
|
|
acd2da7b3c | ||
|
|
befb625719 | ||
|
|
43f7b1f96b | ||
|
|
3cbfcff2a1 | ||
|
|
40214ad0f9 | ||
|
|
7aeecb33de | ||
|
|
120c8f067f | ||
|
|
4aef962f93 | ||
|
|
ccfd0210d9 | ||
|
|
efb3892845 | ||
|
|
0a076d5864 | ||
|
|
aa3d21f60d | ||
|
|
6057fa9b53 | ||
|
|
af32c2d607 | ||
|
|
738392a032 | ||
|
|
23a494f865 | ||
|
|
fbf81a76fe | ||
|
|
b5bbb4ab54 | ||
|
|
79091dad0d | ||
|
|
86c76cea8f | ||
|
|
5833e5b3b3 | ||
|
|
a30b7fb50e | ||
|
|
663a066477 | ||
|
|
ff52f0c86f | ||
|
|
d045f176a1 | ||
|
|
71fda3d5be | ||
|
|
dedff2bbda | ||
|
|
c990583855 | ||
|
|
4f93848f0f | ||
|
|
4a368ce478 | ||
|
|
92f3ef63e8 | ||
|
|
1d8a178b8a | ||
|
|
fdf0cf1596 | ||
|
|
315430e76b | ||
|
|
f96e6906b8 | ||
|
|
99bf99112d | ||
|
|
17b2bb6b34 | ||
|
|
fe9ce8f275 | ||
|
|
a709eb1a3d | ||
|
|
978f08b5b5 | ||
|
|
c8e9707bb9 | ||
|
|
4b1cdc1193 | ||
|
|
2d8bc2352d | ||
|
|
0ebc632024 | ||
|
|
7365a191ea | ||
|
|
c1182639f7 | ||
|
|
dc4e685dce | ||
|
|
068aed3cd8 | ||
|
|
8cf06e4e2e | ||
|
|
d54b04c285 | ||
|
|
c2af6c8d9f | ||
|
|
e85a60ebce | ||
|
|
87926e93b0 | ||
|
|
7e5d9ed650 | ||
|
|
2fa2e5ad01 | ||
|
|
532b7e635d | ||
|
|
d2d9447caa | ||
|
|
3b61af4e85 | ||
|
|
7de187df81 | ||
|
|
65f171ac10 | ||
|
|
d7e2e05c66 | ||
|
|
8c161c821f | ||
|
|
fc4c4b1900 | ||
|
|
0ccd9ff9fa | ||
|
|
5df8cd540a | ||
|
|
e6936b650c | ||
|
|
3998e40cef | ||
|
|
f5d80e4f01 | ||
|
|
2d1fa2a083 | ||
|
|
8125ca9a29 | ||
|
|
296df1bfde | ||
|
|
6a89474d30 | ||
|
|
acfaeb05a2 | ||
|
|
2f90ccd1a8 | ||
|
|
c0b30cf1e7 | ||
|
|
b5f96496f4 | ||
|
|
d0fbe0defa | ||
|
|
d9454a11ef | ||
|
|
bca8dd8802 | ||
|
|
45c4e32c2a | ||
|
|
e637d53155 | ||
|
|
537bd1b73a | ||
|
|
2fcf4be1e2 | ||
|
|
86ee3f4ad1 | ||
|
|
106c010d53 | ||
|
|
80917277a5 | ||
|
|
f0fe150ec0 | ||
|
|
46523080d3 | ||
|
|
68b5e9e7c4 | ||
|
|
c3b1df17a0 | ||
|
|
d7af0fc449 | ||
|
|
c2408e4223 | ||
|
|
2ec3561107 | ||
|
|
acc3c15744 | ||
|
|
fd2c8b365b | ||
|
|
cb369968e9 | ||
|
|
70f018b26f | ||
|
|
f6a4d9022f | ||
|
|
616815d794 | ||
|
|
8767e96bcd | ||
|
|
26dcedadef | ||
|
|
58a39c8fb8 | ||
|
|
7cf738b911 | ||
|
|
42b7a46dee | ||
|
|
70314bd2b4 | ||
|
|
d42dc6e42e | ||
|
|
b824673188 | ||
|
|
c34725bbef | ||
|
|
f517e56b83 | ||
|
|
9ed98d4f9d | ||
|
|
7a9ff69e14 | ||
|
|
8acb79fbd4 | ||
|
|
04b7d3251e | ||
|
|
e64b5d2e23 | ||
|
|
ed74850972 | ||
|
|
caed4cf474 | ||
|
|
971e661a0e | ||
|
|
8a87f281f9 | ||
|
|
c54b8ed321 | ||
|
|
62301ff268 | ||
|
|
1f2d1e0820 | ||
|
|
9eb840b026 | ||
|
|
bc5d868c62 |
@@ -43,6 +43,7 @@
|
||||
<plugin id="org.talend.migrationTool.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.model.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.repository.generic.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.repository.json.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.repository.items.importexport.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.repository.items.importexport.ui.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.repository.localprovider.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
|
||||
@@ -56,8 +56,9 @@
|
||||
String jobClassPackageFolder = codeGenArgument.getCurrentProjectName().toLowerCase() + '/' + jobFolderName;
|
||||
|
||||
boolean isLog4jEnabled = ("true").equals(ElementParameterParser.getValue(process, "__LOG4J_ACTIVATE__"));//log4j enable
|
||||
boolean isLog4j2Enabled = ("true").equals(ElementParameterParser.getValue(process, "__LOG4J2_ACTIVATE__"));//log4j2 enable
|
||||
boolean isLog4j1Enabled = !isLog4j2Enabled;//log4j1 enable
|
||||
boolean isLog4j2Enabled = ("true").equals(ElementParameterParser.getValue(process, "__LOG4J2_ACTIVATE__"));//log4j2 enable
|
||||
boolean isLog4j1Enabled = !isLog4j2Enabled;//log4j1 enable
|
||||
String MDC_CLASS = "org.slf4j.MDC";
|
||||
|
||||
boolean exist_tParallelize = false;
|
||||
List<? extends INode> tParallelizeList = process.getNodesOfType("tParallelize");
|
||||
@@ -321,6 +322,8 @@
|
||||
globalMap.put(GLOBAL_CONNECTION_POOL_KEY, connectionPool);
|
||||
}
|
||||
<%}%>
|
||||
|
||||
private final static java.util.Properties jobInfo = new java.util.Properties();
|
||||
|
||||
public static void main(String[] args){
|
||||
final <%=className %> <%=className %>Class = new <%=className %>();
|
||||
@@ -334,6 +337,42 @@
|
||||
|
||||
System.exit(exitCode);
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
private void getjobInfo() {
|
||||
final String TEMPLATE_PATH = "src/main/templates/jobInfo_template.properties";
|
||||
final String BUILD_PATH = "../jobInfo.properties";
|
||||
final String path = this.getClass().getResource("").getPath();
|
||||
if(path.lastIndexOf("target") > 0) {
|
||||
final java.io.File templateFile = new java.io.File(
|
||||
path.substring(0, path.lastIndexOf("target")).concat(TEMPLATE_PATH));
|
||||
if (templateFile.exists()) {
|
||||
readJobInfo(templateFile);
|
||||
return;
|
||||
}
|
||||
}
|
||||
readJobInfo(new java.io.File(BUILD_PATH));
|
||||
}
|
||||
|
||||
private void readJobInfo(java.io.File jobInfoFile){
|
||||
|
||||
if(jobInfoFile.exists()) {
|
||||
try {
|
||||
jobInfo.load(new java.io.FileInputStream(jobInfoFile));
|
||||
} catch (IOException e) {
|
||||
<%if(isLog4jEnabled){%>
|
||||
log.debug("Read jobInfo.properties file fail: " + e.getMessage());
|
||||
<%}%>
|
||||
|
||||
}
|
||||
}
|
||||
<%if(isLog4jEnabled){%>
|
||||
log.info(String.format("Project name: %s\tJob name: %s\tGIT Commit ID: %s\tTalend Version: %s",
|
||||
projectName,jobName,jobInfo.getProperty("gitCommitId"), "<%=System.getProperties().getProperty("talend.studio.version")%>"));
|
||||
<%}%>
|
||||
}
|
||||
|
||||
<%
|
||||
if (isTestContainer) {
|
||||
@@ -515,8 +554,34 @@
|
||||
org.apache.logging.log4j.core.config.Configurator.setLevel(org.apache.logging.log4j.LogManager.getRootLogger().getName(), log.getLevel());
|
||||
<%}%>
|
||||
}
|
||||
|
||||
getjobInfo();
|
||||
log.info("TalendJob: '<%=codeGenArgument.getJobName()%>' - Start.");
|
||||
<%}%>
|
||||
|
||||
<%if(isLog4j2Enabled) {%>
|
||||
java.util.Set<Object> jobInfoKeys = jobInfo.keySet();
|
||||
for(Object jobInfoKey: jobInfoKeys) {
|
||||
<%=MDC_CLASS%>.put("_" + jobInfoKey.toString(), jobInfo.get(jobInfoKey).toString());
|
||||
}
|
||||
<%=MDC_CLASS%>.put("_pid", pid);
|
||||
<%=MDC_CLASS%>.put("_rootPid", rootPid);
|
||||
<%=MDC_CLASS%>.put("_fatherPid", fatherPid);
|
||||
<%=MDC_CLASS%>.put("_projectName", projectName);
|
||||
<%=MDC_CLASS%>.put("_startTimestamp",java.time.ZonedDateTime.now(java.time.ZoneOffset.UTC ).format( java.time.format.DateTimeFormatter.ISO_INSTANT ));
|
||||
<%=MDC_CLASS%>.put("_jobRepositoryId","<%=process.getId() %>");
|
||||
<%=MDC_CLASS%>.put("_compiledAtTimestamp","<%=java.time.ZonedDateTime.now(java.time.ZoneOffset.UTC ).format( java.time.format.DateTimeFormatter.ISO_INSTANT )%>");
|
||||
|
||||
java.lang.management.RuntimeMXBean mx = java.lang.management.ManagementFactory.getRuntimeMXBean();
|
||||
String[] mxNameTable = mx.getName().split("@"); //$NON-NLS-1$
|
||||
if (mxNameTable.length == 2) {
|
||||
<%=MDC_CLASS%>.put("_systemPid", mxNameTable[0]);
|
||||
} else {
|
||||
<%=MDC_CLASS%>.put("_systemPid", String.valueOf(java.lang.Thread.currentThread().getId()));
|
||||
}
|
||||
|
||||
<%
|
||||
}%>
|
||||
|
||||
<%
|
||||
INode jobCatcherNode = null;
|
||||
@@ -642,14 +707,26 @@
|
||||
pid = TalendString.getAsciiRandomString(6);
|
||||
}
|
||||
|
||||
<%if(isLog4j2Enabled) {%>
|
||||
<%=MDC_CLASS%>.put("_pid", pid);
|
||||
<%}%>
|
||||
|
||||
if (rootPid==null) {
|
||||
rootPid = pid;
|
||||
}
|
||||
|
||||
<%if(isLog4j2Enabled) {%>
|
||||
<%=MDC_CLASS%>.put("_rootPid", rootPid);
|
||||
<%}%>
|
||||
|
||||
if (fatherPid==null) {
|
||||
fatherPid = pid;
|
||||
}else{
|
||||
isChildJob = true;
|
||||
}
|
||||
<%if(isLog4j2Enabled) {%>
|
||||
<%=MDC_CLASS%>.put("_fatherPid", fatherPid);
|
||||
<%}%>
|
||||
|
||||
<%
|
||||
if (stats) {
|
||||
@@ -883,7 +960,12 @@
|
||||
}
|
||||
%>
|
||||
//Resume: jobStart
|
||||
resumeUtil.addLog("JOB_STARTED", "JOB:" + jobName, parent_part_launcher, Thread.currentThread().getId() + "", "","","","",resumeUtil.convertToJsonText(context,parametersToEncrypt));
|
||||
resumeUtil.addLog("JOB_STARTED", "JOB:" + jobName, parent_part_launcher, Thread.currentThread().getId() + "", "","","","",resumeUtil.convertToJsonText(context,ContextProperties.class,parametersToEncrypt));
|
||||
|
||||
<%if(isLog4j2Enabled) {%>
|
||||
<%=MDC_CLASS%>.put("_context", contextStr);
|
||||
log.info("TalendJob: '<%=codeGenArgument.getJobName()%>' - Started.");
|
||||
<%}%>
|
||||
|
||||
<%
|
||||
if (stats) {
|
||||
@@ -1156,9 +1238,15 @@ this.globalResumeTicket = false;//to run others jobs
|
||||
if (!componentName.equals("tJobStructureCatcher") && !componentName.equals("tLogCatcher") && !componentName.equals("tFlowMeterCatcher") && !componentName.equals("tAssertCatcher") && !componentName.equals("tStatCatcher") && !componentName.equals("tAsyncIn")) {
|
||||
%>
|
||||
<%=createCallProcess(rootNode, className, false) %>
|
||||
<% }
|
||||
}
|
||||
}// end if(isRunInMultiThread)
|
||||
<%
|
||||
if (process.getNodesOfType("tStatCatcher").size() > 0) {
|
||||
%>
|
||||
<%=statsErrorHandlingAfterMainCall(rootNode, process.getNodesOfType("tStatCatcher"))%>
|
||||
<%
|
||||
}
|
||||
}
|
||||
}
|
||||
}// end if(isRunInMultiThread)
|
||||
%>
|
||||
|
||||
this.globalResumeTicket = true;//to run tPostJob
|
||||
@@ -1292,6 +1380,15 @@ if (execStat) {
|
||||
returnCode = errorCode.intValue();
|
||||
}
|
||||
resumeUtil.addLog("JOB_ENDED", "JOB:" + jobName, parent_part_launcher, Thread.currentThread().getId() + "", "","" + returnCode,"","","");
|
||||
resumeUtil.flush();
|
||||
|
||||
<%if(isLog4j2Enabled) {%>
|
||||
|
||||
<%=MDC_CLASS%>.remove("_subJobName");
|
||||
<%=MDC_CLASS%>.remove("_subJobPid");
|
||||
<%=MDC_CLASS%>.remove("_systemPid");
|
||||
log.info("TalendJob: '<%=codeGenArgument.getJobName()%>' - Finished - status: " + status + " returnCode: " + returnCode );
|
||||
<%}%>
|
||||
|
||||
return returnCode;
|
||||
|
||||
|
||||
@@ -42,10 +42,10 @@ public class CLASS
|
||||
|
||||
//List< ? extends IConnection> onSubJobErrorConns = rootNode.getOutgoingConnections(EConnectionType.ON_SUBJOB_ERROR);
|
||||
//if(onSubJobErrorConns!=null){
|
||||
// for(IConnection conn : onSubJobErrorConns) {
|
||||
// for(IConnection conn : onSubJobErrorConns) {
|
||||
// toReturn += createCallProcess(conn.getTarget(), className, isMultiThread);
|
||||
// }
|
||||
//}
|
||||
//}
|
||||
if(isMultiThread){
|
||||
toReturn += "\n}catch (java.lang.Error e_" + rootNode.getUniqueName() + ") {\n";
|
||||
toReturn += "globalMap.put(\""+rootNode.getUniqueName()+ "_SUBPROCESS_STATE\", -1);\n";
|
||||
@@ -55,7 +55,20 @@ public class CLASS
|
||||
toReturn += "\n}";
|
||||
return toReturn;
|
||||
}
|
||||
|
||||
|
||||
public String statsErrorHandlingAfterMainCall(INode rootNode, List<? extends INode> statsNodes) {
|
||||
String catchErrorReturn = "catch (Error error_" + rootNode.getUniqueName() + " ) {\n";
|
||||
catchErrorReturn+="end = System.currentTimeMillis();\n";
|
||||
for (INode statCatcherNode : statsNodes) {
|
||||
catchErrorReturn += statCatcherNode.getUniqueName() + ".addMessage(\"failure\", (end-startTime));\n";
|
||||
catchErrorReturn += "try {\n " + statCatcherNode.getDesignSubjobStartNode().getUniqueName() + "Process(globalMap);\n";
|
||||
catchErrorReturn += "} catch (Exception e_" + statCatcherNode.getUniqueName() + ") {\n";
|
||||
catchErrorReturn += "e_" + statCatcherNode.getUniqueName() + ".printStackTrace();\n}\n";
|
||||
}
|
||||
catchErrorReturn+= "throw error_" + rootNode.getUniqueName() + ";\n}\n";
|
||||
return catchErrorReturn;
|
||||
}
|
||||
|
||||
public String generate(Object argument) {
|
||||
return "";
|
||||
}
|
||||
|
||||
@@ -32,6 +32,8 @@
|
||||
boolean stat = codeGenArgument.isStatistics();
|
||||
boolean containsTPartitioner = subTree.getRootNode().getProcess().getNodesOfType("tPartitioner").size() > 0 ? true : false;
|
||||
boolean isLog4jEnabled = ("true").equals(ElementParameterParser.getValue(subTree.getRootNode().getProcess(), "__LOG4J_ACTIVATE__"));
|
||||
boolean isLog4j2Enabled = ("true").equals(ElementParameterParser.getValue(subTree.getRootNode().getProcess(), "__LOG4J2_ACTIVATE__"));//log4j2 enable
|
||||
String MDC_CLASS = "org.slf4j.MDC";
|
||||
%>
|
||||
|
||||
<%
|
||||
@@ -1603,6 +1605,11 @@ public void <%=subTree.getName() %>Process(final java.util.Map<String, Object> g
|
||||
globalMap.put("<%=subTree.getName() %>_SUBPROCESS_STATE", 0);
|
||||
|
||||
final boolean execStat = this.execStat;
|
||||
<%if(isLog4j2Enabled) {%>
|
||||
<%=MDC_CLASS%>.put("_subJobName", "<%=subTree.getName() %>");
|
||||
<%=MDC_CLASS%>.put("_subJobPid", TalendString.getAsciiRandomString(6));
|
||||
<%}%>
|
||||
|
||||
<%
|
||||
boolean isParallelize = false;
|
||||
for (INode node : subTree.getNodes()) {
|
||||
|
||||
@@ -152,7 +152,9 @@ public class CodeGeneratorService implements ICodeGeneratorService {
|
||||
ComponentsFactoryProvider.getInstance().resetCache();
|
||||
ILibraryManagerService librairesManagerService = (ILibraryManagerService) GlobalServiceRegister.getDefault().getService(
|
||||
ILibraryManagerService.class);
|
||||
librairesManagerService.clearCache();
|
||||
//TUP-31721: The generated studio index will include every possible values with TP_ALL license .
|
||||
//Studio 8 will not re-generate the index after applying patch and installing any component.
|
||||
librairesManagerService.clearCache(false);
|
||||
CorePlugin.getDefault().getLibrariesService().syncLibraries();
|
||||
Job job = CodeGeneratorEmittersPoolFactory.initialize();
|
||||
// achen modify to record ctrl+shift+f3 is pressed to fix bug 0006107
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
ExchangeView.Exchange=Exchange
|
||||
AvailableExtensionsComposite.ExtensionName=Extension\u540D
|
||||
AvailableExtensionsComposite.ExtensionName=\u62E1\u5F35\u5B50\u540D
|
||||
AvailableExtensionsComposite.Version=\u30D0\u30FC\u30B8\u30E7\u30F3
|
||||
AvailableExtensionsComposite.Rating=\u8A55\u4FA1
|
||||
AvailableExtensionsComposite.Author=\u4F5C\u6210\u8005
|
||||
@@ -8,14 +8,14 @@ AvailableExtensionsComposite.ViewDetail.installOperateStatus=\u30A4\u30F3\u30B9\
|
||||
AvailableExtensionsComposite.ViewDetail.WriteReview=\u518D\u8ABF\u67FB\u306E\u66F8\u304D\u8FBC\u307F
|
||||
AvailableExtensionsComposite.ViewDetail.InsertionReviewFailure=Review\u633F\u5165\u5931\u6557\u3002
|
||||
AvailableExtensionsComposite.ViewDetail.InsertionReviewFailureTip=\u30C1\u30A7\u30C3\u30AF\u3092\u3057\u3066\u304F\u3060\u3055\u3044\u3002
|
||||
DownloadedExtensionsComposite.ExtensionName=Extension\u540D
|
||||
DownloadedExtensionsComposite.ExtensionName=\u62E1\u5F35\u5B50\u540D
|
||||
DownloadedExtensionsComposite.DownloadedVersion=\u30C0\u30A6\u30F3\u30ED\u30FC\u30C9\u30D0\u30FC\u30B8\u30E7\u30F3
|
||||
DownloadedExtensionsComposite.DownloadDate=\u30C0\u30A6\u30F3\u30ED\u30FC\u30C9\u65E5\u4ED8
|
||||
DownloadedExtensionsComposite.OperateStatus=\u30B9\u30C6\u30FC\u30BF\u30B9\u64CD\u4F5C
|
||||
DownloadedExtensionsComposite.installOperateStatus=\u30A4\u30F3\u30B9\u30C8\u30FC\u30EB
|
||||
DownloadedExtensionsComposite.installedOperateStatus=\u30A4\u30F3\u30B9\u30C8\u30FC\u30EB\u6E08\u307F
|
||||
DownloadedExtensionsComposite.updateOperateStatus=\u30A2\u30C3\u30D7\u30C7\u30FC\u30C8
|
||||
MyExtensionsComposite.ExtensionName=Extension\u540D
|
||||
MyExtensionsComposite.ExtensionName=\u62E1\u5F35\u5B50\u540D
|
||||
MyExtensionsComposite.Version=\u30D0\u30FC\u30B8\u30E7\u30F3
|
||||
MyExtensionsComposite.UploadDate=\u30A2\u30C3\u30D7\u30ED\u30FC\u30C9\u65E5\u4ED8
|
||||
MyExtensionsComposite.AddNewExtensionTitle=\u65B0\u898FExtension\u8FFD\u52A0
|
||||
@@ -91,7 +91,7 @@ ImportExchangeDialog.dialogTitle=Talend Exchange \u304B\u3089\u9805\u76EE\u306E\
|
||||
ImportExchangeDialog.WARNING=\u8B66\u544A
|
||||
ImportExchangeDialog.NOTSELECTWARNING=\u30C6\u30FC\u30D6\u30EB\u304B\u3089\u30A2\u30A4\u30C6\u30E0\u3092\uFF11\u3064\u9078\u629E\u3057\u3066\u304F\u3060\u3055\u3044...
|
||||
ImportExchangeDialog.downloadProgressBar=\u30A2\u30A4\u30C6\u30E0\u3092\u30C0\u30A6\u30F3\u30ED\u30FC\u30C9\u4E2D\u3067\u3059\u3002\u66AB\u304F\u304A\u5F85\u3061\u304F\u3060\u3055\u3044!
|
||||
ImportExchangeDialog.EXTENSION_NAME=Extension\u540D
|
||||
ImportExchangeDialog.EXTENSION_NAME=\u62E1\u5F35\u5B50\u540D
|
||||
ImportExchangeDialog.AUTHOR_NAME=\u4F5C\u6210\u8005\u540D
|
||||
ImportExchangeDialog.LATEST_REVISION=\u6700\u65B0\u30EA\u30D3\u30B8\u30E7\u30F3
|
||||
ImportExchangeDialog.EXTENSION_DESCRIPTION=\u62E1\u5F35\u306E\u8AAC\u660E
|
||||
|
||||
@@ -3,7 +3,7 @@
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
<groupId>com.microsoft.azure</groupId>
|
||||
<artifactId>adal4j</artifactId>
|
||||
<version>1.6.4-20211021</version>
|
||||
<version>1.6.6-20220707</version>
|
||||
<packaging>jar</packaging>
|
||||
<name>adal4j</name>
|
||||
<description>
|
||||
@@ -99,12 +99,12 @@
|
||||
<dependency>
|
||||
<groupId>com.nimbusds</groupId>
|
||||
<artifactId>nimbus-jose-jwt</artifactId>
|
||||
<version>8.11</version>
|
||||
<version>9.22</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.google.code.gson</groupId>
|
||||
<artifactId>gson</artifactId>
|
||||
<version>2.8.6</version>
|
||||
<version>2.8.9</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.slf4j</groupId>
|
||||
|
||||
@@ -4,7 +4,7 @@
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
<groupId>org.talend</groupId>
|
||||
<artifactId>talendMQRFH2</artifactId>
|
||||
<version>1.1.0-20220307</version>
|
||||
<version>1.2.0-20220707</version>
|
||||
<packaging>jar</packaging>
|
||||
|
||||
<licenses>
|
||||
@@ -47,7 +47,7 @@
|
||||
<dependency>
|
||||
<groupId>com.ibm.mq</groupId>
|
||||
<artifactId>com.ibm.mq.allclient</artifactId>
|
||||
<version>9.2.4.0</version>
|
||||
<version>9.2.5.0</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.talend.libraries</groupId>
|
||||
|
||||
@@ -6,7 +6,7 @@
|
||||
<!-- #################################################### -->
|
||||
|
||||
<!-- modification 1: config -->
|
||||
<property name="jar.name" value="MsmqTalend-1.0.0.jar" />
|
||||
<property name="jar.name" value="MsmqTalend-1.0.5.jar" />
|
||||
<property name="component.name" value="tMicrosoftMQInput" />
|
||||
<property name="author.name" value="ytao" />
|
||||
|
||||
@@ -81,4 +81,4 @@
|
||||
<delete dir="${build.dir}" />
|
||||
<mkdir dir="${build.dir}" />
|
||||
</target>
|
||||
</project>
|
||||
</project>
|
||||
|
||||
@@ -54,11 +54,6 @@
|
||||
<artifactId>poi</artifactId>
|
||||
<version>4.1.2</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.apache.poi</groupId>
|
||||
<artifactId>poi-scratchpad</artifactId>
|
||||
<version>4.1.2</version>
|
||||
</dependency>
|
||||
<!-- https://mvnrepository.com/artifact/org.apache.poi/poi-ooxml -->
|
||||
<dependency>
|
||||
<groupId>org.apache.poi</groupId>
|
||||
|
||||
@@ -4,7 +4,7 @@
|
||||
|
||||
<groupId>org.talend.components.lib</groupId>
|
||||
<artifactId>talend-aws</artifactId>
|
||||
<version>1.0</version>
|
||||
<version>1.1</version>
|
||||
<packaging>jar</packaging>
|
||||
|
||||
<name>talend-aws</name>
|
||||
@@ -50,7 +50,7 @@
|
||||
<dependency>
|
||||
<groupId>com.amazonaws</groupId>
|
||||
<artifactId>aws-java-sdk</artifactId>
|
||||
<version>1.11.848</version>
|
||||
<version>1.12.297</version>
|
||||
</dependency>
|
||||
</dependencies>
|
||||
<build>
|
||||
|
||||
@@ -3,7 +3,7 @@
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
<groupId>org.talend.components</groupId>
|
||||
<artifactId>talend-mscrm</artifactId>
|
||||
<version>3.11-20220401</version>
|
||||
<version>3.14-20220707</version>
|
||||
<packaging>jar</packaging>
|
||||
|
||||
<name>talend-mscrm</name>
|
||||
@@ -26,7 +26,7 @@
|
||||
<httpclient.version>4.5.13</httpclient.version>
|
||||
<httpcore.version>4.4.13</httpcore.version>
|
||||
<junit.version>4.13.2</junit.version>
|
||||
<adal4j.version>1.6.4-20211021</adal4j.version>
|
||||
<adal4j.version>1.6.6-20220707</adal4j.version>
|
||||
<jackson.version>2.13.2</jackson.version>
|
||||
<jackson-databind.version>2.13.2.2</jackson-databind.version>
|
||||
|
||||
@@ -34,7 +34,7 @@
|
||||
<maven-jar-plugin.version>3.2.0</maven-jar-plugin.version>
|
||||
<maven-compiler-plugin.version>3.8.1</maven-compiler-plugin.version>
|
||||
</properties>
|
||||
|
||||
|
||||
<repositories>
|
||||
<repository>
|
||||
<id>talend_nexus_deployment</id>
|
||||
@@ -69,7 +69,7 @@
|
||||
</releases>
|
||||
</repository>
|
||||
</distributionManagement>
|
||||
|
||||
|
||||
<dependencies>
|
||||
<dependency>
|
||||
<groupId>org.apache.axis2</groupId>
|
||||
@@ -102,7 +102,7 @@
|
||||
</exclusion>
|
||||
</exclusions>
|
||||
</dependency>
|
||||
|
||||
|
||||
<dependency>
|
||||
<groupId>org.apache.olingo</groupId>
|
||||
<artifactId>odata-client-core</artifactId>
|
||||
@@ -144,11 +144,6 @@
|
||||
<version>${junit.version}</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.microsoft.azure</groupId>
|
||||
<artifactId>adal4j</artifactId>
|
||||
<version>${adal4j.version}</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.fasterxml.jackson.core</groupId>
|
||||
<artifactId>jackson-core</artifactId>
|
||||
@@ -164,6 +159,17 @@
|
||||
<artifactId>jackson-annotations</artifactId>
|
||||
<version>${jackson.version}</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.microsoft.azure</groupId>
|
||||
<artifactId>msal4j</artifactId>
|
||||
<version>1.11.2</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.google.code.gson</groupId>
|
||||
<artifactId>gson</artifactId>
|
||||
<version>2.8.9</version>
|
||||
</dependency>
|
||||
|
||||
</dependencies>
|
||||
<build>
|
||||
<resources>
|
||||
|
||||
@@ -0,0 +1,164 @@
|
||||
package com.microsoft.aad.msal4j;
|
||||
|
||||
import java.util.Collections;
|
||||
import java.util.Date;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.concurrent.CompletableFuture;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import com.nimbusds.oauth2.sdk.ParseException;
|
||||
import com.nimbusds.oauth2.sdk.auth.ClientAuthentication;
|
||||
import com.nimbusds.oauth2.sdk.auth.ClientAuthenticationMethod;
|
||||
import com.nimbusds.oauth2.sdk.auth.ClientSecretPost;
|
||||
import com.nimbusds.oauth2.sdk.auth.PrivateKeyJWT;
|
||||
import com.nimbusds.oauth2.sdk.auth.Secret;
|
||||
import com.nimbusds.oauth2.sdk.id.ClientID;
|
||||
import static com.microsoft.aad.msal4j.ParameterValidationUtils.validateNotNull;
|
||||
|
||||
public class OauthClientApplication extends AbstractClientApplicationBase implements IConfidentialClientApplication {
|
||||
|
||||
private ClientAuthentication clientAuthentication;
|
||||
private CustomJWTAuthentication customJWTAuthentication;
|
||||
private boolean clientCertAuthentication = false;
|
||||
private ClientCertificate clientCertificate;
|
||||
private boolean sendX5c;
|
||||
private final String username;
|
||||
private final String password;
|
||||
|
||||
private OauthClientApplication(OauthClientApplication.Builder builder) {
|
||||
super(builder);
|
||||
validateNotNull("username", builder.username);
|
||||
validateNotNull("password", builder.password);
|
||||
sendX5c = builder.sendX5c;
|
||||
log = LoggerFactory.getLogger(ConfidentialClientApplication.class);
|
||||
initClientAuthentication(builder.clientCredential);
|
||||
this.username = builder.username;
|
||||
this.password = builder.password;
|
||||
}
|
||||
|
||||
@Override
|
||||
public CompletableFuture<IAuthenticationResult> acquireToken(ClientCredentialParameters parameters) {
|
||||
validateNotNull("parameters", parameters);
|
||||
|
||||
RequestContext context = new RequestContext(this, PublicApi.ACQUIRE_TOKEN_FOR_CLIENT, parameters);
|
||||
OauthCredentialRequest clientCredentialRequest = new OauthCredentialRequest(parameters,
|
||||
username, password,this, context);
|
||||
|
||||
return this.executeRequest(clientCredentialRequest);
|
||||
}
|
||||
|
||||
@Override
|
||||
public CompletableFuture<IAuthenticationResult> acquireToken(OnBehalfOfParameters parameters) {
|
||||
throw new IllegalStateException("Use ConfidentialClientApplication instead");
|
||||
}
|
||||
|
||||
private void initClientAuthentication(IClientCredential clientCredential) {
|
||||
validateNotNull("clientCredential", clientCredential);
|
||||
if (clientCredential instanceof ClientSecret) {
|
||||
clientAuthentication = new ClientSecretPost(new ClientID(clientId()), new Secret(((ClientSecret) clientCredential).clientSecret()));
|
||||
} else if (clientCredential instanceof ClientCertificate) {
|
||||
this.clientCertAuthentication = true;
|
||||
this.clientCertificate = (ClientCertificate) clientCredential;
|
||||
clientAuthentication = buildValidClientCertificateAuthority();
|
||||
} else if (clientCredential instanceof ClientAssertion) {
|
||||
clientAuthentication = createClientAuthFromClientAssertion((ClientAssertion) clientCredential);
|
||||
} else {
|
||||
throw new IllegalArgumentException("Unsupported client credential");
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
protected ClientAuthentication clientAuthentication() {
|
||||
if (clientCertAuthentication) {
|
||||
final Date currentDateTime = new Date(System.currentTimeMillis());
|
||||
final Date expirationTime = ((PrivateKeyJWT) clientAuthentication).getJWTAuthenticationClaimsSet().getExpirationTime();
|
||||
if (expirationTime.before(currentDateTime)) {
|
||||
//The asserted private jwt with the client certificate can expire so rebuild it when the
|
||||
clientAuthentication = buildValidClientCertificateAuthority();
|
||||
}
|
||||
}
|
||||
return clientAuthentication;
|
||||
}
|
||||
|
||||
private ClientAuthentication buildValidClientCertificateAuthority() {
|
||||
ClientAssertion clientAssertion = JwtHelper.buildJwt(clientId(), clientCertificate, this.authenticationAuthority.selfSignedJwtAudience(), sendX5c);
|
||||
return createClientAuthFromClientAssertion(clientAssertion);
|
||||
}
|
||||
|
||||
private ClientAuthentication createClientAuthFromClientAssertion(final ClientAssertion clientAssertion) {
|
||||
final Map<String, List<String>> map = new HashMap<>();
|
||||
try {
|
||||
map.put("client_assertion_type", Collections.singletonList(ClientAssertion.assertionType));
|
||||
map.put("client_assertion", Collections.singletonList(clientAssertion.assertion()));
|
||||
return PrivateKeyJWT.parse(map);
|
||||
} catch (final ParseException e) {
|
||||
//This library is not supposed to validate Issuer and subject values.
|
||||
//The next lines of code ensures that exception is not thrown.
|
||||
if (e.getMessage().contains("Issuer and subject in client JWT assertion must designate the same client identifier")) {
|
||||
return new CustomJWTAuthentication(ClientAuthenticationMethod.PRIVATE_KEY_JWT, clientAssertion, new ClientID(clientId()));
|
||||
}
|
||||
throw new MsalClientException(e);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Creates instance of Builder of ConfidentialClientApplication
|
||||
|
||||
*
|
||||
|
||||
* @param clientId Client ID (Application ID) of the application as registered
|
||||
|
||||
* in the application registration portal (portal.azure.com)
|
||||
|
||||
* @param clientCredential The client credential to use for token acquisition.
|
||||
|
||||
* @return instance of Builder of ConfidentialClientApplication
|
||||
*/
|
||||
public static OauthClientApplication.Builder builder(String clientId, IClientCredential clientCredential, String username, String password) {
|
||||
return new OauthClientApplication.Builder(clientId, clientCredential, username, password);
|
||||
}
|
||||
|
||||
|
||||
public static class Builder extends AbstractClientApplicationBase.Builder<OauthClientApplication.Builder> {
|
||||
|
||||
private IClientCredential clientCredential;
|
||||
private final String username;
|
||||
private final String password;
|
||||
private boolean sendX5c = true;
|
||||
|
||||
private Builder(String clientId, IClientCredential clientCredential, String username, String password) {
|
||||
super(clientId);
|
||||
this.clientCredential = clientCredential;
|
||||
this.username = username;
|
||||
this.password = password;
|
||||
}
|
||||
|
||||
/**
|
||||
* Specifies if the x5c claim (public key of the certificate) should be sent to the STS.
|
||||
* Default value is true
|
||||
*
|
||||
* @param val true if the x5c should be sent. Otherwise false
|
||||
* @return instance of the Builder on which method was called
|
||||
*/
|
||||
public OauthClientApplication.Builder sendX5c(boolean val) {
|
||||
this.sendX5c = val;
|
||||
return self();
|
||||
}
|
||||
|
||||
@Override
|
||||
public OauthClientApplication build() {
|
||||
return new OauthClientApplication(this);
|
||||
}
|
||||
|
||||
@Override
|
||||
protected OauthClientApplication.Builder self() {
|
||||
return this;
|
||||
}
|
||||
}
|
||||
|
||||
@java.lang.SuppressWarnings("all")
|
||||
public boolean sendX5c() {
|
||||
return this.sendX5c;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,20 @@
|
||||
package com.microsoft.aad.msal4j;
|
||||
|
||||
import com.nimbusds.oauth2.sdk.ResourceOwnerPasswordCredentialsGrant;
|
||||
import com.nimbusds.oauth2.sdk.auth.Secret;
|
||||
|
||||
class OauthCredentialRequest extends MsalRequest {
|
||||
ClientCredentialParameters parameters;
|
||||
OauthCredentialRequest(ClientCredentialParameters parameters, String username, String password,
|
||||
OauthClientApplication application, RequestContext requestContext) {
|
||||
super(application, createMsalGrant(parameters, username, password), requestContext);
|
||||
this.parameters = parameters;
|
||||
}
|
||||
|
||||
private static OAuthAuthorizationGrant createMsalGrant(ClientCredentialParameters parameters,
|
||||
String username, String password) {
|
||||
return new OAuthAuthorizationGrant(new ResourceOwnerPasswordCredentialsGrant(username, new Secret(
|
||||
password)), parameters.scopes(), parameters.claims());
|
||||
}
|
||||
|
||||
}
|
||||
@@ -13,14 +13,12 @@
|
||||
package org.talend.ms.crm.odata.authentication;
|
||||
|
||||
import java.net.Proxy;
|
||||
import java.util.Collections;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
import java.util.concurrent.Future;
|
||||
|
||||
import javax.naming.AuthenticationException;
|
||||
import javax.naming.ServiceUnavailableException;
|
||||
|
||||
import com.microsoft.aad.adal4j.ClientCredential;
|
||||
import org.apache.http.client.methods.HttpRequestBase;
|
||||
import org.apache.olingo.client.api.communication.request.ODataRequest;
|
||||
import org.apache.olingo.commons.api.http.HttpHeader;
|
||||
@@ -28,15 +26,19 @@ import org.talend.ms.crm.odata.ClientConfiguration;
|
||||
import org.talend.ms.crm.odata.ProxyProvider;
|
||||
import org.talend.ms.crm.odata.httpclientfactory.IHttpclientFactoryObservable;
|
||||
import org.talend.ms.crm.odata.httpclientfactory.OAuthHttpClientFactory;
|
||||
|
||||
import com.microsoft.aad.adal4j.AuthenticationContext;
|
||||
import com.microsoft.aad.adal4j.AuthenticationResult;
|
||||
import com.microsoft.aad.msal4j.ClientCredentialFactory;
|
||||
import com.microsoft.aad.msal4j.ClientCredentialParameters;
|
||||
import com.microsoft.aad.msal4j.ConfidentialClientApplication;
|
||||
import com.microsoft.aad.msal4j.IAuthenticationResult;
|
||||
import com.microsoft.aad.msal4j.OauthClientApplication;
|
||||
import com.microsoft.aad.msal4j.PublicClientApplication;
|
||||
import com.microsoft.aad.msal4j.UserNamePasswordParameters;
|
||||
|
||||
public class OAuthStrategyImpl implements IAuthStrategy {
|
||||
|
||||
private ClientConfiguration conf;
|
||||
|
||||
private AuthenticationResult authResult;
|
||||
private IAuthenticationResult authResult;
|
||||
|
||||
private IHttpclientFactoryObservable httpClientFactory;
|
||||
|
||||
@@ -71,12 +73,12 @@ public class OAuthStrategyImpl implements IAuthStrategy {
|
||||
|
||||
@Override
|
||||
public void configureRequest(ODataRequest request) {
|
||||
request.addCustomHeader(HttpHeader.AUTHORIZATION, "Bearer " + authResult.getAccessToken());
|
||||
request.addCustomHeader(HttpHeader.AUTHORIZATION, "Bearer " + authResult.accessToken());
|
||||
}
|
||||
|
||||
@Override
|
||||
public void configureRequest(HttpRequestBase request) {
|
||||
request.addHeader(HttpHeader.AUTHORIZATION, "Bearer " + authResult.getAccessToken());
|
||||
request.addHeader(HttpHeader.AUTHORIZATION, "Bearer " + authResult.accessToken());
|
||||
}
|
||||
|
||||
@Override
|
||||
@@ -115,34 +117,71 @@ public class OAuthStrategyImpl implements IAuthStrategy {
|
||||
}
|
||||
}
|
||||
|
||||
private Future<AuthenticationResult> acquireToken(AuthenticationContext context) throws Exception {
|
||||
Future<AuthenticationResult> future;
|
||||
private Future<IAuthenticationResult> acquireToken(PublicClientApplication context) throws Exception {
|
||||
Future<IAuthenticationResult> future;
|
||||
UserNamePasswordParameters parameters = UserNamePasswordParameters.builder(
|
||||
Collections.singleton(conf.getResource() + "/.default"), conf.getUserName(), conf.getPassword().toCharArray()).build();
|
||||
future = context.acquireToken(parameters);
|
||||
return future;
|
||||
|
||||
if(conf.getAppRegisteredType() == ClientConfiguration.AppRegisteredType.NATIVE_APP){
|
||||
future = context.acquireToken(conf.getResource(), conf.getClientId(), conf.getUserName(), conf.getPassword(), null);
|
||||
}
|
||||
else if(conf.getAppRegisteredType() == ClientConfiguration.AppRegisteredType.WEB_APP && conf.getWebAppPermission() == ClientConfiguration.WebAppPermission.DELEGATED){
|
||||
future = context.acquireToken(conf.getResource(), new ClientCredential(conf.getClientId(), conf.getClientSecret()), conf.getUserName(), conf.getPassword(), null);
|
||||
}
|
||||
else{
|
||||
throw new Exception("Can't retrieve token with this configuration : registered application type: "+conf.getAppRegisteredType()+", Web application permission: "+conf.getWebAppPermission());
|
||||
}
|
||||
|
||||
return future;
|
||||
}
|
||||
private Future<IAuthenticationResult> acquireToken(OauthClientApplication context) throws Exception {
|
||||
ClientCredentialParameters parameters = ClientCredentialParameters.builder(
|
||||
Collections.singleton(conf.getResource() + "/.default")).build();
|
||||
return context.acquireToken(parameters);
|
||||
}
|
||||
|
||||
private AuthenticationResult getAccessToken() throws ServiceUnavailableException {
|
||||
AuthenticationContext context = null;
|
||||
AuthenticationResult result = null;
|
||||
private IAuthenticationResult getAccessToken() throws ServiceUnavailableException {
|
||||
if(conf.getAppRegisteredType() == ClientConfiguration.AppRegisteredType.NATIVE_APP){
|
||||
return getAccessTokenNative();
|
||||
} if(conf.getAppRegisteredType() == ClientConfiguration.AppRegisteredType.WEB_APP && conf.getWebAppPermission() == ClientConfiguration.WebAppPermission.DELEGATED){
|
||||
return getAccessTokenWebApp();
|
||||
} else {
|
||||
throw new RuntimeException("Can't retrieve token with this configuration : registered application type: "+conf.getAppRegisteredType()+", Web application permission: "+conf.getWebAppPermission());
|
||||
}
|
||||
}
|
||||
|
||||
private IAuthenticationResult getAccessTokenNative() throws ServiceUnavailableException {
|
||||
PublicClientApplication context = null;
|
||||
IAuthenticationResult result = null;
|
||||
ExecutorService service = null;
|
||||
try {
|
||||
service = Executors.newFixedThreadPool(1);
|
||||
context = new AuthenticationContext(conf.getAuthoryEndpoint(), false, service);
|
||||
Proxy proxy = ProxyProvider.getProxy();
|
||||
PublicClientApplication.Builder contextBuilder = PublicClientApplication.builder(conf.getClientId()).authority("https://login.microsoftonline.com/organizations");
|
||||
if (proxy != null) {
|
||||
contextBuilder = contextBuilder.proxy(proxy);
|
||||
}
|
||||
context = contextBuilder.build();
|
||||
Future<IAuthenticationResult> future = this.acquireToken(context);
|
||||
result = future.get();
|
||||
} catch (Exception e) {
|
||||
throw new ServiceUnavailableException(e.getMessage());
|
||||
} finally {
|
||||
service.shutdown();
|
||||
}
|
||||
|
||||
if (result == null) {
|
||||
throw new ServiceUnavailableException("Authenticated failed! Please check your configuration!");
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
private IAuthenticationResult getAccessTokenWebApp() throws ServiceUnavailableException {
|
||||
OauthClientApplication context = null;
|
||||
IAuthenticationResult result = null;
|
||||
ExecutorService service = null;
|
||||
try {
|
||||
service = Executors.newFixedThreadPool(1);
|
||||
OauthClientApplication.Builder contextBuilder = OauthClientApplication.builder(conf.getClientId(),
|
||||
ClientCredentialFactory.createFromSecret(conf.getClientSecret()), conf.getUserName(), conf.getPassword())
|
||||
.authority(conf.getAuthoryEndpoint());
|
||||
Proxy proxy = ProxyProvider.getProxy();
|
||||
if (proxy != null) {
|
||||
context.setProxy(proxy);
|
||||
contextBuilder.proxy(proxy);
|
||||
}
|
||||
Future<AuthenticationResult> future = this.acquireToken(context);
|
||||
context = contextBuilder.build();
|
||||
Future<IAuthenticationResult> future = this.acquireToken(context);
|
||||
result = future.get();
|
||||
} catch (Exception e) {
|
||||
throw new ServiceUnavailableException(e.getMessage());
|
||||
|
||||
@@ -65,11 +65,6 @@
|
||||
<artifactId>poi</artifactId>
|
||||
<version>4.1.2</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.apache.poi</groupId>
|
||||
<artifactId>poi-scratchpad</artifactId>
|
||||
<version>4.1.2</version>
|
||||
</dependency>
|
||||
<!-- https://mvnrepository.com/artifact/org.apache.poi/poi-ooxml -->
|
||||
<dependency>
|
||||
<groupId>org.apache.poi</groupId>
|
||||
|
||||
@@ -5,7 +5,7 @@
|
||||
|
||||
<groupId>org.talend</groupId>
|
||||
<artifactId>talendMQConnectionUtil</artifactId>
|
||||
<version>1.1.0-20220307</version>
|
||||
<version>1.2.0-20220707</version>
|
||||
<packaging>jar</packaging>
|
||||
|
||||
<name>talendMQConnectionUtil</name>
|
||||
@@ -64,7 +64,7 @@
|
||||
<dependency>
|
||||
<groupId>com.ibm.mq</groupId>
|
||||
<artifactId>com.ibm.mq.allclient</artifactId>
|
||||
<version>9.2.4.0</version>
|
||||
<version>9.2.5.0</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>javax.resource</groupId>
|
||||
@@ -74,7 +74,7 @@
|
||||
<dependency>
|
||||
<groupId>org.talend</groupId>
|
||||
<artifactId>talendMQRFH2</artifactId>
|
||||
<version>1.1.0-20220307</version>
|
||||
<version>1.2.0-20220707</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.mockito</groupId>
|
||||
|
||||
@@ -58,12 +58,31 @@
|
||||
<dependency>
|
||||
<groupId>org.apache.poi</groupId>
|
||||
<artifactId>poi-scratchpad</artifactId>
|
||||
<version>4.1.2</version>
|
||||
<version>5.2.2</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>ch.qos.reload4j</groupId>
|
||||
<artifactId>reload4j</artifactId>
|
||||
<version>1.2.19</version>
|
||||
<groupId>commons-io</groupId>
|
||||
<artifactId>commons-io</artifactId>
|
||||
<version>2.8.0</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>junit</groupId>
|
||||
<artifactId>junit</artifactId>
|
||||
<version>4.12</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.apache.logging.log4j</groupId>
|
||||
<artifactId>log4j-api</artifactId>
|
||||
<version>2.17.1</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.apache.logging.log4j</groupId>
|
||||
<artifactId>log4j-core</artifactId>
|
||||
<version>2.17.1</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
</dependencies>
|
||||
<build>
|
||||
|
||||
@@ -0,0 +1,29 @@
|
||||
package org.talend.msg.utils;
|
||||
|
||||
import org.apache.poi.hsmf.exceptions.ChunkNotFoundException;
|
||||
import org.junit.Assert;
|
||||
import org.junit.Rule;
|
||||
import org.junit.Test;
|
||||
import org.junit.rules.TemporaryFolder;
|
||||
|
||||
import java.io.File;
|
||||
import java.io.IOException;
|
||||
|
||||
public class MsgMailUtilTest {
|
||||
|
||||
@Rule
|
||||
public TemporaryFolder folder = new TemporaryFolder();
|
||||
|
||||
@Test
|
||||
public void test() throws IOException, ChunkNotFoundException {
|
||||
File outDir = folder.newFolder("out");
|
||||
|
||||
MsgMailUtil msgMailUtil_tFileInputMail_1 = new MsgMailUtil(this.getClass().getClassLoader().getResource("test.msg").getPath(),
|
||||
outDir.getAbsolutePath());
|
||||
|
||||
msgMailUtil_tFileInputMail_1.getAttachments();
|
||||
|
||||
Assert.assertEquals("Chaudhari,Pankaj", msgMailUtil_tFileInputMail_1.processMessage("From"));
|
||||
}
|
||||
|
||||
}
|
||||
Binary file not shown.
@@ -49,7 +49,7 @@ TABLE_ACTION.ITEM.CLEAR=\u30C6\u30FC\u30D6\u30EB\u3092\u30AF\u30EA\u30A2
|
||||
TABLE_ACTION.ITEM.CREATE=\u30C6\u30FC\u30D6\u30EB\u306E\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.CREATE_IF_NOT_EXISTS=\u5B58\u5728\u3057\u306A\u3044\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_CREATE=\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u524A\u9664\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.NONE=\u30C7\u30D5\u30A9\u30EB\u30C8
|
||||
TABLE_ACTION.NAME=\u30C6\u30FC\u30D6\u30EB\u3067\u306E\u30A2\u30AF\u30B7\u30E7\u30F3
|
||||
USER.NAME=\u30E6\u30FC\u30B6\u30FC\u540D
|
||||
|
||||
@@ -13,7 +13,7 @@ TABLE_ACTION.ITEM.CLEAR=\u30C6\u30FC\u30D6\u30EB\u3092\u30AF\u30EA\u30A2
|
||||
TABLE_ACTION.ITEM.TRUNCATE=\u30C6\u30FC\u30D6\u30EB\u3092\u5207\u308A\u6368\u3066
|
||||
TABLE_ACTION.ITEM.CREATE=\u30C6\u30FC\u30D6\u30EB\u306E\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.CREATE_IF_NOT_EXISTS=\u5B58\u5728\u3057\u306A\u3044\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u524A\u9664\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_CREATE=\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.NONE=\u306A\u3057
|
||||
DATA_ACTION.NAME=\u30C7\u30FC\u30BF\u3067\u306E\u30A2\u30AF\u30B7\u30E7\u30F3
|
||||
|
||||
@@ -118,7 +118,7 @@
|
||||
<IMPORT NAME="Driver-JACKCESS" MODULE="jackcess-2.1.12.jar" MVN="mvn:com.healthmarketscience.jackcess/jackcess/2.1.12" REQUIRED="true"/>
|
||||
|
||||
<IMPORT NAME="jackcess-encrypt-2.1.4" MODULE="jackcess-encrypt-2.1.4.jar" MVN="mvn:com.healthmarketscience.jackcess/jackcess-encrypt/2.1.4" REQUIRED="true"/>
|
||||
<IMPORT NAME="bcprov-jdk15on-1.69" MODULE="bcprov-jdk15on-1.69.jar" MVN="mvn:org.bouncycastle/bcprov-jdk15on/1.69" REQUIRED="true"/>
|
||||
<IMPORT NAME="bcprov-jdk15on-1.70" MODULE="bcprov-jdk15on-1.70.jar" MVN="mvn:org.bouncycastle/bcprov-jdk15on/1.70" REQUIRED="true"/>
|
||||
<IMPORT NAME="talend-ucanaccess-utils-1.0.0" MODULE="talend-ucanaccess-utils-1.0.0.jar" MVN="mvn:org.talend.libraries/talend-ucanaccess-utils-1.0.0/6.4.0" REQUIRED="true"/>
|
||||
|
||||
<IMPORT NAME="common2.6" MODULE="commons-lang-2.6.jar" MVN="mvn:commons-lang/commons-lang/2.6" UrlPath="platform:/plugin/org.talend.libraries.apache.common/lib/commons-lang-2.6.jar" REQUIRED="true"/>
|
||||
|
||||
@@ -121,7 +121,7 @@
|
||||
<IMPORT NAME="Driver-JACKCESS" MODULE="jackcess-2.1.12.jar" MVN="mvn:com.healthmarketscience.jackcess/jackcess/2.1.12" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
|
||||
<IMPORT NAME="jackcess-encrypt-2.1.4" MODULE="jackcess-encrypt-2.1.4.jar" MVN="mvn:com.healthmarketscience.jackcess/jackcess-encrypt/2.1.4" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
<IMPORT NAME="bcprov-jdk15on-1.69" MODULE="bcprov-jdk15on-1.69.jar" MVN="mvn:org.bouncycastle/bcprov-jdk15on/1.69" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
<IMPORT NAME="bcprov-jdk15on-1.70" MODULE="bcprov-jdk15on-1.70.jar" MVN="mvn:org.bouncycastle/bcprov-jdk15on/1.70" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
<IMPORT NAME="talend-ucanaccess-utils-1.0.0" MODULE="talend-ucanaccess-utils-1.0.0.jar" MVN="mvn:org.talend.libraries/talend-ucanaccess-utils-1.0.0/6.4.0" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
|
||||
<IMPORT NAME="common2.6" MODULE="commons-lang-2.6.jar" MVN="mvn:commons-lang/commons-lang/2.6" UrlPath="platform:/plugin/org.talend.libraries.apache.common/lib/commons-lang-2.6.jar" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
|
||||
@@ -207,7 +207,7 @@
|
||||
<IMPORT NAME="Driver-JACKCESS" MODULE="jackcess-2.1.12.jar" MVN="mvn:com.healthmarketscience.jackcess/jackcess/2.1.12" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
|
||||
<IMPORT NAME="jackcess-encrypt-2.1.4" MODULE="jackcess-encrypt-2.1.4.jar" MVN="mvn:com.healthmarketscience.jackcess/jackcess-encrypt/2.1.4" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
<IMPORT NAME="bcprov-jdk15on-1.69" MODULE="bcprov-jdk15on-1.69.jar" MVN="mvn:org.bouncycastle/bcprov-jdk15on/1.69" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
<IMPORT NAME="bcprov-jdk15on-1.70" MODULE="bcprov-jdk15on-1.70.jar" MVN="mvn:org.bouncycastle/bcprov-jdk15on/1.70" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
<IMPORT NAME="talend-ucanaccess-utils-1.0.0" MODULE="talend-ucanaccess-utils-1.0.0.jar" MVN="mvn:org.talend.libraries/talend-ucanaccess-utils-1.0.0/6.4.0" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
|
||||
<IMPORT NAME="common2.6" MODULE="commons-lang-2.6.jar" MVN="mvn:commons-lang/commons-lang/2.6" UrlPath="platform:/plugin/org.talend.libraries.apache.common/lib/commons-lang-2.6.jar" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
|
||||
@@ -30,7 +30,7 @@ TABLE.NAME=\u30C6\u30FC\u30D6\u30EB
|
||||
USER.NAME=\u30E6\u30FC\u30B6\u30FC\u540D
|
||||
TABLE_ACTION.ITEM.CLEAR=\u30C6\u30FC\u30D6\u30EB\u3092\u30AF\u30EA\u30A2
|
||||
TABLE_ACTION.ITEM.CREATE=\u30C6\u30FC\u30D6\u30EB\u306E\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u524A\u9664\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.CREATE_IF_NOT_EXISTS=\u5B58\u5728\u3057\u306A\u3044\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_CREATE=\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.NONE=\u30C7\u30D5\u30A9\u30EB\u30C8
|
||||
|
||||
@@ -14,7 +14,7 @@ TABLE.NAME=\u30C6\u30FC\u30D6\u30EB
|
||||
TABLE_ACTION.ITEM.CLEAR=\u30C6\u30FC\u30D6\u30EB\u3092\u30AF\u30EA\u30A2
|
||||
TABLE_ACTION.ITEM.CREATE=\u30C6\u30FC\u30D6\u30EB\u306E\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.CREATE_IF_NOT_EXISTS=\u5B58\u5728\u3057\u306A\u3044\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u524A\u9664\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_CREATE=\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.NONE=\u306A\u3057
|
||||
TABLE_ACTION.NAME=\u30C6\u30FC\u30D6\u30EB\u3067\u306E\u30A2\u30AF\u30B7\u30E7\u30F3
|
||||
|
||||
@@ -181,7 +181,7 @@
|
||||
<IMPORT NAME="Driver-JACKCESS" MODULE="jackcess-2.1.12.jar" MVN="mvn:com.healthmarketscience.jackcess/jackcess/2.1.12" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
|
||||
<IMPORT NAME="jackcess-encrypt-2.1.4" MODULE="jackcess-encrypt-2.1.4.jar" MVN="mvn:com.healthmarketscience.jackcess/jackcess-encrypt/2.1.4" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
<IMPORT NAME="bcprov-jdk15on-1.69" MODULE="bcprov-jdk15on-1.69.jar" MVN="mvn:org.bouncycastle/bcprov-jdk15on/1.69" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
<IMPORT NAME="bcprov-jdk15on-1.70" MODULE="bcprov-jdk15on-1.70.jar" MVN="mvn:org.bouncycastle/bcprov-jdk15on/1.70" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
<IMPORT NAME="talend-ucanaccess-utils-1.0.0" MODULE="talend-ucanaccess-utils-1.0.0.jar" MVN="mvn:org.talend.libraries/talend-ucanaccess-utils-1.0.0/6.4.0" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
|
||||
<IMPORT NAME="common2.6" MODULE="commons-lang-2.6.jar" MVN="mvn:commons-lang/commons-lang/2.6" UrlPath="platform:/plugin/org.talend.libraries.apache.common/lib/commons-lang-2.6.jar" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')"/>
|
||||
|
||||
@@ -51,7 +51,7 @@ TABLE_ACTION.ITEM.CLEAR=\u30C6\u30FC\u30D6\u30EB\u3092\u30AF\u30EA\u30A2
|
||||
TABLE_ACTION.ITEM.TRUNCATE=\u30C6\u30FC\u30D6\u30EB\u3092\u5207\u308A\u6368\u3066
|
||||
TABLE_ACTION.ITEM.CREATE=\u30C6\u30FC\u30D6\u30EB\u306E\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.CREATE_IF_NOT_EXISTS=\u5B58\u5728\u3057\u306A\u3044\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u524A\u9664\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_CREATE=\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.NONE=\u306A\u3057
|
||||
TABLE_ACTION.NAME=\u30C6\u30FC\u30D6\u30EB\u3067\u306E\u30A2\u30AF\u30B7\u30E7\u30F3
|
||||
|
||||
@@ -228,8 +228,8 @@
|
||||
|
||||
<CODEGENERATION>
|
||||
<IMPORTS>
|
||||
<IMPORT NAME="aws-java-sdk-1.11.848.jar" MODULE="aws-java-sdk-1.11.848.jar"
|
||||
MVN="mvn:com.amazonaws/aws-java-sdk/1.11.848"
|
||||
<IMPORT NAME="aws-java-sdk-1.12.297.jar" MODULE="aws-java-sdk-1.12.297.jar"
|
||||
MVN="mvn:com.amazonaws/aws-java-sdk/1.12.297"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-core-2.13.2.jar" MODULE="jackson-core-2.13.2.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.2"
|
||||
|
||||
@@ -555,8 +555,8 @@
|
||||
|
||||
<CODEGENERATION>
|
||||
<IMPORTS>
|
||||
<IMPORT NAME="aws-java-sdk-1.11.848.jar" MODULE="aws-java-sdk-1.11.848.jar"
|
||||
MVN="mvn:com.amazonaws/aws-java-sdk/1.11.848"
|
||||
<IMPORT NAME="aws-java-sdk-1.12.297.jar" MODULE="aws-java-sdk-1.12.297.jar"
|
||||
MVN="mvn:com.amazonaws/aws-java-sdk/1.12.297"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-core-2.13.2.jar" MODULE="jackson-core-2.13.2.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.2"
|
||||
|
||||
@@ -126,9 +126,9 @@ SERVICE_ACCESS_SECURITY_GROUP.NAME=\u30B5\u30FC\u30D3\u30B9\u30A2\u30AF\u30BB\u3
|
||||
CLUSTER_FINAL_ID.NAME=\u30AF\u30E9\u30B9\u30BF\u30FCID
|
||||
CLUSTER_FINAL_NAME.NAME=\u30AF\u30E9\u30B9\u30BF\u30FC\u540D
|
||||
PREDICATES.NAME=\u8FF0\u8A9E
|
||||
PREDICATES.ITEM.RUNNING=\u3059\u3079\u3066\u306E\u30AF\u30E9\u30B9\u30BF\u30FC\u3092\u8D77\u52D5
|
||||
PREDICATES.ITEM.RUNNING_WITH_NAME=\u4E8B\u524D\u306B\u5B9A\u7FA9\u6E08\u307F\u306E\u540D\u524D\u3067\u30AF\u30E9\u30B9\u30BF\u30FC\u3092\u8D77\u52D5
|
||||
PREDICATES.ITEM.RUNNING_WITH_ID=\u4E8B\u524D\u306B\u5B9A\u7FA9\u6E08\u307F\u306EID\u3067\u30AF\u30E9\u30B9\u30BF\u30FC\u3092\u8D77\u52D5
|
||||
PREDICATES.ITEM.RUNNING=\u5B9F\u884C\u4E2D\u306E\u3059\u3079\u3066\u306E\u30AF\u30E9\u30B9\u30BF\u30FC
|
||||
PREDICATES.ITEM.RUNNING_WITH_NAME=\u4E8B\u524D\u5B9A\u7FA9\u6E08\u307F\u306E\u540D\u524D\u3067\u5B9F\u884C\u4E2D\u306E\u3059\u3079\u3066\u306E\u30AF\u30E9\u30B9\u30BF\u30FC
|
||||
PREDICATES.ITEM.RUNNING_WITH_ID=\u4E8B\u524D\u5B9A\u7FA9\u6E08\u307F\u306EID\u3067\u5B9F\u884C\u4E2D\u306E\u30AF\u30E9\u30B9\u30BF\u30FC
|
||||
NAME_OF_CLUSTER.NAME=\u30AF\u30E9\u30B9\u30BF\u30FC\u540D
|
||||
ID_OF_CLUSTER.NAME=\u30AF\u30E9\u30B9\u30BF\u30FCID
|
||||
WAIT_FOR_CLUSTER_READY.NAME=\u30AF\u30E9\u30B9\u30BF\u30FC\u306E\u6E96\u5099\u304C\u3067\u304D\u308B\u307E\u3067\u5F85\u6A5F
|
||||
|
||||
@@ -285,8 +285,8 @@
|
||||
|
||||
<CODEGENERATION>
|
||||
<IMPORTS>
|
||||
<IMPORT NAME="aws-java-sdk-1.11.848.jar" MODULE="aws-java-sdk-1.11.848.jar"
|
||||
MVN="mvn:com.amazonaws/aws-java-sdk/1.11.848"
|
||||
<IMPORT NAME="aws-java-sdk-1.12.297.jar" MODULE="aws-java-sdk-1.12.297.jar"
|
||||
MVN="mvn:com.amazonaws/aws-java-sdk/1.12.297"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-core-2.13.2.jar" MODULE="jackson-core-2.13.2.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.2"
|
||||
|
||||
@@ -58,7 +58,7 @@ TABLE_ACTION.ITEM.CLEAR=\u30C6\u30FC\u30D6\u30EB\u3092\u30AF\u30EA\u30A2
|
||||
TABLE_ACTION.ITEM.TRUNCATE=\u30C6\u30FC\u30D6\u30EB\u3092\u5207\u308A\u6368\u3066
|
||||
TABLE_ACTION.ITEM.CREATE=\u30C6\u30FC\u30D6\u30EB\u306E\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.CREATE_IF_NOT_EXISTS=\u5B58\u5728\u3057\u306A\u3044\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u524A\u9664\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_CREATE=\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.NONE=\u306A\u3057
|
||||
TABLE_ACTION.NAME=\u30C6\u30FC\u30D6\u30EB\u3067\u306E\u30A2\u30AF\u30B7\u30E7\u30F3
|
||||
|
||||
@@ -52,7 +52,7 @@ TABLE_ACTION.ITEM.CLEAR=\u30C6\u30FC\u30D6\u30EB\u3092\u30AF\u30EA\u30A2
|
||||
TABLE_ACTION.ITEM.TRUNCATE=\u30C6\u30FC\u30D6\u30EB\u3092\u5207\u308A\u6368\u3066
|
||||
TABLE_ACTION.ITEM.CREATE=\u30C6\u30FC\u30D6\u30EB\u306E\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.CREATE_IF_NOT_EXISTS=\u5B58\u5728\u3057\u306A\u3044\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u524A\u9664\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_CREATE=\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.NONE=\u306A\u3057
|
||||
TABLE_ACTION.NAME=\u30C6\u30FC\u30D6\u30EB\u3067\u306E\u30A2\u30AF\u30B7\u30E7\u30F3
|
||||
|
||||
@@ -345,8 +345,8 @@
|
||||
|
||||
<CODEGENERATION>
|
||||
<IMPORTS>
|
||||
<IMPORT NAME="aws-java-sdk-1.11.848.jar" MODULE="aws-java-sdk-1.11.848.jar"
|
||||
MVN="mvn:com.amazonaws/aws-java-sdk/1.11.848"
|
||||
<IMPORT NAME="aws-java-sdk-1.12.297.jar" MODULE="aws-java-sdk-1.12.297.jar"
|
||||
MVN="mvn:com.amazonaws/aws-java-sdk/1.12.297"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-core-2.13.2.jar" MODULE="jackson-core-2.13.2.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.2"
|
||||
|
||||
@@ -395,7 +395,7 @@
|
||||
<IMPORT NAME="content-type" MODULE="content-type-2.1.jar" MVN="mvn:com.nimbusds/content-type/2.1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="lang-tag" MODULE="lang-tag-1.5.jar" MVN="mvn:com.nimbusds/lang-tag/1.5" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.9.3.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.9.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.22.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.22" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
|
||||
@@ -87,7 +87,7 @@ TABLE_ACTION.ITEM.CLEAR=\u30C6\u30FC\u30D6\u30EB\u3092\u30AF\u30EA\u30A2
|
||||
TABLE_ACTION.ITEM.CREATE=\u30C6\u30FC\u30D6\u30EB\u306E\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.CREATE_IF_NOT_EXISTS=\u5B58\u5728\u3057\u306A\u3044\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_CREATE=\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u524A\u9664\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.NONE=\u306A\u3057
|
||||
TABLE_ACTION.ITEM.TRUNCATE=\u30C6\u30FC\u30D6\u30EB\u3092\u5207\u308A\u6368\u3066
|
||||
TABLE_ACTION.NAME=\u30C6\u30FC\u30D6\u30EB\u3067\u306E\u30A2\u30AF\u30B7\u30E7\u30F3
|
||||
|
||||
@@ -218,7 +218,7 @@
|
||||
<IMPORT NAME="content-type" MODULE="content-type-2.1.jar" MVN="mvn:com.nimbusds/content-type/2.1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="lang-tag" MODULE="lang-tag-1.5.jar" MVN="mvn:com.nimbusds/lang-tag/1.5" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.9.3.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.9.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.22.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.22" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
|
||||
@@ -278,7 +278,7 @@
|
||||
<IMPORT NAME="content-type" MODULE="content-type-2.1.jar" MVN="mvn:com.nimbusds/content-type/2.1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="lang-tag" MODULE="lang-tag-1.5.jar" MVN="mvn:com.nimbusds/lang-tag/1.5" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.9.3.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.9.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.22.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.22" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
|
||||
@@ -349,7 +349,7 @@
|
||||
<IMPORT NAME="content-type" MODULE="content-type-2.1.jar" MVN="mvn:com.nimbusds/content-type/2.1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="lang-tag" MODULE="lang-tag-1.5.jar" MVN="mvn:com.nimbusds/lang-tag/1.5" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.9.3.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.9.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.22.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.22" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
|
||||
@@ -64,7 +64,7 @@ TABLE_ACTION.ITEM.TRUNCATE=\u30C6\u30FC\u30D6\u30EB\u3092\u5207\u308A\u6368\u306
|
||||
TABLE_ACTION.ITEM.CREATE=\u30C6\u30FC\u30D6\u30EB\u306E\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.CREATE_IF_NOT_EXISTS=\u5B58\u5728\u3057\u306A\u3044\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_CREATE=\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u524A\u9664\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.NONE=\u306A\u3057
|
||||
TABLE_ACTION.NAME=\u30C6\u30FC\u30D6\u30EB\u3067\u306E\u30A2\u30AF\u30B7\u30E7\u30F3
|
||||
USER.NAME=\u30E6\u30FC\u30B6\u30FC\u540D
|
||||
|
||||
@@ -334,7 +334,7 @@
|
||||
<IMPORT NAME="content-type" MODULE="content-type-2.1.jar" MVN="mvn:com.nimbusds/content-type/2.1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="lang-tag" MODULE="lang-tag-1.5.jar" MVN="mvn:com.nimbusds/lang-tag/1.5" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.9.3.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.9.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.22.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.22" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
|
||||
@@ -262,7 +262,7 @@
|
||||
<IMPORT NAME="google-api-services-oauth2-v2-rev20200213-1.31.0.jar" MODULE="google-api-services-oauth2-v2-rev20200213-1.31.0.jar" MVN="mvn:com.google.apis/google-api-services-oauth2/v2-rev20200213-1.31.0" REQUIRED="true" />
|
||||
<IMPORT NAME="google-api-services-bigquery-v2-rev20201030-1.31.0.jar" MODULE="google-api-services-bigquery-v2-rev20201030-1.31.0.jar" MVN="mvn:com.google.apis/google-api-services-bigquery/v2-rev20201030-1.31.0" REQUIRED="true" />
|
||||
<IMPORT NAME="google-http-client-1.38.0.jar" MODULE="google-http-client-1.38.0.jar" MVN="mvn:com.google.http-client/google-http-client/1.38.0" REQUIRED="true" />
|
||||
<IMPORT NAME="google-oauth-client-1.31.0.jar" MODULE="google-oauth-client-1.31.0.jar" MVN="mvn:com.google.oauth-client/google-oauth-client/1.31.0" REQUIRED="true" />
|
||||
<IMPORT NAME="google-oauth-client-1.33.3.jar" MODULE="google-oauth-client-1.33.3.jar" MVN="mvn:com.google.oauth-client/google-oauth-client/1.33.3" REQUIRED="true" />
|
||||
<IMPORT NAME="google-http-client-jackson2-1.38.0.jar" MODULE="google-http-client-jackson2-1.38.0.jar" MVN="mvn:com.google.http-client/google-http-client-jackson2/1.38.0" REQUIRED="true" />
|
||||
<IMPORT NAME="guava-30.0-jre.jar" MODULE="guava-30.0-jre.jar" MVN="mvn:com.google.guava/guava/30.0-jre" REQUIRED="true" />
|
||||
<IMPORT NAME="failureaccess-1.0.1.jar" MODULE="failureaccess-1.0.1.jar" MVN="mvn:com.google.guava/failureaccess/1.0.1" REQUIRED="true" />
|
||||
@@ -292,7 +292,7 @@
|
||||
<IMPORT NAME="google-cloud-storage-1.104.0" MODULE="google-cloud-storage-1.104.0.jar" MVN="mvn:com.google.cloud/google-cloud-storage/1.104.0" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<!-- Transitive dependencies of google-cloud-storage -->
|
||||
<IMPORT NAME="google-api-services-storage-v1-rev20201112-1.31.0" MODULE="google-api-services-storage-v1-rev20201112-1.31.0.jar" MVN="mvn:com.google.apis/google-api-services-storage/v1-rev20201112-1.31.0" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="gson-2.8.6" MODULE="gson-2.8.6.jar" MVN="mvn:com.google.code.gson/gson/2.8.6" REQUIRED="true" />
|
||||
<IMPORT NAME="gson-2.8.9" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED="true" />
|
||||
<IMPORT NAME="javax.annotation-api" MODULE="javax.annotation-api-1.3.jar" MVN="mvn:javax.annotation/javax.annotation-api/1.3" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="protobuf-java-3.19.2" MODULE="protobuf-java-3.19.2.jar" MVN="mvn:com.google.protobuf/protobuf-java/3.19.2" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="error_prone_annotation-2.1.3" MODULE="error_prone_annotation-2.1.3.jar" MVN="mvn:com.google.errorprone/error_prone_annotations/2.1.3" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
|
||||
@@ -14,7 +14,7 @@ ACCESS_TOKEN.NAME=OAuth\u30A2\u30AF\u30BB\u30B9\u30C8\u30FC\u30AF\u30F3
|
||||
SCHEMA.NAME=\u30B9\u30AD\u30FC\u30DE
|
||||
DATASET.NAME=\u30C7\u30FC\u30BF\u30BB\u30C3\u30C8
|
||||
TABLE.NAME=\u30C6\u30FC\u30D6\u30EB
|
||||
CREATE_TABLE_IF_NOT_EXIST.NAME=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3057\u306A\u3051\u308C\u3070\u4F5C\u6210
|
||||
CREATE_TABLE_IF_NOT_EXIST.NAME=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3057\u306A\u3044\u5834\u5408\u306F\u4F5C\u6210
|
||||
ACTION_ON_DATA.NAME=\u30C7\u30FC\u30BF\u3067\u306E\u30A2\u30AF\u30B7\u30E7\u30F3
|
||||
ACTION_ON_DATA.ITEM.APPEND=\u8FFD\u52A0
|
||||
ACTION_ON_DATA.ITEM.TRUNCATE=\u5168\u524A\u9664
|
||||
|
||||
@@ -35,7 +35,7 @@ USE_CUSTOM_NULL_MARKER.NAME=\u4F7F\u7528\u81EA\u5B9A\u4E49 null \u6807\u8BB0
|
||||
CUSTOM_NULL_MARKER.NAME=
|
||||
DROP.NAME=\u5982\u679C\u8868\u5B58\u5728\u5219\u5220\u9664
|
||||
DIE_ON_ERROR.NAME=\u9519\u8BEF\u65F6\u7EC8\u6B62
|
||||
AUTH_TYPE.NAME=\u7528\u6237\u540D\u548C\u5BC6\u7801\u7C7B\u578B
|
||||
AUTH_TYPE.NAME=\u51ED\u8BC1\u7C7B\u578B
|
||||
AUTH_TYPE.ITEM.GS_SERVICE_ACCOUNT=\u670D\u52A1\u5E10\u6237
|
||||
GS_SERVICE_ACCOUNT_KEY.NAME=\u670D\u52A1\u5E10\u6237\u5BC6\u94A5
|
||||
GS_ACCESS_TOKEN.NAME=OAuth \u8BBF\u95EE\u4EE4\u724C
|
||||
|
||||
@@ -205,7 +205,7 @@
|
||||
<IMPORT NAME="google-api-services-oauth2-v2-rev20200213-1.31.0.jar" MODULE="google-api-services-oauth2-v2-rev20200213-1.31.0.jar" MVN="mvn:com.google.apis/google-api-services-oauth2/v2-rev20200213-1.31.0" REQUIRED="true" />
|
||||
<IMPORT NAME="google-api-services-bigquery-v2-rev20201030-1.31.0.jar" MODULE="google-api-services-bigquery-v2-rev20201030-1.31.0.jar" MVN="mvn:com.google.apis/google-api-services-bigquery/v2-rev20201030-1.31.0" REQUIRED="true" />
|
||||
<IMPORT NAME="google-http-client-1.38.0.jar" MODULE="google-http-client-1.38.0.jar" MVN="mvn:com.google.http-client/google-http-client/1.38.0" REQUIRED="true" />
|
||||
<IMPORT NAME="google-oauth-client-1.31.0.jar" MODULE="google-oauth-client-1.31.0.jar" MVN="mvn:com.google.oauth-client/google-oauth-client/1.31.0" REQUIRED="true" />
|
||||
<IMPORT NAME="google-oauth-client-1.33.3.jar" MODULE="google-oauth-client-1.33.3.jar" MVN="mvn:com.google.oauth-client/google-oauth-client/1.33.3" REQUIRED="true" />
|
||||
<IMPORT NAME="google-http-client-jackson2-1.38.0.jar" MODULE="google-http-client-jackson2-1.38.0.jar" MVN="mvn:com.google.http-client/google-http-client-jackson2/1.38.0" REQUIRED="true" />
|
||||
<IMPORT NAME="guava-30.0-jre.jar" MODULE="guava-30.0-jre.jar" MVN="mvn:com.google.guava/guava/30.0-jre" REQUIRED="true" />
|
||||
<IMPORT NAME="failureaccess-1.0.1.jar" MODULE="failureaccess-1.0.1.jar" MVN="mvn:com.google.guava/failureaccess/1.0.1" REQUIRED="true" />
|
||||
@@ -228,7 +228,7 @@
|
||||
<IMPORT NAME="opencensus-api-0.24.0" MODULE="opencensus-api-0.24.0.jar" MVN="mvn:io.opencensus/opencensus-api/0.24.0" REQUIRED="true" />
|
||||
<IMPORT NAME="opencensus-contrib-http-util-0.24.0" MODULE="opencensus-contrib-http-util-0.24.0.jar" MVN="mvn:io.opencensus/opencensus-contrib-http-util/0.24.0" REQUIRED="true" />
|
||||
<IMPORT NAME="grpc-context-1.22.1" MODULE="grpc-context-1.22.1.jar" MVN="mvn:io.grpc/grpc-context/1.22.1" REQUIRED="true" />
|
||||
<IMPORT NAME="gson-2.8.6" MODULE="gson-2.8.6.jar" MVN="mvn:com.google.code.gson/gson/2.8.6" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'" />
|
||||
<IMPORT NAME="gson-2.8.9" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
<RETURNS>
|
||||
|
||||
@@ -282,6 +282,13 @@
|
||||
<DEFAULT>"\""</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="USE_CUSTOM_NULL_MARKER" FIELD="CHECK" NUM_ROW="35">
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
<PARAMETER NAME="CUSTOM_NULL_MARKER" FIELD="TEXT" NUM_ROW="35" SHOW_IF="USE_CUSTOM_NULL_MARKER=='true'">
|
||||
<DEFAULT>""</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="CREATE" FIELD="CHECK" REQUIRED="true" NUM_ROW="40">
|
||||
<DEFAULT>true</DEFAULT>
|
||||
</PARAMETER>
|
||||
@@ -367,6 +374,11 @@
|
||||
|
||||
<TEMPLATE_PARAM SOURCE="self.TEXT_ENCLOSURE" TARGET="tBQOB.TEXT_ENCLOSURE" />
|
||||
|
||||
<TEMPLATE_PARAM SOURCE="self.USE_CUSTOM_NULL_MARKER" TARGET="tBQOB.USE_CUSTOM_NULL_MARKER" />
|
||||
<TEMPLATE_PARAM SOURCE="self.CUSTOM_NULL_MARKER" TARGET="tBQOB.CUSTOM_NULL_MARKER" />
|
||||
<TEMPLATE_PARAM SOURCE="self.USE_CUSTOM_NULL_MARKER" TARGET="tBQBE.USE_CUSTOM_NULL_MARKER" />
|
||||
<TEMPLATE_PARAM SOURCE="self.CUSTOM_NULL_MARKER" TARGET="tBQBE.CUSTOM_NULL_MARKER" />
|
||||
|
||||
<TEMPLATE_PARAM SOURCE="self.SCHEMA" TARGET="tBQOB.SCHEMA" />
|
||||
<TEMPLATE_PARAM SOURCE="self.SCHEMA" TARGET="tBQBE.SCHEMA" />
|
||||
|
||||
|
||||
@@ -55,3 +55,5 @@ GS_ACCESS_TOKEN.NAME=OAuth Access Token
|
||||
JOBID.NAME=BigQuery JobId
|
||||
STATISTICS.NAME=Statistics of the main query
|
||||
USE_12_HOUR_FORMAT.NAME=Use 12-hour format for dynamic columns
|
||||
USE_CUSTOM_NULL_MARKER.NAME=Use custom null marker
|
||||
CUSTOM_NULL_MARKER.NAME=
|
||||
|
||||
@@ -55,3 +55,5 @@ GS_ACCESS_TOKEN.NAME=Jeton d'acc\u00E8s OAuth
|
||||
JOBID.NAME=ID du Job BigQuery
|
||||
STATISTICS.NAME=Statistiques de la requ\u00EAte principale
|
||||
USE_12_HOUR_FORMAT.NAME=Utiliser le format 12\u00A0heures pour les colonnes dynamiques
|
||||
USE_CUSTOM_NULL_MARKER.NAME=Utiliser un marqueur personnalis\u00E9 pour les nulls
|
||||
CUSTOM_NULL_MARKER.NAME=
|
||||
|
||||
@@ -29,7 +29,7 @@ ACCESS_TOKEN.NAME=OAuth\u30A2\u30AF\u30BB\u30B9\u30C8\u30FC\u30AF\u30F3
|
||||
SCHEMA.NAME=\u30B9\u30AD\u30FC\u30DE
|
||||
DATASET.NAME=\u30C7\u30FC\u30BF\u30BB\u30C3\u30C8
|
||||
TABLE.NAME=\u30C6\u30FC\u30D6\u30EB
|
||||
CREATE_TABLE_IF_NOT_EXIST.NAME=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3057\u306A\u3051\u308C\u3070\u4F5C\u6210
|
||||
CREATE_TABLE_IF_NOT_EXIST.NAME=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3057\u306A\u3044\u5834\u5408\u306F\u4F5C\u6210
|
||||
ACTION_ON_DATA.NAME=\u30C7\u30FC\u30BF\u3067\u306E\u30A2\u30AF\u30B7\u30E7\u30F3
|
||||
ACTION_ON_DATA.ITEM.APPEND=\u8FFD\u52A0
|
||||
ACTION_ON_DATA.ITEM.TRUNCATE=\u5168\u524A\u9664
|
||||
@@ -55,3 +55,5 @@ GS_ACCESS_TOKEN.NAME=OAuth\u30A2\u30AF\u30BB\u30B9\u30C8\u30FC\u30AF\u30F3
|
||||
JOBID.NAME=BigQuery JobId
|
||||
STATISTICS.NAME=\u30E1\u30A4\u30F3\u30AF\u30A8\u30EA\u30FC\u306E\u7D71\u8A08
|
||||
USE_12_HOUR_FORMAT.NAME=\u30C0\u30A4\u30CA\u30DF\u30C3\u30AF\u30AB\u30E9\u30E0\u306B\u306F12\u6642\u9593\u5F62\u5F0F\u3092\u4F7F\u7528
|
||||
USE_CUSTOM_NULL_MARKER.NAME=\u30AB\u30B9\u30BF\u30E0Null\u30DE\u30FC\u30AB\u30FC\u306E\u4F7F\u7528
|
||||
CUSTOM_NULL_MARKER.NAME=
|
||||
|
||||
@@ -47,7 +47,7 @@ FIELD_DELIMITER.NAME=
|
||||
TOKEN_NAME.NAME=\u4EE4\u724C\u5C5E\u6027\u6587\u4EF6\u540D
|
||||
CHECK_DISK_SPACE.NAME=\u68C0\u67E5\u78C1\u76D8\u7A7A\u95F4
|
||||
DIE_ON_ERROR.NAME=\u9519\u8BEF\u65F6\u7EC8\u6B62
|
||||
AUTH_TYPE.NAME=\u7528\u6237\u540D\u548C\u5BC6\u7801\u7C7B\u578B
|
||||
AUTH_TYPE.NAME=\u51ED\u8BC1\u7C7B\u578B
|
||||
AUTH_TYPE.ITEM.GS_SERVICE_ACCOUNT=\u670D\u52A1\u5E10\u6237
|
||||
AUTH_TYPE.ITEM.TOKEN=OAuth \u8BBF\u95EE\u4EE4\u724C
|
||||
GS_SERVICE_ACCOUNT_KEY.NAME=\u670D\u52A1\u5E10\u6237\u5BC6\u94A5
|
||||
@@ -55,3 +55,5 @@ GS_ACCESS_TOKEN.NAME=OAuth \u8BBF\u95EE\u4EE4\u724C
|
||||
JOBID.NAME=BigQuery JobId
|
||||
STATISTICS.NAME=\u4E3B\u67E5\u8BE2\u7EDF\u8BA1
|
||||
USE_12_HOUR_FORMAT.NAME=\u5BF9\u52A8\u6001\u5217\u91C7\u7528 12 \u5C0F\u65F6\u683C\u5F0F
|
||||
USE_CUSTOM_NULL_MARKER.NAME=\u4F7F\u7528\u81EA\u5B9A\u4E49 null \u6807\u8BB0
|
||||
CUSTOM_NULL_MARKER.NAME=
|
||||
|
||||
@@ -191,7 +191,7 @@
|
||||
<IMPORT NAME="google-api-services-oauth2-v2-rev20200213-1.31.0.jar" MODULE="google-api-services-oauth2-v2-rev20200213-1.31.0.jar" MVN="mvn:com.google.apis/google-api-services-oauth2/v2-rev20200213-1.31.0" REQUIRED="true" />
|
||||
<IMPORT NAME="google-api-services-bigquery-v2-rev20201030-1.31.0.jar" MODULE="google-api-services-bigquery-v2-rev20201030-1.31.0.jar" MVN="mvn:com.google.apis/google-api-services-bigquery/v2-rev20201030-1.31.0" REQUIRED="true" />
|
||||
<IMPORT NAME="google-http-client-1.38.0.jar" MODULE="google-http-client-1.38.0.jar" MVN="mvn:com.google.http-client/google-http-client/1.38.0" REQUIRED="true" />
|
||||
<IMPORT NAME="google-oauth-client-1.31.0.jar" MODULE="google-oauth-client-1.31.0.jar" MVN="mvn:com.google.oauth-client/google-oauth-client/1.31.0" REQUIRED="true" />
|
||||
<IMPORT NAME="google-oauth-client-1.33.3.jar" MODULE="google-oauth-client-1.33.3.jar" MVN="mvn:com.google.oauth-client/google-oauth-client/1.33.3" REQUIRED="true" />
|
||||
<IMPORT NAME="google-http-client-jackson2-1.38.0.jar" MODULE="google-http-client-jackson2-1.38.0.jar" MVN="mvn:com.google.http-client/google-http-client-jackson2/1.38.0" REQUIRED="true" />
|
||||
<IMPORT NAME="guava-30.0-jre.jar" MODULE="guava-30.0-jre.jar" MVN="mvn:com.google.guava/guava/30.0-jre" REQUIRED="true"/>
|
||||
<IMPORT NAME="failureaccess-1.0.1.jar" MODULE="failureaccess-1.0.1.jar" MVN="mvn:com.google.guava/failureaccess/1.0.1" REQUIRED="true" />
|
||||
@@ -233,7 +233,7 @@
|
||||
<IMPORT NAME="opencensus-api-0.24.0" MODULE="opencensus-api-0.24.0.jar" MVN="mvn:io.opencensus/opencensus-api/0.24.0" REQUIRED="true" />
|
||||
<IMPORT NAME="opencensus-contrib-http-util-0.24.0" MODULE="opencensus-contrib-http-util-0.24.0.jar" MVN="mvn:io.opencensus/opencensus-contrib-http-util/0.24.0" REQUIRED="true" />
|
||||
<IMPORT NAME="grpc-context-1.22.1" MODULE="grpc-context-1.22.1.jar" MVN="mvn:io.grpc/grpc-context/1.22.1" REQUIRED="true" />
|
||||
<IMPORT NAME="gson-2.8.6" MODULE="gson-2.8.6.jar" MVN="mvn:com.google.code.gson/gson/2.8.6" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'" />
|
||||
<IMPORT NAME="gson-2.8.9" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
<RETURNS>
|
||||
|
||||
@@ -26,7 +26,7 @@ BONITA_ENVIRONMENT_FILE.NAME =Bonita\u30E9\u30F3\u30BF\u30A4\u30E0\u74B0\u5883\u
|
||||
JASS_STANDARD_FILE.NAME=Bonita\u30E9\u30F3\u30BF\u30A4\u30E0JAAS\u30D5\u30A1\u30A4\u30EB
|
||||
LOGGING_FILE.NAME =Bonita\u30E9\u30F3\u30BF\u30A4\u30E0\u30ED\u30B0\u30D5\u30A1\u30A4\u30EB
|
||||
|
||||
USE_PROCESS_ID.NAME=\u30D7\u30ED\u30BB\u30B9ID\u306E\u4F7F\u7528
|
||||
USE_PROCESS_ID.NAME=\u30D7\u30ED\u30BB\u30B9ID\u3092\u4F7F\u7528
|
||||
PROCESS_NAME.NAME=\u30D7\u30ED\u30BB\u30B9\u540D
|
||||
PROCESS_VERSION.NAME=\u30D7\u30ED\u30BB\u30B9\u30D0\u30FC\u30B8\u30E7\u30F3
|
||||
LOGIN_MODULE.NAME=\u30ED\u30B0\u30A4\u30F3\u30E2\u30B8\u30E5\u30FC\u30EB
|
||||
|
||||
@@ -163,29 +163,31 @@ COMPATIBILITY="ALL"
|
||||
|
||||
<CODEGENERATION>
|
||||
<IMPORTS>
|
||||
<IMPORT NAME="aopalliance-1_0" MODULE="aopalliance-1.0.jar" MVN="mvn:aopalliance/aopalliance/1.0" UrlPath="platform:/plugin/org.talend.libraries.esb/lib/aopalliance-1.0.jar" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="aws-ec2-2_0_2" MODULE="aws-ec2-2.0.2.jar" MVN="mvn:org.talend.libraries/aws-ec2-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="commons-io-2.8.0" MODULE="commons-io-2.8.0.jar" MVN="mvn:commons-io/commons-io/2.8.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="ec2-2_0_2" MODULE="ec2-2.0.2.jar" MVN="mvn:org.talend.libraries/ec2-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="gson-2_2" MODULE="gson-2.2.jar" MVN="mvn:org.talend.libraries/gson-2.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="guava-16.0.1" MODULE="guava-16.0.1.jar" MVN="mvn:com.google.guava/guava/16.0.1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="guice-3_0" MODULE="guice-3.0.jar" MVN="mvn:com.google.inject/guice/3.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="guice-assistedinject-3_0" MODULE="guice-assistedinject-3.0.jar" MVN="mvn:org.talend.libraries/guice-assistedinject-3.0/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="javax_inject-1" MODULE="javax.inject-1.jar" MVN="mvn:javax.inject/javax.inject/1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-bouncycastle-2_0_2" MODULE="jclouds-bouncycastle-2.0.2.jar" MVN="mvn:org.talend.libraries/jclouds-bouncycastle-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-compute-2_0_2" MODULE="jclouds-compute-2.0.2.jar" MVN="mvn:org.talend.libraries/jclouds-compute-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-core-2_0_2" MODULE="jclouds-core-2.0.2.jar" MVN="mvn:org.talend.libraries/jclouds-core-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-scriptbuilder-2_0_2" MODULE="jclouds-scriptbuilder-2.0.2.jar" MVN="mvn:org.talend.libraries/jclouds-scriptbuilder-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-slf4j-2_0_2" MODULE="jclouds-slf4j-2.0.2.jar" MVN="mvn:org.talend.libraries/jclouds-slf4j-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-sshj-2_0_2" MODULE="jclouds-sshj-2.0.2.jar" MVN="mvn:org.talend.libraries/jclouds-sshj-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jsr250-api-1_0" MODULE="jsr250-api-1.0.jar" MVN="mvn:org.talend.libraries/jsr250-api-1.0/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jsr311-api-1_1_1" MODULE="jsr311-api-1.1.1.jar" MVN="mvn:org.talend.libraries/jsr311-api-1.1.1/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="rocoto-6_1" MODULE="rocoto-6.1.jar" MVN="mvn:org.talend.libraries/rocoto-6.1/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="slf4j-api-1_7_2" MODULE="slf4j-api-1.7.2.jar" MVN="mvn:org.talend.libraries/slf4j-api-1.7.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="sshj-0_8_1" MODULE="sshj-0.8.1.jar" MVN="mvn:org.talend.libraries/sshj-0.8.1/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
|
||||
<IMPORT NAME="sts-2.0.2" MODULE="sts-2.0.2.jar" MVN="mvn:org.talend.libraries/sts-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jaxb-api-2.3.1" MODULE="jaxb-api-2.3.1.jar" MVN="mvn:javax.xml.bind/jaxb-api/2.3.1" REQUIRED="true"/>
|
||||
<IMPORT NAME="aws-ec2" MODULE="aws-ec2-2.5.0.jar" MVN="mvn:org.apache.jclouds.provider/aws-ec2/2.5.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="ec2" MODULE="ec2-2.5.0.jar" MVN="mvn:org.apache.jclouds.api/ec2/2.5.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="sts" MODULE="sts-2.5.0.jar" MVN="mvn:org.apache.jclouds.api/sts/2.5.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-core" MODULE="jclouds-core-2.5.0.jar" MVN="mvn:org.apache.jclouds/jclouds-core/2.5.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="gson" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="guava" MODULE="guava-30.0-jre.jar" MVN="mvn:com.google.guava/guava/30.0-jre" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="failureaccess" MODULE="failureaccess-1.0.1.jar" MVN="mvn:com.google.guava/failureaccess/1.0.1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="listenablefuture" MODULE="listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar" MVN="mvn:com.google.guava/listenablefuture/9999.0-empty-to-avoid-conflict-with-guava" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jsr305" MODULE="jsr305-3.0.2.jar" MVN="mvn:com.google.code.findbugs/jsr305/3.0.2" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="checker-qual" MODULE="checker-qual-2.5.2.jar" MVN="mvn:org.checkerframework/checker-qual/2.5.2" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="error_prone_annotations" MODULE="error_prone_annotations-2.2.0.jar" MVN="mvn:com.google.errorprone/error_prone_annotations/2.2.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="j2objc-annotations" MODULE="j2objc-annotations-1.1.jar" MVN="mvn:com.google.j2objc/j2objc-annotations/1.1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="animal-sniffer-annotations" MODULE="animal-sniffer-annotations-1.17.jar" MVN="mvn:org.codehaus.mojo/animal-sniffer-annotations/1.17" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="guice" MODULE="guice-5.0.1.jar" MVN="mvn:com.google.inject/guice/5.0.1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="javax.inject" MODULE="javax.inject-1.jar" MVN="mvn:javax.inject/javax.inject/1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="aopalliance" MODULE="aopalliance-1.0.jar" MVN="mvn:aopalliance/aopalliance/1.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="guice-assistedinject" MODULE="guice-assistedinject-5.0.1.jar" MVN="mvn:com.google.inject.extensions/guice-assistedinject/5.0.1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="javax.ws.rs-api" MODULE="javax.ws.rs-api-2.0.1.jar" MVN="mvn:javax.ws.rs/javax.ws.rs-api/2.0.1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="javax.annotation-api" MODULE="javax.annotation-api-1.2.jar" MVN="mvn:javax.annotation/javax.annotation-api/1.2" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jaxb-impl" MODULE="jaxb-impl-2.3.3.jar" MVN="mvn:com.sun.xml.bind/jaxb-impl/2.3.3" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jakarta.xml.bind-api" MODULE="jakarta.xml.bind-api-2.3.3.jar" MVN="mvn:jakarta.xml.bind/jakarta.xml.bind-api/2.3.3" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jakarta.activation" MODULE="jakarta.activation-1.2.2.jar" MVN="mvn:com.sun.activation/jakarta.activation/1.2.2" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-compute" MODULE="jclouds-compute-2.5.0.jar" MVN="mvn:org.apache.jclouds/jclouds-compute/2.5.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-scriptbuilder" MODULE="jclouds-scriptbuilder-2.5.0.jar" MVN="mvn:org.apache.jclouds/jclouds-scriptbuilder/2.5.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jaxb-api-2.3.1" MODULE="jaxb-api-2.3.1.jar" MVN="mvn:javax.xml.bind/jaxb-api/2.3.1" REQUIRED="true"/>
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
|
||||
@@ -72,29 +72,31 @@ COMPATIBILITY="ALL"
|
||||
|
||||
<CODEGENERATION>
|
||||
<IMPORTS>
|
||||
<IMPORT NAME="aopalliance-1_0" MODULE="aopalliance-1.0.jar" MVN="mvn:aopalliance/aopalliance/1.0" UrlPath="platform:/plugin/org.talend.libraries.esb/lib/aopalliance-1.0.jar" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="aws-ec2-2_0_2" MODULE="aws-ec2-2.0.2.jar" MVN="mvn:org.talend.libraries/aws-ec2-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="commons-io-2.8.0" MODULE="commons-io-2.8.0.jar" MVN="mvn:commons-io/commons-io/2.8.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="ec2-2_0_2" MODULE="ec2-2.0.2.jar" MVN="mvn:org.talend.libraries/ec2-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="gson-2_2" MODULE="gson-2.2.jar" MVN="mvn:org.talend.libraries/gson-2.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="guava-16.0.1" MODULE="guava-16.0.1.jar" MVN="mvn:com.google.guava/guava/16.0.1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="guice-3_0" MODULE="guice-3.0.jar" MVN="mvn:com.google.inject/guice/3.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="guice-assistedinject-3_0" MODULE="guice-assistedinject-3.0.jar" MVN="mvn:org.talend.libraries/guice-assistedinject-3.0/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="javax_inject-1" MODULE="javax.inject-1.jar" MVN="mvn:javax.inject/javax.inject/1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-bouncycastle-2_0_2" MODULE="jclouds-bouncycastle-2.0.2.jar" MVN="mvn:org.talend.libraries/jclouds-bouncycastle-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-compute-2_0_2" MODULE="jclouds-compute-2.0.2.jar" MVN="mvn:org.talend.libraries/jclouds-compute-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-core-2_0_2" MODULE="jclouds-core-2.0.2.jar" MVN="mvn:org.talend.libraries/jclouds-core-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-scriptbuilder-2_0_2" MODULE="jclouds-scriptbuilder-2.0.2.jar" MVN="mvn:org.talend.libraries/jclouds-scriptbuilder-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-slf4j-2_0_2" MODULE="jclouds-slf4j-2.0.2.jar" MVN="mvn:org.talend.libraries/jclouds-slf4j-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-sshj-2_0_2" MODULE="jclouds-sshj-2.0.2.jar" MVN="mvn:org.talend.libraries/jclouds-sshj-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jsr250-api-1_0" MODULE="jsr250-api-1.0.jar" MVN="mvn:org.talend.libraries/jsr250-api-1.0/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jsr311-api-1_1_1" MODULE="jsr311-api-1.1.1.jar" MVN="mvn:org.talend.libraries/jsr311-api-1.1.1/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="rocoto-6_1" MODULE="rocoto-6.1.jar" MVN="mvn:org.talend.libraries/rocoto-6.1/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="slf4j-api-1_7_2" MODULE="slf4j-api-1.7.2.jar" MVN="mvn:org.talend.libraries/slf4j-api-1.7.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="sshj-0_8_1" MODULE="sshj-0.8.1.jar" MVN="mvn:org.talend.libraries/sshj-0.8.1/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
|
||||
<IMPORT NAME="sts-2.0.2" MODULE="sts-2.0.2.jar" MVN="mvn:org.talend.libraries/sts-2.0.2/6.0.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jaxb-api-2.3.1" MODULE="jaxb-api-2.3.1.jar" MVN="mvn:javax.xml.bind/jaxb-api/2.3.1" REQUIRED="true"/>
|
||||
<IMPORT NAME="aws-ec2" MODULE="aws-ec2-2.5.0.jar" MVN="mvn:org.apache.jclouds.provider/aws-ec2/2.5.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="ec2" MODULE="ec2-2.5.0.jar" MVN="mvn:org.apache.jclouds.api/ec2/2.5.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="sts" MODULE="sts-2.5.0.jar" MVN="mvn:org.apache.jclouds.api/sts/2.5.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-core" MODULE="jclouds-core-2.5.0.jar" MVN="mvn:org.apache.jclouds/jclouds-core/2.5.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="gson" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="guava" MODULE="guava-30.0-jre.jar" MVN="mvn:com.google.guava/guava/30.0-jre" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="failureaccess" MODULE="failureaccess-1.0.1.jar" MVN="mvn:com.google.guava/failureaccess/1.0.1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="listenablefuture" MODULE="listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar" MVN="mvn:com.google.guava/listenablefuture/9999.0-empty-to-avoid-conflict-with-guava" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jsr305" MODULE="jsr305-3.0.2.jar" MVN="mvn:com.google.code.findbugs/jsr305/3.0.2" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="checker-qual" MODULE="checker-qual-2.5.2.jar" MVN="mvn:org.checkerframework/checker-qual/2.5.2" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="error_prone_annotations" MODULE="error_prone_annotations-2.2.0.jar" MVN="mvn:com.google.errorprone/error_prone_annotations/2.2.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="j2objc-annotations" MODULE="j2objc-annotations-1.1.jar" MVN="mvn:com.google.j2objc/j2objc-annotations/1.1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="animal-sniffer-annotations" MODULE="animal-sniffer-annotations-1.17.jar" MVN="mvn:org.codehaus.mojo/animal-sniffer-annotations/1.17" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="guice" MODULE="guice-5.0.1.jar" MVN="mvn:com.google.inject/guice/5.0.1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="javax.inject" MODULE="javax.inject-1.jar" MVN="mvn:javax.inject/javax.inject/1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="aopalliance" MODULE="aopalliance-1.0.jar" MVN="mvn:aopalliance/aopalliance/1.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="guice-assistedinject" MODULE="guice-assistedinject-5.0.1.jar" MVN="mvn:com.google.inject.extensions/guice-assistedinject/5.0.1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="javax.ws.rs-api" MODULE="javax.ws.rs-api-2.0.1.jar" MVN="mvn:javax.ws.rs/javax.ws.rs-api/2.0.1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="javax.annotation-api" MODULE="javax.annotation-api-1.2.jar" MVN="mvn:javax.annotation/javax.annotation-api/1.2" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jaxb-impl" MODULE="jaxb-impl-2.3.3.jar" MVN="mvn:com.sun.xml.bind/jaxb-impl/2.3.3" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jakarta.xml.bind-api" MODULE="jakarta.xml.bind-api-2.3.3.jar" MVN="mvn:jakarta.xml.bind/jakarta.xml.bind-api/2.3.3" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jakarta.activation" MODULE="jakarta.activation-1.2.2.jar" MVN="mvn:com.sun.activation/jakarta.activation/1.2.2" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-compute" MODULE="jclouds-compute-2.5.0.jar" MVN="mvn:org.apache.jclouds/jclouds-compute/2.5.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-scriptbuilder" MODULE="jclouds-scriptbuilder-2.5.0.jar" MVN="mvn:org.apache.jclouds/jclouds-scriptbuilder/2.5.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jaxb-api-2.3.1" MODULE="jaxb-api-2.3.1.jar" MVN="mvn:javax.xml.bind/jaxb-api/2.3.1" REQUIRED="true"/>
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
|
||||
@@ -99,7 +99,7 @@
|
||||
}
|
||||
%>
|
||||
|
||||
resumeUtil.addLog("NODE", "NODE:<%=cid %>", "", Thread.currentThread().getId() + "", "","","","",resumeUtil.convertToJsonText(context,parametersToEncrypt_<%=cid%>));
|
||||
resumeUtil.addLog("NODE", "NODE:<%=cid %>", "", Thread.currentThread().getId() + "", "","","","",resumeUtil.convertToJsonText(context,ContextProperties.class,parametersToEncrypt_<%=cid%>));
|
||||
<%if(isLog4jEnabled){%>
|
||||
log.info("<%=cid%> - Loaded contexts count: " + nb_line_<%=cid %> + ".");
|
||||
<%}%>
|
||||
|
||||
@@ -95,7 +95,8 @@ if ((metadatas!=null)&&(metadatas.size()>0)) {
|
||||
for (IContextParameter ctxParam: params) {
|
||||
if ("id_Password".equals(ctxParam.getType()) ) {
|
||||
%>
|
||||
if ((key_<%=cid %> != null) && ("<%=ctxParam.getName()%>".equals(key_<%=cid %>)) ) currentValue_<%=cid %> = currentValue_<%=cid %>.replaceAll(".", "*");
|
||||
if ((key_<%=cid %> != null) && ("<%=ctxParam.getName()%>".equals(key_<%=cid %>)) && (currentValue_<%=cid %> != null))
|
||||
currentValue_<%=cid %> = currentValue_<%=cid %>.replaceAll(".", "*");
|
||||
<%
|
||||
}
|
||||
|
||||
|
||||
@@ -858,7 +858,7 @@
|
||||
<IMPORT NAME="asm" MODULE="asm-9.1.jar" MVN="mvn:org.ow2.asm/asm/9.1" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="content-type" MODULE="content-type-2.1.jar" MVN="mvn:com.nimbusds/content-type/2.1" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="lang-tag" MODULE="lang-tag-1.5.jar" MVN="mvn:com.nimbusds/lang-tag/1.5" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.9.3.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.9.3" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.22.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.22" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
|
||||
<IMPORT NAME="Driver-MYSQL5" MODULE="mysql-connector-java-5.1.49.jar" MVN="mvn:mysql/mysql-connector-java/5.1.49" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') and (DBTYPE=='MYSQL') and (DB_MYSQL_VERSION=='MYSQL_5')"/>
|
||||
<IMPORT NAME="Driver-MYSQL8" MODULE="mysql-connector-java-8.0.18.jar" MVN="mvn:mysql/mysql-connector-java/8.0.18" REQUIRED_IF="(DB_MYSQL_VERSION == 'MYSQL_8') AND (USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MYSQL')" />
|
||||
@@ -870,7 +870,7 @@
|
||||
<IMPORT NAME="Driver-Oracle12c" MODULE="ojdbc7.jar" MVN="mvn:org.talend.libraries/ojdbc7/6.0.0" REQUIRED_IF="(DBTYPE=='DBORACLE') AND (DB_VERSION == 'ORACLE_12') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="ORACLE_18" MODULE="ojdbc8-19.3.0.0.jar" MVN="mvn:com.oracle.ojdbc/ojdbc8/19.3.0.0" REQUIRED_IF="(DBTYPE=='DBORACLE') AND (DB_VERSION == 'ORACLE_18') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="Driver-POSTGRESQL" MODULE="postgresql-8.4-703.jdbc4.jar" MVN="mvn:postgresql/postgresql/8.4-703.jdbc4" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((((DBTYPE=='POSTGRE') or (DBTYPE=='POSTGREPLUS')) AND (DB_POSTGRE_VERSION =='PRIOR_TO_V9')) or (DBTYPE=='GREENPLUM'))" />
|
||||
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.14.jar" MVN="mvn:org.postgresql/postgresql/42.2.14" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (((DBTYPE=='POSTGRE') or (DBTYPE=='POSTGREPLUS')) AND (DB_POSTGRE_VERSION =='V9_X'))" />
|
||||
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.26.jar" MVN="mvn:org.postgresql/postgresql/42.2.26" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (((DBTYPE=='POSTGRE') or (DBTYPE=='POSTGREPLUS')) AND (DB_POSTGRE_VERSION =='V9_X'))" />
|
||||
<IMPORT NAME="Driver-FIREBIRD" MODULE="jaybird-full-2.1.1.jar" MVN="mvn:org.talend.libraries/jaybird-full-2.1.1/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.jdbc.firebird/lib/jaybird-full-2.1.1.jar" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='FIREBIRD')" />
|
||||
<IMPORT NAME="Driver-HSQLDb" MODULE="hsqldb.jar" MVN="mvn:org.talend.libraries/hsqldb/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.jdbc.hsql/lib/hsqldb.jar" REQUIRED_IF="DBTYPE=='HSQLDB'"/>
|
||||
<IMPORT NAME="Driver-INFORMIX-JDBC" MODULE="ifxjdbc.jar" MVN="mvn:org.talend.libraries/ifxjdbc/6.0.0" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='INFORMIX')" />
|
||||
|
||||
@@ -132,7 +132,7 @@ MSSQL_DRIVER.ITEM.MSSQL_PROP=Microsoft
|
||||
DB_SYBASE_VERSION.NAME=DB Version
|
||||
DB_SYBASE_VERSION.ITEM.SYBSEIQ_12_15=Sybase 12/15
|
||||
DB_SYBASE_VERSION.ITEM.SYBSEIQ_16=Sybase 16
|
||||
DB_SYBASE_VERSION.ITEM.SYBSEIQ_16_SA=Sybase 16 (SQL Anywhere)
|
||||
DB_SYBASE_VERSION.ITEM.SYBSEIQ_16_SA=Sybase 16 (SQL Anywhere) and above
|
||||
ACCOUNT.NAME=Account
|
||||
ROLE.NAME=Role
|
||||
ENFORCE_DELIMITED_IDENTIFIERS.NAME=Enforce database delimited identifiers
|
||||
|
||||
@@ -132,7 +132,7 @@ MSSQL_DRIVER.ITEM.MSSQL_PROP=Microsoft
|
||||
DB_SYBASE_VERSION.NAME=Version de la base de donn\u00E9es
|
||||
DB_SYBASE_VERSION.ITEM.SYBSEIQ_12_15=Sybase 12/15
|
||||
DB_SYBASE_VERSION.ITEM.SYBSEIQ_16=Sybase 16
|
||||
DB_SYBASE_VERSION.ITEM.SYBSEIQ_16_SA=Sybase 16 (SQL Anywhere)
|
||||
DB_SYBASE_VERSION.ITEM.SYBSEIQ_16_SA=Sybase 16 (SQL Anywhere) et sup\u00E9rieures
|
||||
ACCOUNT.NAME=Compte
|
||||
ROLE.NAME=R\u00F4le
|
||||
ENFORCE_DELIMITED_IDENTIFIERS.NAME=Impl\u00E9menter les identifiants d\u00E9limit\u00E9s de base de donn\u00E9es
|
||||
|
||||
@@ -59,13 +59,13 @@ MSSQL_ACTIVE_DIR_AUTH.NAME=Azure Active Directory\u3092\u4F7F\u3063\u3066\u8A8D\
|
||||
RUNNING_MODE.ITEM.HSQLDB_INPROGRESS_PERSISTENT=\u51E6\u7406\u7D99\u7D9A\u4E2D\u306EHSQLD\uFF42
|
||||
RUNNING_MODE.ITEM.HSQLDB_SERVER=HSQLDb\u30B5\u30FC\u30D0
|
||||
RUNNING_MODE.ITEM.HSQLDB_WEBSERVER=HSQLDb Web\u30B5\u30FC\u30D0
|
||||
RUNNING_MODE.NAME=\u30E9\u30F3\u30CB\u30F3\u30B0\u30E2\u30FC\u30C9
|
||||
RUNNING_MODE.NAME=\u5B9F\u884C\u30E2\u30FC\u30C9
|
||||
LOCAL_SERVICE_NAME.NAME=\u30ED\u30FC\u30AB\u30EB\u30B5\u30FC\u30D3\u30B9\u540D
|
||||
SCHEMA_DB.NAME=\u30B9\u30AD\u30FC\u30DE
|
||||
TABLE.NAME=\u30C6\u30FC\u30D6\u30EB\u540D
|
||||
TABLEACTION.ITEM.CREATE_IF_NOT_EXIST=\u30C6\u30FC\u30D6\u30EB\u304C\u306A\u3044\u5834\u5408\u306F\u4F5C\u6210
|
||||
TABLEACTION.ITEM.CREATE_TABLE=\u30C6\u30FC\u30D6\u30EB\u306E\u4F5C\u6210
|
||||
TABLEACTION.ITEM.DROP_IF_EXIST_CREATE=\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u524A\u9664\u3057\u3066\u4F5C\u6210
|
||||
TABLEACTION.ITEM.DROP_IF_EXIST_CREATE=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u4F5C\u6210
|
||||
TABLEACTION.NAME=\u30C6\u30FC\u30D6\u30EB\u3067\u306E\u30A2\u30AF\u30B7\u30E7\u30F3
|
||||
TEMPTABLE.NAME=\u4E00\u6642\u30C6\u30FC\u30D6\u30EB
|
||||
TLS.NAME=TLS/SSL\u30BD\u30B1\u30C3\u30C8\u3092\u4F7F\u7528
|
||||
@@ -132,7 +132,7 @@ MSSQL_DRIVER.ITEM.MSSQL_PROP=Microsoft
|
||||
DB_SYBASE_VERSION.NAME=\u30C7\u30FC\u30BF\u30D9\u30FC\u30B9\u30D0\u30FC\u30B8\u30E7\u30F3
|
||||
DB_SYBASE_VERSION.ITEM.SYBSEIQ_12_15=Sybase 12/15
|
||||
DB_SYBASE_VERSION.ITEM.SYBSEIQ_16=Sybase 16
|
||||
DB_SYBASE_VERSION.ITEM.SYBSEIQ_16_SA=Sybase 16 (SQL Anywhere)
|
||||
DB_SYBASE_VERSION.ITEM.SYBSEIQ_16_SA=Sybase 16 (SQL Anywhere)\u4EE5\u964D
|
||||
ACCOUNT.NAME=\u30A2\u30AB\u30A6\u30F3\u30C8
|
||||
ROLE.NAME=\u30ED\u30FC\u30EB
|
||||
ENFORCE_DELIMITED_IDENTIFIERS.NAME=\u30C7\u30FC\u30BF\u30D9\u30FC\u30B9\u533A\u5207\u308A\u4ED8\u304D\u8B58\u5225\u5B50\u306E\u5F37\u5236
|
||||
|
||||
@@ -132,7 +132,7 @@ MSSQL_DRIVER.ITEM.MSSQL_PROP=Microsoft
|
||||
DB_SYBASE_VERSION.NAME=\u6570\u636E\u5E93\u7248\u672C
|
||||
DB_SYBASE_VERSION.ITEM.SYBSEIQ_12_15=Sybase 12/15
|
||||
DB_SYBASE_VERSION.ITEM.SYBSEIQ_16=Sybase 16
|
||||
DB_SYBASE_VERSION.ITEM.SYBSEIQ_16_SA=Sybase 16 (SQL Anywhere)
|
||||
DB_SYBASE_VERSION.ITEM.SYBSEIQ_16_SA=Sybase 16 (SQL Anywhere) \u53CA\u66F4\u9AD8\u7248\u672C
|
||||
ACCOUNT.NAME=\u5E10\u6237
|
||||
ROLE.NAME=\u89D2\u8272
|
||||
ENFORCE_DELIMITED_IDENTIFIERS.NAME=\u6267\u884C\u6570\u636E\u5E93\u5206\u9694\u578B\u6807\u8BC6\u7B26
|
||||
|
||||
@@ -20,7 +20,7 @@ TABLE.NAME=\u30C6\u30FC\u30D6\u30EB
|
||||
TABLE_ACTION.ITEM.CLEAR=\u30C6\u30FC\u30D6\u30EB\u3092\u30AF\u30EA\u30A2
|
||||
TABLE_ACTION.ITEM.CREATE=\u30C6\u30FC\u30D6\u30EB\u306E\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.CREATE_IF_NOT_EXISTS=\u5B58\u5728\u3057\u306A\u3044\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u524A\u9664\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_CREATE=\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.NONE=\u30C7\u30D5\u30A9\u30EB\u30C8
|
||||
TABLE_ACTION.NAME=\u30C6\u30FC\u30D6\u30EB\u3067\u306E\u30A2\u30AF\u30B7\u30E7\u30F3
|
||||
|
||||
@@ -51,7 +51,7 @@ TABLE_ACTION.ITEM.TRUNCATE=\u30C6\u30FC\u30D6\u30EB\u3092\u5207\u308A\u6368\u306
|
||||
TABLE_ACTION.ITEM.TRUNCATE_REUSE_STORAGE=Truncate table with reuse storage
|
||||
TABLE_ACTION.ITEM.CREATE=\u30C6\u30FC\u30D6\u30EB\u306E\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.CREATE_IF_NOT_EXISTS=\u5B58\u5728\u3057\u306A\u3044\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u524A\u9664\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_CREATE=\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.NONE=\u30C7\u30D5\u30A9\u30EB\u30C8
|
||||
TABLE_ACTION.NAME=\u30C6\u30FC\u30D6\u30EB\u3067\u306E\u30A2\u30AF\u30B7\u30E7\u30F3
|
||||
|
||||
@@ -29,7 +29,7 @@ TABLE_ACTION.ITEM.CLEAR=\u30C6\u30FC\u30D6\u30EB\u3092\u30AF\u30EA\u30A2
|
||||
TABLE_ACTION.ITEM.TRUNCATE=\u30C6\u30FC\u30D6\u30EB\u3092\u5207\u308A\u6368\u3066
|
||||
TABLE_ACTION.ITEM.CREATE=\u30C6\u30FC\u30D6\u30EB\u306E\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.CREATE_IF_NOT_EXISTS=\u5B58\u5728\u3057\u306A\u3044\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u524A\u9664\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_CREATE=\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.NONE=\u30C7\u30D5\u30A9\u30EB\u30C8
|
||||
TABLE_ACTION.NAME=\u30C6\u30FC\u30D6\u30EB\u3067\u306E\u30A2\u30AF\u30B7\u30E7\u30F3
|
||||
|
||||
@@ -175,8 +175,8 @@ while(<%=inputColumn%>_iterator_<%=cid %>.hasNext()){
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
denormalize_row_<%=cid %>.<%=inputColumn %> = sb_<%=cid %>.toString();
|
||||
if (sb_<%=cid %> != null)
|
||||
denormalize_row_<%=cid %>.<%=inputColumn %> = sb_<%=cid %>.toString();
|
||||
|
||||
sb_<%=cid %> = null;
|
||||
|
||||
|
||||
@@ -212,7 +212,7 @@
|
||||
<IMPORT NAME="content-type" MODULE="content-type-2.1.jar" MVN="mvn:com.nimbusds/content-type/2.1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="lang-tag" MODULE="lang-tag-1.5.jar" MVN="mvn:com.nimbusds/lang-tag/1.5" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.9.3.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.9.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.22.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.22" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
|
||||
@@ -47,7 +47,7 @@ TABLE_ACTION.ITEM.CLEAR=\u30C6\u30FC\u30D6\u30EB\u3092\u30AF\u30EA\u30A2
|
||||
TABLE_ACTION.ITEM.TRUNCATE=\u30C6\u30FC\u30D6\u30EB\u3092\u5207\u308A\u6368\u3066
|
||||
TABLE_ACTION.ITEM.CREATE=\u30C6\u30FC\u30D6\u30EB\u306E\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.CREATE_IF_NOT_EXISTS=\u5B58\u5728\u3057\u306A\u3044\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u524A\u9664\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_CREATE=\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.NONE=\u306A\u3057
|
||||
TABLE_ACTION.NAME=\u30C6\u30FC\u30D6\u30EB\u3067\u306E\u30A2\u30AF\u30B7\u30E7\u30F3
|
||||
|
||||
@@ -189,8 +189,8 @@
|
||||
|
||||
<CODEGENERATION>
|
||||
<IMPORTS>
|
||||
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.14.jar" MVN="mvn:org.postgresql/postgresql/42.2.14" REQUIRED_IF="DB_VERSION =='V9_X'" />
|
||||
<IMPORT NAME="Driver-Postgres" MODULE="postgresql-8.4-703.jdbc4.jar" MVN="mvn:postgresql/postgresql/8.4-703.jdbc4" REQUIRED_IF="DB_VERSION =='PRIOR_TO_V9'" />
|
||||
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.26.jar" MVN="mvn:org.postgresql/postgresql/42.2.26" REQUIRED_IF="DB_VERSION =='V9_X' AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="Driver-Postgres" MODULE="postgresql-8.4-703.jdbc4.jar" MVN="mvn:postgresql/postgresql/8.4-703.jdbc4" REQUIRED_IF="DB_VERSION =='PRIOR_TO_V9' AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
|
||||
@@ -20,4 +20,4 @@ CONNECTION.NAME=Component List
|
||||
DB_VERSION.NAME=DB Version
|
||||
DB_VERSION.ITEM.SYBSEIQ_12_15=Sybase 12/15
|
||||
DB_VERSION.ITEM.SYBSEIQ_16=Sybase 16
|
||||
DB_VERSION.ITEM.SYBSEIQ_16_SA=Sybase 16 (SQL Anywhere)
|
||||
DB_VERSION.ITEM.SYBSEIQ_16_SA=Sybase 16 (SQL Anywhere) and above
|
||||
|
||||
@@ -20,4 +20,4 @@ CONNECTION.NAME=Liste des composants
|
||||
DB_VERSION.NAME=Version de la base de donn\u00E9es
|
||||
DB_VERSION.ITEM.SYBSEIQ_12_15=Sybase 12/15
|
||||
DB_VERSION.ITEM.SYBSEIQ_16=Sybase 16
|
||||
DB_VERSION.ITEM.SYBSEIQ_16_SA=Sybase 16 (SQL Anywhere)
|
||||
DB_VERSION.ITEM.SYBSEIQ_16_SA=Sybase 16 (SQL Anywhere) et sup\u00E9rieures
|
||||
|
||||
@@ -20,4 +20,4 @@ CONNECTION.NAME=\u30B3\u30F3\u30DD\u30FC\u30CD\u30F3\u30C8\u30EA\u30B9\u30C8
|
||||
DB_VERSION.NAME=\u30C7\u30FC\u30BF\u30D9\u30FC\u30B9\u30D0\u30FC\u30B8\u30E7\u30F3
|
||||
DB_VERSION.ITEM.SYBSEIQ_12_15=Sybase 12/15
|
||||
DB_VERSION.ITEM.SYBSEIQ_16=Sybase 16
|
||||
DB_VERSION.ITEM.SYBSEIQ_16_SA=Sybase 16 (SQL Anywhere)
|
||||
DB_VERSION.ITEM.SYBSEIQ_16_SA=Sybase 16 (SQL Anywhere)\u4EE5\u964D
|
||||
|
||||
@@ -20,4 +20,4 @@ CONNECTION.NAME=\u7EC4\u4EF6\u5217\u8868
|
||||
DB_VERSION.NAME=\u6570\u636E\u5E93\u7248\u672C
|
||||
DB_VERSION.ITEM.SYBSEIQ_12_15=Sybase 12/15
|
||||
DB_VERSION.ITEM.SYBSEIQ_16=Sybase 16
|
||||
DB_VERSION.ITEM.SYBSEIQ_16_SA=Sybase 16 (SQL Anywhere)
|
||||
DB_VERSION.ITEM.SYBSEIQ_16_SA=Sybase 16 (SQL Anywhere) \u53CA\u66F4\u9AD8\u7248\u672C
|
||||
|
||||
@@ -55,7 +55,7 @@ TABLE_ACTION.ITEM.CLEAR=\u30C6\u30FC\u30D6\u30EB\u3092\u30AF\u30EA\u30A2
|
||||
TABLE_ACTION.ITEM.CREATE=\u30C6\u30FC\u30D6\u30EB\u306E\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.CREATE_IF_NOT_EXISTS=\u5B58\u5728\u3057\u306A\u3044\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_CREATE=\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u30C6\u30FC\u30D6\u30EB\u3092\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C6\u30FC\u30D6\u30EB\u3092\u524A\u9664\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.DROP_IF_EXISTS_AND_CREATE=\u30C6\u30FC\u30D6\u30EB\u304C\u5B58\u5728\u3059\u308B\u5834\u5408\u306F\u30C9\u30ED\u30C3\u30D7\u3057\u3066\u4F5C\u6210
|
||||
TABLE_ACTION.ITEM.NONE=\u306A\u3057
|
||||
TABLE_ACTION.ITEM.TRUNCATE=\u30C6\u30FC\u30D6\u30EB\u3092\u5207\u308A\u6368\u3066
|
||||
TABLE_ACTION.NAME=\u30C6\u30FC\u30D6\u30EB\u3067\u306E\u30A2\u30AF\u30B7\u30E7\u30F3
|
||||
|
||||
@@ -3,7 +3,7 @@ LIMIT.NAME=\u5236\u9650
|
||||
LONG_NAME=JSON\u30D5\u30A3\u30FC\u30EB\u30C9\u5185\u306E\u7279\u5B9A\u306E\u30AB\u30E9\u30E0\u304B\u3089\u8907\u6570\u306E\u30AB\u30E9\u30E0\u3092\u751F\u6210\u3057\u307E\u3059
|
||||
LOOP_QUERY.NAME=\u30EB\u30FC\u30D7 XPath\u30AF\u30A8\u30EA\u30FC
|
||||
MAPPING.ITEM.QUERY=XPath\u30AF\u30A8\u30EA\u30FC
|
||||
MAPPING.ITEM.NODECHECK=\u30CE\u30FC\u30C9\u306E\u53D6\u5F97
|
||||
MAPPING.ITEM.NODECHECK=\u30CE\u30FC\u30C9\u3092\u53D6\u5F97
|
||||
MAPPING.ITEM.ISARRAY=Array
|
||||
MAPPING.NAME=\u30DE\u30C3\u30D4\u30F3\u30B0
|
||||
NB_LINE.NAME=\u884C\u6570
|
||||
|
||||
@@ -3,7 +3,7 @@ LIMIT.NAME=\u5236\u9650
|
||||
LONG_NAME=tFileInputXML\u3068\u3057\u3066\u5165\u529B\u884C\u30D5\u30A3\u30FC\u30EB\u30C9\u3092\u89E3\u6790\u3057\u307E\u3059
|
||||
LOOP_QUERY.NAME=\u30EB\u30FC\u30D7 XPath\u30AF\u30A8\u30EA\u30FC
|
||||
MAPPING.ITEM.QUERY=XPath\u30AF\u30A8\u30EA\u30FC
|
||||
MAPPING.ITEM.NODECHECK=\u30CE\u30FC\u30C9\u306E\u53D6\u5F97
|
||||
MAPPING.ITEM.NODECHECK=\u30CE\u30FC\u30C9\u3092\u53D6\u5F97
|
||||
MAPPING.NAME=\u30DE\u30C3\u30D4\u30F3\u30B0
|
||||
NB_LINE.NAME=\u884C\u6570
|
||||
REJECT.LINK=\u30EA\u30B8\u30A7\u30AF\u30C8
|
||||
|
||||
@@ -5,6 +5,8 @@
|
||||
org.talend.designer.codegen.config.CodeGeneratorArgument
|
||||
org.talend.core.model.process.IElementParameter
|
||||
org.talend.core.model.utils.NodeUtil
|
||||
java.util.List
|
||||
java.util.Map
|
||||
"
|
||||
%>
|
||||
<%@ include file="../templates/Log4j/Log4jFileUtil.javajet"%>
|
||||
@@ -36,6 +38,8 @@ String timeoutValue = ElementParameterParser.getValue(node, "__CONNECTION_TIMEOU
|
||||
boolean useRemoteVerification = ("true").equals(ElementParameterParser.getValue(node, "__REMOTE_VERIFICATION__"));
|
||||
boolean isLog4jEnabled = ("true").equals(ElementParameterParser.getValue(node.getProcess(), "__LOG4J_ACTIVATE__"));
|
||||
boolean useStrictReplyParsing = ("true").equals(ElementParameterParser.getValue(node, "__USE_STRICT_REPLY_PARSING__"));
|
||||
boolean isConfigClient = "true".equals(ElementParameterParser.getValue(node, "__CONFIG_CLIENT__"));
|
||||
List<Map<String, String>> clientParams = (List<Map<String,String>>)ElementParameterParser.getObjectValue(node, "__CLIENT_PARAMETERS__");
|
||||
String passwordFieldName = "";
|
||||
|
||||
if (useProxy) {
|
||||
|
||||
@@ -244,11 +244,31 @@
|
||||
NUM_ROW="100" REPOSITORY_VALUE="USE_STRICT_REPLY_PARSING">
|
||||
<DEFAULT>true</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER
|
||||
NAME="CONFIG_CLIENT"
|
||||
FIELD="CHECK"
|
||||
NUM_ROW="110"
|
||||
SHOW_IF="SFTP == 'true'"
|
||||
>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER
|
||||
NAME="CLIENT_PARAMETERS"
|
||||
FIELD="TABLE"
|
||||
NUM_ROW="120"
|
||||
SHOW_IF="(CONFIG_CLIENT == 'true') AND (SFTP == 'true')"
|
||||
>
|
||||
<ITEMS>
|
||||
<ITEM NAME="PARAMETER"></ITEM>
|
||||
<ITEM NAME="VALUE"></ITEM>
|
||||
</ITEMS>
|
||||
</PARAMETER>
|
||||
</ADVANCED_PARAMETERS>
|
||||
|
||||
<CODEGENERATION>
|
||||
<IMPORTS>
|
||||
<IMPORT NAME="Java-SFTP" MODULE="jsch-0.1.55.jar" MVN="mvn:com.jcraft/jsch/0.1.55" REQUIRED_IF="(SFTP == 'true')"/>
|
||||
<IMPORT NAME="Java-SFTP" MODULE="jsch-0.2.1.jar" MVN="mvn:com.github.mwiede/jsch/0.2.1" REQUIRED_IF="(SFTP == 'true')"/>
|
||||
<IMPORT NAME="Java-FTP+S" MODULE="commons-net-3.6.jar" MVN="mvn:commons-net/commons-net/3.6" REQUIRED_IF="(SFTP == 'false')" />
|
||||
<IMPORT NAME="FTP+S-Proxy-talend" MODULE="commons-net-ftps-proxy-3.6.1-talend-20200902.jar" MVN="mvn:org.talend.components.lib/commons-net-ftps-proxy/3.6.1-talend-20200902" REQUIRED_IF="(FTPS == 'true')" />
|
||||
<IMPORT NAME="talend-proxy" MODULE="talend-proxy-1.0.2.jar" MVN="mvn:org.talend.components.lib/talend-proxy/1.0.2" REQUIRED="true" />
|
||||
|
||||
@@ -36,3 +36,7 @@ SECURITY_MODE.ITEM.EXPLICIT=Explicit
|
||||
USE_ENCODING.NAME=Filename encoding
|
||||
CONNECTION_TIMEOUT.NAME=Connection timeout (milliseconds)
|
||||
USE_STRICT_REPLY_PARSING.NAME=Use strict reply parsing
|
||||
CONFIG_CLIENT.NAME=Config client
|
||||
CLIENT_PARAMETERS.NAME=
|
||||
CLIENT_PARAMETERS.ITEM.PARAMETER=Client parameter
|
||||
CLIENT_PARAMETERS.ITEM.VALUE=Value
|
||||
|
||||
@@ -36,3 +36,7 @@ SECURITY_MODE.ITEM.EXPLICIT=Explicite
|
||||
USE_ENCODING.NAME=Encodage du nom de fichier
|
||||
CONNECTION_TIMEOUT.NAME=D\u00E9lai avant l'expiration de la connexion (millisecondes)
|
||||
USE_STRICT_REPLY_PARSING.NAME=Utiliser le parsage de la r\u00E9ponse stricte
|
||||
CONFIG_CLIENT.NAME=Config client
|
||||
CLIENT_PARAMETERS.NAME=
|
||||
CLIENT_PARAMETERS.ITEM.PARAMETER=Param\u00E8tre client
|
||||
CLIENT_PARAMETERS.ITEM.VALUE=Valeur
|
||||
|
||||
@@ -35,4 +35,8 @@ SECURITY_MODE.ITEM.IMPLICIT=\u6697\u9ED9\u7684
|
||||
SECURITY_MODE.ITEM.EXPLICIT=\u660E\u793A\u7684
|
||||
USE_ENCODING.NAME=\u30D5\u30A1\u30A4\u30EB\u540D\u306E\u30A8\u30F3\u30B3\u30FC\u30C7\u30A3\u30F3\u30B0
|
||||
CONNECTION_TIMEOUT.NAME=\u63A5\u7D9A\u30BF\u30A4\u30E0\u30A2\u30A6\u30C8(\u30DF\u30EA\u79D2)
|
||||
USE_STRICT_REPLY_PARSING.NAME=\u8FD4\u4FE1\u89E3\u6790\u306E\u5236\u9650\u3092\u4F7F\u7528
|
||||
USE_STRICT_REPLY_PARSING.NAME=\u53B3\u5BC6\u306A\u8FD4\u4FE1\u89E3\u6790\u3092\u4F7F\u7528
|
||||
CONFIG_CLIENT.NAME=\u30AF\u30E9\u30A4\u30A2\u30F3\u30C8\u8A2D\u5B9A
|
||||
CLIENT_PARAMETERS.NAME=
|
||||
CLIENT_PARAMETERS.ITEM.PARAMETER=\u30AF\u30E9\u30A4\u30A2\u30F3\u30C8\u30D1\u30E9\u30E1\u30FC\u30BF\u30FC
|
||||
CLIENT_PARAMETERS.ITEM.VALUE=\u5024
|
||||
|
||||
@@ -36,3 +36,7 @@ SECURITY_MODE.ITEM.EXPLICIT=\u663E\u5F0F
|
||||
USE_ENCODING.NAME=\u6587\u4EF6\u540D\u7F16\u7801
|
||||
CONNECTION_TIMEOUT.NAME=\u8FDE\u63A5\u8D85\u65F6 (\u6BEB\u79D2)
|
||||
USE_STRICT_REPLY_PARSING.NAME=\u4F7F\u7528\u4E25\u683C\u56DE\u590D\u89E3\u6790
|
||||
CONFIG_CLIENT.NAME=\u914D\u7F6E\u5BA2\u6237\u7AEF
|
||||
CLIENT_PARAMETERS.NAME=
|
||||
CLIENT_PARAMETERS.ITEM.PARAMETER=\u5BA2\u6237\u7AEF\u53C2\u6570
|
||||
CLIENT_PARAMETERS.ITEM.VALUE=\u503C
|
||||
|
||||
@@ -46,6 +46,8 @@ String protectionBufferSize = ElementParameterParser.getValue(node, "__FTPS_PROT
|
||||
String timeoutValue = ElementParameterParser.getValue(node, "__CONNECTION_TIMEOUT__");
|
||||
boolean useRemoteVerification = ("true").equals(ElementParameterParser.getValue(node, "__REMOTE_VERIFICATION__"));
|
||||
boolean useStrictReplyParsing = ("true").equals(ElementParameterParser.getValue(node, "__USE_STRICT_REPLY_PARSING__"));
|
||||
boolean isConfigClient = "true".equals(ElementParameterParser.getValue(node, "__CONFIG_CLIENT__"));
|
||||
List<Map<String, String>> clientParams = (List<Map<String,String>>)ElementParameterParser.getObjectValue(node, "__CLIENT_PARAMETERS__");
|
||||
|
||||
if (("true").equals(useExistingConn)) {
|
||||
List<? extends INode> nodeList = node.getProcess().getGeneratingNodes();
|
||||
|
||||
@@ -299,11 +299,31 @@
|
||||
NUM_ROW="100" SHOW_IF="USE_EXISTING_CONNECTION == 'false'" REPOSITORY_VALUE="USE_STRICT_REPLY_PARSING">
|
||||
<DEFAULT>true</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER
|
||||
NAME="CONFIG_CLIENT"
|
||||
FIELD="CHECK"
|
||||
NUM_ROW="110"
|
||||
SHOW_IF="(SFTP == 'true') AND (USE_EXISTING_CONNECTION == 'false')"
|
||||
>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER
|
||||
NAME="CLIENT_PARAMETERS"
|
||||
FIELD="TABLE"
|
||||
NUM_ROW="120"
|
||||
SHOW_IF="(CONFIG_CLIENT == 'true') AND (SFTP == 'true') AND (USE_EXISTING_CONNECTION == 'false')"
|
||||
>
|
||||
<ITEMS>
|
||||
<ITEM NAME="PARAMETER"></ITEM>
|
||||
<ITEM NAME="VALUE"></ITEM>
|
||||
</ITEMS>
|
||||
</PARAMETER>
|
||||
</ADVANCED_PARAMETERS>
|
||||
|
||||
<CODEGENERATION>
|
||||
<IMPORTS>
|
||||
<IMPORT NAME="Java-SFTP" MODULE="jsch-0.1.55.jar" MVN="mvn:com.jcraft/jsch/0.1.55" REQUIRED_IF="(SFTP == 'true') AND (USE_EXISTING_CONNECTION == 'false')"/>
|
||||
<IMPORT NAME="Java-SFTP" MODULE="jsch-0.2.1.jar" MVN="mvn:com.github.mwiede/jsch/0.2.1" REQUIRED_IF="(SFTP == 'true') AND (USE_EXISTING_CONNECTION == 'false')"/>
|
||||
<IMPORT NAME="jakarta-oro" MODULE="jakarta-oro-2.0.8.jar" MVN="mvn:org.talend.libraries/jakarta-oro-2.0.8/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache/lib/jakarta-oro-2.0.8.jar" REQUIRED="true" />
|
||||
<IMPORT NAME="Java-FTP+S" MODULE="commons-net-3.6.jar" MVN="mvn:commons-net/commons-net/3.6" REQUIRED_IF="(SFTP == 'false') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="FTP+S-Proxy-talend" MODULE="commons-net-ftps-proxy-3.6.1-talend-20200902.jar"
|
||||
|
||||
@@ -51,3 +51,7 @@ MOVE_TO_THE_CURRENT_DIRECTORY.NAME=Move to the current directory
|
||||
USE_ENCODING.NAME=Filename encoding
|
||||
CONNECTION_TIMEOUT.NAME=Connection timeout (milliseconds)
|
||||
USE_STRICT_REPLY_PARSING.NAME=Use strict reply parsing
|
||||
CONFIG_CLIENT.NAME=Config client
|
||||
CLIENT_PARAMETERS.NAME=
|
||||
CLIENT_PARAMETERS.ITEM.PARAMETER=Client parameter
|
||||
CLIENT_PARAMETERS.ITEM.VALUE=Value
|
||||
|
||||
@@ -51,3 +51,7 @@ MOVE_TO_THE_CURRENT_DIRECTORY.NAME=D\u00E9placer vers le r\u00E9pertoire courant
|
||||
USE_ENCODING.NAME=Encodage du nom de fichier
|
||||
CONNECTION_TIMEOUT.NAME=D\u00E9lai avant l'expiration de la connexion (millisecondes)
|
||||
USE_STRICT_REPLY_PARSING.NAME=Utiliser le parsage de la r\u00E9ponse stricte
|
||||
CONFIG_CLIENT.NAME=Config client
|
||||
CLIENT_PARAMETERS.NAME=
|
||||
CLIENT_PARAMETERS.ITEM.PARAMETER=Param\u00E8tre client
|
||||
CLIENT_PARAMETERS.ITEM.VALUE=Valeur
|
||||
|
||||
@@ -50,4 +50,8 @@ PERL5_REGEX.NAME=Perl5\u6B63\u898F\u8868\u73FE\u5F0F\u3092\u30D5\u30A1\u30A4\u30
|
||||
MOVE_TO_THE_CURRENT_DIRECTORY.NAME=\u73FE\u5728\u306E\u30C7\u30A3\u30EC\u30AF\u30C8\u30EA\u30FC\u306B\u79FB\u52D5
|
||||
USE_ENCODING.NAME=\u30D5\u30A1\u30A4\u30EB\u540D\u306E\u30A8\u30F3\u30B3\u30FC\u30C7\u30A3\u30F3\u30B0
|
||||
CONNECTION_TIMEOUT.NAME=\u63A5\u7D9A\u30BF\u30A4\u30E0\u30A2\u30A6\u30C8(\u30DF\u30EA\u79D2)
|
||||
USE_STRICT_REPLY_PARSING.NAME=\u8FD4\u4FE1\u89E3\u6790\u306E\u5236\u9650\u3092\u4F7F\u7528
|
||||
USE_STRICT_REPLY_PARSING.NAME=\u53B3\u5BC6\u306A\u8FD4\u4FE1\u89E3\u6790\u3092\u4F7F\u7528
|
||||
CONFIG_CLIENT.NAME=\u30AF\u30E9\u30A4\u30A2\u30F3\u30C8\u8A2D\u5B9A
|
||||
CLIENT_PARAMETERS.NAME=
|
||||
CLIENT_PARAMETERS.ITEM.PARAMETER=\u30AF\u30E9\u30A4\u30A2\u30F3\u30C8\u30D1\u30E9\u30E1\u30FC\u30BF\u30FC
|
||||
CLIENT_PARAMETERS.ITEM.VALUE=\u5024
|
||||
|
||||
@@ -51,3 +51,7 @@ MOVE_TO_THE_CURRENT_DIRECTORY.NAME=\u79FB\u81F3\u5F53\u524D\u76EE\u5F55
|
||||
USE_ENCODING.NAME=\u6587\u4EF6\u540D\u7F16\u7801
|
||||
CONNECTION_TIMEOUT.NAME=\u8FDE\u63A5\u8D85\u65F6 (\u6BEB\u79D2)
|
||||
USE_STRICT_REPLY_PARSING.NAME=\u4F7F\u7528\u4E25\u683C\u56DE\u590D\u89E3\u6790
|
||||
CONFIG_CLIENT.NAME=\u914D\u7F6E\u5BA2\u6237\u7AEF
|
||||
CLIENT_PARAMETERS.NAME=
|
||||
CLIENT_PARAMETERS.ITEM.PARAMETER=\u5BA2\u6237\u7AEF\u53C2\u6570
|
||||
CLIENT_PARAMETERS.ITEM.VALUE=\u503C
|
||||
|
||||
@@ -4,6 +4,7 @@
|
||||
org.talend.core.model.process.ElementParameterParser
|
||||
org.talend.designer.codegen.config.CodeGeneratorArgument
|
||||
java.util.List
|
||||
java.util.Map
|
||||
org.talend.core.model.process.IElementParameter
|
||||
org.talend.core.model.utils.NodeUtil
|
||||
"
|
||||
@@ -47,6 +48,9 @@ boolean useRemoteVerification = ("true").equals(ElementParameterParser.getValue(
|
||||
boolean useStrictReplyParsing = ("true").equals(ElementParameterParser.getValue(node, "__USE_STRICT_REPLY_PARSING__"));
|
||||
|
||||
boolean isLog4jEnabled = ("true").equals(ElementParameterParser.getValue(node.getProcess(), "__LOG4J_ACTIVATE__"));
|
||||
boolean isConfigClient = "true".equals(ElementParameterParser.getValue(node, "__CONFIG_CLIENT__"));
|
||||
List<Map<String, String>> clientParams = (List<Map<String,String>>)ElementParameterParser.getObjectValue(node, "__CLIENT_PARAMETERS__");
|
||||
|
||||
if (("true").equals(useExistingConn)) {
|
||||
List<? extends INode> nodeList = node.getProcess().getGeneratingNodes();
|
||||
|
||||
|
||||
@@ -287,11 +287,31 @@ COMPATIBILITY="ALL"
|
||||
NUM_ROW="100" SHOW_IF="USE_EXISTING_CONNECTION == 'false'" REPOSITORY_VALUE="USE_STRICT_REPLY_PARSING">
|
||||
<DEFAULT>true</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER
|
||||
NAME="CONFIG_CLIENT"
|
||||
FIELD="CHECK"
|
||||
NUM_ROW="110"
|
||||
SHOW_IF="(SFTP == 'true') AND (USE_EXISTING_CONNECTION == 'false')"
|
||||
>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER
|
||||
NAME="CLIENT_PARAMETERS"
|
||||
FIELD="TABLE"
|
||||
NUM_ROW="120"
|
||||
SHOW_IF="(CONFIG_CLIENT == 'true') AND (SFTP == 'true') AND (USE_EXISTING_CONNECTION == 'false')"
|
||||
>
|
||||
<ITEMS>
|
||||
<ITEM NAME="PARAMETER"></ITEM>
|
||||
<ITEM NAME="VALUE"></ITEM>
|
||||
</ITEMS>
|
||||
</PARAMETER>
|
||||
</ADVANCED_PARAMETERS>
|
||||
|
||||
<CODEGENERATION>
|
||||
<IMPORTS>
|
||||
<IMPORT NAME="Java-SFTP" MODULE="jsch-0.1.55.jar" MVN="mvn:com.jcraft/jsch/0.1.55" REQUIRED_IF="(SFTP == 'true') AND (USE_EXISTING_CONNECTION == 'false')"/>
|
||||
<IMPORT NAME="Java-SFTP" MODULE="jsch-0.2.1.jar" MVN="mvn:com.github.mwiede/jsch/0.2.1" REQUIRED_IF="(SFTP == 'true') AND (USE_EXISTING_CONNECTION == 'false')"/>
|
||||
<IMPORT NAME="Java-FTP+S" MODULE="commons-net-3.6.jar" MVN="mvn:commons-net/commons-net/3.6" REQUIRED_IF="(SFTP == 'false') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="FTP+S-Proxy-talend" MODULE="commons-net-ftps-proxy-3.6.1-talend-20200902.jar"
|
||||
MVN="mvn:org.talend.components.lib/commons-net-ftps-proxy/3.6.1-talend-20200902"
|
||||
|
||||
@@ -47,3 +47,7 @@ IGNORE_FAILURE_AT_QUIT.NAME=Ignore Failure At Quit (FTP)
|
||||
USE_ENCODING.NAME=Filename encoding
|
||||
CONNECTION_TIMEOUT.NAME=Connection timeout (milliseconds)
|
||||
USE_STRICT_REPLY_PARSING.NAME=Use strict reply parsing
|
||||
CONFIG_CLIENT.NAME=Config client
|
||||
CLIENT_PARAMETERS.NAME=
|
||||
CLIENT_PARAMETERS.ITEM.PARAMETER=Client parameter
|
||||
CLIENT_PARAMETERS.ITEM.VALUE=Value
|
||||
|
||||
@@ -47,3 +47,7 @@ IGNORE_FAILURE_AT_QUIT.NAME=Ignorer les erreurs \u00E0 la fermeture (FTP)
|
||||
USE_ENCODING.NAME=Encodage du nom de fichier
|
||||
CONNECTION_TIMEOUT.NAME=D\u00E9lai avant l'expiration de la connexion (millisecondes)
|
||||
USE_STRICT_REPLY_PARSING.NAME=Utiliser le parsage de la r\u00E9ponse stricte
|
||||
CONFIG_CLIENT.NAME=Config client
|
||||
CLIENT_PARAMETERS.NAME=
|
||||
CLIENT_PARAMETERS.ITEM.PARAMETER=Param\u00E8tre client
|
||||
CLIENT_PARAMETERS.ITEM.VALUE=Valeur
|
||||
|
||||
@@ -46,4 +46,8 @@ CONNECT_MODE.ITEM.PASSIVE=\u4E0D\u6D3B\u6027
|
||||
IGNORE_FAILURE_AT_QUIT.NAME=\u7D42\u4E86\u6642\u306B\u30A8\u30E9\u30FC\u3092\u7121\u8996(FTP)
|
||||
USE_ENCODING.NAME=\u30D5\u30A1\u30A4\u30EB\u540D\u306E\u30A8\u30F3\u30B3\u30FC\u30C7\u30A3\u30F3\u30B0
|
||||
CONNECTION_TIMEOUT.NAME=\u63A5\u7D9A\u30BF\u30A4\u30E0\u30A2\u30A6\u30C8(\u30DF\u30EA\u79D2)
|
||||
USE_STRICT_REPLY_PARSING.NAME=\u8FD4\u4FE1\u89E3\u6790\u306E\u5236\u9650\u3092\u4F7F\u7528
|
||||
USE_STRICT_REPLY_PARSING.NAME=\u53B3\u5BC6\u306A\u8FD4\u4FE1\u89E3\u6790\u3092\u4F7F\u7528
|
||||
CONFIG_CLIENT.NAME=\u30AF\u30E9\u30A4\u30A2\u30F3\u30C8\u8A2D\u5B9A
|
||||
CLIENT_PARAMETERS.NAME=
|
||||
CLIENT_PARAMETERS.ITEM.PARAMETER=\u30AF\u30E9\u30A4\u30A2\u30F3\u30C8\u30D1\u30E9\u30E1\u30FC\u30BF\u30FC
|
||||
CLIENT_PARAMETERS.ITEM.VALUE=\u5024
|
||||
|
||||
@@ -47,3 +47,7 @@ IGNORE_FAILURE_AT_QUIT.NAME=\u9000\u51FA\u65F6\u5FFD\u7565\u5931\u8D25 (FTP)
|
||||
USE_ENCODING.NAME=\u6587\u4EF6\u540D\u7F16\u7801
|
||||
CONNECTION_TIMEOUT.NAME=\u8FDE\u63A5\u8D85\u65F6 (\u6BEB\u79D2)
|
||||
USE_STRICT_REPLY_PARSING.NAME=\u4F7F\u7528\u4E25\u683C\u56DE\u590D\u89E3\u6790
|
||||
CONFIG_CLIENT.NAME=\u914D\u7F6E\u5BA2\u6237\u7AEF
|
||||
CLIENT_PARAMETERS.NAME=
|
||||
CLIENT_PARAMETERS.ITEM.PARAMETER=\u5BA2\u6237\u7AEF\u53C2\u6570
|
||||
CLIENT_PARAMETERS.ITEM.VALUE=\u503C
|
||||
|
||||
@@ -45,6 +45,8 @@ String protectionBufferSize = ElementParameterParser.getValue(node, "__FTPS_PROT
|
||||
String timeoutValue = ElementParameterParser.getValue(node, "__CONNECTION_TIMEOUT__");
|
||||
boolean useRemoteVerification = ("true").equals(ElementParameterParser.getValue(node, "__REMOTE_VERIFICATION__"));
|
||||
boolean useStrictReplyParsing = ("true").equals(ElementParameterParser.getValue(node, "__USE_STRICT_REPLY_PARSING__"));
|
||||
boolean isConfigClient = "true".equals(ElementParameterParser.getValue(node, "__CONFIG_CLIENT__"));
|
||||
List<Map<String, String>> clientParams = (List<Map<String,String>>)ElementParameterParser.getObjectValue(node, "__CLIENT_PARAMETERS__");
|
||||
|
||||
if (("true").equals(useExistingConn)) {
|
||||
List< ? extends INode> nodeList = node.getProcess().getGeneratingNodes();
|
||||
|
||||
@@ -265,11 +265,31 @@
|
||||
NUM_ROW="100" SHOW_IF="USE_EXISTING_CONNECTION == 'false'" REPOSITORY_VALUE="USE_STRICT_REPLY_PARSING">
|
||||
<DEFAULT>true</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER
|
||||
NAME="CONFIG_CLIENT"
|
||||
FIELD="CHECK"
|
||||
NUM_ROW="110"
|
||||
SHOW_IF="(SFTP == 'true') AND (USE_EXISTING_CONNECTION == 'false')"
|
||||
>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER
|
||||
NAME="CLIENT_PARAMETERS"
|
||||
FIELD="TABLE"
|
||||
NUM_ROW="120"
|
||||
SHOW_IF="(CONFIG_CLIENT == 'true') AND (SFTP == 'true') AND (USE_EXISTING_CONNECTION == 'false')"
|
||||
>
|
||||
<ITEMS>
|
||||
<ITEM NAME="PARAMETER"></ITEM>
|
||||
<ITEM NAME="VALUE"></ITEM>
|
||||
</ITEMS>
|
||||
</PARAMETER>
|
||||
</ADVANCED_PARAMETERS>
|
||||
|
||||
<CODEGENERATION>
|
||||
<IMPORTS>
|
||||
<IMPORT NAME="Java-SFTP" MODULE="jsch-0.1.55.jar" MVN="mvn:com.jcraft/jsch/0.1.55" REQUIRED_IF="(SFTP == 'true') AND (USE_EXISTING_CONNECTION == 'false')"/>
|
||||
<IMPORT NAME="Java-SFTP" MODULE="jsch-0.2.1.jar" MVN="mvn:com.github.mwiede/jsch/0.2.1" REQUIRED_IF="(SFTP == 'true') AND (USE_EXISTING_CONNECTION == 'false')"/>
|
||||
<IMPORT NAME="Java-FTP+S" MODULE="commons-net-3.6.jar" MVN="mvn:commons-net/commons-net/3.6" REQUIRED_IF="(SFTP == 'false') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="FTP+S-Proxy-talend" MODULE="commons-net-ftps-proxy-3.6.1-talend-20200902.jar"
|
||||
MVN="mvn:org.talend.components.lib/commons-net-ftps-proxy/3.6.1-talend-20200902"
|
||||
|
||||
@@ -48,3 +48,7 @@ MOVE_TO_THE_CURRENT_DIRECTORY.NAME=Move to the current directory
|
||||
USE_ENCODING.NAME=Filename encoding
|
||||
CONNECTION_TIMEOUT.NAME=Connection timeout (milliseconds)
|
||||
USE_STRICT_REPLY_PARSING.NAME=Use strict reply parsing
|
||||
CONFIG_CLIENT.NAME=Config client
|
||||
CLIENT_PARAMETERS.NAME=
|
||||
CLIENT_PARAMETERS.ITEM.PARAMETER=Client parameter
|
||||
CLIENT_PARAMETERS.ITEM.VALUE=Value
|
||||
|
||||
@@ -48,3 +48,7 @@ MOVE_TO_THE_CURRENT_DIRECTORY.NAME=D\u00E9placer vers le r\u00E9pertoire courant
|
||||
USE_ENCODING.NAME=Encodage du nom de fichier
|
||||
CONNECTION_TIMEOUT.NAME=D\u00E9lai avant l'expiration de la connexion (millisecondes)
|
||||
USE_STRICT_REPLY_PARSING.NAME=Utiliser le parsage de la r\u00E9ponse stricte
|
||||
CONFIG_CLIENT.NAME=Config client
|
||||
CLIENT_PARAMETERS.NAME=
|
||||
CLIENT_PARAMETERS.ITEM.PARAMETER=Param\u00E8tre client
|
||||
CLIENT_PARAMETERS.ITEM.VALUE=Valeur
|
||||
|
||||
@@ -47,4 +47,8 @@ FILES.ITEM.FILEMASK=\u30D5\u30A1\u30A4\u30EB\u30DE\u30B9\u30AF
|
||||
MOVE_TO_THE_CURRENT_DIRECTORY.NAME=\u73FE\u5728\u306E\u30C7\u30A3\u30EC\u30AF\u30C8\u30EA\u30FC\u306B\u79FB\u52D5
|
||||
USE_ENCODING.NAME=\u30D5\u30A1\u30A4\u30EB\u540D\u306E\u30A8\u30F3\u30B3\u30FC\u30C7\u30A3\u30F3\u30B0
|
||||
CONNECTION_TIMEOUT.NAME=\u63A5\u7D9A\u30BF\u30A4\u30E0\u30A2\u30A6\u30C8(\u30DF\u30EA\u79D2)
|
||||
USE_STRICT_REPLY_PARSING.NAME=\u8FD4\u4FE1\u89E3\u6790\u306E\u5236\u9650\u3092\u4F7F\u7528
|
||||
USE_STRICT_REPLY_PARSING.NAME=\u53B3\u5BC6\u306A\u8FD4\u4FE1\u89E3\u6790\u3092\u4F7F\u7528
|
||||
CONFIG_CLIENT.NAME=\u30AF\u30E9\u30A4\u30A2\u30F3\u30C8\u8A2D\u5B9A
|
||||
CLIENT_PARAMETERS.NAME=
|
||||
CLIENT_PARAMETERS.ITEM.PARAMETER=\u30AF\u30E9\u30A4\u30A2\u30F3\u30C8\u30D1\u30E9\u30E1\u30FC\u30BF\u30FC
|
||||
CLIENT_PARAMETERS.ITEM.VALUE=\u5024
|
||||
|
||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user