Compare commits

...

96 Commits

Author SHA1 Message Date
pyzhou
997c7f3761 feat(TDI-46737):print jobinfo log move (#7832) 2022-08-18 15:20:12 +08:00
Xilai Dai
5ebb56f309 fix(APPINT-34738) add MsmqTalend into osgi-exclude.properties (#7895) 2022-08-17 16:05:45 +08:00
vyu-talend
a0b3c983fb Revert "fix(TDI-48213):fix the closing resources issues. (#7826)" (#7880)
This reverts commit a092a9caab.
2022-08-11 15:34:36 +08:00
jiezhang-tlnd
43c4e71705 Revert "Jzhnag/80/tup 36410 need select talendssl (#7865)" (#7876)
This reverts commit ff24577e43.
2022-08-11 15:03:59 +08:00
jiezhang-tlnd
3a53d8a958 Revert "feat(TUP-35808)Generate module name from maven url (#7732)" (#7875)
This reverts commit 68a69cad7f.
2022-08-11 15:03:26 +08:00
wang wei
f6233bb17d fix(TDI-47696): [JDBC TCK]: Support dynamic changable setting when every row come, for tjdbcrow preparedstatementtable ui (#7711) 2022-08-10 20:38:20 +08:00
vyu-talend
a092a9caab fix(TDI-48213):fix the closing resources issues. (#7826)
* fix(TDI-48213):fix the closing resources issues.

* fix(TDI-48213):change the log level.
2022-08-10 17:15:08 +08:00
Oleksandr Zhelezniak
d8c18ff269 fix(TDI-46563): fix log message (#7869)
* add variable with empty value
2022-08-09 14:14:00 +03:00
jiezhang-tlnd
ff24577e43 Jzhnag/80/tup 36410 need select talendssl (#7865)
* fix(TUP-36410)Need select talendssl.jar from local while building job
which using tLDAPInput

* format code

* add <stripVersion>true</stripVersion>
2022-08-09 18:00:13 +08:00
hcyi
2fdda554d8 feat(TUP-35963):fix a bug when rename the link. (#7725) 2022-08-09 16:35:22 +08:00
hzhao-talendbj
7bd4190816 (TUP-36341): Unable to run DQ reports with subjob+joblet on a cloud or (#7838)
* (TUP-36341): Unable to run DQ reports with subjob+joblet on a cloud or
remote engine

* fix(TUP-36341): Unable to run DQ reports with subjob+joblet on a cloud

* fix(TUP-36341): Unable to run DQ reports with subjob+joblet on a cloud

* (TUP-36341): Unable to run DQ reports with subjob+joblet on a cloud

* fix(TUP-36341): Unable to run DQ reports with subjob+joblet on a cloud

* fix(TUP-36341): Unable to run DQ reports with subjob+joblet on a cloud

* fix(TUP-36341): Unable to run DQ reports with subjob+joblet on a cloud
2022-08-09 16:21:09 +08:00
Abdulhamid Rashankar
6d1c78e5e1 APPINT-34738:Integrate Talend-customized Microsoft MQ driver jar with improved native library loading (#7859)
Co-authored-by: arashankar <abdulhamid0606@gmail.com>
2022-08-09 09:17:48 +02:00
zyuan-talend
b0d427b936 fix(TUP-35909):update junit test. (#7854) 2022-08-09 11:25:55 +08:00
pyzhou
0042ffa19e fix(TDI-48322):align javax.mail version (#7847) 2022-08-09 10:23:44 +08:00
wang wei
c4efcea671 fix(TDI-47717): [JDBC TCK]: support tjdbccommit/tjdbcrollback (#7591) 2022-08-09 09:43:02 +08:00
pyzhou
c2a61959da feat(TDI-47369): tSendMail Oauth2 (#7784)
* fix(TDI-47369): tSendMail Oauth2

* fix migration

* feat(TDI-47447):tPOP OAuth2.0

* rename

* fix show if

* tSendMile MVN path

* tPOP mvn path

* correct migration description.
2022-08-08 17:23:58 +08:00
qiongli
19b29ea519 fix(TDQ-20362): Update and save analysis when rename jdbc connection (#7797) 2022-08-08 09:49:07 +08:00
pyzhou
cac9e1f72e fix(TDI-46737) (#7843) 2022-08-05 10:31:16 +08:00
jiezhang-tlnd
2d6fc1c328 Add localized files (#7846) (#7850)
Co-authored-by: jenkins-git <jenkins-git@talend.com>

Co-authored-by: Xuwei ZHU <xzhu@talend.com>
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-08-04 17:26:12 +08:00
jiezhang-tlnd
5c3637bfee Add localized files (#7845) (#7849)
Co-authored-by: jenkins-git <jenkins-git@talend.com>

Co-authored-by: jzhangbj <jzhang@talend.com>
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-08-04 17:22:26 +08:00
jiezhang-tlnd
3e6c3d65a5 Add localized files (#7844) (#7848)
Co-authored-by: jenkins-git <jenkins-git@talend.com>

Co-authored-by: Alexiane Yvonet <ayvonet@talend.com>
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-08-04 17:17:32 +08:00
msjian
4320d5a6d4 fix(TDQ-20638): fix a replacement error for DQ item (#7841) 2022-08-02 17:14:51 +08:00
sbliu
1cc40dac56 feat(TUP-29393) amend message. (#7836) 2022-08-02 15:33:43 +08:00
vyu-talend
b56d39476c fix(TDI-48246):upgrade guava to align. (#7809) 2022-08-02 11:40:05 +08:00
pyzhou
10ebfa7c56 fix(TDI-48254): tRSSOoutput encoding issue (#7799)
* fix(TDI-48254): tRSSOoutput encoding issue

* Changed to compatible with jdk 8
2022-08-02 10:27:49 +08:00
vyu-talend
864565e5f8 fix(TDI-48082):add additional parameters to all greenplum. (#7794) 2022-08-01 17:31:24 +08:00
zyuan-talend
d4db372bd9 801 loc 2022 07 29 (#7825)
* Add localized files (#7810)

Co-authored-by: jenkins-git <jenkins-git@talend.com>

* Add localized files (#7821)

Co-authored-by: jenkins-git <jenkins-git@talend.com>

* Add localized files (#7822)

Co-authored-by: jenkins-git <jenkins-git@talend.com>

* Add localized files (#7823)

Co-authored-by: jenkins-git <jenkins-git@talend.com>

Co-authored-by: jzhangbj <jzhang@talend.com>
Co-authored-by: jenkins-git <jenkins-git@talend.com>
Co-authored-by: Alexiane Yvonet <ayvonet@talend.com>
Co-authored-by: tsasada-talend <51699524+tsasada-talend@users.noreply.github.com>
2022-07-29 15:45:53 +08:00
jiezhang-tlnd
68a69cad7f feat(TUP-35808)Generate module name from maven url (#7732)
* feat(TUP-35808)Generate module name from maven url

* format code
2022-07-27 18:38:29 +08:00
sbliu
88ec878129 feat(TUP-29393) remove preference initialization of nexus connection timeout (#7789)
* feat(TUP-29393) remove preference initialization of nexus connection timeout

* use same label for both local and remote connection, for default connection timeout / default read timeout

* change label for database connection timeout
2022-07-27 17:42:16 +08:00
jiezhang-tlnd
03fd7be5b8 fix(TUP-35446)CVE: org.apache.maven:maven-core:3.8.3 (#7747) 2022-07-27 11:25:08 +08:00
wang wei
1281774f65 fix(TDI-48086): CVE poi-scratchpad (#7786) 2022-07-27 10:19:45 +08:00
wang wei
3b73492a15 fix(TDI-48203): [CVE]: routines.system.JSONObject(Object bean) use reflect to call method invoke, that's dangerous for evil script inject(#7721) 2022-07-27 09:28:53 +08:00
Oleksandr Zhelezniak
d692b7c0d0 chore(TDI-48177): bump google oauth (#7765)
* 1.31.0 -> 1.33.3
2022-07-26 11:06:14 +03:00
sbliu
3e57b5c1f5 fix(TUP-36128) fix problem when parse where condition string which contains global string for tELTmap. (#7801)
* fix(TUP-36128) fix problem when parse where condition string which contains global string for tELTmap.

* fix(TUP-36128) add junit .
2022-07-26 14:29:28 +08:00
sbliu
e04186b994 fix(TUP-36252) fix NPE for tos studio build job (#7795) 2022-07-26 14:25:07 +08:00
pyzhou
449699463f feat(TDI-46737):print jobinfo log (#7618)
* feat(TDI-46737):print jobinfo log

* fix compaile error when log4jndisabled

* feat(TDI-46737): replace /n with /t

* put jobinfo outside main method

* add boundary check
2022-07-26 11:01:45 +08:00
sbliu
b6bc8f8bb4 chore(TUP-35865) remove dependency link to wstx-asl in libraries.apache.axis (#7726) 2022-07-22 17:27:58 +08:00
Oleksandr Zhelezniak
ee41b11458 chore(TDI-48081): bump xmlsec 2.3.1 (#7769)
* MCRMInput\Output 2.1.2 -> 2.3.1
2022-07-22 09:51:32 +03:00
kjwang
cd0a376742 TUP-36157 Error when install Bigtable in studio: Illegal character in (#7761)
TUP-36157 Error when install Bigtable in studio: Illegal character in query
https://jira.talendforge.org/browse/TUP-36157
2022-07-22 09:37:38 +08:00
Jane Ding
0e942c29ec Add localized files (#7800) (#7803)
Co-authored-by: jenkins-git <jenkins-git@talend.com>

Co-authored-by: tsasada-talend <51699524+tsasada-talend@users.noreply.github.com>
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-07-21 17:43:54 +08:00
Jane Ding
263c68aa1c fix(TUP-36192):Talend 8 - Unable to Save Job (#7783)
* fix(TUP-36192):Talend 8 - Unable to Save Job
https://jira.talendforge.org/browse/TUP-36192

* fix(TUP-36192):Talend 8 - Unable to Save Job
https://jira.talendforge.org/browse/TUP-36192
2022-07-21 17:36:43 +08:00
jzhao
9c734ed1ab fix(TDI-48235):align bouncycastle to 1.70 (#7760) 2022-07-20 16:36:55 +08:00
jzhao
34ea4e2000 fix(TDI-48046): CVE: IBM MQ 9.2.4.0 (#7758) 2022-07-20 15:48:16 +08:00
hzhao-talendbj
3a7cdb4a7d Revert "chore(TUP-35265): upgrade 'crypto-utils' jar in low level (#7645)" (#7790)
This reverts commit 71e030028b.
2022-07-19 16:25:40 +08:00
pyzhou
b3f59bb007 fix(TDI-48024): ResumeUtil performance issue. (#7771) 2022-07-19 10:35:34 +08:00
vyu-talend
5dacef1e96 fix(TDI-47976):fix some potencial npe. (#7757) 2022-07-19 10:00:33 +08:00
wang wei
50390195d3 fix(TDI-48221): tDBBulkExec (MYSQL) Failing with error (#7739) 2022-07-18 10:11:43 +08:00
Dmytro Sylaiev
fda862cc39 feat(TDI-46563): Allow not to fire ANALYZE command (#7729) 2022-07-15 12:19:10 +03:00
Jane Ding
f8cc41a85e feat(TUP-35644):tMap - possible simplified metrics to send to Pendo (#7690)
* feat(TUP-35644):tMap - possible simplified metrics to send to Pendo
https://jira.talendforge.org/browse/TUP-35644

* feat(TUP-35644):tMap - possible simplified metrics to send to Pendo
https://jira.talendforge.org/browse/TUP-35644

* feat(TUP-35644):tMap - possible simplified metrics to send to Pendo
https://jira.talendforge.org/browse/TUP-35644

* feat(TUP-35644):tMap - possible simplified metrics to send to Pendo
https://jira.talendforge.org/browse/TUP-35644

* feat(TUP-35644):tMap - possible simplified metrics to send to Pendo
https://jira.talendforge.org/browse/TUP-35644

* feat(TUP-35644):tMap - possible simplified metrics to send to Pendo
https://jira.talendforge.org/browse/TUP-35644

* feat(TUP-35644):tMap - possible simplified metrics to send to Pendo
https://jira.talendforge.org/browse/TUP-35644

* feat(TUP-35644):tMap - possible simplified metrics to send to Pendo
https://jira.talendforge.org/browse/TUP-35644

* feat(TUP-35644):tMap - possible simplified metrics to send to Pendo
https://jira.talendforge.org/browse/TUP-35644
2022-07-14 17:23:09 +08:00
vyu-talend
080d15bb46 feat(TDI-44761):improve sftp in ftp components (#7728)
* feat(TDI-44761):improve sftp in ftp components.

* feat(TDI-44761):update plugin.xml for migration task.

* Delete .project

* feat(TDI-47761):improve code

* feat(TDI-44761):fix something

* feat(TDI-44761):fix migration issue.

* feat(TDI-47761):fix migration task.

* feat(TDI-44761):test manual build patch

* feat(TDI-44761):test migration task.

* feat(TDI-44761):improve code

* feat(TDI-44761):fix string value issue.

* feat(TDI-44761):import java.util.map.

* feat(TDI-44761):fix UI issue.

* feat(TDI-44761):improve migration.

* feat(TDI-44761):improve migration.
2022-07-14 16:51:35 +08:00
sbliu
6ef21d35df chore(TUP-35948) showOverwrite enabled when is cloud connection (#7770)
show override in preference page load from logon dialog when product is cloud license or tp_all license.
2022-07-14 15:51:52 +08:00
hcyi
bfd6eeb40c feat(TUP-30684):fix a bug if the table is start with a number or (#7774)
illegal character.
2022-07-14 15:12:54 +08:00
zshen-talend
a88cecbea1 fix(TDQ-20577): replace project name with lowercase mode in TDQItems when export job 2022-07-14 12:31:40 +08:00
pyzhou
98dced7251 Revert "migration" (#7773)
This reverts commit 4422793a56.

Revert "UI change"

This reverts commit b0d9c95d5a.

Revert "fix(TDI-47369): tSendMail Oauth2"

This reverts commit 5639383b2b.
2022-07-14 11:50:12 +08:00
Jill Yan
2e80d7e136 APPINT-34809 fix JSON exception (#7752)
Co-authored-by: jillyan <yan955599@gmail.com>
2022-07-14 09:37:23 +08:00
Jane Ding
1675c694a4 Jding/tup 35939 file dialog style (#7755)
* fix(TUP-35939):tFileOutput components resulting in File not found error
when selecting a file path for saving the output file.
https://jira.talendforge.org/browse/TUP-35939

* fix(TUP-35939):tFileOutput components resulting in File not found error
when selecting a file path for saving the output file.
https://jira.talendforge.org/browse/TUP-35939

* fix(TUP-35939):tFileOutput components resulting in File not found error
when selecting a file path for saving the output file.
https://jira.talendforge.org/browse/TUP-35939
2022-07-13 17:53:53 +08:00
Zhiwei Xue
d08c179dec fix(TUP-18979):Migration tasks including mapping files (#7730) 2022-07-13 11:02:31 +08:00
pyzhou
4422793a56 migration
Conflicts:
	main/plugins/org.talend.repository/plugin.xml
2022-07-12 22:19:43 +08:00
pyzhou
b0d9c95d5a UI change 2022-07-12 22:18:28 +08:00
pyzhou
5639383b2b fix(TDI-47369): tSendMail Oauth2 2022-07-12 22:18:22 +08:00
Dmytro Sylaiev
6ae35f5f87 fix(TDI-47908): Commit stats in case of Error (#7703) 2022-07-12 11:15:40 +03:00
pyzhou
f82cc232e2 fix(TDI-48290): tCould upgrade (#7750) 2022-07-12 09:29:31 +08:00
hcyi
9c90588ab5 feat(TUP-30684):snowflake Feature request to refresh the table schema instead of automatically refreshing all table schemas. (#7694)
* feat(TUP-30684):snowflake Feature request to refresh the table schema
instead of automatically refreshing all table schemas.

* feat(TUP-30684):add junits
2022-07-11 18:41:28 +08:00
kjwang
ddff7906c8 Fix: TUP-36107 In Studio 8 Stats & Logs project settings are removed (#7723)
Fix: TUP-36107 In Studio 8 Stats & Logs project settings are removed after enabling "Publish to artifact repository" feature
https://jira.talendforge.org/browse/TUP-36107
2022-07-08 18:33:55 +08:00
zshen-talend
ffddff1dbb fix(TDQ-20754): revert code to keep project is lowercase (#7741) 2022-07-08 16:17:55 +08:00
wang wei
59a4f69506 fix(TDI-47694): [JDBC TCK]: Inject runtime context for tck connector runtime(#7744) 2022-07-08 15:44:10 +08:00
pyzhou
06b2da94fc fix(TDI-48107):gson CVE (#7649)
* fix(TDI-48107):gson CVE

* fix(TDI-48107):gson CVE 2.8.9

* fix(TDI-48107):gson CVE

* fix(TDI-48107):gson CVE

* upgrade version

* missing GoogleDataprocManage
# Conflicts:
#	main/plugins/org.talend.designer.components.libs/libs_src/adal4j/pom.xml
#	main/plugins/org.talend.designer.components.libs/libs_src/talend-mscrm/pom.xml
2022-07-07 23:44:49 +08:00
Emmanuel GALLOIS
2a8024f79e fix(TCOMP-2171): fix ComponentIndex constructor in TaCoKitUtilTest (#7736) 2022-07-07 14:37:04 +02:00
zyuan-talend
7f6d815c1f Add localized files (#7735)
* Add localized files (#7733)

Co-authored-by: jenkins-git <jenkins-git@talend.com>

* Add localized files (#7734)

Co-authored-by: jenkins-git <jenkins-git@talend.com>

Co-authored-by: Alexiane Yvonet <ayvonet@talend.com>
Co-authored-by: jenkins-git <jenkins-git@talend.com>
Co-authored-by: tsasada-talend <51699524+tsasada-talend@users.noreply.github.com>
2022-07-07 18:09:25 +08:00
Emmanuel GALLOIS
31092cc40f fix(TCOMP-2171): fix ComponentIndex constructor (#7716) 2022-07-07 10:30:00 +02:00
Hongchun Yi
b7d9ba140c feat(TUP-35963):revert the fix a bug when rename the link. 2022-07-06 10:21:25 +08:00
Hongchun Yi
686564ae5e feat(TUP-35963):fix a bug when rename the link. 2022-07-05 18:42:25 +08:00
hzhao-talendbj
71e030028b chore(TUP-35265): upgrade 'crypto-utils' jar in low level (#7645) 2022-07-04 17:42:13 +08:00
sponomarova
d981791b42 fix(TBD-13990): [Patch R2022-05v2_8.0.1] tHiveConnection component doesn't generate code for url_tHiveConnection variable definition (#7669) 2022-07-04 12:06:26 +03:00
Dmytro Grygorenko
82f35f6e41 fix(TDI-48185): bump "nimbus-jose" version (leftovers). (#7717) 2022-07-04 11:29:42 +03:00
jzhao
99d434d29b fix(TDI-48159):tSalesforceEinsteinBulkExec align force-wsc with other sf
components (#7693)
2022-07-01 14:44:38 +08:00
zyuan-talend
f8865cb213 chore(TUP-8888):Add localized files (#7709)
* Add localized files (#7706)

Co-authored-by: jenkins-git <jenkins-git@talend.com>

* Add localized files (#7707)

Co-authored-by: jenkins-git <jenkins-git@talend.com>

Co-authored-by: tsasada-talend <51699524+tsasada-talend@users.noreply.github.com>
Co-authored-by: jenkins-git <jenkins-git@talend.com>
Co-authored-by: jzhangbj <jzhang@talend.com>
2022-07-01 11:42:53 +08:00
Jane Ding
dd9fd8cb24 fix(TUP-35939):tFileOutput components resulting in File not found error (#7666)
* fix(TUP-35939):tFileOutput components resulting in File not found error
when selecting a file path for saving the output file.
https://jira.talendforge.org/browse/TUP-35939

* fix(TUP-35939):tFileOutput components resulting in File not found error
when selecting a file path for saving the output file.
https://jira.talendforge.org/browse/TUP-35939
2022-07-01 09:28:25 +08:00
pyzhou
6655f97987 fix(TDI-48113):CVE woodstox-core (#7650) 2022-06-30 15:05:50 +08:00
zyuan-talend
4e7e7e3f92 fix(TUP-31721):Not clear studio index cache in normal case. (#7616) 2022-06-30 14:54:16 +08:00
wang wei
8200e6db62 fix(TDI-47714): [JDBC TCK]: "Use existed connection" ui appear in (#7586) 2022-06-30 11:38:06 +08:00
Dmytro Sylaiev
55ce5dea3c fix(TDI-48004): Handle dependency with classifier (#7672) 2022-06-29 15:18:35 +03:00
Abdulhamid Rashankar
cc71d9db71 APPINT-34489 : profile added for promthus dependencies (#7689)
Co-authored-by: arashankar <abdulhamid0606@gmail.com>
2022-06-29 13:55:39 +02:00
kjwang
dff68c17f2 Fix:TUP-35887 "build job" working in 7.2.1 fails in 8.0.1: Failed to generate code : NPE org.talend.designer.dbmap.language.oracle.OracleGenerationManager.addQuoteForSpecialChar (#7667)
* Fix:TUP-35887
"build job" working in 7.2.1 fails in 8.0.1: Failed to generate code :
NPE org.talend.designer.dbmap.language.oracle.OracleGenerationManager.addQuoteForSpecialChar
https://jira.talendforge.org/browse/TUP-35887
2022-06-29 11:38:42 +08:00
bhe-talendbj
1d99eba2b7 fix(TUP-35942): update relevant job only after renaming joblet (#7673) 2022-06-29 11:05:07 +08:00
Jill Yan
251293a356 APPINT-34694 build routlet module (#7676)
Co-authored-by: jillyan <yan955599@gmail.com>
2022-06-29 10:48:26 +08:00
Wei Hua
2ad83e745a APPINT-31958 Wrong endpoint displayed in console message when using cRest/tRESTRequest (#7680) 2022-06-28 16:23:47 +08:00
msjian
bc7b87956d fix(TDQ-19435): fix a NPE (#7665) 2022-06-28 14:17:48 +08:00
zshen-talend
fd8cf997dc fix(TDQ-19623): fix junit about BuildJobHandlerTest.testBuildJobWithTDM (#7692) 2022-06-27 19:03:14 +08:00
Olha V
6318139dd4 fix(TDI-48035): Add null marker to tBigQueryOutput (#7662) (#7687) 2022-06-24 12:27:25 +03:00
Jane Ding
9f034e9752 fix(TUP-35599):SuggestionValues.Item support of user friendly UI label (#7685)
different from it's id
https://jira.talendforge.org/browse/TUP-35599
2022-06-24 14:26:57 +08:00
hcyi
22168da847 fix(TUP-35960):signer.version show a fixed value in job's pom.xml. (#7681) 2022-06-23 18:08:20 +08:00
Chao MENG
024fbf3e6f chore: update plugin timestamp (#7683) 2022-06-23 17:13:57 +08:00
Jane Ding
7e4f1971ab fix(TUP-35599):SuggestionValues.Item support of user friendly UI label (#7619)
* fix(TUP-35599):SuggestionValues.Item support of user friendly UI label
different from it's id
https://jira.talendforge.org/browse/TUP-35599

* fix(TUP-35599):SuggestionValues.Item support of user friendly UI label
different from it's id
https://jira.talendforge.org/browse/TUP-35599
2022-06-21 22:07:41 +08:00
wwang
e24bc3e0c6 Revert "fix(TDI-47694): [JDBC TCK]: Inject runtime context for tck connector runtime (#7567)"
This reverts commit 77e3b8bb8a.
2022-06-21 09:08:32 +08:00
wang wei
77e3b8bb8a fix(TDI-47694): [JDBC TCK]: Inject runtime context for tck connector runtime (#7567) 2022-06-21 09:03:53 +08:00
319 changed files with 3059 additions and 671 deletions

View File

@@ -321,6 +321,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 +336,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,6 +553,8 @@
org.apache.logging.log4j.core.config.Configurator.setLevel(org.apache.logging.log4j.LogManager.getRootLogger().getName(), log.getLevel());
<%}%>
}
getjobInfo();
log.info("TalendJob: '<%=codeGenArgument.getJobName()%>' - Start.");
<%}%>
@@ -883,7 +923,7 @@
}
%>
//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 (stats) {
@@ -1156,9 +1196,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,7 +1338,7 @@ if (execStat) {
returnCode = errorCode.intValue();
}
resumeUtil.addLog("JOB_ENDED", "JOB:" + jobName, parent_part_launcher, Thread.currentThread().getId() + "", "","" + returnCode,"","","");
resumeUtil.flush();
return returnCode;
}

View File

@@ -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 "";
}

View File

@@ -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

View File

@@ -3,7 +3,7 @@
<modelVersion>4.0.0</modelVersion>
<groupId>com.microsoft.azure</groupId>
<artifactId>adal4j</artifactId>
<version>1.6.4-20210713</version>
<version>1.6.6-20220707</version>
<packaging>jar</packaging>
<name>adal4j</name>
<description>
@@ -104,7 +104,7 @@
<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>

View File

@@ -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>
<properties>
@@ -39,7 +39,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>

View File

@@ -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" />

View File

@@ -46,11 +46,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>

View File

@@ -3,7 +3,7 @@
<modelVersion>4.0.0</modelVersion>
<groupId>org.talend.components</groupId>
<artifactId>talend-mscrm</artifactId>
<version>3.12-20220513</version>
<version>3.14-20220707</version>
<packaging>jar</packaging>
<name>talend-mscrm</name>
@@ -25,8 +25,9 @@
<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-20210713</adal4j.version>
<jackson.version>2.11.4</jackson.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>
<!-- plugin's versions -->
<maven-jar-plugin.version>3.2.0</maven-jar-plugin.version>
@@ -165,7 +166,7 @@
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.9.0</version>
<version>2.8.9</version>
</dependency>
</dependencies>

View File

@@ -57,11 +57,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>

View File

@@ -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>
@@ -56,7 +56,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>
@@ -66,7 +66,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>

View File

@@ -50,12 +50,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>

View File

@@ -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"));
}
}

View File

@@ -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

View File

@@ -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

View File

@@ -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"/>

View File

@@ -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')"/>

View File

@@ -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')"/>

View File

@@ -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

View File

@@ -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

View File

@@ -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')"/>

View File

@@ -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

View File

@@ -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

View File

@@ -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

View File

@@ -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

View File

@@ -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>

View File

@@ -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

View File

@@ -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')" />

View File

@@ -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

View File

@@ -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>

View File

@@ -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" />

View File

@@ -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=

View File

@@ -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=

View File

@@ -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=

View File

@@ -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=

View File

@@ -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>

View File

@@ -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

View File

@@ -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>

View File

@@ -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>

View File

@@ -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 %> + ".");
<%}%>

View File

@@ -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(".", "*");
<%
}

View File

@@ -65,7 +65,7 @@ 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

View File

@@ -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

View File

@@ -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

View File

@@ -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

View File

@@ -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;

View File

@@ -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

View File

@@ -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

View File

@@ -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) {

View File

@@ -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" />

View File

@@ -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

View File

@@ -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

View File

@@ -36,3 +36,7 @@ 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=\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

View File

@@ -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

View File

@@ -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();

View File

@@ -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"

View File

@@ -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

View File

@@ -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

View File

@@ -51,3 +51,7 @@ MOVE_TO_THE_CURRENT_DIRECTORY.NAME=\u73FE\u5728\u306E\u30C7\u30A3\u30EC\u30AF\u3
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=\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

View File

@@ -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

View File

@@ -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();

View File

@@ -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"

View File

@@ -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

View File

@@ -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

View File

@@ -47,3 +47,7 @@ IGNORE_FAILURE_AT_QUIT.NAME=\u7D42\u4E86\u6642\u306B\u30A8\u30E9\u30FC\u3092\u71
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=\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

View File

@@ -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

View File

@@ -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();

View File

@@ -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"

View File

@@ -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

View File

@@ -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

View File

@@ -48,3 +48,7 @@ MOVE_TO_THE_CURRENT_DIRECTORY.NAME=\u73FE\u5728\u306E\u30C7\u30A3\u30EC\u30AF\u3
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=\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

View File

@@ -48,3 +48,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

View File

@@ -6,6 +6,7 @@ imports="
org.talend.core.model.process.IConnectionCategory
org.talend.designer.codegen.config.CodeGeneratorArgument
java.util.List
java.util.Map
org.talend.core.model.process.IElementParameter
org.talend.core.model.utils.NodeUtil
"
@@ -49,6 +50,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__");
log4jFileUtil.componentStartInfo(node);

View File

@@ -262,11 +262,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"

View File

@@ -45,3 +45,7 @@ MODE.NAME=Transfer mode
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

View File

@@ -45,3 +45,7 @@ MODE.NAME=Mode de transfert
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

View File

@@ -45,3 +45,7 @@ MODE.NAME=\u8EE2\u9001\u30E2\u30FC\u30C9
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=\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

View File

@@ -45,3 +45,7 @@ MODE.NAME=\u4F20\u8F93\u65B9\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

View File

@@ -54,6 +54,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__");
String passwordFieldName = "";
if ("true".equals(useExistingConn)) {

View File

@@ -305,11 +305,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="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"

View File

@@ -63,3 +63,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

View File

@@ -63,3 +63,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

View File

@@ -63,3 +63,7 @@ MOVE_TO_THE_CURRENT_DIRECTORY.NAME=\u73FE\u5728\u306E\u30C7\u30A3\u30EC\u30AF\u3
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=\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

View File

@@ -63,3 +63,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

View File

@@ -51,6 +51,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__");
String passwordFieldName = "";
if (("true").equals(useExistingConn)) {

View File

@@ -346,16 +346,36 @@ 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-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"
REQUIRED_IF="(SFTP == 'false') AND (USE_EXISTING_CONNECTION == 'false')" />
<IMPORT NAME="talend-proxy" MODULE="talend-proxy-1.0.2.jar" MVN="mvn:org.talend.components.lib/talend-proxy/1.0.2" REQUIRED_IF="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"
REQUIRED_IF="(SFTP == 'false') AND (USE_EXISTING_CONNECTION == 'false')" />
<IMPORT NAME="talend-proxy" MODULE="talend-proxy-1.0.2.jar" MVN="mvn:org.talend.components.lib/talend-proxy/1.0.2" REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
</IMPORTS>
</CODEGENERATION>
<RETURNS>

View File

@@ -67,3 +67,7 @@ FTPSOVERWRITE.NAME=Overwrite file
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

View File

@@ -67,3 +67,7 @@ FTPSOVERWRITE.NAME=\u00C9craser le fichier
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

View File

@@ -67,3 +67,7 @@ FTPSOVERWRITE.NAME=\u30D5\u30A1\u30A4\u30EB\u306E\u4E0A\u66F8\u304D
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=\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

View File

@@ -67,3 +67,7 @@ FTPSOVERWRITE.NAME=\u6539\u5199\u6587\u4EF6
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

View File

@@ -47,6 +47,9 @@ boolean useRemoteVerification = ("true").equals(ElementParameterParser.getValue(
boolean useStrictReplyParsing = ("true").equals(ElementParameterParser.getValue(node, "__USE_STRICT_REPLY_PARSING__"));
boolean dieOnError = ("true").equals(ElementParameterParser.getValue(node,"__DIE_ON_ERROR__"));
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();

View File

@@ -268,11 +268,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"

View File

@@ -52,3 +52,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

View File

@@ -52,3 +52,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

View File

@@ -52,3 +52,7 @@ MOVE_TO_THE_CURRENT_DIRECTORY.NAME=\u73FE\u5728\u306E\u30C7\u30A3\u30EC\u30AF\u3
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=\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

View File

@@ -52,3 +52,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

View File

@@ -45,6 +45,9 @@ String timeoutValue = ElementParameterParser.getValue(node, "__CONNECTION_TIMEOU
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();

View File

@@ -256,11 +256,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"

View File

@@ -47,3 +47,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

View File

@@ -47,3 +47,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

Some files were not shown because too many files have changed in this diff Show More