Compare commits

...

92 Commits

Author SHA1 Message Date
Chao MENG
163e0d70ec chore: support export item 2022-09-19 00:46:30 +08:00
Chao MENG
6800625fe9 chore: support code generator server 2022-09-15 17:42:18 +08:00
vyu-talend
a6190d6896 fix(TDI-48213):fix the risk of not closing resources (#7922)
* fix(TDI-48213):fix the closing resources issues. (#7826)

* fix(TDI-48213):fix the closing resources issues.

* fix(TDI-48213):change the log level.

* fix(TDI-48213):fix the risk of not closing resources.

* fix(TDI-48213):remove useless try/catch.

* feat(TDI-42323):add entry to custom ratio.

* Revert "feat(TDI-42323):add entry to custom ratio."

This reverts commit 18e23af73c.

* fix(TDI-48213):add finish flag to end and finally.

* fix(TDI-48213):remove useless codes.

Co-authored-by: vyu <vyu@192.168.1.15>
2022-09-15 16:33:45 +08:00
Dmytro Grygorenko
1f5a3f62d8 feat(TDI-46676): MDC logging for Log4J. (#7702)
* feat(TDI-46676): MDC logging for Log4J.

* feat(TDI-46676): implement for Log4J2 only.

* feat(TDI-46676): formatting, duplicate entries removed.

* feat(TDI-46676): restoring after rebase.

* feat(TDI-46676): fix after rebase.

* feat(TDI-46676): add content of jobInfo.properties

* fix(TDI-46676): corrections after rebase.

* feat(TDI-46676): typos.

* feat(TDI-46676): changes after code review.
2022-09-14 16:11:56 +03:00
Jane Ding
56577d508b fix(TUP-36251):[8.0.1] File JSON metadata not working when special character or space is available in the field name (#7992)
* fix(TUP-36251):[8.0.1] File JSON metadata not working when special (#7939)

* fix(TUP-36251):[8.0.1] File JSON metadata not working when special
character or space is available in the field name
https://jira.talendforge.org/browse/TUP-36251

* fix(TUP-36251):[8.0.1] File JSON metadata not working when special
character or space is available in the field name
https://jira.talendforge.org/browse/TUP-36251

* fix(TUP-36251):[8.0.1] File JSON metadata not working when special
character or space is available in the field name
https://jira.talendforge.org/browse/TUP-36251

* fix(TUP-36251):[8.0.1] File JSON metadata not working when special
character or space is available in the field name
https://jira.talendforge.org/browse/TUP-36251

* fix(TUP-36251):[8.0.1] File JSON metadata not working when special
character or space is available in the field name
https://jira.talendforge.org/browse/TUP-36251

* fix(TUP-36251):[8.0.1] File JSON metadata not working when special
character or space is available in the field name
https://jira.talendforge.org/browse/TUP-36251

* fix(TUP-36251):[8.0.1] File JSON metadata not working when special
character or space is available in the field name
https://jira.talendforge.org/browse/TUP-36251

* fix(TUP-36251):[8.0.1] File JSON metadata not working when special
character or space is available in the field name
https://jira.talendforge.org/browse/TUP-36251

* fix(TUP-36251):[8.0.1] File JSON metadata not working when special
character or space is available in the field name
https://jira.talendforge.org/browse/TUP-36251

* fix(TUP-36251):[8.0.1] File JSON metadata not working when special
character or space is available in the field name
https://jira.talendforge.org/browse/TUP-36251
2022-09-14 20:15:55 +08:00
Liu Xinquan
a5ad384e46 Revert "fix(TDQ-20610) org.apache.lucene:lucene-core (#7944)" (#7982)
This reverts commit 8ea780dc4d.
2022-09-13 17:47:58 +08:00
AlixMetivier
4e9e4e0290 feat(TBD-13647): allow switch from transient to interactive cluster (#7713) (#7971)
* feat(TBD-13647): allow switch from transient to interactive cluster

* refacto

* fix(TBD-14086): fix empty spark conf

* feat(TBD-13647): contextualize DBR wizard

* fix isContext

Co-authored-by: unknown <ametivier@talend.com>

Co-authored-by: AlixMetivier-zz <50327620+AlixMetivier-zz@users.noreply.github.com>
2022-09-13 08:38:40 +02:00
zyuan-talend
021574267c fix(TUP-35745): Research: Bring a dark mode for Talend Studio. (#7966) 2022-09-13 10:49:19 +08:00
pyzhou
761e336111 feat(TDI-48332):oracle orai18n.jar (#7921)
* feat(TDI-48332):oracle orai18n.jar

* add dependency

* Add name

* fix wrong mvn path and name

* wrong import
2022-09-13 10:10:39 +08:00
jzhangbj
edb39550e6 Add localized files (#7969)
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-09-09 17:26:00 +08:00
Dmytro Ochkas
245bd37ca8 chore(TDI-48339): aws CVE path traversal (#7957)
bump aws-java-sdk to 1.12.297
2022-09-09 11:55:39 +03:00
Oleksandr Zhelezniak
54c00306d9 fix(TDI-47865): guess schema flow (#7863) 2022-09-09 11:31:50 +03:00
tsasada-talend
2c7248ef83 Add localized files (#7967)
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-09-09 15:13:57 +08:00
Alexiane Yvonet
01cd9c232b Add localized files (#7965)
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-09-09 14:59:42 +08:00
Jane Ding
fea8d4065a update jdt pref (#7964) 2022-09-08 11:54:33 +08:00
sbliu
d143d33850 feat(TUP-36340) oracle add support of orai18n.jar (#7861) (#7962) 2022-09-08 11:08:19 +08:00
hcyi
8e3ec1f574 fix(TUP-35511):[JDBC TCK]: improve the ui layout for tck connector in (#7948)
studio
2022-09-07 15:35:43 +08:00
bhe-talendbj
17742a2c68 feat(TUP-36373): move m2 setting out of local setting (#7956) (#7958) 2022-09-07 09:59:01 +08:00
Liu Xinquan
8ea780dc4d fix(TDQ-20610) org.apache.lucene:lucene-core (#7944) 2022-09-06 17:19:16 +08:00
hzhao
b63ce620eb fix(TUP-36593): Nexus proxy password is stored in clear text in project (#7935) (#7953)
* fix(TUP-36593): Nexus proxy password is stored in clear text in project
setting preference

* fix(TUP-36593): Nexus proxy password is stored in clear text in project

* fix(TUP-36593): Nexus proxy password is stored in clear text in project
add junit
2022-09-06 09:34:19 +08:00
Jane Ding
19e68c1694 fix(TUP-36440):JSON parsing issue when creating a new JSON file input in (#7909) (#7952)
* fix(TUP-36440):JSON parsing issue when creating a new JSON file input in
a repository
https://jira.talendforge.org/browse/TUP-36440

* fix(TUP-36440):JSON parsing issue when creating a new JSON file input in
a repository
https://jira.talendforge.org/browse/TUP-36440

* fix(TUP-36440):JSON parsing issue when creating a new JSON file input in
a repository
https://jira.talendforge.org/browse/TUP-36440
2022-09-05 17:49:07 +08:00
kjwang
64b10e61a9 Kjwang/tup 32641 change the help system (#7856) (#7950)
* TUP-32641 Change the help system to open the links of component from CLM
https://jira.talendforge.org/browse/TUP-32641
2022-09-05 14:48:05 +08:00
wang wei
7d7e4398ac fix(TDI-48333): [CVE]: replace or remove xalan dependency for tfileinputxml and twebservicexxx components (#7890) (#7949) 2022-09-05 11:08:06 +08:00
pyzhou
f5b4f882ff fix(TDI-48456):tPOP java8 compatibility (#7929) 2022-09-02 17:39:04 +08:00
jzhangbj
20b460ddc3 Add localized files (#7936)
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-09-02 14:56:04 +08:00
tsasada-talend
125870fea8 Add localized files (#7934)
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-09-02 14:41:20 +08:00
sbliu
ac916cbc57 fix junit failure(#7933) (#7940) 2022-09-02 14:27:07 +08:00
bhe-talendbj
e180852f07 feat(TUP-36373): Delete .m2 with UI option when apply a monthly updat… (#7928)
* feat(TUP-36373): Delete .m2 with UI option when apply a monthly update (#7906)

* feat(TUP-36373): inital impl

* feat(TUP-36373): update messages

* feat(TUP-36373): fix UI

* feat(TUP-36373): update UI and message

* feat(TUP-36373): update UI of updatesite settings

* feat(TUP-36373): update UI of updatesite settings

* feat(TUP-36373): delete m2 during startup

* feat(TUP-36373): add doc link
2022-09-01 16:54:53 +08:00
Oleksandr Zhelezniak
c05c6f3c7f fix(TDI-48363): skip null enum parameter (#7870) 2022-09-01 11:11:49 +03:00
Oleksandr Zhelezniak
50db6d0d8a fix(TDI-48446): require library when no connection (#7924) 2022-09-01 10:36:47 +03:00
pyzhou
d09be2efef Added extra fields, dependencies + token fetch logic. (#7918) (#7923)
Co-authored-by: Balázs Gunics <bgunics@talend.com>

Co-authored-by: Balázs Gunics <bgunics@talend.com>
2022-09-01 11:20:50 +08:00
hcyi
2b69024fee fix(TUP-36483):Code generation fails with xmlmap. (#7892) 2022-08-30 17:56:55 +08:00
jzhao
2c97652a74 fix(TDI-48426):CVE: org.postgresql:postgresql:42.2.25 (#7902) 2022-08-30 15:57:33 +08:00
bhe-talendbj
f6d32e4ac1 fix(TUP-35879): Default value is not saved into the job in tck component (#7815) (#7914)
* fix(TUP-35879): persist closed_list of tck into job item

* fix(TUP-35879): add migration task and junit test

* fix(TUP-35879): fix test case
2022-08-29 17:46:44 +08:00
sbliu
b03481e60e chore(TUP-36502) upgrade org.postgresql:postgresql:42.2.25 to 42.2.26 (#7901) 2022-08-29 16:37:51 +08:00
Joe
4455d61521 fix(TUP-35231): tELTMap update query not be wrapped for SET column when (#7855) (#7916)
* fix(TUP-35231): tELTMap update query not be wrapped for SET column when
enable `Use update statement without subqueries` in tELTOutput

* fix(TUP-35231): tELTMap update query not be wrapped for SET column

* fix(TUP-35231): tELTMap update query not be wrapped for SET column
2022-08-29 10:21:01 +08:00
Dmytro Sylaiev
c9c84e121c fix(TDI-48316): Add remote dir name (#7864) 2022-08-19 20:39:32 +03:00
Alexiane Yvonet
4905cfd090 Add localized files (#7908)
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-08-19 10:30:10 +08:00
Xilai Dai
30c0b563b1 fix(APPINT-34738) add MsmqTalend into osgi-exclude.properties (#7898) 2022-08-17 18:33:20 +08:00
wang wei
710bf29d2f fix(TDI-47696): [JDBC TCK]: Support dynamic changable setting when every row come, for tjdbcrow preparedstatementtable ui (#7711) (#7893) 2022-08-17 10:07:41 +08:00
zyuan-talend
e6c614bbc2 fix(TUP-35909):add junit test. (#7887) 2022-08-15 10:59:54 +08:00
Xuwei ZHU
4782532dca Add localized files (#7881)
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-08-12 08:58:23 +08:00
jzhangbj
2f3bdc3e0b Add localized files (#7883)
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-08-12 08:49:17 +08:00
Alexiane Yvonet
b2250689e9 Add localized files (#7877)
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-08-11 17:40:01 +08:00
vyu-talend
ac2245fb06 Revert "fix(TDI-48213):fix the closing resources issues. (#7826) (#7873)" (#7879)
This reverts commit e29fa80408.
2022-08-11 15:35:10 +08:00
zyuan-talend
32dcb2e020 fix(TUP-35909):update junit test. (#7854) (#7871) 2022-08-10 19:17:38 +08:00
vyu-talend
e29fa80408 fix(TDI-48213):fix the closing resources issues. (#7826) (#7873)
* fix(TDI-48213):fix the closing resources issues.

* fix(TDI-48213):change the log level.
2022-08-10 18:30:52 +08:00
hzhao-talendbj
f1967f2645 (TUP-36341): Unable to run DQ reports with subjob+joblet on a cloud or (#7838) (#7872)
* (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-10 16:58:09 +08:00
Oleksandr Zhelezniak
2c2f8e884e fix(TDI-46563): fix log message (#7869)
* add variable with empty value
2022-08-09 14:10:25 +03:00
jiezhang-tlnd
74d5f20345 Jzhang/tup 36410 (#7868)
* 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:18 +08:00
hcyi
db8732247a feat(TUP-35963):fix a bug when rename the link. (#7731) 2022-08-09 16:35:16 +08:00
Abdulhamid Rashankar
a91a2f6e71 APPINT-34738: Integrate Talend-customized Microsoft MQ driver jar with improved native library loading (#7858)
* APPINT-34738: Integrate Talend-customized Microsoft MQ driver jar with improved native library loading

* APPINT-34738: Integrate Talend-customized Microsoft MQ driver jar with improved native library loading

* APPINT-34738: Integrate Talend-customized Microsoft MQ driver jar with improved native library loading
2022-08-09 09:18:01 +02:00
pyzhou
e6f036a519 feat(TDI-47369): tSendMail Oauth2 (#7784) (#7866)
* 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.
# Conflicts:
#	main/plugins/org.talend.repository/plugin.xml
2022-08-09 10:07:51 +08:00
pyzhou
6c5527d6e9 fix(TDI-48322):align javax.mail version (#7847) 2022-08-09 10:06:48 +08:00
wang wei
532c950982 fix(TDI-47717): [JDBC TCK]: support tjdbccommit/tjdbcrollback (#7867) 2022-08-09 09:42:54 +08:00
qiongli
f26d262975 fix(TDQ-20362): Update and save analysis when rename jdbc connection (#7817) 2022-08-08 09:48:59 +08:00
pyzhou
d3800d42ea fix(TDI-46737) (#7843) 2022-08-05 10:29:07 +08:00
Xuwei ZHU
4a2583f672 Add localized files (#7846)
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-08-04 17:24:30 +08:00
jzhangbj
4fde7f3df4 Add localized files (#7845)
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-08-04 17:20:09 +08:00
Alexiane Yvonet
5c962b4b9c Add localized files (#7844)
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-08-04 17:02:20 +08:00
msjian
acd2da7b3c fix(TDQ-20638): fix a replacement error for DQ item (#7839) 2022-08-02 17:14:43 +08:00
sbliu
befb625719 feat(TUP-29393) amend message. (#7837) 2022-08-02 15:33:48 +08:00
pyzhou
43f7b1f96b feat(TDI-46737):print jobinfo log move (#7832) 2022-08-02 14:46:18 +08:00
vyu-talend
3cbfcff2a1 fix(TDI-48246):upgrade guava to align. (#7809) (#7834) 2022-08-02 12:03:25 +08:00
pyzhou
40214ad0f9 fix(TDI-48254): tRSSOoutput encoding issue (#7799)
* fix(TDI-48254): tRSSOoutput encoding issue

* Changed to compatible with jdk 8
2022-08-02 10:26:22 +08:00
vyu-talend
7aeecb33de fix(TDI-48082):add additional parameters to all greenplum. (#7794) (#7830) 2022-08-02 10:20:19 +08:00
tsasada-talend
120c8f067f Add localized files (#7823)
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-07-29 15:29:58 +08:00
jzhangbj
4aef962f93 Add localized files (#7822)
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-07-29 15:29:16 +08:00
Alexiane Yvonet
ccfd0210d9 Add localized files (#7821)
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-07-29 15:28:23 +08:00
jzhangbj
efb3892845 Add localized files (#7810)
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-07-29 15:27:22 +08:00
sbliu
0a076d5864 feat(TUP-29393) remove preference initialization of nexus connection timeout (#7789) (#7820)
* 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:58:14 +08:00
jiezhang-tlnd
aa3d21f60d fix(TUP-35446)CVE: org.apache.maven:maven-core:3.8.3 (#7747) (#7819) 2022-07-27 15:09:11 +08:00
sbliu
6057fa9b53 fix(TUP-36128) fix problem when parse where condition string which contains global string for tELTmap. (#7801) (#7816)
* fix(TUP-36128) fix problem when parse where condition string which contains global string for tELTmap.

* fix(TUP-36128) add junit .
2022-07-27 10:48:10 +08:00
wang wei
af32c2d607 fix(TDI-48086): CVE poi-scratchpad (#7814) 2022-07-27 10:19:52 +08:00
wang wei
738392a032 fix(TDI-48203): [CVE]: routines.system.JSONObject(Object bean) use reflect to call method invoke, that's dangerous for evil script inject(#7721) (#7813) 2022-07-27 09:51:33 +08:00
Oleksandr Zhelezniak
23a494f865 chore(TDI-48177): bump google oauth (#7765)
* 1.31.0 -> 1.33.3
2022-07-26 11:03:43 +03:00
sbliu
fbf81a76fe fix(TUP-36252) fix NPE for tos studio build job (#7806) 2022-07-26 14:25:30 +08:00
jzhao
b5bbb4ab54 feat(TDI-46737):print jobinfo log (#7618) (#7811)
* 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

Co-authored-by: pyzhou <pyzhou@talend.com>
2022-07-26 11:29:58 +08:00
sbliu
79091dad0d chore(TUP-35865) remove dependency link to wstx-asl in libraries.apache.axis (#7727) 2022-07-22 17:28:11 +08:00
Zhiwei Xue
86c76cea8f fix(TUP-18979):Migration tasks including mapping files (#7730) (#7808) 2022-07-22 16:51:42 +08:00
Oleksandr Zhelezniak
5833e5b3b3 chore(TDI-48081): bump xmlsec 2.3.1 (#7769)
* MCRMInput\Output 2.1.2 -> 2.3.1
2022-07-22 09:47:10 +03:00
kjwang
a30b7fb50e TUP-36157 Error when install Bigtable in studio: Illegal character in (#7764)
TUP-36157 Error when install Bigtable in studio: Illegal character in query
https://jira.talendforge.org/browse/TUP-36157
2022-07-22 09:37:05 +08:00
Jane Ding
663a066477 fix(TUP-36192):Talend 8 - Unable to Save Job (#7783) (#7805)
* 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:50:30 +08:00
tsasada-talend
ff52f0c86f Add localized files (#7800)
Co-authored-by: jenkins-git <jenkins-git@talend.com>
2022-07-21 16:43:36 +08:00
sbliu
d045f176a1 chore(TUP-35948) showOverwrite enabled when is cloud connection (#7770) (#7796)
show override in preference page load from logon dialog when product is cloud license or tp_all license.
2022-07-21 10:58:35 +08:00
jzhao
71fda3d5be fix(TDI-48235):align bouncycastle to 1.70 (#7760) 2022-07-20 16:16:31 +08:00
jzhao
dedff2bbda fix(TDI-48046): CVE: IBM MQ 9.2.4.0 (#7758) 2022-07-20 15:41:56 +08:00
hzhao-talendbj
c990583855 Revert "chore(TUP-35265): upgrade 'crypto-utils' jar in low level (#7645) (#7724)" (#7792)
This reverts commit 7e5d9ed650.
2022-07-19 16:55:41 +08:00
jiezhang-tlnd
4f93848f0f Revert "Revert "feat(TUP-35808)Generate module name from maven url (#7751)" (#7759)" (#7793)
This reverts commit c8e9707bb9.
2022-07-19 16:04:46 +08:00
pyzhou
4a368ce478 fix(TDI-48024): ResumeUtil performance issue. (#7771) 2022-07-19 10:31:11 +08:00
vyu-talend
92f3ef63e8 fix(TDI-47976):fix some potencial npe. (#7757) (#7787) 2022-07-19 10:21:27 +08:00
wang wei
1d8a178b8a fix(TDI-48221): tDBBulkExec (MYSQL) Failing with error (#7785) 2022-07-18 10:10:59 +08:00
313 changed files with 3431 additions and 746 deletions

View File

@@ -43,6 +43,7 @@
<plugin id="org.talend.migrationTool.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
<plugin id="org.talend.model.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
<plugin id="org.talend.repository.generic.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
<plugin id="org.talend.repository.json.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
<plugin id="org.talend.repository.items.importexport.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
<plugin id="org.talend.repository.items.importexport.ui.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
<plugin id="org.talend.repository.localprovider.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>

View File

@@ -58,6 +58,7 @@
boolean isLog4jEnabled = ("true").equals(ElementParameterParser.getValue(process, "__LOG4J_ACTIVATE__"));//log4j enable
boolean isLog4j2Enabled = ("true").equals(ElementParameterParser.getValue(process, "__LOG4J2_ACTIVATE__"));//log4j2 enable
boolean isLog4j1Enabled = !isLog4j2Enabled;//log4j1 enable
String MDC_CLASS = "org.slf4j.MDC";
boolean exist_tParallelize = false;
List<? extends INode> tParallelizeList = process.getNodesOfType("tParallelize");
@@ -322,6 +323,8 @@
}
<%}%>
private final static java.util.Properties jobInfo = new java.util.Properties();
public static void main(String[] args){
final <%=className %> <%=className %>Class = new <%=className %>();
@@ -335,6 +338,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) {
List<String> instanceList = ProcessUtils.getTestInstances(process);
@@ -515,9 +554,35 @@
org.apache.logging.log4j.core.config.Configurator.setLevel(org.apache.logging.log4j.LogManager.getRootLogger().getName(), log.getLevel());
<%}%>
}
getjobInfo();
log.info("TalendJob: '<%=codeGenArgument.getJobName()%>' - Start.");
<%}%>
<%if(isLog4j2Enabled) {%>
java.util.Set<Object> jobInfoKeys = jobInfo.keySet();
for(Object jobInfoKey: jobInfoKeys) {
<%=MDC_CLASS%>.put("_" + jobInfoKey.toString(), jobInfo.get(jobInfoKey).toString());
}
<%=MDC_CLASS%>.put("_pid", pid);
<%=MDC_CLASS%>.put("_rootPid", rootPid);
<%=MDC_CLASS%>.put("_fatherPid", fatherPid);
<%=MDC_CLASS%>.put("_projectName", projectName);
<%=MDC_CLASS%>.put("_startTimestamp",java.time.ZonedDateTime.now(java.time.ZoneOffset.UTC ).format( java.time.format.DateTimeFormatter.ISO_INSTANT ));
<%=MDC_CLASS%>.put("_jobRepositoryId","<%=process.getId() %>");
<%=MDC_CLASS%>.put("_compiledAtTimestamp","<%=java.time.ZonedDateTime.now(java.time.ZoneOffset.UTC ).format( java.time.format.DateTimeFormatter.ISO_INSTANT )%>");
java.lang.management.RuntimeMXBean mx = java.lang.management.ManagementFactory.getRuntimeMXBean();
String[] mxNameTable = mx.getName().split("@"); //$NON-NLS-1$
if (mxNameTable.length == 2) {
<%=MDC_CLASS%>.put("_systemPid", mxNameTable[0]);
} else {
<%=MDC_CLASS%>.put("_systemPid", String.valueOf(java.lang.Thread.currentThread().getId()));
}
<%
}%>
<%
INode jobCatcherNode = null;
@@ -642,14 +707,26 @@
pid = TalendString.getAsciiRandomString(6);
}
<%if(isLog4j2Enabled) {%>
<%=MDC_CLASS%>.put("_pid", pid);
<%}%>
if (rootPid==null) {
rootPid = pid;
}
<%if(isLog4j2Enabled) {%>
<%=MDC_CLASS%>.put("_rootPid", rootPid);
<%}%>
if (fatherPid==null) {
fatherPid = pid;
}else{
isChildJob = true;
}
<%if(isLog4j2Enabled) {%>
<%=MDC_CLASS%>.put("_fatherPid", fatherPid);
<%}%>
<%
if (stats) {
@@ -883,7 +960,12 @@
}
%>
//Resume: jobStart
resumeUtil.addLog("JOB_STARTED", "JOB:" + jobName, parent_part_launcher, Thread.currentThread().getId() + "", "","","","",resumeUtil.convertToJsonText(context,parametersToEncrypt));
resumeUtil.addLog("JOB_STARTED", "JOB:" + jobName, parent_part_launcher, Thread.currentThread().getId() + "", "","","","",resumeUtil.convertToJsonText(context,ContextProperties.class,parametersToEncrypt));
<%if(isLog4j2Enabled) {%>
<%=MDC_CLASS%>.put("_context", contextStr);
log.info("TalendJob: '<%=codeGenArgument.getJobName()%>' - Started.");
<%}%>
<%
if (stats) {
@@ -1298,6 +1380,15 @@ if (execStat) {
returnCode = errorCode.intValue();
}
resumeUtil.addLog("JOB_ENDED", "JOB:" + jobName, parent_part_launcher, Thread.currentThread().getId() + "", "","" + returnCode,"","","");
resumeUtil.flush();
<%if(isLog4j2Enabled) {%>
<%=MDC_CLASS%>.remove("_subJobName");
<%=MDC_CLASS%>.remove("_subJobPid");
<%=MDC_CLASS%>.remove("_systemPid");
log.info("TalendJob: '<%=codeGenArgument.getJobName()%>' - Finished - status: " + status + " returnCode: " + returnCode );
<%}%>
return returnCode;

View File

@@ -32,6 +32,8 @@
boolean stat = codeGenArgument.isStatistics();
boolean containsTPartitioner = subTree.getRootNode().getProcess().getNodesOfType("tPartitioner").size() > 0 ? true : false;
boolean isLog4jEnabled = ("true").equals(ElementParameterParser.getValue(subTree.getRootNode().getProcess(), "__LOG4J_ACTIVATE__"));
boolean isLog4j2Enabled = ("true").equals(ElementParameterParser.getValue(subTree.getRootNode().getProcess(), "__LOG4J2_ACTIVATE__"));//log4j2 enable
String MDC_CLASS = "org.slf4j.MDC";
%>
<%
@@ -1603,6 +1605,11 @@ public void <%=subTree.getName() %>Process(final java.util.Map<String, Object> g
globalMap.put("<%=subTree.getName() %>_SUBPROCESS_STATE", 0);
final boolean execStat = this.execStat;
<%if(isLog4j2Enabled) {%>
<%=MDC_CLASS%>.put("_subJobName", "<%=subTree.getName() %>");
<%=MDC_CLASS%>.put("_subJobPid", TalendString.getAsciiRandomString(6));
<%}%>
<%
boolean isParallelize = false;
for (INode node : subTree.getNodes()) {

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>
<licenses>
@@ -47,7 +47,7 @@
<dependency>
<groupId>com.ibm.mq</groupId>
<artifactId>com.ibm.mq.allclient</artifactId>
<version>9.2.4.0</version>
<version>9.2.5.0</version>
</dependency>
<dependency>
<groupId>org.talend.libraries</groupId>

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

@@ -54,11 +54,6 @@
<artifactId>poi</artifactId>
<version>4.1.2</version>
</dependency>
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-scratchpad</artifactId>
<version>4.1.2</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.poi/poi-ooxml -->
<dependency>
<groupId>org.apache.poi</groupId>

View File

@@ -4,7 +4,7 @@
<groupId>org.talend.components.lib</groupId>
<artifactId>talend-aws</artifactId>
<version>1.0</version>
<version>1.1</version>
<packaging>jar</packaging>
<name>talend-aws</name>
@@ -50,7 +50,7 @@
<dependency>
<groupId>com.amazonaws</groupId>
<artifactId>aws-java-sdk</artifactId>
<version>1.11.848</version>
<version>1.12.297</version>
</dependency>
</dependencies>
<build>

View File

@@ -65,11 +65,6 @@
<artifactId>poi</artifactId>
<version>4.1.2</version>
</dependency>
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-scratchpad</artifactId>
<version>4.1.2</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.poi/poi-ooxml -->
<dependency>
<groupId>org.apache.poi</groupId>

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>
@@ -64,7 +64,7 @@
<dependency>
<groupId>com.ibm.mq</groupId>
<artifactId>com.ibm.mq.allclient</artifactId>
<version>9.2.4.0</version>
<version>9.2.5.0</version>
</dependency>
<dependency>
<groupId>javax.resource</groupId>
@@ -74,7 +74,7 @@
<dependency>
<groupId>org.talend</groupId>
<artifactId>talendMQRFH2</artifactId>
<version>1.1.0-20220307</version>
<version>1.2.0-20220707</version>
</dependency>
<dependency>
<groupId>org.mockito</groupId>

View File

@@ -58,12 +58,31 @@
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-scratchpad</artifactId>
<version>4.1.2</version>
<version>5.2.2</version>
</dependency>
<dependency>
<groupId>ch.qos.reload4j</groupId>
<artifactId>reload4j</artifactId>
<version>1.2.19</version>
<groupId>commons-io</groupId>
<artifactId>commons-io</artifactId>
<version>2.8.0</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-api</artifactId>
<version>2.17.1</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-core</artifactId>
<version>2.17.1</version>
<scope>test</scope>
</dependency>
</dependencies>
<build>

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

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

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

@@ -228,8 +228,8 @@
<CODEGENERATION>
<IMPORTS>
<IMPORT NAME="aws-java-sdk-1.11.848.jar" MODULE="aws-java-sdk-1.11.848.jar"
MVN="mvn:com.amazonaws/aws-java-sdk/1.11.848"
<IMPORT NAME="aws-java-sdk-1.12.297.jar" MODULE="aws-java-sdk-1.12.297.jar"
MVN="mvn:com.amazonaws/aws-java-sdk/1.12.297"
REQUIRED="true" />
<IMPORT NAME="jackson-core-2.13.2.jar" MODULE="jackson-core-2.13.2.jar"
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.2"

View File

@@ -555,8 +555,8 @@
<CODEGENERATION>
<IMPORTS>
<IMPORT NAME="aws-java-sdk-1.11.848.jar" MODULE="aws-java-sdk-1.11.848.jar"
MVN="mvn:com.amazonaws/aws-java-sdk/1.11.848"
<IMPORT NAME="aws-java-sdk-1.12.297.jar" MODULE="aws-java-sdk-1.12.297.jar"
MVN="mvn:com.amazonaws/aws-java-sdk/1.12.297"
REQUIRED="true" />
<IMPORT NAME="jackson-core-2.13.2.jar" MODULE="jackson-core-2.13.2.jar"
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.2"

View File

@@ -285,8 +285,8 @@
<CODEGENERATION>
<IMPORTS>
<IMPORT NAME="aws-java-sdk-1.11.848.jar" MODULE="aws-java-sdk-1.11.848.jar"
MVN="mvn:com.amazonaws/aws-java-sdk/1.11.848"
<IMPORT NAME="aws-java-sdk-1.12.297.jar" MODULE="aws-java-sdk-1.12.297.jar"
MVN="mvn:com.amazonaws/aws-java-sdk/1.12.297"
REQUIRED="true" />
<IMPORT NAME="jackson-core-2.13.2.jar" MODULE="jackson-core-2.13.2.jar"
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.2"

View File

@@ -345,8 +345,8 @@
<CODEGENERATION>
<IMPORTS>
<IMPORT NAME="aws-java-sdk-1.11.848.jar" MODULE="aws-java-sdk-1.11.848.jar"
MVN="mvn:com.amazonaws/aws-java-sdk/1.11.848"
<IMPORT NAME="aws-java-sdk-1.12.297.jar" MODULE="aws-java-sdk-1.12.297.jar"
MVN="mvn:com.amazonaws/aws-java-sdk/1.12.297"
REQUIRED="true" />
<IMPORT NAME="jackson-core-2.13.2.jar" MODULE="jackson-core-2.13.2.jar"
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.2"

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

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

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

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

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

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

@@ -870,7 +870,7 @@
<IMPORT NAME="Driver-Oracle12c" MODULE="ojdbc7.jar" MVN="mvn:org.talend.libraries/ojdbc7/6.0.0" REQUIRED_IF="(DBTYPE=='DBORACLE') AND (DB_VERSION == 'ORACLE_12') AND (USE_EXISTING_CONNECTION == 'false')" />
<IMPORT NAME="ORACLE_18" MODULE="ojdbc8-19.3.0.0.jar" MVN="mvn:com.oracle.ojdbc/ojdbc8/19.3.0.0" REQUIRED_IF="(DBTYPE=='DBORACLE') AND (DB_VERSION == 'ORACLE_18') AND (USE_EXISTING_CONNECTION == 'false')" />
<IMPORT NAME="Driver-POSTGRESQL" MODULE="postgresql-8.4-703.jdbc4.jar" MVN="mvn:postgresql/postgresql/8.4-703.jdbc4" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((((DBTYPE=='POSTGRE') or (DBTYPE=='POSTGREPLUS')) AND (DB_POSTGRE_VERSION =='PRIOR_TO_V9')) or (DBTYPE=='GREENPLUM'))" />
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.25.jar" MVN="mvn:org.postgresql/postgresql/42.2.25" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (((DBTYPE=='POSTGRE') or (DBTYPE=='POSTGREPLUS')) AND (DB_POSTGRE_VERSION =='V9_X'))" />
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.26.jar" MVN="mvn:org.postgresql/postgresql/42.2.26" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (((DBTYPE=='POSTGRE') or (DBTYPE=='POSTGREPLUS')) AND (DB_POSTGRE_VERSION =='V9_X'))" />
<IMPORT NAME="Driver-FIREBIRD" MODULE="jaybird-full-2.1.1.jar" MVN="mvn:org.talend.libraries/jaybird-full-2.1.1/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.jdbc.firebird/lib/jaybird-full-2.1.1.jar" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='FIREBIRD')" />
<IMPORT NAME="Driver-HSQLDb" MODULE="hsqldb.jar" MVN="mvn:org.talend.libraries/hsqldb/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.jdbc.hsql/lib/hsqldb.jar" REQUIRED_IF="DBTYPE=='HSQLDB'"/>
<IMPORT NAME="Driver-INFORMIX-JDBC" MODULE="ifxjdbc.jar" MVN="mvn:org.talend.libraries/ifxjdbc/6.0.0" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='INFORMIX')" />

View File

@@ -175,7 +175,7 @@ while(<%=inputColumn%>_iterator_<%=cid %>.hasNext()){
}
}
if (sb_<%=cid %> != null)
denormalize_row_<%=cid %>.<%=inputColumn %> = sb_<%=cid %>.toString();
sb_<%=cid %> = null;

View File

@@ -189,8 +189,8 @@
<CODEGENERATION>
<IMPORTS>
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.25.jar" MVN="mvn:org.postgresql/postgresql/42.2.25" REQUIRED_IF="DB_VERSION =='V9_X'" />
<IMPORT NAME="Driver-Postgres" MODULE="postgresql-8.4-703.jdbc4.jar" MVN="mvn:postgresql/postgresql/8.4-703.jdbc4" REQUIRED_IF="DB_VERSION =='PRIOR_TO_V9'" />
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.26.jar" MVN="mvn:org.postgresql/postgresql/42.2.26" REQUIRED_IF="DB_VERSION =='V9_X' AND (USE_EXISTING_CONNECTION == 'false')" />
<IMPORT NAME="Driver-Postgres" MODULE="postgresql-8.4-703.jdbc4.jar" MVN="mvn:postgresql/postgresql/8.4-703.jdbc4" REQUIRED_IF="DB_VERSION =='PRIOR_TO_V9' AND (USE_EXISTING_CONNECTION == 'false')" />
</IMPORTS>
</CODEGENERATION>

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

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

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

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

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

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

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

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

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

View File

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

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

@@ -194,7 +194,7 @@
<IMPORT NAME="poi-ooxml-schemas" MODULE="poi-ooxml-schemas-4.1.2-20200903124306_modified_talend.jar" MVN="mvn:org.apache.poi/poi-ooxml-schemas/4.1.2-20200903124306_modified_talend" UrlPath="platform:/plugin/org.talend.libraries.excel/lib/poi-ooxml-schemas-4.1.2-20200903124306_modified_talend.jar" REQUIRED_IF="(VERSION_2007 == 'true')" />
<IMPORT NAME="xmlbeans" MODULE="xmlbeans-3.1.0.jar" MVN="mvn:org.apache.xmlbeans/xmlbeans/3.1.0" REQUIRED_IF="(VERSION_2007 == 'true')" />
<IMPORT NAME="poi-scratchpad" MODULE="poi-scratchpad-4.1.2-20200903124306_modified_talend.jar" MVN="mvn:org.apache.poi/poi-scratchpad/4.1.2-20200903124306_modified_talend" UrlPath="platform:/plugin/org.talend.libraries.excel/lib/poi-scratchpad-4.1.2-20200903124306_modified_talend.jar" REQUIRED_IF="(VERSION_2007 == 'true')" />
<IMPORT NAME="poi-scratchpad" MODULE="poi-scratchpad-5.2.2.jar" MVN="mvn:org.apache.poi/poi-scratchpad/5.2.2" UrlPath="platform:/plugin/org.talend.libraries.excel/lib/poi-scratchpad-5.2.2.jar" REQUIRED_IF="(VERSION_2007 == 'true')" />
</IMPORTS>
</CODEGENERATION>

View File

@@ -85,7 +85,7 @@
<CODEGENERATION>
<IMPORTS>
<IMPORT NAME="JavaMail" MODULE="javax.mail-1.6.2.jar" MVN="mvn:com.sun.mail/javax.mail/1.6.2" REQUIRED_IF="(MAIL_TYPE == 'MIME')" />
<IMPORT NAME="jakartaMail" MODULE="jakarta.mail-1.6.7.jar" MVN="mvn:com.sun.mail/jakarta.mail/1.6.7" REQUIRED_IF="(MAIL_TYPE == 'MIME')" />
<IMPORT NAME="JAF" MODULE="activation.jar" MVN="mvn:org.talend.libraries/activation/6.0.0" REQUIRED_IF="(MAIL_TYPE == 'MIME')" />
<IMPORT NAME="poi" MODULE="poi-4.1.2-20200903124306_modified_talend.jar" MVN="mvn:org.apache.poi/poi/4.1.2-20200903124306_modified_talend" UrlPath="platform:/plugin/org.talend.libraries.excel/lib/poi-4.1.2-20200903124306_modified_talend.jar" REQUIRED_IF="(MAIL_TYPE == 'MSG')" />
@@ -94,7 +94,8 @@
<IMPORT NAME="commons-collections4" MODULE="commons-collections4-4.4.jar" MVN="mvn:org.apache.commons/commons-collections4/4.4" REQUIRED_IF="(MAIL_TYPE == 'MSG')" />
<IMPORT NAME="commons-math3" MODULE="commons-math3-3.6.1.jar" MVN="mvn:org.apache.commons/commons-math3/3.6.1" REQUIRED_IF="(MAIL_TYPE == 'MSG')" />
<IMPORT NAME="poi-scratchpad" MODULE="poi-scratchpad-4.1.2-20200903124306_modified_talend.jar" MVN="mvn:org.apache.poi/poi-scratchpad/4.1.2-20200903124306_modified_talend" UrlPath="platform:/plugin/org.talend.libraries.excel/lib/poi-scratchpad-4.1.2-20200903124306_modified_talend.jar" REQUIRED_IF="(MAIL_TYPE == 'MSG')" />
<IMPORT NAME="poi-scratchpad" MODULE="poi-scratchpad-5.2.2.jar" MVN="mvn:org.apache.poi/poi-scratchpad/5.2.2" UrlPath="platform:/plugin/org.talend.libraries.excel/lib/poi-scratchpad-5.2.2.jar" REQUIRED_IF="(MAIL_TYPE == 'MSG')" />
<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="(MAIL_TYPE == 'MSG')" />
<IMPORT NAME="talendMsgMailUtil" MODULE="talendMsgMailUtil-1.2-20201022.jar" MVN="mvn:org.talend.components/talendMsgMailUtil/1.2-20201022" UrlPath="platform:/plugin/org.talend.libraries.excel/lib/talendMsgMailUtil-1.2-20201022.jar" REQUIRED_IF="(MAIL_TYPE == 'MSG')" />
<IMPORT NAME="reload4j-1.2.19" MODULE="reload4j-1.2.19.jar" MVN="mvn:ch.qos.reload4j/reload4j/1.2.19" REQUIRED_IF="(MAIL_TYPE == 'MSG')" />

View File

@@ -592,7 +592,7 @@
}
}
%>
}
}//PositionalUtil end
PositionalUtil_<%=cid%> positionalUtil_<%=cid%>=new PositionalUtil_<%=cid%>();
positionalUtil_<%=cid%>.setUseStar(useStar_<%=cid%>);
@@ -809,6 +809,10 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
<%
}
%>
resourceMap.put("byteReader_<%=cid %>", byteReader_<%=cid %>);
resourceMap.put("reader_<%=cid %>", reader_<%=cid %>);
<%
if("BYTES".equals(patternUnits)&&(("").equals(rowSeparator) || ("\"\"").equals(rowSeparator))){
%>
@@ -858,6 +862,10 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
<%
}
%>
resourceMap.put("byteReader_<%=cid %>", byteReader_<%=cid %>);
resourceMap.put("reader_<%=cid %>", reader_<%=cid %>);
<%
if("BYTES".equals(patternUnits)&&(("").equals(rowSeparator) || ("\"\"").equals(rowSeparator)) ){
%>

View File

@@ -37,6 +37,7 @@ if(!(filename_<%=cid %> instanceof java.io.InputStream)){
}
}
globalMap.put("<%=cid %>_NB_LINE",nb_line_<%=cid %>);
resourceMap.put("finish_<%=cid%>", true);
<%
}
}

View File

@@ -0,0 +1,28 @@
<%@ jet
imports="
org.talend.core.model.process.INode
org.talend.core.model.metadata.IMetadataTable
org.talend.designer.codegen.config.CodeGeneratorArgument
org.talend.core.model.process.ElementParameterParser
java.util.List
"
%>
<%@ include file="../templates/Log4j/Log4jFileUtil.javajet"%>
<%
CodeGeneratorArgument codeGenArgument = (CodeGeneratorArgument) argument;
INode node = (INode)codeGenArgument.getArgument();
String cid = node.getUniqueName();
%>
if(resourceMap.get("finish_<%=cid%>") == null){
org.talend.fileprocess.delimited.RowParser reader_<%=cid %> = (org.talend.fileprocess.delimited.RowParser)resourceMap.get("reader_<%=cid %>");
org.talend.fileprocess.delimited.RowParserByByte byteReader_<%=cid %> = (org.talend.fileprocess.delimited.RowParserByByte)resourceMap.get("byteReader_<%=cid %>");
if(reader_<%=cid %>!=null) {
reader_<%=cid %>.close();
}
if(byteReader_<%=cid %>!=null) {
byteReader_<%=cid %>.close();
}
}

View File

@@ -82,7 +82,7 @@ class IgnoreDTDEntityResolver_<%=cid%> implements org.xml.sax.EntityResolver {
// *** Xerces *** //
if(("Xerces").equals(mode)){
%>
class TalendPrefixResolver_<%=cid%> implements org.apache.xml.utils.PrefixResolver {
class TalendPrefixResolver_<%=cid%> {
private java.util.Map<String, String> map = new java.util.HashMap<String, String>();
@@ -92,26 +92,14 @@ class TalendPrefixResolver_<%=cid%> implements org.apache.xml.utils.PrefixResolv
return defualtNSPath;
}
public String getBaseIdentifier() {
return null;
}
public String getNamespaceForPrefix(String prefix) {
public String getNamespaceURI(String prefix) {
if (("xml").equals(prefix)) {
return org.apache.xml.utils.Constants.S_XMLNAMESPACEURI;
return "http://www.w3.org/XML/1998/namespace";
} else {
return map.get(prefix);
}
}
public String getNamespaceForPrefix(String prefix, org.w3c.dom.Node context) {
return getNamespaceForPrefix(prefix);
}
public boolean handlesNullPrefixes() {
return false;
}
public boolean countNSMap(org.w3c.dom.Node el) {
boolean hasDefaultPrefix = false;
if (el.getNodeType() == org.w3c.dom.Node.ELEMENT_NODE) {
@@ -149,9 +137,10 @@ class TalendPrefixResolver_<%=cid%> implements org.apache.xml.utils.PrefixResolv
class XML_API_<%=cid%>{
javax.xml.xpath.XPath xpathEvaluator = new net.sf.saxon.xpath.XPathFactoryImpl().newXPath();
String loopPath = null;
boolean hasDefaultNS = false;
TalendPrefixResolver_<%=cid%> pr = null;
public boolean isDefNull(org.w3c.dom.Node node) throws javax.xml.transform.TransformerException {
if (node != null && node.getNodeType() == org.w3c.dom.Node.ELEMENT_NODE) {
@@ -174,37 +163,45 @@ class XML_API_<%=cid%>{
private final org.talend.xpath.XPathUtil util = new org.talend.xpath.XPathUtil();
public void initXPath(org.w3c.dom.Node root){
pr= new TalendPrefixResolver_<%=cid%>();
final TalendPrefixResolver_<%=cid%> pr = new TalendPrefixResolver_<%=cid%>();
hasDefaultNS = pr.countNSMap(root);
util.setDefaultNSPath(pr.getDefualtNSPath());
xpathEvaluator.setNamespaceContext(new javax.xml.namespace.NamespaceContext() {
@Override
public String getNamespaceURI(String prefix) {
return pr.getNamespaceURI(prefix);
}
@Override
public String getPrefix(String namespaceURI) {
return null;
}
@Override
public java.util.Iterator getPrefixes(String namespaceURI) {
return null;
}
});
}
//==============add for feature 10753 start================================
org.apache.xpath.objects.XObject obj = null;
public int getNodeType(org.w3c.dom.Node node, String xpath) throws javax.xml.transform.TransformerException{
obj = org.apache.xpath.XPathAPI.eval(node, util.addDefaultNSPrefix(xpath,loopPath), pr);
return obj.getType();
public String getNodeString(org.w3c.dom.Node node, String xpath) throws javax.xml.xpath.XPathExpressionException {
javax.xml.xpath.XPathExpression expression = xpathEvaluator.compile(util.addDefaultNSPrefix(xpath,loopPath));
return expression.evaluate(node);
}
public String getNodeString(org.w3c.dom.Node node, String xpath) throws javax.xml.transform.TransformerException{
if(obj==null){
obj = org.apache.xpath.XPathAPI.eval(node, util.addDefaultNSPrefix(xpath,loopPath), pr);
}
return obj.str();
}
public org.w3c.dom.Node getSingleNode(org.w3c.dom.Node node, String xpath) throws javax.xml.transform.TransformerException {
if(obj==null){
obj = org.apache.xpath.XPathAPI.eval(node, util.addDefaultNSPrefix(xpath,loopPath), pr);
}
return obj.nodelist().item(0);
public org.w3c.dom.Node getSingleNode(org.w3c.dom.Node node, String xpath) throws javax.xml.xpath.XPathExpressionException {
javax.xml.xpath.XPathExpression expression = xpathEvaluator.compile(util.addDefaultNSPrefix(xpath,loopPath));
Object result = expression.evaluate(node, javax.xml.xpath.XPathConstants.NODESET);
return org.w3c.dom.NodeList.class.cast(result).item(0);
}
//=====================end=================================================
public org.w3c.dom.NodeList getNodeList(org.w3c.dom.Node node, String xpath) throws javax.xml.transform.TransformerException {
org.apache.xpath.objects.XObject obj = org.apache.xpath.XPathAPI.eval(node, util.addDefaultNSPrefix(xpath), pr);
return obj.nodelist();
public org.w3c.dom.NodeList getNodeList(org.w3c.dom.Node node, String xpath) throws javax.xml.xpath.XPathExpressionException {
javax.xml.xpath.XPathExpression expression = xpathEvaluator.compile(util.addDefaultNSPrefix(xpath));
Object result = expression.evaluate(node, javax.xml.xpath.XPathConstants.NODESET);
return org.w3c.dom.NodeList.class.cast(result);
}
}
@@ -813,7 +810,7 @@ if ((metadatas!=null)&&(metadatas.size()>0)) {
String nodeCheck = mapping.get(i).get("NODECHECK");
if(("Xerces").equals(mode)){
%>
if(xml_api_<%=cid%>.getNodeType(tmp_<%=cid %>,<%=query%>)==org.apache.xpath.objects.XObject.CLASS_NODESET){
try {
node_<%=cid%> = xml_api_<%=cid%>.getSingleNode(tmp_<%=cid %>,<%=query%>);
<%
if("true".equals(useSeparator)){
@@ -830,7 +827,7 @@ if ((metadatas!=null)&&(metadatas.size()>0)) {
<%
}
%>
}else{
} catch (javax.xml.xpath.XPathExpressionException xee) {
node_<%=cid %> = tmp_<%=cid %>;
str_<%=cid %> = xml_api_<%=cid%>.getNodeString(tmp_<%=cid %>,<%=query%>);
}

View File

@@ -144,7 +144,7 @@
REQUIRED_IF="(GENERATION_MODE == 'XERCES') OR (GENERATION_MODE == 'SAX')" BundleID="" />
<IMPORT NAME="xml-apis-1.4.01" MODULE="xml-apis-1.4.01.jar" MVN="mvn:xml-apis/xml-apis/1.4.01"
REQUIRED_IF="(GENERATION_MODE == 'XERCES') OR (GENERATION_MODE == 'SAX')" BundleID="" />
<IMPORT NAME="Java_xalan" MODULE="xalan-2.7.2.jar" MVN="mvn:xalan/xalan/2.7.2" REQUIRED_IF="GENERATION_MODE == 'XERCES'" BundleID="" />
<IMPORT NAME="SAXON-HE" MODULE="Saxon-HE-10.6.jar" MVN="mvn:net.sf.saxon/Saxon-HE/10.6" REQUIRED_IF="GENERATION_MODE == 'XERCES'" BundleID="" />
<IMPORT NAME="Java_talendSAX" MODULE="TalendSAX-1.0.1-20190326.jar" MVN="mvn:org.talend.libraries/TalendSAX/1.0.1-20190326" UrlPath="platform:/plugin/org.talend.libraries.xml/lib/TalendSAX-1.0.1-20190326.jar"
REQUIRED_IF="GENERATION_MODE == 'SAX'" />
<IMPORT NAME="xpathutil" MODULE="xpathutil-1.0.0.jar" MVN="mvn:org.talend.libraries/xpathutil-1.0.0/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.xml/lib/xpathutil-1.0.0.jar"

View File

@@ -487,7 +487,9 @@ if(("false").equals(ElementParameterParser.getValue(node,"__CSV_OPTION__"))) {
new java.io.FileOutputStream(fullName_<%=cid%> + splitedFileNo_<%=cid%> + extension_<%=cid%>, <%=isAppend%>),<%=encoding%>));
<%
}
%>
resourceMap.put("out_<%=cid%>", out<%=cid%>);
<%
if(isIncludeHeader && !hasDynamic){
%>
<%
@@ -588,7 +590,10 @@ if(("false").equals(ElementParameterParser.getValue(node,"__CSV_OPTION__"))) {
out<%=cid%> = new <%=writerClass%>(writer_<%=cid%>);
<%
}
%>
resourceMap.put("out_<%=cid%>", out<%=cid%>);
resourceMap.put("writer_<%=cid%>", writer_<%=cid%>);
<%
if(isIncludeHeader && !hasDynamic){
List<IMetadataColumn> columns = metadata.getListColumns();
int sizeColumns = columns.size();
@@ -904,6 +909,14 @@ if(("false").equals(ElementParameterParser.getValue(node,"__CSV_OPTION__"))) {
<%
}
}
%>
resourceMap.put("CsvWriter_<%=cid%>", CsvWriter<%=cid%>);
<%
if(isInRowMode) {
%>
resourceMap.put("out_<%=cid%>", out<%=cid%>);
<%
}
if(!useOSLineSeparator) {
%>
@@ -1053,6 +1066,20 @@ if(("false").equals(ElementParameterParser.getValue(node,"__CSV_OPTION__"))) {
}
}
%>
resourceMap.put("CsvWriter_<%=cid%>", CsvWriter<%=cid%>);
<%
if(isInRowMode){
%>
resourceMap.put("out_<%=cid%>", out<%=cid%>);
resourceMap.put("outWriter_<%=cid%>", outWriter_<%=cid%>);
<%
}else{
%>
resourceMap.put("bufferWriter_<%=cid%>", bufferWriter_<%=cid%>);
resourceMap.put("outWriter_<%=cid%>", outWriter_<%=cid%>);
<%
}
if(!useOSLineSeparator) {
%>
if(csvSettings_<%=cid%>.isUseCRLFRecordDelimiter()) {
@@ -1104,51 +1131,10 @@ if(("false").equals(ElementParameterParser.getValue(node,"__CSV_OPTION__"))) {
}
}
}
%>
<%
// ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
}
%>
<%
if(("false").equals(ElementParameterParser.getValue(node,"__CSV_OPTION__"))) {
if(!useStream){
%>
resourceMap.put("out_<%=cid%>", out<%=cid%>);
<%
}else{
%>
resourceMap.put("out_<%=cid%>", out<%=cid%>);
resourceMap.put("writer_<%=cid%>", writer_<%=cid%>);
<%
}
}else{//the following is the tFileOutputCSV component
%>
resourceMap.put("CsvWriter_<%=cid%>", CsvWriter<%=cid%>);
<%
if(!useStream){
if(isInRowMode){
%>
resourceMap.put("out_<%=cid%>", out<%=cid%>);
<%
}
}else{
if(isInRowMode){
%>
resourceMap.put("out_<%=cid%>", out<%=cid%>);
resourceMap.put("outWriter_<%=cid%>", outWriter_<%=cid%>);
<%
}else{
%>
resourceMap.put("bufferWriter_<%=cid%>", bufferWriter_<%=cid%>);
resourceMap.put("outWriter_<%=cid%>", outWriter_<%=cid%>);
<%
}
}
}
%>
resourceMap.put("nb_line_<%=cid%>", nb_line_<%=cid%>);
<%if(!useStream && ("true").equals(ElementParameterParser.getValue(node, "__DELETE_EMPTYFILE__"))){%>
resourceMap.put("isFileGenerated_<%=cid%>", isFileGenerated_<%=cid%>);

View File

@@ -270,6 +270,7 @@ if(("false").equals(ElementParameterParser.getValue(node,"__CSV_OPTION__"))) {
<%}%>
out<%=cid %> = new <%=isInRowMode?"routines.system.BufferedOutput":"java.io.BufferedWriter"%>(new java.io.OutputStreamWriter(
new java.io.FileOutputStream(fullName_<%=cid%> + splitedFileNo_<%=cid%> + extension_<%=cid%>, <%= isAppend%>),<%= encoding%>));
resourceMap.put("out_<%=cid%>", out<%=cid %>);
<%
if(isIncludeHeader){
%>
@@ -643,12 +644,15 @@ if(("false").equals(ElementParameterParser.getValue(node,"__CSV_OPTION__"))) {
strWriter<%=cid%> = new java.io.StringWriter();
CsvWriter<%=cid%> = new com.talend.csv.CSVWriter(strWriter<%=cid%>);
CsvWriter<%=cid%>.setSeparator(csvSettings_<%=cid %>.getFieldDelim());
resourceMap.put("out_<%=cid%>", out<%=cid%>);
<%}else{%>
CsvWriter<%=cid%> = new com.talend.csv.CSVWriter(new java.io.BufferedWriter(new java.io.OutputStreamWriter(
new java.io.FileOutputStream(fullName_<%=cid%> + splitedFileNo_<%=cid%> + extension_<%=cid%>, <%=isAppend%>),<%=encoding%>)));
CsvWriter<%=cid%>.setSeparator(csvSettings_<%=cid %>.getFieldDelim());
<%}%>
resourceMap.put("CsvWriter_<%=cid%>", CsvWriter<%=cid%>);
<%
if(!useOSLineSeparator) {
%>

View File

@@ -257,7 +257,7 @@
<IMPORT NAME="poi-ooxml-schemas" MODULE="poi-ooxml-schemas-4.1.2-20200903124306_modified_talend.jar" MVN="mvn:org.apache.poi/poi-ooxml-schemas/4.1.2-20200903124306_modified_talend" UrlPath="platform:/plugin/org.talend.libraries.excel/lib/poi-ooxml-schemas-4.1.2-20200903124306_modified_talend.jar" REQUIRED_IF="(VERSION_2007 == 'true')" />
<IMPORT NAME="xmlbeans" MODULE="xmlbeans-3.1.0.jar" MVN="mvn:org.apache.xmlbeans/xmlbeans/3.1.0" REQUIRED_IF="(VERSION_2007 == 'true')" />
<IMPORT NAME="poi-scratchpad" MODULE="poi-scratchpad-4.1.2-20200903124306_modified_talend.jar" MVN="mvn:org.apache.poi/poi-scratchpad/4.1.2-20200903124306_modified_talend" UrlPath="platform:/plugin/org.talend.libraries.excel/lib/poi-scratchpad-4.1.2-20200903124306_modified_talend.jar" REQUIRED_IF="(VERSION_2007 == 'true')" />
<IMPORT NAME="poi-scratchpad" MODULE="poi-scratchpad-5.2.2.jar" MVN="mvn:org.apache.poi/poi-scratchpad/5.2.2" UrlPath="platform:/plugin/org.talend.libraries.excel/lib/poi-scratchpad-5.2.2.jar" REQUIRED_IF="(VERSION_2007 == 'true')" />
</IMPORTS>
</CODEGENERATION>

View File

@@ -34,6 +34,8 @@
for(IConnection incomingConn : incomingConns) {
if(incomingConn.getLineStyle().hasConnectionCategory(IConnectionCategory.DATA)) {
%>
java.io.InputStream fis_<%=cid%> = null;
java.io.FileOutputStream fos_<%=cid%> = null;
try {
Object content_<%=cid%> = <%=incomingConn.getName()%>.<%=columnList.get(0).getLabel()%>;
@@ -48,8 +50,8 @@
} else if(content_<%=cid%> instanceof byte[]) {
org.apache.commons.io.FileUtils.writeByteArrayToFile(file_<%=cid%>, (byte[])content_<%=cid%>);
} else if(content_<%=cid%> instanceof java.io.InputStream) {
java.io.InputStream fis_<%=cid%> = (java.io.InputStream) content_<%=cid%>;
java.io.FileOutputStream fos_<%=cid%> = new java.io.FileOutputStream(file_<%=cid%>);
fis_<%=cid%> = (java.io.InputStream) content_<%=cid%>;
fos_<%=cid%> = new java.io.FileOutputStream(file_<%=cid%>);
byte[] buffer_<%=cid%> = new byte[65536];
int nb_<%=cid%> = 0;
while (true) {
@@ -59,8 +61,6 @@
}
fos_<%=cid%>.write(buffer_<%=cid%>, 0, nb_<%=cid%>);
}
fis_<%=cid%>.close();
fos_<%=cid%>.close();
} else {
org.apache.commons.io.FileUtils.writeStringToFile(file_<%=cid%>, content_<%=cid%>.toString(), <%=encoding%>);
}
@@ -83,6 +83,33 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e_<%=cid%>.getMessage());
}
}
%>
} finally {
if(fis_<%=cid%> != null) {
try {
fis_<%=cid%>.close();
} catch (java.io.IOException fisIOE_<%=cid%>) {
<%
if(isLog4jEnabled) {
%>
log.warn("<%=cid%> - " + fisIOE_<%=cid%>.getMessage());
<%
}
%>
}
}
if(fos_<%=cid%> != null) {
try {
fos_<%=cid%>.close();
} catch (java.io.IOException fosIOE_<%=cid%>) {
<%
if(isLog4jEnabled) {
%>
log.warn("<%=cid%> - " + fosIOE_<%=cid%>.getMessage());
<%
}
%>
}
}
}
<%
}

View File

@@ -193,7 +193,7 @@
<!-- Transitive dependencies of google-cloud-storage -->
<IMPORT NAME="google-cloud-core-1.93.4.jar" MODULE="google-cloud-core-1.93.4.jar" MVN="mvn:com.google.cloud/google-cloud-core/1.93.4" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="google-api-client-1.31.1.jar" MODULE="google-api-client-1.31.1.jar" MVN="mvn:com.google.api-client/google-api-client/1.31.1" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="gson-2.8.9" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="api-common-1.6.0" MODULE="api-common-1.6.0.jar" MVN="mvn:com.google.api/api-common/1.6.0" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />

View File

@@ -22,7 +22,7 @@ PROJECT_ID.NAME=\u5DE5\u7A0B ID
SECRET_KEY.NAME=\u5BC6\u94A5
SPECIAL_CONFIGUER.NAME=\u4F4D\u7F6E\u53CA\u8BBF\u95EE\u63A7\u5236
USE_EXISTING_CONNECTION.NAME=\u4F7F\u7528\u4E00\u4E2A\u73B0\u6709\u8FDE\u63A5
AUTH_TYPE.NAME=\u7528\u6237\u540D\u548C\u5BC6\u7801\u7C7B\u578B
AUTH_TYPE.NAME=\u51ED\u8BC1\u7C7B\u578B
AUTH_TYPE.ITEM.SERVICE_ACCOUNT=\u670D\u52A1\u5E10\u6237
AUTH_TYPE.ITEM.TOKEN=OAuth \u8BBF\u95EE\u4EE4\u724C
GS_ACCESS_TOKEN.NAME=OAuth \u8BBF\u95EE\u4EE4\u724C

View File

@@ -145,7 +145,7 @@
<!-- Transitive dependencies of google-cloud-storage -->
<IMPORT NAME="google-cloud-core-1.93.4.jar" MODULE="google-cloud-core-1.93.4.jar" MVN="mvn:com.google.cloud/google-cloud-core/1.93.4" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="google-api-client-1.31.1.jar" MODULE="google-api-client-1.31.1.jar" MVN="mvn:com.google.api-client/google-api-client/1.31.1" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="gson-2.8.9" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="api-common-1.6.0" MODULE="api-common-1.6.0.jar" MVN="mvn:com.google.api/api-common/1.6.0" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />

View File

@@ -7,7 +7,7 @@ HELP=org.talend.help.tGSBucketDelete
LONG_NAME=\u5728Google\u5B58\u50A8\u7A7A\u95F4\u4E2D\u5220\u9664\u4E00\u4E2Abucket
SECRET_KEY.NAME=\u5BC6\u94A5
USE_EXISTING_CONNECTION.NAME=\u4F7F\u7528\u4E00\u4E2A\u73B0\u6709\u8FDE\u63A5
AUTH_TYPE.NAME=\u7528\u6237\u540D\u548C\u5BC6\u7801\u7C7B\u578B
AUTH_TYPE.NAME=\u51ED\u8BC1\u7C7B\u578B
AUTH_TYPE.ITEM.SERVICE_ACCOUNT=\u670D\u52A1\u5E10\u6237
AUTH_TYPE.ITEM.TOKEN=OAuth \u8BBF\u95EE\u4EE4\u724C
GS_ACCESS_TOKEN.NAME=OAuth \u8BBF\u95EE\u4EE4\u724C

View File

@@ -145,7 +145,7 @@
<!-- Transitive dependencies of google-cloud-storage -->
<IMPORT NAME="google-cloud-core-1.93.4.jar" MODULE="google-cloud-core-1.93.4.jar" MVN="mvn:com.google.cloud/google-cloud-core/1.93.4" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="google-api-client-1.31.1.jar" MODULE="google-api-client-1.31.1.jar" MVN="mvn:com.google.api-client/google-api-client/1.31.1" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="gson-2.8.9" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="api-common-1.6.0" MODULE="api-common-1.6.0.jar" MVN="mvn:com.google.api/api-common/1.6.0" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />

View File

@@ -9,7 +9,7 @@ HELP=org.talend.help.tGSBucketExist
LONG_NAME=\u68C0\u67E5 Google \u5B58\u50A8\u4E2D\u662F\u5426\u5B58\u5728\u7279\u5B9A\u7684\u6876\u540D\u79F0
SECRET_KEY.NAME=\u5BC6\u94A5
USE_EXISTING_CONNECTION.NAME=\u4F7F\u7528\u4E00\u4E2A\u73B0\u6709\u8FDE\u63A5
AUTH_TYPE.NAME=\u7528\u6237\u540D\u548C\u5BC6\u7801\u7C7B\u578B
AUTH_TYPE.NAME=\u51ED\u8BC1\u7C7B\u578B
AUTH_TYPE.ITEM.SERVICE_ACCOUNT=\u670D\u52A1\u5E10\u6237
AUTH_TYPE.ITEM.TOKEN=OAuth \u8BBF\u95EE\u4EE4\u724C
GS_ACCESS_TOKEN.NAME=OAuth \u8BBF\u95EE\u4EE4\u724C

View File

@@ -130,7 +130,7 @@
<!-- Transitive dependencies of google-cloud-storage -->
<IMPORT NAME="google-cloud-core-1.93.4.jar" MODULE="google-cloud-core-1.93.4.jar" MVN="mvn:com.google.cloud/google-cloud-core/1.93.4" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="google-api-client-1.31.1.jar" MODULE="google-api-client-1.31.1.jar" MVN="mvn:com.google.api-client/google-api-client/1.31.1" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="gson-2.8.9" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="api-common-1.6.0" MODULE="api-common-1.6.0.jar" MVN="mvn:com.google.api/api-common/1.6.0" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />

View File

@@ -9,7 +9,7 @@ PROJECT_ID.NAME=\u5DE5\u7A0B ID
SECRET_KEY.NAME=\u5BC6\u94A5
SPECIFY_PROJECT.NAME=\u6307\u5B9A\u5DE5\u7A0B ID
USE_EXISTING_CONNECTION.NAME=\u4F7F\u7528\u4E00\u4E2A\u73B0\u6709\u8FDE\u63A5
AUTH_TYPE.NAME=\u7528\u6237\u540D\u548C\u5BC6\u7801\u7C7B\u578B
AUTH_TYPE.NAME=\u51ED\u8BC1\u7C7B\u578B
AUTH_TYPE.ITEM.SERVICE_ACCOUNT=\u670D\u52A1\u5E10\u6237
AUTH_TYPE.ITEM.TOKEN=OAuth \u8BBF\u95EE\u4EE4\u724C
GS_ACCESS_TOKEN.NAME=OAuth \u8BBF\u95EE\u4EE4\u724C

View File

@@ -103,7 +103,7 @@
<!-- Transitive dependencies of google-cloud-storage -->
<IMPORT NAME="google-cloud-core-1.93.4.jar" MODULE="google-cloud-core-1.93.4.jar" MVN="mvn:com.google.cloud/google-cloud-core/1.93.4" REQUIRED_IF="(AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
<IMPORT NAME="google-api-client-1.31.1.jar" MODULE="google-api-client-1.31.1.jar" MVN="mvn:com.google.api-client/google-api-client/1.31.1" REQUIRED_IF="(AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
<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_IF="(AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
<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_IF="(AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
<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 == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
<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_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
<IMPORT NAME="api-common-1.6.0" MODULE="api-common-1.6.0.jar" MVN="mvn:com.google.api/api-common/1.6.0" REQUIRED_IF="(AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />

View File

@@ -2,7 +2,7 @@ ACCESS_KEY.NAME=\u8BBF\u95EE\u5BC6\u94A5
HELP=org.talend.help.tGSConnection
LONG_NAME=\u521B\u5EFA\u5230 Google \u5B58\u50A8\u670D\u52A1\u7684\u8FDE\u63A5
SECRET_KEY.NAME=\u5BC6\u94A5
AUTH_TYPE.NAME=\u7528\u6237\u540D\u548C\u5BC6\u7801\u7C7B\u578B
AUTH_TYPE.NAME=\u51ED\u8BC1\u7C7B\u578B
AUTH_TYPE.ITEM.SERVICE_ACCOUNT=\u670D\u52A1\u5E10\u6237
AUTH_TYPE.ITEM.TOKEN=OAuth \u8BBF\u95EE\u4EE4\u724C
SERVICE_ACCOUNT_KEY.NAME=\u670D\u52A1\u5E10\u6237\u5BC6\u94A5

View File

@@ -223,7 +223,7 @@
<!-- Transitive dependencies of google-cloud-storage -->
<IMPORT NAME="google-cloud-core-1.93.4.jar" MODULE="google-cloud-core-1.93.4.jar" MVN="mvn:com.google.cloud/google-cloud-core/1.93.4" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="google-api-client-1.31.1.jar" MODULE="google-api-client-1.31.1.jar" MVN="mvn:com.google.api-client/google-api-client/1.31.1" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="gson-2.8.9" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="api-common-1.6.0" MODULE="api-common-1.6.0.jar" MVN="mvn:com.google.api/api-common/1.6.0" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />

View File

@@ -40,7 +40,7 @@
}
if ("USER_ACCOUNT_HMAC".equals(authType)){
%>
%>
org.jets3t.service.impl.rest.httpclient.GoogleStorageService service_<%=cid%> = null;
try {
<%
@@ -53,13 +53,10 @@ if ("USER_ACCOUNT_HMAC".equals(authType)){
log.info("<%=cid%> - Get an free connection from " + "<%=connection%>" + ".");
<%
}
}else{
%>
<%
} else {
String passwordFieldName = "__SECRET_KEY__";
final String GoogleTracker = org.talend.core.utils.TrackerUtil.getGoogleTracker();
%>
%>
<%@ include file="@{org.talend.designer.components.localprovider}/components/templates/password.javajet"%>
@@ -229,32 +226,36 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e_<%=cid%>.getMessage());
}
%>
}
<%
<%
}else{
%>
%>
com.google.cloud.storage.Blob blob_<%=cid%> = storage_<%=cid%>.get(<%=srcBucketName%>, <%=sourceObjectKey%>);
String targetName_<%=cid%> = blob_<%=cid%>.getName();
<% if(!useSrcPath) { %>
<%
if(!useSrcPath) {
%>
targetName_<%=cid%> = targetFolder_<%=cid%>+targetName_<%=cid%>.substring(targetName_<%=cid%>.lastIndexOf('/') + 1);
<% } %>
<%
<%
} else {
%>
targetName_<%=cid%> = targetFolder_<%=cid%>+targetName_<%=cid%>;
<%
}
if(isRename){
%>
%>
targetName_<%=cid%> = targetFolder_<%=cid%>+<%=newObjectKey%>;
<%
<%
}
%>
%>
com.google.cloud.storage.CopyWriter copyWriter_<%=cid%> = blob_<%=cid%>.copyTo(<%=targetBucket%>, targetName_<%=cid%>);
<%
<%
if("MOVE".equals(actionType) ){
%>
%>
blob_<%=cid%>.delete();
<%
<%
}
%>
<%
}
%>
%>
globalMap.put("<%=cid %>_SOURCE_BUCKET",<%=srcBucketName%>);
globalMap.put("<%=cid %>_SOURCE_OBJECTKEY",<%=sourceObjectKey%>);

View File

@@ -19,7 +19,7 @@ SOURCE_OBJECTKEY.NAME=\u6E90\u5BF9\u8C61\u952E
TARGET_BUCKET.NAME=\u76EE\u6807\u6876\u540D\u79F0
TARGET_FOLDER.NAME=\u76EE\u6807\u6587\u4EF6\u5939
USE_EXISTING_CONNECTION.NAME=\u4F7F\u7528\u4E00\u4E2A\u73B0\u6709\u8FDE\u63A5
AUTH_TYPE.NAME=\u7528\u6237\u540D\u548C\u5BC6\u7801\u7C7B\u578B
AUTH_TYPE.NAME=\u51ED\u8BC1\u7C7B\u578B
AUTH_TYPE.ITEM.SERVICE_ACCOUNT=\u670D\u52A1\u5E10\u6237
AUTH_TYPE.ITEM.TOKEN=OAuth \u8BBF\u95EE\u4EE4\u724C
GS_ACCESS_TOKEN.NAME=OAuth \u8BBF\u95EE\u4EE4\u724C

View File

@@ -186,7 +186,7 @@
<!-- Transitive dependencies of google-cloud-storage -->
<IMPORT NAME="google-cloud-core-1.93.4.jar" MODULE="google-cloud-core-1.93.4.jar" MVN="mvn:com.google.cloud/google-cloud-core/1.93.4" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="google-api-client-1.31.1.jar" MODULE="google-api-client-1.31.1.jar" MVN="mvn:com.google.api-client/google-api-client/1.31.1" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="gson-2.8.9" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="api-common-1.6.0" MODULE="api-common-1.6.0.jar" MVN="mvn:com.google.api/api-common/1.6.0" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />

View File

@@ -21,7 +21,7 @@ PROJECT_ID.NAME=\u5DE5\u7A0B ID
SECRET_KEY.NAME=\u5BC6\u94A5
SPECIFY_PROJECT.NAME=\u6307\u5B9A\u5DE5\u7A0B ID
USE_EXISTING_CONNECTION.NAME=\u4F7F\u7528\u4E00\u4E2A\u73B0\u6709\u8FDE\u63A5
AUTH_TYPE.NAME=\u7528\u6237\u540D\u548C\u5BC6\u7801\u7C7B\u578B
AUTH_TYPE.NAME=\u51ED\u8BC1\u7C7B\u578B
AUTH_TYPE.ITEM.SERVICE_ACCOUNT=\u670D\u52A1\u5E10\u6237
AUTH_TYPE.ITEM.TOKEN=OAuth \u8BBF\u95EE\u4EE4\u724C
GS_ACCESS_TOKEN.NAME=OAuth \u8BBF\u95EE\u4EE4\u724C

View File

@@ -223,7 +223,7 @@
<!-- Transitive dependencies of google-cloud-storage -->
<IMPORT NAME="google-cloud-core-1.93.4.jar" MODULE="google-cloud-core-1.93.4.jar" MVN="mvn:com.google.cloud/google-cloud-core/1.93.4" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="google-api-client-1.31.1.jar" MODULE="google-api-client-1.31.1.jar" MVN="mvn:com.google.api-client/google-api-client/1.31.1" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="gson-2.8.9" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="api-common-1.6.0" MODULE="api-common-1.6.0.jar" MVN="mvn:com.google.api/api-common/1.6.0" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />

View File

@@ -27,7 +27,7 @@ SECRET_KEY.NAME=\u5BC6\u94A5
SPECIFY_PROJECT.NAME=\u6307\u5B9A\u5DE5\u7A0B ID
USE_EXISTING_CONNECTION.NAME=\u4F7F\u7528\u4E00\u4E2A\u73B0\u6709\u8FDE\u63A5
USE_KEYS_LIST.NAME=\u4F7F\u7528\u952E
AUTH_TYPE.NAME=\u7528\u6237\u540D\u548C\u5BC6\u7801\u7C7B\u578B
AUTH_TYPE.NAME=\u51ED\u8BC1\u7C7B\u578B
AUTH_TYPE.ITEM.SERVICE_ACCOUNT=\u670D\u52A1\u5E10\u6237
AUTH_TYPE.ITEM.TOKEN=OAuth \u8BBF\u95EE\u4EE4\u724C
GS_ACCESS_TOKEN.NAME=OAuth \u8BBF\u95EE\u4EE4\u724C

View File

@@ -186,7 +186,7 @@
<!-- Transitive dependencies of google-cloud-storage -->
<IMPORT NAME="google-cloud-core-1.93.4.jar" MODULE="google-cloud-core-1.93.4.jar" MVN="mvn:com.google.cloud/google-cloud-core/1.93.4" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="google-api-client-1.31.1.jar" MODULE="google-api-client-1.31.1.jar" MVN="mvn:com.google.api-client/google-api-client/1.31.1" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="gson-2.8.9" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="api-common-1.6.0" MODULE="api-common-1.6.0.jar" MVN="mvn:com.google.api/api-common/1.6.0" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />

View File

@@ -23,7 +23,7 @@ QUERY_CONFIG.NAME=\u67E5\u8BE2\u914D\u7F6E
SECRET_KEY.NAME=\u5BC6\u94A5
SPECIFY_PROJECT.NAME=\u6307\u5B9A\u5DE5\u7A0B ID
USE_EXISTING_CONNECTION.NAME=\u4F7F\u7528\u4E00\u4E2A\u73B0\u6709\u8FDE\u63A5
AUTH_TYPE.NAME=\u7528\u6237\u540D\u548C\u5BC6\u7801\u7C7B\u578B
AUTH_TYPE.NAME=\u51ED\u8BC1\u7C7B\u578B
AUTH_TYPE.ITEM.SERVICE_ACCOUNT=\u670D\u52A1\u5E10\u6237
AUTH_TYPE.ITEM.TOKEN=OAuth \u8BBF\u95EE\u4EE4\u724C
GS_ACCESS_TOKEN.NAME=OAuth \u8BBF\u95EE\u4EE4\u724C

View File

@@ -200,7 +200,7 @@
<!-- Transitive dependencies of google-cloud-storage -->
<IMPORT NAME="google-cloud-core-1.93.4.jar" MODULE="google-cloud-core-1.93.4.jar" MVN="mvn:com.google.cloud/google-cloud-core/1.93.4" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="google-api-client-1.31.1.jar" MODULE="google-api-client-1.31.1.jar" MVN="mvn:com.google.api-client/google-api-client/1.31.1" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<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="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="gson-2.8.9" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />
<IMPORT NAME="api-common-1.6.0" MODULE="api-common-1.6.0.jar" MVN="mvn:com.google.api/api-common/1.6.0" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((AUTH_TYPE == 'SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN'))" />

View File

@@ -16,7 +16,7 @@ REMOTEDIR.NAME=Google \u5B58\u50A8\u76EE\u5F55
SECRET_KEY.NAME=\u5BC6\u94A5
USE_EXISTING_CONNECTION.NAME=\u4F7F\u7528\u4E00\u4E2A\u73B0\u6709\u8FDE\u63A5
USE_FILES_LIST.NAME=\u4F7F\u7528\u6587\u4EF6\u5217\u8868
AUTH_TYPE.NAME=\u7528\u6237\u540D\u548C\u5BC6\u7801\u7C7B\u578B
AUTH_TYPE.NAME=\u51ED\u8BC1\u7C7B\u578B
AUTH_TYPE.ITEM.SERVICE_ACCOUNT=\u670D\u52A1\u5E10\u6237
AUTH_TYPE.ITEM.TOKEN=OAuth \u8BBF\u95EE\u4EE4\u724C
GS_ACCESS_TOKEN.NAME=OAuth \u8BBF\u95EE\u4EE4\u724C

View File

@@ -390,16 +390,16 @@
MODULE="google-http-client-jackson2-1.30.1.jar" MVN="mvn:com.google.http-client/google-http-client-jackson2/1.30.1" REQUIRED="true"/>
<IMPORT NAME="google-http-client-protobuf"
MODULE="google-http-client-protobuf-1.30.2.jar" MVN="mvn:com.google.http-client/google-http-client-protobuf/1.30.2" REQUIRED="true"/>
<IMPORT NAME="google-oauth-client"
MODULE="google-oauth-client-1.30.1.jar" MVN="mvn:com.google.oauth-client/google-oauth-client/1.30.1" 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-oauth-client-appengine"
MODULE="google-oauth-client-appengine-1.30.1.jar" MVN="mvn:com.google.oauth-client/google-oauth-client-appengine/1.30.1" REQUIRED="true"/>
MODULE="google-oauth-client-appengine-1.33.3.jar" MVN="mvn:com.google.oauth-client/google-oauth-client-appengine/1.33.3" REQUIRED="true"/>
<IMPORT NAME="google-oauth-client-java6"
MODULE="google-oauth-client-java6-1.30.1.jar" MVN="mvn:com.google.oauth-client/google-oauth-client-java6/1.30.1" REQUIRED="true"/>
MODULE="google-oauth-client-java6-1.33.3.jar" MVN="mvn:com.google.oauth-client/google-oauth-client-java6/1.33.3" REQUIRED="true"/>
<IMPORT NAME="google-oauth-client-jetty"
MODULE="google-oauth-client-jetty-1.30.1.jar" MVN="mvn:com.google.oauth-client/google-oauth-client-jetty/1.30.1" REQUIRED="true"/>
MODULE="google-oauth-client-jetty-1.33.3.jar" MVN="mvn:com.google.oauth-client/google-oauth-client-jetty/1.33.3" REQUIRED="true"/>
<IMPORT NAME="google-oauth-client-servlet"
MODULE="google-oauth-client-servlet-1.30.1.jar" MVN="mvn:com.google.oauth-client/google-oauth-client-servlet/1.30.1" REQUIRED="true"/>
MODULE="google-oauth-client-servlet-1.33.3.jar" MVN="mvn:com.google.oauth-client/google-oauth-client-servlet/1.33.3" REQUIRED="true"/>
<IMPORT NAME="grpc-context"
MODULE="grpc-context-1.19.0.jar" MVN="mvn:io.grpc/grpc-context/1.19.0" REQUIRED="true"/>
<IMPORT NAME="gson"
@@ -407,7 +407,7 @@
<IMPORT NAME="json"
MODULE="json-20170516.jar" MVN="mvn:org.json/json/20170516" REQUIRED="true"/>
<IMPORT NAME="guava"
MODULE="guava-27.0.1-jre.jar" MVN="mvn:com.google.guava/guava/27.0.1-jre" REQUIRED="true"/>
MODULE="guava-30.0-jre.jar" MVN="mvn:com.google.guava/guava/30.0-jre" REQUIRED="true"/>
<IMPORT NAME="jackson-core"
MODULE="jackson-core-2.13.2.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.2" REQUIRED="true"/>
<IMPORT NAME="jackson-core-asl"

View File

@@ -24,6 +24,7 @@ String dataAction = ElementParameterParser.getValue(node,"__DATA_ACTION__");
boolean convertToUppercase = false; // not active this function
String dbDriver = ElementParameterParser.getValue(node, "__DB_DRIVER__");
boolean useExistingConnection = "true".equalsIgnoreCase(ElementParameterParser.getValue(node,"__USE_EXISTING_CONNECTION__"));
String dbproperties = ElementParameterParser.getValue(node, "__PROPERTIES__");
%>
String tableName_<%=cid%> = null;
String dbschema_<%=cid%> = null;
@@ -124,12 +125,22 @@ if(useExistingConnection) {
log4jCodeGenerateUtil.useExistConnection(node);
} else {
%>
String dbProperties_<%=cid%> = <%=dbproperties%>;
<%if (dbDriver.equals("POSTGRESQL")){%>
String driverClass_<%=cid%> = "org.postgresql.Driver";
String url_<%=cid %> = "jdbc:postgresql://" + <%=host%> + ":" + <%=port%> + "/" + <%=dbName%>;
if(dbProperties_<%=cid%> != null && !"".equals(dbProperties_<%=cid%>.trim())) {
url_<%=cid %> = url_<%=cid%> + "?" + dbProperties_<%=cid%>;
}
<%} else {%>
String driverClass_<%=cid%> = "com.pivotal.jdbc.GreenplumDriver";
String url_<%=cid %> = "jdbc:pivotal:greenplum://"+<%=host%>+":"+<%=port%>+";DatabaseName="+<%=dbName%>;
if(dbProperties_<%=cid%> != null && !"".equals(dbProperties_<%=cid%>.trim())) {
url_<%=cid %> = url_<%=cid%> + ";" + dbProperties_<%=cid%>;
}
<%}%>
java.lang.Class.forName(driverClass_<%=cid%>).newInstance();
String dbUser_<%=cid%> = <%=userName%>;

View File

@@ -126,6 +126,16 @@
</PARAMETERS>
<ADVANCED_PARAMETERS>
<PARAMETER
NAME="PROPERTIES"
FIELD="TEXT"
NUM_ROW="1"
REPOSITORY_VALUE="PROPERTIES_STRING"
SHOW_IF="USE_EXISTING_CONNECTION == 'false'"
>
<DEFAULT>""</DEFAULT>
</PARAMETER>
<PARAMETER
NAME="DB_DRIVER"
FIELD="CLOSED_LIST"

View File

@@ -52,3 +52,4 @@ CONNECTION.NAME=Component List
DB_DRIVER.NAME=DB driver
DB_DRIVER.ITEM.POSTGRESQL=PostgreSQL
DB_DRIVER.ITEM.GREENPLUM=Greenplum
PROPERTIES.NAME=Additional JDBC Parameters

View File

@@ -52,3 +52,4 @@ CONNECTION.NAME=Liste des composants
DB_DRIVER.NAME=Pilote de la BdD
DB_DRIVER.ITEM.POSTGRESQL=PostgreSQL
DB_DRIVER.ITEM.GREENPLUM=Greenplum
PROPERTIES.NAME=Param\u00E8tres suppl\u00E9mentaires JDBC

View File

@@ -52,3 +52,4 @@ CONNECTION.NAME=\u30B3\u30F3\u30DD\u30FC\u30CD\u30F3\u30C8\u30EA\u30B9\u30C8
DB_DRIVER.NAME=DB\u30C9\u30E9\u30A4\u30D0\u30FC
DB_DRIVER.ITEM.POSTGRESQL=PostgreSQL
DB_DRIVER.ITEM.GREENPLUM=Greenplum
PROPERTIES.NAME=\u8FFD\u52A0\u306EJDBC\u30D1\u30E9\u30E1\u30FC\u30BF\u30FC

View File

@@ -52,3 +52,4 @@ CONNECTION.NAME=\u7EC4\u4EF6\u5217\u8868
DB_DRIVER.NAME=\u6570\u636E\u5E93\u9A71\u52A8
DB_DRIVER.ITEM.POSTGRESQL=PostgreSQL
DB_DRIVER.ITEM.GREENPLUM=Greenplum
PROPERTIES.NAME=\u9644\u52A0 JDBC \u53C2\u6570

View File

@@ -20,10 +20,21 @@ imports="
public void setURL(INode node) {
dbDriver = ElementParameterParser.getValue(node, "__DB_DRIVER__");
if (dbDriver.equals("POSTGRESQL")){%>
%>
String dbProperties_<%=cid%> = <%=dbproperties%>;
<%if (dbDriver.equals("POSTGRESQL")){%>
String url_<%=cid %> = "jdbc:postgresql://" + <%=dbhost%> + ":" + <%=dbport%> + "/" + <%=dbname%>;
if(dbProperties_<%=cid%> != null && !"".equals(dbProperties_<%=cid%>.trim())) {
url_<%=cid %> = url_<%=cid%> + "?" + dbProperties_<%=cid%>;
}
<%} else {%>
String url_<%=cid %> = "jdbc:pivotal:greenplum://"+<%=dbhost%>+":"+<%=dbport%>+";DatabaseName="+<%=dbname%>;
if(dbProperties_<%=cid%> != null && !"".equals(dbProperties_<%=cid%>.trim())) {
url_<%=cid %> = url_<%=cid%> + ";" + dbProperties_<%=cid%>;
}
<%}
}

View File

@@ -190,6 +190,16 @@
</PARAMETERS>
<ADVANCED_PARAMETERS>
<PARAMETER
NAME="PROPERTIES"
FIELD="TEXT"
NUM_ROW="1"
REPOSITORY_VALUE="PROPERTIES_STRING"
SHOW_IF="USE_EXISTING_CONNECTION == 'false'"
>
<DEFAULT>""</DEFAULT>
</PARAMETER>
<PARAMETER
NAME="DB_DRIVER"
FIELD="CLOSED_LIST"

View File

@@ -39,3 +39,4 @@ MAPPING.NAME=Mapping
DB_DRIVER.NAME=DB driver
DB_DRIVER.ITEM.POSTGRESQL=PostgreSQL
DB_DRIVER.ITEM.GREENPLUM=Greenplum
PROPERTIES.NAME=Additional JDBC Parameters

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