Compare commits
106 Commits
hwei/worki
...
release/8.
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
255e6d6c9c | ||
|
|
ba0902b8f7 | ||
|
|
0bf9432753 | ||
|
|
a64f3a269a | ||
|
|
206b82f8c9 | ||
|
|
7adfc08eec | ||
|
|
fbd03b27ff | ||
|
|
1ddca53d50 | ||
|
|
76dbc39e66 | ||
|
|
01e79e7a7e | ||
|
|
02fb11dcd4 | ||
|
|
f45cc4154d | ||
|
|
fdaea4bbf0 | ||
|
|
791fba4e55 | ||
|
|
7fb59d7f0e | ||
|
|
d37214d277 | ||
|
|
a58d7c9d1c | ||
|
|
e05a70073e | ||
|
|
bebe81ef37 | ||
|
|
24ddd70b72 | ||
|
|
a0ba4fa179 | ||
|
|
8878b983c4 | ||
|
|
1b6e82c73d | ||
|
|
8a35240fc1 | ||
|
|
238bf1c36f | ||
|
|
81267113c4 | ||
|
|
3f1f9495a3 | ||
|
|
06c87d8edf | ||
|
|
f3f79aea29 | ||
|
|
8640719bd5 | ||
|
|
2c1e96eca2 | ||
|
|
0013730512 | ||
|
|
735e374149 | ||
|
|
8415bd7cc9 | ||
|
|
5afb158f40 | ||
|
|
d19115a92e | ||
|
|
0fac5f128f | ||
|
|
cd2debb8fe | ||
|
|
cce55fd50c | ||
|
|
15d5cb8534 | ||
|
|
6fd3096f1e | ||
|
|
6c4fb6eeb4 | ||
|
|
d8e56c0821 | ||
|
|
58308e99f9 | ||
|
|
290f738f89 | ||
|
|
f974cb0dc2 | ||
|
|
b0a3cbc10b | ||
|
|
466b3b9168 | ||
|
|
80b698e8d1 | ||
|
|
79d60a2a8c | ||
|
|
a2ca6d172f | ||
|
|
28e78735b3 | ||
|
|
6744f0bb9e | ||
|
|
0a422f524d | ||
|
|
d919f0ca6c | ||
|
|
1f3a7ecde8 | ||
|
|
07d3021d7a | ||
|
|
6aa673aff4 | ||
|
|
64a73f19e7 | ||
|
|
af2df9217f | ||
|
|
13e54313da | ||
|
|
47c46997e4 | ||
|
|
fc4d3dced3 | ||
|
|
2ecfd9721a | ||
|
|
87e2f6d579 | ||
|
|
f7fafdfafe | ||
|
|
1a7d627354 | ||
|
|
f8a0cdcb02 | ||
|
|
8aeae703e0 | ||
|
|
1493c8b5db | ||
|
|
b9175d5539 | ||
|
|
23cc5b5294 | ||
|
|
32e2da5e46 | ||
|
|
bf60d556f6 | ||
|
|
c03753ed3b | ||
|
|
2e95175cf5 | ||
|
|
e6db20eb6b | ||
|
|
3740aa7555 | ||
|
|
f60f9b8556 | ||
|
|
b9284fb195 | ||
|
|
2be2aca776 | ||
|
|
e7bf6903e0 | ||
|
|
217b2066a2 | ||
|
|
7c08e6236b | ||
|
|
a140559eb0 | ||
|
|
5fd368e8da | ||
|
|
dd13213130 | ||
|
|
6def4544bc | ||
|
|
7a5d67f917 | ||
|
|
cb5e3ee0f2 | ||
|
|
e3d4a2572b | ||
|
|
a4b963cea5 | ||
|
|
c30e472013 | ||
|
|
2c9f2f1588 | ||
|
|
0dd7f8768b | ||
|
|
306a8f9acb | ||
|
|
9d9ff25810 | ||
|
|
dc411f2ae9 | ||
|
|
1dca9cefa0 | ||
|
|
4462619833 | ||
|
|
98973f34fa | ||
|
|
7b8faa1f7f | ||
|
|
9a5f894828 | ||
|
|
0f19086ebb | ||
|
|
a36783bb22 | ||
|
|
ebf6d6e3ca |
@@ -1,6 +1,6 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<projectDescription>
|
||||
<name>org.talend.studio.components.tcompv0.jira.feature</name>
|
||||
<name>org.talend.studio.components.tck.jdbc.feature</name>
|
||||
<comment></comment>
|
||||
<projects>
|
||||
</projects>
|
||||
@@ -0,0 +1,40 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<feature
|
||||
id="org.talend.studio.components.tck.jdbc.feature"
|
||||
label="JDBC"
|
||||
version="8.0.1.qualifier">
|
||||
|
||||
<description url="http://www.example.com/description">
|
||||
JDBC
|
||||
</description>
|
||||
|
||||
<copyright url="http://www.example.com/copyright">
|
||||
[Enter Copyright Description here.]
|
||||
</copyright>
|
||||
|
||||
<license url="http://www.example.com/license">
|
||||
JDBC
|
||||
Copyright (c) 2006-2021 Talend Inc. - www.talend.com
|
||||
All rights reserved.
|
||||
|
||||
This product includes software developed at
|
||||
GlassFish Community (https://glassfish.dev.java.net)
|
||||
Licensed under the CDDL,GPL-2.0-only license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
The Apache Software Foundation (http://jakarta.apache.org/)
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
FasterXML
|
||||
Licensed under the Apache-2.0 license.
|
||||
</license>
|
||||
|
||||
<requires>
|
||||
<import plugin="org.talend.designer.maven.repo.tck"/>
|
||||
<import plugin="org.talend.studio.components.tck.jdbc"/>
|
||||
</requires>
|
||||
|
||||
</feature>
|
||||
@@ -7,6 +7,6 @@
|
||||
<version>8.0.1-SNAPSHOT</version>
|
||||
<relativePath>../../../</relativePath>
|
||||
</parent>
|
||||
<artifactId>org.talend.studio.components.tcompv0.jira.feature</artifactId>
|
||||
<artifactId>org.talend.studio.components.tck.jdbc.feature</artifactId>
|
||||
<packaging>eclipse-feature</packaging>
|
||||
</project>
|
||||
@@ -1,23 +1,17 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<projectDescription>
|
||||
<name>org.talend.studio.components.tcompv0.splunk.feature</name>
|
||||
<comment></comment>
|
||||
<projects>
|
||||
</projects>
|
||||
<buildSpec>
|
||||
<buildCommand>
|
||||
<name>org.eclipse.pde.FeatureBuilder</name>
|
||||
<arguments>
|
||||
</arguments>
|
||||
</buildCommand>
|
||||
<buildCommand>
|
||||
<name>org.eclipse.m2e.core.maven2Builder</name>
|
||||
<arguments>
|
||||
</arguments>
|
||||
</buildCommand>
|
||||
</buildSpec>
|
||||
<natures>
|
||||
<nature>org.eclipse.m2e.core.maven2Nature</nature>
|
||||
<nature>org.eclipse.pde.FeatureNature</nature>
|
||||
</natures>
|
||||
</projectDescription>
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<projectDescription>
|
||||
<name>org.talend.studio.components.tck.jira.feature</name>
|
||||
<comment></comment>
|
||||
<projects>
|
||||
</projects>
|
||||
<buildSpec>
|
||||
<buildCommand>
|
||||
<name>org.eclipse.pde.FeatureBuilder</name>
|
||||
<arguments>
|
||||
</arguments>
|
||||
</buildCommand>
|
||||
</buildSpec>
|
||||
<natures>
|
||||
<nature>org.eclipse.pde.FeatureNature</nature>
|
||||
</natures>
|
||||
</projectDescription>
|
||||
@@ -0,0 +1,2 @@
|
||||
bin.includes = feature.xml,\
|
||||
p2.inf
|
||||
@@ -1,102 +1,91 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<feature
|
||||
id="org.talend.studio.components.tcompv0.jira.feature"
|
||||
label="Jira"
|
||||
version="8.0.1.qualifier">
|
||||
|
||||
<description url="http://www.example.com/description">
|
||||
Jira component
|
||||
</description>
|
||||
|
||||
<copyright url="http://www.example.com/copyright">
|
||||
[Enter Copyright Description here.]
|
||||
</copyright>
|
||||
|
||||
<license url="http://www.example.com/license">
|
||||
Jira component
|
||||
Copyright (c) 2006-2021 Talend Inc. - www.talend.com
|
||||
All rights reserved.
|
||||
|
||||
This product includes software developed at
|
||||
OPS4J - Open Participation Software for Java
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
GlassFish Community (https://glassfish.dev.java.net)
|
||||
Licensed under the CDDL,GPL-2.0-only license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
The Apache Software Foundation (http://jakarta.apache.org/)
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
FasterXML
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
OSGi Alliance (http://www.osgi.org/)
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
Joda.org (http://www.joda.org)
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
FasterXML (http://fasterxml.com)
|
||||
Licensed under the JSON license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
Google, Inc.
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
AddThis
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
SLF4J.ORG
|
||||
Licensed under the MIT license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
SLF4J.ORG
|
||||
Licensed under the X11 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
JUnit
|
||||
Licensed under the EPL-1.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
Seam Framework
|
||||
Licensed under the Apache-2.0 license.
|
||||
</license>
|
||||
|
||||
<requires>
|
||||
<import plugin="org.talend.designer.maven.repo.tcompv0" version="0.0.0" match="greaterOrEqual"/>
|
||||
</requires>
|
||||
|
||||
<plugin
|
||||
id="org.talend.studio.components.tcompv0.jira"
|
||||
download-size="0"
|
||||
install-size="0"
|
||||
version="0.0.0"/>
|
||||
|
||||
<plugin
|
||||
id="org.talend.components.jira"
|
||||
download-size="0"
|
||||
install-size="0"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
</feature>
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<feature
|
||||
id="org.talend.studio.components.tck.jira.feature"
|
||||
label="Jira"
|
||||
version="8.0.1.qualifier">
|
||||
|
||||
<description url="http://www.example.com/description">
|
||||
Jira component
|
||||
</description>
|
||||
|
||||
<copyright url="http://www.example.com/copyright">
|
||||
[Enter Copyright Description here.]
|
||||
</copyright>
|
||||
|
||||
<license url="http://www.example.com/license">
|
||||
Jira component
|
||||
Copyright (c) 2006-2021 Talend Inc. - www.talend.com
|
||||
All rights reserved.
|
||||
|
||||
This product includes software developed at
|
||||
OPS4J - Open Participation Software for Java
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
GlassFish Community (https://glassfish.dev.java.net)
|
||||
Licensed under the CDDL,GPL-2.0-only license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
The Apache Software Foundation (http://jakarta.apache.org/)
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
FasterXML
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
OSGi Alliance (http://www.osgi.org/)
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
Joda.org (http://www.joda.org)
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
FasterXML (http://fasterxml.com)
|
||||
Licensed under the JSON license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
Google, Inc.
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
AddThis
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
SLF4J.ORG
|
||||
Licensed under the MIT license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
SLF4J.ORG
|
||||
Licensed under the X11 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
JUnit
|
||||
Licensed under the EPL-1.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
Seam Framework
|
||||
Licensed under the Apache-2.0 license.
|
||||
</license>
|
||||
|
||||
<requires>
|
||||
<import plugin="org.talend.designer.maven.repo.tck" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="org.talend.designer.maven.repo.tcksdk" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="org.talend.studio.components.tck.jira"/>
|
||||
</requires>
|
||||
|
||||
</feature>
|
||||
@@ -0,0 +1,4 @@
|
||||
properties.0.name=TALEND_COMPONENT_tJIRAInput
|
||||
properties.0.value=
|
||||
properties.1.name=TALEND_COMPONENT_tJIRAOutput
|
||||
properties.1.value=
|
||||
@@ -7,6 +7,6 @@
|
||||
<version>8.0.1-SNAPSHOT</version>
|
||||
<relativePath>../../../</relativePath>
|
||||
</parent>
|
||||
<artifactId>org.talend.studio.components.tcompv0.splunk.feature</artifactId>
|
||||
<artifactId>org.talend.studio.components.tck.jira.feature</artifactId>
|
||||
<packaging>eclipse-feature</packaging>
|
||||
</project>
|
||||
@@ -0,0 +1,17 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<projectDescription>
|
||||
<name>org.talend.studio.components.tck.splunk.feature</name>
|
||||
<comment></comment>
|
||||
<projects>
|
||||
</projects>
|
||||
<buildSpec>
|
||||
<buildCommand>
|
||||
<name>org.eclipse.pde.FeatureBuilder</name>
|
||||
<arguments>
|
||||
</arguments>
|
||||
</buildCommand>
|
||||
</buildSpec>
|
||||
<natures>
|
||||
<nature>org.eclipse.pde.FeatureNature</nature>
|
||||
</natures>
|
||||
</projectDescription>
|
||||
@@ -0,0 +1,2 @@
|
||||
bin.includes = feature.xml,\
|
||||
p2.inf
|
||||
@@ -1,102 +1,91 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<feature
|
||||
id="org.talend.studio.components.tcompv0.splunk.feature"
|
||||
label="Splunk"
|
||||
version="8.0.1.qualifier">
|
||||
|
||||
<description url="http://www.example.com/description">
|
||||
Splunk component
|
||||
</description>
|
||||
|
||||
<copyright url="http://www.example.com/copyright">
|
||||
[Enter Copyright Description here.]
|
||||
</copyright>
|
||||
|
||||
<license url="http://www.example.com/license">
|
||||
Splunk component
|
||||
Copyright (c) 2006-2021 Talend Inc. - www.talend.com
|
||||
All rights reserved.
|
||||
|
||||
This product includes software developed at
|
||||
OPS4J - Open Participation Software for Java
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
GlassFish Community (https://glassfish.dev.java.net)
|
||||
Licensed under the CDDL,GPL-2.0-only license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
The Apache Software Foundation (http://jakarta.apache.org/)
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
FasterXML
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
OSGi Alliance (http://www.osgi.org/)
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
Joda.org (http://www.joda.org)
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
FasterXML (http://fasterxml.com)
|
||||
Licensed under the JSON license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
Google, Inc.
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
AddThis
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
SLF4J.ORG
|
||||
Licensed under the MIT license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
SLF4J.ORG
|
||||
Licensed under the X11 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
JUnit
|
||||
Licensed under the EPL-1.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
Seam Framework
|
||||
Licensed under the Apache-2.0 license.
|
||||
</license>
|
||||
|
||||
<requires>
|
||||
<import plugin="org.talend.designer.maven.repo.tcompv0" version="0.0.0" match="greaterOrEqual"/>
|
||||
</requires>
|
||||
|
||||
<plugin
|
||||
id="org.talend.studio.components.tcompv0.splunk"
|
||||
download-size="0"
|
||||
install-size="0"
|
||||
version="0.0.0"/>
|
||||
|
||||
<plugin
|
||||
id="org.talend.components.splunk"
|
||||
download-size="0"
|
||||
install-size="0"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
</feature>
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<feature
|
||||
id="org.talend.studio.components.tck.splunk.feature"
|
||||
label="Splunk"
|
||||
version="8.0.1.qualifier">
|
||||
|
||||
<description url="http://www.example.com/description">
|
||||
Splunk component
|
||||
</description>
|
||||
|
||||
<copyright url="http://www.example.com/copyright">
|
||||
[Enter Copyright Description here.]
|
||||
</copyright>
|
||||
|
||||
<license url="http://www.example.com/license">
|
||||
Splunk component
|
||||
Copyright (c) 2006-2021 Talend Inc. - www.talend.com
|
||||
All rights reserved.
|
||||
|
||||
This product includes software developed at
|
||||
OPS4J - Open Participation Software for Java
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
GlassFish Community (https://glassfish.dev.java.net)
|
||||
Licensed under the CDDL,GPL-2.0-only license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
The Apache Software Foundation (http://jakarta.apache.org/)
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
FasterXML
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
OSGi Alliance (http://www.osgi.org/)
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
Joda.org (http://www.joda.org)
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
FasterXML (http://fasterxml.com)
|
||||
Licensed under the JSON license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
Google, Inc.
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
AddThis
|
||||
Licensed under the Apache-2.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
SLF4J.ORG
|
||||
Licensed under the MIT license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
SLF4J.ORG
|
||||
Licensed under the X11 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
JUnit
|
||||
Licensed under the EPL-1.0 license.
|
||||
|
||||
|
||||
This product includes software developed at
|
||||
Seam Framework
|
||||
Licensed under the Apache-2.0 license.
|
||||
</license>
|
||||
|
||||
<requires>
|
||||
<import plugin="org.talend.designer.maven.repo.tck" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="org.talend.designer.maven.repo.tcksdk" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="org.talend.studio.components.tck.splunk"/>
|
||||
</requires>
|
||||
|
||||
</feature>
|
||||
@@ -0,0 +1,2 @@
|
||||
properties.0.name=TALEND_COMPONENT_tSplunkEventCollector
|
||||
properties.0.value=
|
||||
@@ -7,6 +7,6 @@
|
||||
<version>8.0.1-SNAPSHOT</version>
|
||||
<relativePath>../../../</relativePath>
|
||||
</parent>
|
||||
<artifactId>org.talend.libraries.hadoop.mapr.5.0.0</artifactId>
|
||||
<packaging>eclipse-plugin</packaging>
|
||||
<artifactId>org.talend.studio.components.tck.splunk.feature</artifactId>
|
||||
<packaging>eclipse-feature</packaging>
|
||||
</project>
|
||||
@@ -1 +0,0 @@
|
||||
bin.includes = feature.xml
|
||||
@@ -17,14 +17,14 @@
|
||||
</license>
|
||||
|
||||
<requires>
|
||||
<import feature="org.talend.studio.components.tck.jira.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import feature="org.talend.studio.components.tck.splunk.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import feature="org.talend.studio.components.tcompv0.jdbc.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import feature="org.talend.studio.components.tcompv0.netsuite.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import feature="org.talend.studio.components.tcompv0.googledrive.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import feature="org.talend.studio.components.tcompv0.marketo.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import feature="org.talend.studio.components.tcompv0.azurestorage.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import feature="org.talend.studio.components.tcompv0.snowflake.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import feature="org.talend.studio.components.tcompv0.jira.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import feature="org.talend.studio.components.tcompv0.splunk.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import feature="org.talend.studio.components.tcompv0.salesforce.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import feature="org.talend.esb.tooling.ws.consumer.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="biz.aQute.bnd.annotation" version="0.0.0" match="greaterOrEqual"/>
|
||||
@@ -84,7 +84,7 @@
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.talend.components.jira"
|
||||
id="org.talend.studio.components.tck.jira"
|
||||
download-size="0"
|
||||
install-size="0"
|
||||
version="0.0.0"
|
||||
@@ -119,7 +119,7 @@
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.talend.components.splunk"
|
||||
id="org.talend.studio.components.tck.splunk"
|
||||
download-size="0"
|
||||
install-size="0"
|
||||
version="0.0.0"
|
||||
@@ -158,7 +158,7 @@
|
||||
install-size="0"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
|
||||
<plugin
|
||||
id="org.talend.designer.filemultischemas"
|
||||
download-size="0"
|
||||
@@ -242,12 +242,18 @@
|
||||
install-size="0"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
|
||||
<plugin
|
||||
id="org.talend.designer.esb.components.rs.consumer"
|
||||
download-size="0"
|
||||
install-size="0"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.talend.studio.components.tck.jdbc"
|
||||
download-size="0"
|
||||
install-size="0"
|
||||
version="0.0.0"/>
|
||||
|
||||
</feature>
|
||||
|
||||
@@ -30,7 +30,6 @@
|
||||
<plugin id="org.talend.libraries.excel" download-size="0" install-size="0" version="0.0.0"/>
|
||||
<plugin id="org.talend.libraries.groovy" download-size="0" install-size="0" version="0.0.0"/>
|
||||
<plugin id="org.talend.libraries.guava" download-size="0" install-size="0" version="0.0.0"/>
|
||||
<plugin id="org.talend.libraries.hadoop.mapr.5.0.0" download-size="0" install-size="0" version="0.0.0"/>
|
||||
<plugin id="org.talend.libraries.jackson" download-size="0" install-size="0" version="0.0.0"/>
|
||||
<plugin download-size="0" install-size="0" version="0.0.0" unpack="false" id="org.talend.libraries.javacsv"/>
|
||||
<plugin id="org.talend.libraries.jax" download-size="0" install-size="0" version="0.0.0"/>
|
||||
|
||||
@@ -87,12 +87,12 @@
|
||||
"tIngresConnection",
|
||||
"tInterbaseConnection",
|
||||
"tJDBCConnection",
|
||||
"JDBCConnection",
|
||||
"tMSSqlConnection",
|
||||
"tMysqlConnection",
|
||||
"tNetezzaConnection",
|
||||
"tOracleConnection",
|
||||
"tParAccelConnection",
|
||||
"tPostgresPlusConnection",
|
||||
"tPostgresqlConnection",
|
||||
"tRedshiftConnection",
|
||||
"tSQLiteConnection",
|
||||
@@ -786,7 +786,7 @@
|
||||
//print info and job continue to run, for case: context_param is not empty.
|
||||
System.err.println("Could not find the context " + contextStr);
|
||||
}
|
||||
|
||||
|
||||
if(!context_param.isEmpty()) {
|
||||
context.putAll(context_param);
|
||||
//set types for params from parentJobs
|
||||
@@ -1870,6 +1870,31 @@ if (execStat) {
|
||||
context_param.put(keyValue.substring(0, index), keyValue.substring(index + 1) );
|
||||
}
|
||||
}
|
||||
} else if (arg.startsWith("--context_file")) {
|
||||
String keyValue = arg.substring(15);
|
||||
String filePath = new String(java.util.Base64.getDecoder().decode(keyValue));
|
||||
java.nio.file.Path contextFile = java.nio.file.Paths.get(filePath);
|
||||
try (java.io.BufferedReader reader = java.nio.file.Files.newBufferedReader(contextFile)) {
|
||||
String line;
|
||||
while ((line = reader.readLine()) != null) {
|
||||
int index = -1;
|
||||
if ( (index = line.indexOf('=')) > -1) {
|
||||
if (line.startsWith("--context_param")) {
|
||||
if ("id_Password".equals(context_param.getContextType(line.substring(16, index)))) {
|
||||
context_param.put(line.substring(16, index), routines.system.PasswordEncryptUtil.decryptPassword(
|
||||
line.substring(index + 1)));
|
||||
} else {
|
||||
context_param.put(line.substring(16, index), line.substring(index + 1));
|
||||
}
|
||||
}else {//--context_type
|
||||
context_param.setContextType(line.substring(15, index), line.substring(index + 1));
|
||||
}
|
||||
}
|
||||
}
|
||||
} catch (java.io.IOException e) {
|
||||
System.err.println("Could not load the context file: " + filePath);
|
||||
e.printStackTrace();
|
||||
}
|
||||
} else if (arg.startsWith("--log4jLevel=")) {
|
||||
log4jLevel = arg.substring(13);
|
||||
} else if (arg.startsWith("--audit.enabled") && arg.contains("=")) {//for trunjob call
|
||||
|
||||
@@ -138,7 +138,7 @@
|
||||
SchemaSettingTool_<%=cid%>_<%=schemaIndex%>_<%=classNameTail%> sst_<%=cid%>_<%=schemaIndex%>_<%=classNameTail%> = new SchemaSettingTool_<%=cid%>_<%=schemaIndex%>_<%=classNameTail%>();
|
||||
|
||||
props_<%=cid %><%=propInfo.fieldName%>.setValue("<%=property.getName()%>",
|
||||
new org.apache.avro.Schema.Parser().parse(sst_<%=cid%>_<%=schemaIndex%>_<%=classNameTail%>.getSchemaValue()));
|
||||
new org.apache.avro.Schema.Parser().setValidateDefaults(false).parse(sst_<%=cid%>_<%=schemaIndex%>_<%=classNameTail%>.getSchemaValue()));
|
||||
<%
|
||||
} else if (!(value instanceof String) || !((String)value).equals("")) {
|
||||
%>
|
||||
|
||||
@@ -224,7 +224,7 @@ public static class <%=conn.getName() %>Struct<%=templateOrigin %> implements ro
|
||||
<% if (column.getOriginalDbColumnName() == null) { %>
|
||||
return null;
|
||||
<% } else { %>
|
||||
return "<%=TalendTextUtils.escapeJavaText(TalendTextUtils.removeQuotes(column.getOriginalDbColumnName()))%>";
|
||||
return "<%=TalendTextUtils.escapeJavaText(column.getOriginalDbColumnName())%>";
|
||||
<% } %>
|
||||
}
|
||||
|
||||
|
||||
@@ -599,6 +599,13 @@ public class CodeGenerator implements ICodeGenerator {
|
||||
|
||||
} else {
|
||||
// if (!isIterate) {
|
||||
if (isTacokitProcessor(node)) {
|
||||
codeComponent.append(generateComponentCode(subProcess, node, ECodePart.PROCESS_RECORDS_END, incomingName, typeGen));
|
||||
codeComponent.append(generateComponentCode(subProcess, node, ECodePart.PROCESS_DATA_BEGIN, incomingName, typeGen));
|
||||
codeComponent.append(generatesTreeCode(subProcess, node, ECodePart.MAIN, typeGen));
|
||||
codeComponent.append(generateComponentCode(subProcess, node, ECodePart.PROCESS_DATA_END, incomingName, typeGen));
|
||||
}
|
||||
|
||||
codeComponent.append(generateComponentCode(subProcess, node, ECodePart.END, incomingName, typeGen));
|
||||
// }
|
||||
if (node.getComponent() instanceof Component) {
|
||||
@@ -629,12 +636,6 @@ public class CodeGenerator implements ICodeGenerator {
|
||||
}
|
||||
}
|
||||
|
||||
if (isTacokitProcessor(node)) {
|
||||
codeComponent.append(generateComponentCode(subProcess, node, ECodePart.PROCESS_RECORDS_END, incomingName, typeGen));
|
||||
codeComponent.append(generateComponentCode(subProcess, node, ECodePart.PROCESS_DATA_BEGIN, incomingName, typeGen));
|
||||
codeComponent.append(generatesTreeCode(subProcess, node, ECodePart.MAIN, typeGen));
|
||||
codeComponent.append(generateComponentCode(subProcess, node, ECodePart.PROCESS_DATA_END, incomingName, typeGen));
|
||||
}
|
||||
codeComponent.append(generatesTreeCode(subProcess, node, part, typeGen));
|
||||
// if (isIterate) {
|
||||
// codeComponent.append(generateComponentCode(node,
|
||||
@@ -655,11 +656,14 @@ public class CodeGenerator implements ICodeGenerator {
|
||||
return codeComponent;
|
||||
}
|
||||
|
||||
private static final String TACOKIT_PROCESSOR_CODE_DIR = "tacokit/jet_stub/generic/processor";
|
||||
|
||||
private boolean isTacokitProcessor(final INode node) {
|
||||
return "org.talend.sdk.component.studio.ComponentModel".equals(node.getComponent().getClass().getName())
|
||||
&& !NodeUtil.getIncomingConnections(node, IConnectionCategory.DATA).isEmpty(); //has input data
|
||||
final String componentModelClass = node.getComponent().getClass().getName();
|
||||
return ("org.talend.sdk.component.studio.ComponentModel".equals(componentModelClass) || "org.talend.sdk.component.studio.AdditionalJDBCComponentModel".equals(componentModelClass))
|
||||
&& (!NodeUtil.getIncomingConnections(node, IConnectionCategory.DATA).isEmpty() || TACOKIT_PROCESSOR_CODE_DIR.equals(node.getComponent().getTemplateFolder()));
|
||||
}
|
||||
|
||||
|
||||
private StringBuffer generateSeperateEndCode(NodesSubTree subProcess, INode node, String incomingName, ETypeGen typeGen)
|
||||
throws CodeGeneratorException {
|
||||
StringBuffer codeComponent = new StringBuffer();
|
||||
|
||||
@@ -59,7 +59,9 @@ import org.talend.core.model.components.IComponentsFactory;
|
||||
import org.talend.core.model.components.IComponentsHandler;
|
||||
import org.talend.core.model.components.filters.ComponentsFactoryProviderManager;
|
||||
import org.talend.core.model.components.filters.IComponentFactoryFilter;
|
||||
import org.talend.core.runtime.services.IGenericService;
|
||||
import org.talend.core.runtime.util.ComponentsLocationProvider;
|
||||
import org.talend.core.service.ITCKUIService;
|
||||
import org.talend.core.ui.IJobletProviderService;
|
||||
import org.talend.core.ui.ISparkJobletProviderService;
|
||||
import org.talend.core.ui.ISparkStreamingJobletProviderService;
|
||||
@@ -73,6 +75,7 @@ import org.talend.designer.core.model.components.EmfComponent;
|
||||
import org.talend.designer.core.model.process.AbstractProcessProvider;
|
||||
import org.talend.designer.core.model.process.GenericProcessProvider;
|
||||
import org.talend.designer.core.ui.editor.jobletcontainer.JobletUtil;
|
||||
import org.talend.designer.core.utils.UnifiedComponentUtil;
|
||||
|
||||
/**
|
||||
* Component factory that look for each component and load their information. <br/>
|
||||
@@ -231,7 +234,15 @@ public class ComponentsFactory implements IComponentsFactory {
|
||||
if (StringUtils.isEmpty(componentName)) {
|
||||
continue;
|
||||
}
|
||||
if (IGenericService.getService().isTcompv0(component)
|
||||
&& (UnifiedComponentUtil.isAdditionalJDBCComponent(component.getName())
|
||||
|| component.getName().contains(ITCKUIService.get().getTCKJDBCType().getLabel()))) {
|
||||
continue;
|
||||
}
|
||||
String componentNameLowerCase = componentName.toLowerCase();
|
||||
if (componentNameLowerCase.startsWith(ITCKUIService.get().getTCKJDBCType().getLabel().toLowerCase())) {
|
||||
componentNameLowerCase = "t" + componentNameLowerCase;
|
||||
}
|
||||
Map<String, Set<IComponent>> map = componentNameMap.get(componentNameLowerCase);
|
||||
if (map == null) {
|
||||
map = new HashMap<String, Set<IComponent>>();
|
||||
|
||||
@@ -378,7 +378,7 @@ public class TalendJetEmitter extends JETEmitter {
|
||||
// Construct a proper URL for relative lookup.
|
||||
//
|
||||
URL url = new File(project.getLocation() + "/" + "runtime" + "/") //$NON-NLS-1$ //$NON-NLS-2$
|
||||
.toURL();
|
||||
.toURI().toURL();
|
||||
URLClassLoader theClassLoader = new URLClassLoader(new URL[] { url }, jetEmitter.classLoader);
|
||||
Class theClass = theClassLoader.loadClass((packageName.length() == 0 ? "" : packageName + ".") //$NON-NLS-1$ //$NON-NLS-2$
|
||||
+ jetCompiler.getSkeleton().getClassName());
|
||||
@@ -633,7 +633,7 @@ public class TalendJetEmitter extends JETEmitter {
|
||||
final IWorkspace workspace = ResourcesPlugin.getWorkspace();
|
||||
IProject project = workspace.getRoot().getProject(projectName);
|
||||
|
||||
URL url = new File(project.getLocation() + "/runtime").toURL(); //$NON-NLS-1$
|
||||
URL url = new File(project.getLocation() + "/runtime").toURI().toURL(); //$NON-NLS-1$
|
||||
currentClassLoader = jetbean.getClassLoader();
|
||||
theClassLoader = new URLClassLoader(new URL[] { url }, jetbean.getClassLoader());
|
||||
}
|
||||
|
||||
@@ -564,7 +564,7 @@ public final class CodeGeneratorEmittersPoolFactory {
|
||||
JetBean jetBean = new JetBean(componentsPath, templateURI, "component", component.getVersion(), //$NON-NLS-1$
|
||||
"", codePart.getName());//$NON-NLS-1$
|
||||
addCommonLibs(jetBean);
|
||||
jetBean.addClassPath("AVRO", "org.apache.servicemix.bundles.avro"); //$NON-NLS-1$ //$NON-NLS-2$
|
||||
jetBean.addClassPath("AVRO", "avro"); //$NON-NLS-1$ //$NON-NLS-2$
|
||||
|
||||
for (String pluginDependency : component.getPluginDependencies()) {
|
||||
jetBean.addClassPath(pluginDependency.toUpperCase().replaceAll("\\.", "_") + "_LIBRARIES", pluginDependency); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$
|
||||
|
||||
@@ -7,11 +7,11 @@
|
||||
<groupId>org.talend.libraries</groupId>
|
||||
<artifactId>talend-codegen-utils</artifactId>
|
||||
<!-- release for revert version of library -->
|
||||
<version>0.34.0</version>
|
||||
<version>0.35.0</version>
|
||||
<packaging>jar</packaging>
|
||||
|
||||
<properties>
|
||||
<avro.version>1.8.0</avro.version>
|
||||
<avro.version>1.11.2</avro.version>
|
||||
<components.version>0.37.17</components.version>
|
||||
<daikon.version>7.0.5</daikon.version>
|
||||
<hamcrest.version>1.3</hamcrest.version>
|
||||
|
||||
@@ -12,6 +12,7 @@
|
||||
// ============================================================================
|
||||
package org.talend.codegen;
|
||||
|
||||
import org.apache.avro.AvroTypeException;
|
||||
import org.apache.avro.Schema;
|
||||
import org.talend.daikon.avro.AvroUtils;
|
||||
|
||||
@@ -39,4 +40,12 @@ public final class DynamicFieldUtils {
|
||||
return AvroUtils.isIncludeAllFields(schema)
|
||||
? Integer.valueOf(schema.getProp(DiSchemaConstants.TALEND6_DYNAMIC_COLUMN_POSITION)) : NO_DYNAMIC_FIELD;
|
||||
}
|
||||
|
||||
public static Schema.Field cloneAvroField(Schema.Field origin) {
|
||||
try {
|
||||
return new Schema.Field(origin.name(), origin.schema(), origin.doc(), origin.defaultVal());
|
||||
} catch (AvroTypeException e) {
|
||||
return new Schema.Field(origin.name(), origin.schema(), origin.doc(), null);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -37,6 +37,7 @@ import org.apache.avro.generic.GenericData;
|
||||
import org.apache.avro.generic.IndexedRecord;
|
||||
import org.apache.avro.SchemaParseException;
|
||||
import org.talend.codegen.DiSchemaConstants;
|
||||
import org.talend.codegen.DynamicFieldUtils;
|
||||
import org.talend.daikon.avro.AvroUtils;
|
||||
import org.talend.daikon.avro.LogicalTypeUtils;
|
||||
import org.talend.daikon.avro.NameUtil;
|
||||
@@ -374,7 +375,7 @@ public class IncomingSchemaEnforcer {
|
||||
* @return field copy
|
||||
*/
|
||||
private Field copyField(Field original) {
|
||||
Field copy = new Schema.Field(original.name(), original.schema(), original.doc(), original.defaultVal());
|
||||
Field copy = DynamicFieldUtils.cloneAvroField(original);
|
||||
for (Map.Entry<String, Object> e : original.getObjectProps().entrySet()) {
|
||||
copy.addProp(e.getKey(), e.getValue());
|
||||
}
|
||||
|
||||
@@ -24,6 +24,7 @@ import org.apache.avro.Schema;
|
||||
import org.apache.avro.Schema.Field;
|
||||
import org.apache.avro.generic.IndexedRecord;
|
||||
import org.talend.codegen.DiSchemaConstants;
|
||||
import org.talend.codegen.DynamicFieldUtils;
|
||||
import org.talend.daikon.avro.AvroUtils;
|
||||
|
||||
/**
|
||||
@@ -166,8 +167,7 @@ public class OutgoingDynamicSchemaEnforcer extends OutgoingSchemaEnforcer {
|
||||
// List<Integer> dynamicFieldsIndexes = indexMapper.computeDynamicFieldsIndexes();
|
||||
for (int index : dynamicFieldsIndexes) {
|
||||
Field dynamicField = runtimeFields.get(index);
|
||||
Field dynamicFieldCopy = new Schema.Field(dynamicField.name(), dynamicField.schema(), dynamicField.doc(),
|
||||
dynamicField.defaultVal());
|
||||
Field dynamicFieldCopy = DynamicFieldUtils.cloneAvroField(dynamicField);
|
||||
Map<String, Object> fieldProperties = dynamicField.getObjectProps();
|
||||
for (Map.Entry<String, Object> entry : fieldProperties.entrySet()) {
|
||||
Object propValue = entry.getValue();
|
||||
|
||||
@@ -50,7 +50,7 @@
|
||||
<IMPORT NAME="ApacheCommonsCollection32" MODULE="commons-collections-3.2.2.jar" MVN="mvn:commons-collections/commons-collections/3.2.2" UrlPath="platform:/plugin/org.talend.libraries.apache.common/lib/commons-collections-3.2.2.jar" REQUIRED="true" BundleID=""/>
|
||||
<IMPORT NAME="Jboss_Marshalling" MODULE="jboss-marshalling-2.0.12.Final.jar" MVN="mvn:org.jboss.marshalling/jboss-marshalling/2.0.12.Final" REQUIRED="true"/>
|
||||
<IMPORT NAME="Jboss_River" MODULE="jboss-marshalling-river-2.0.12.Final.jar" MVN="mvn:org.jboss.marshalling/jboss-marshalling-river/2.0.12.Final" REQUIRED="true"/>
|
||||
<IMPORT NAME="Trove" MODULE="trove.jar" MVN="mvn:org.talend.libraries/trove/6.0.0" REQUIRED="true"/>
|
||||
<IMPORT NAME="Trove" MODULE="trove-1.0.2.jar" MVN="mvn:trove/trove/1.0.2" REQUIRED="true"/>
|
||||
<IMPORT NAME="reload4j-1.2.22" MODULE="reload4j-1.2.22.jar" MVN="mvn:ch.qos.reload4j/reload4j/1.2.22" REQUIRED="true" BundleID=""/>
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
@@ -59,7 +59,7 @@
|
||||
/>
|
||||
<IMPORT
|
||||
NAME="Trove"
|
||||
MODULE="trove.jar" MVN="mvn:org.talend.libraries/trove/6.0.0"
|
||||
MODULE="trove-1.0.2.jar" MVN="mvn:trove/trove/1.0.2"
|
||||
REQUIRED="true"
|
||||
/>
|
||||
<IMPORT
|
||||
|
||||
@@ -240,14 +240,14 @@
|
||||
<IMPORT NAME="jmespath-java-1.12.315.jar" MODULE="jmespath-java-1.12.315.jar"
|
||||
MVN="mvn:com.amazonaws/jmespath-java/1.12.315"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-core-2.13.4.jar" MODULE="jackson-core-2.13.4.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4"
|
||||
<IMPORT NAME="jackson-core-2.14.3.jar" MODULE="jackson-core-2.14.3.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-databind-2.13.4.2.jar" MODULE="jackson-databind-2.13.4.2.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2"
|
||||
<IMPORT NAME="jackson-databind-2.14.3.jar" MODULE="jackson-databind-2.14.3.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-annotations-2.13.4.jar" MODULE="jackson-annotations-2.13.4.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4"
|
||||
<IMPORT NAME="jackson-annotations-2.14.3.jar" MODULE="jackson-annotations-2.14.3.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="httpcore-4.4.13.jar" MODULE="httpcore-4.4.13.jar"
|
||||
MVN="mvn:org.apache.httpcomponents/httpcore/4.4.13"
|
||||
|
||||
@@ -567,14 +567,14 @@
|
||||
<IMPORT NAME="jmespath-java-1.12.315.jar" MODULE="jmespath-java-1.12.315.jar"
|
||||
MVN="mvn:com.amazonaws/jmespath-java/1.12.315"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-core-2.13.4.jar" MODULE="jackson-core-2.13.4.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4"
|
||||
<IMPORT NAME="jackson-core-2.14.3.jar" MODULE="jackson-core-2.14.3.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-databind-2.13.4.2.jar" MODULE="jackson-databind-2.13.4.2.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2"
|
||||
<IMPORT NAME="jackson-databind-2.14.3.jar" MODULE="jackson-databind-2.14.3.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-annotations-2.13.4.jar" MODULE="jackson-annotations-2.13.4.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4"
|
||||
<IMPORT NAME="jackson-annotations-2.14.3.jar" MODULE="jackson-annotations-2.14.3.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="httpcore-4.4.13.jar" MODULE="httpcore-4.4.13.jar"
|
||||
MVN="mvn:org.apache.httpcomponents/httpcore/4.4.13"
|
||||
|
||||
@@ -297,14 +297,14 @@
|
||||
<IMPORT NAME="jmespath-java-1.12.315.jar" MODULE="jmespath-java-1.12.315.jar"
|
||||
MVN="mvn:com.amazonaws/jmespath-java/1.12.315"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-core-2.13.4.jar" MODULE="jackson-core-2.13.4.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4"
|
||||
<IMPORT NAME="jackson-core-2.14.3.jar" MODULE="jackson-core-2.14.3.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-databind-2.13.4.2.jar" MODULE="jackson-databind-2.13.4.2.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2"
|
||||
<IMPORT NAME="jackson-databind-2.14.3.jar" MODULE="jackson-databind-2.14.3.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-annotations-2.13.4.jar" MODULE="jackson-annotations-2.13.4.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4"
|
||||
<IMPORT NAME="jackson-annotations-2.14.3.jar" MODULE="jackson-annotations-2.14.3.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="httpcore-4.4.13.jar" MODULE="httpcore-4.4.13.jar"
|
||||
MVN="mvn:org.apache.httpcomponents/httpcore/4.4.13"
|
||||
|
||||
@@ -357,14 +357,14 @@
|
||||
<IMPORT NAME="jmespath-java-1.12.315.jar" MODULE="jmespath-java-1.12.315.jar"
|
||||
MVN="mvn:com.amazonaws/jmespath-java/1.12.315"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-core-2.13.4.jar" MODULE="jackson-core-2.13.4.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4"
|
||||
<IMPORT NAME="jackson-core-2.14.3.jar" MODULE="jackson-core-2.14.3.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-databind-2.13.4.2.jar" MODULE="jackson-databind-2.13.4.2.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2"
|
||||
<IMPORT NAME="jackson-databind-2.14.3.jar" MODULE="jackson-databind-2.14.3.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-annotations-2.13.4.jar" MODULE="jackson-annotations-2.13.4.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4"
|
||||
<IMPORT NAME="jackson-annotations-2.14.3.jar" MODULE="jackson-annotations-2.14.3.jar"
|
||||
MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="httpcore-4.4.13.jar" MODULE="httpcore-4.4.13.jar"
|
||||
MVN="mvn:org.apache.httpcomponents/httpcore/4.4.13"
|
||||
|
||||
@@ -383,9 +383,9 @@
|
||||
<IMPORT NAME="Driver-mssql-jdbc" MODULE="mssql-jdbc.jar" MVN="mvn:com.microsoft.sqlserver/mssql-jdbc/actual" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')" />
|
||||
<!--Active directory dependency module: msal4j and transitive -->
|
||||
<IMPORT NAME="msal4j" MODULE="msal4j-1.11.0.jar" MVN="mvn:com.microsoft.azure/msal4j/1.11.0" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-core" MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-databind" MODULE="jackson-databind-2.13.4.2.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-annotations" MODULE="jackson-annotations-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-core" MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-databind" MODULE="jackson-databind-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-annotations" MODULE="jackson-annotations-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="oauth2-oidc-sdk" MODULE="oauth2-oidc-sdk-9.7.jar" MVN="mvn:com.nimbusds/oauth2-oidc-sdk/9.7" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jcip-annotations" MODULE="jcip-annotations-1.0-1.jar" MVN="mvn:com.github.stephenc.jcip/jcip-annotations/1.0-1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="json-smart" MODULE="json-smart-2.4.11.jar" MVN="mvn:net.minidev/json-smart/2.4.11" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
@@ -395,7 +395,7 @@
|
||||
<IMPORT NAME="content-type" MODULE="content-type-2.1.jar" MVN="mvn:com.nimbusds/content-type/2.1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="lang-tag" MODULE="lang-tag-1.5.jar" MVN="mvn:com.nimbusds/lang-tag/1.5" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.22.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.22" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.30.2.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.30.2" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
|
||||
@@ -206,9 +206,9 @@
|
||||
<IMPORT NAME="slf4j-reload4j-1.7.34.jar" MODULE="slf4j-reload4j-1.7.34.jar" MVN="mvn:org.slf4j/slf4j-reload4j/1.7.34" REQUIRED_IF="(USE_SHARED_CONNECTION == 'true' AND SPECIFY_DATASOURCE_ALIAS=='false')" />
|
||||
<!--Active directory dependency module: msal4j and transitive -->
|
||||
<IMPORT NAME="msal4j" MODULE="msal4j-1.11.0.jar" MVN="mvn:com.microsoft.azure/msal4j/1.11.0" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="jackson-core" MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="jackson-databind" MODULE="jackson-databind-2.13.4.2.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="jackson-annotations" MODULE="jackson-annotations-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="jackson-core" MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="jackson-databind" MODULE="jackson-databind-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="jackson-annotations" MODULE="jackson-annotations-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="oauth2-oidc-sdk" MODULE="oauth2-oidc-sdk-9.7.jar" MVN="mvn:com.nimbusds/oauth2-oidc-sdk/9.7" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="jcip-annotations" MODULE="jcip-annotations-1.0-1.jar" MVN="mvn:com.github.stephenc.jcip/jcip-annotations/1.0-1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="json-smart" MODULE="json-smart-2.4.11.jar" MVN="mvn:net.minidev/json-smart/2.4.11" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
@@ -218,7 +218,7 @@
|
||||
<IMPORT NAME="content-type" MODULE="content-type-2.1.jar" MVN="mvn:com.nimbusds/content-type/2.1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="lang-tag" MODULE="lang-tag-1.5.jar" MVN="mvn:com.nimbusds/lang-tag/1.5" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.22.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.22" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.30.2.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.30.2" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true')" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
|
||||
@@ -266,9 +266,9 @@
|
||||
<IMPORT NAME="Talend_MssqlUtil" MODULE="talend_DB_mssqlUtil-1.4.jar" MVN="mvn:org.talend.components.lib/talend_DB_mssqlUtil/1.4" UrlPath="platform:/plugin/org.talend.libraries.custom/lib/talend_DB_mssqlUtil-1.4.jar" REQUIRED="true" />
|
||||
<!--Active directory dependency module: msal4j and transitive -->
|
||||
<IMPORT NAME="msal4j" MODULE="msal4j-1.11.0.jar" MVN="mvn:com.microsoft.azure/msal4j/1.11.0" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-core" MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-databind" MODULE="jackson-databind-2.13.4.2.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-annotations" MODULE="jackson-annotations-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-core" MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-databind" MODULE="jackson-databind-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-annotations" MODULE="jackson-annotations-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="oauth2-oidc-sdk" MODULE="oauth2-oidc-sdk-9.7.jar" MVN="mvn:com.nimbusds/oauth2-oidc-sdk/9.7" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jcip-annotations" MODULE="jcip-annotations-1.0-1.jar" MVN="mvn:com.github.stephenc.jcip/jcip-annotations/1.0-1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="json-smart" MODULE="json-smart-2.4.11.jar" MVN="mvn:net.minidev/json-smart/2.4.11" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
@@ -278,7 +278,7 @@
|
||||
<IMPORT NAME="content-type" MODULE="content-type-2.1.jar" MVN="mvn:com.nimbusds/content-type/2.1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="lang-tag" MODULE="lang-tag-1.5.jar" MVN="mvn:com.nimbusds/lang-tag/1.5" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.22.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.22" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.30.2.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.30.2" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
|
||||
@@ -337,9 +337,9 @@
|
||||
<IMPORT NAME="Driver-mssql-jdbc" MODULE="mssql-jdbc.jar" MVN="mvn:com.microsoft.sqlserver/mssql-jdbc/actual" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')" />
|
||||
<!--Active directory dependency module: msal4j and transitive -->
|
||||
<IMPORT NAME="msal4j" MODULE="msal4j-1.11.0.jar" MVN="mvn:com.microsoft.azure/msal4j/1.11.0" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-core" MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-databind" MODULE="jackson-databind-2.13.4.2.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-annotations" MODULE="jackson-annotations-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-core" MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-databind" MODULE="jackson-databind-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-annotations" MODULE="jackson-annotations-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="oauth2-oidc-sdk" MODULE="oauth2-oidc-sdk-9.7.jar" MVN="mvn:com.nimbusds/oauth2-oidc-sdk/9.7" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jcip-annotations" MODULE="jcip-annotations-1.0-1.jar" MVN="mvn:com.github.stephenc.jcip/jcip-annotations/1.0-1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="json-smart" MODULE="json-smart-2.4.11.jar" MVN="mvn:net.minidev/json-smart/2.4.11" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
@@ -349,7 +349,7 @@
|
||||
<IMPORT NAME="content-type" MODULE="content-type-2.1.jar" MVN="mvn:com.nimbusds/content-type/2.1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="lang-tag" MODULE="lang-tag-1.5.jar" MVN="mvn:com.nimbusds/lang-tag/1.5" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.22.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.22" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.30.2.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.30.2" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
|
||||
@@ -322,9 +322,9 @@
|
||||
<IMPORT NAME="Driver-mssql-jdbc" MODULE="mssql-jdbc.jar" MVN="mvn:com.microsoft.sqlserver/mssql-jdbc/actual" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false')" />
|
||||
<!--Active directory dependency module: msal4j and transitive -->
|
||||
<IMPORT NAME="msal4j" MODULE="msal4j-1.11.0.jar" MVN="mvn:com.microsoft.azure/msal4j/1.11.0" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-core" MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-databind" MODULE="jackson-databind-2.13.4.2.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-annotations" MODULE="jackson-annotations-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-core" MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-databind" MODULE="jackson-databind-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-annotations" MODULE="jackson-annotations-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="oauth2-oidc-sdk" MODULE="oauth2-oidc-sdk-9.7.jar" MVN="mvn:com.nimbusds/oauth2-oidc-sdk/9.7" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jcip-annotations" MODULE="jcip-annotations-1.0-1.jar" MVN="mvn:com.github.stephenc.jcip/jcip-annotations/1.0-1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="json-smart" MODULE="json-smart-2.4.11.jar" MVN="mvn:net.minidev/json-smart/2.4.11" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
@@ -334,7 +334,7 @@
|
||||
<IMPORT NAME="content-type" MODULE="content-type-2.1.jar" MVN="mvn:com.nimbusds/content-type/2.1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="lang-tag" MODULE="lang-tag-1.5.jar" MVN="mvn:com.nimbusds/lang-tag/1.5" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.22.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.22" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.30.2.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.30.2" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
|
||||
@@ -197,21 +197,30 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",ee_<%=cid%>.getMessage());
|
||||
/* ----END-CREATING-CLIENT (OAuth 2.0)---- */
|
||||
|
||||
<%
|
||||
} else if (authMode.equals("SERVICEACCOUNT")) {
|
||||
} else if (authMode.equals("SERVICEACCOUNT") || authMode.equals("APPLICATION_DEFAULT_CREDENTIALS")) {
|
||||
%>
|
||||
/* ----START-CREATING-CLIENT (Cloud API)---- */
|
||||
<% // Fix verifyError for a huge file TDI-50379 %>
|
||||
class BigQueryBuilder_<%=cid%> {
|
||||
public com.google.cloud.bigquery.BigQuery newBigQuery() throws java.io.IOException {
|
||||
com.google.auth.oauth2.GoogleCredentials credentials_<%=cid%>;
|
||||
<%if ("APPLICATION_DEFAULT_CREDENTIALS".equals(authMode)) { %>
|
||||
credentials_<%=cid%> = com.google.auth.oauth2.GoogleCredentials.getApplicationDefault();
|
||||
<%} else { %>
|
||||
java.io.File credentialsFile_<%=cid%> = new java.io.File(<%=credentialsFile%>);
|
||||
try(java.io.FileInputStream credentialsStream_<%=cid%> = new java.io.FileInputStream(credentialsFile_<%=cid%>)) {
|
||||
credentials_<%=cid%> = com.google.auth.oauth2.ServiceAccountCredentials.fromStream(credentialsStream_<%=cid%>);
|
||||
}
|
||||
<%}%>
|
||||
|
||||
com.google.auth.oauth2.GoogleCredentials credentials_<%=cid%>;
|
||||
java.io.File credentialsFile_<%=cid%> = new java.io.File(<%=credentialsFile%>);
|
||||
try(java.io.FileInputStream credentialsStream_<%=cid%> = new java.io.FileInputStream(credentialsFile_<%=cid%>)) {
|
||||
credentials_<%=cid%> = com.google.auth.oauth2.ServiceAccountCredentials.fromStream(credentialsStream_<%=cid%>);
|
||||
com.google.cloud.bigquery.BigQueryOptions.Builder bigQueryOptionsBuilder_<%=cid%> = com.google.cloud.bigquery.BigQueryOptions.newBuilder().setCredentials(credentials_<%=cid%>).setProjectId(<%=projectId%>);
|
||||
<% if( "true".equals(ElementParameterParser.getValue(node, "__USE_REGION_ENDPOINT__")) ){ %>
|
||||
bigQueryOptionsBuilder_<%=cid%>.setHost( <%= ElementParameterParser.getValue(node, "__REGION_ENDPOINT_BQ__")%> );
|
||||
<% } %>
|
||||
return bigQueryOptionsBuilder_<%=cid%>.build().getService();
|
||||
}
|
||||
}
|
||||
|
||||
com.google.cloud.bigquery.BigQueryOptions.Builder bigQueryOptionsBuilder_<%=cid%> = com.google.cloud.bigquery.BigQueryOptions.newBuilder().setCredentials(credentials_<%=cid%>).setProjectId(<%=projectId%>);
|
||||
<% if( "true".equals(ElementParameterParser.getValue(node, "__USE_REGION_ENDPOINT__")) ){ %>
|
||||
bigQueryOptionsBuilder_<%=cid%>.setHost( <%= ElementParameterParser.getValue(node, "__REGION_ENDPOINT_BQ__")%> );
|
||||
<% } %>
|
||||
com.google.cloud.bigquery.BigQuery bigquery_<%=cid%> = bigQueryOptionsBuilder_<%=cid%>.build().getService();
|
||||
com.google.cloud.bigquery.BigQuery bigquery_<%=cid%> = new BigQueryBuilder_<%=cid%>().newBigQuery();
|
||||
|
||||
/* ----END-CREATING-CLIENT (Cloud API)---- */
|
||||
|
||||
@@ -244,7 +253,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",ee_<%=cid%>.getMessage());
|
||||
/* ----END-CREATING-CLIENT (OAuth based Token)---- */
|
||||
<%
|
||||
} else {
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"APPLICATION_DEFAULT_CREDENTIALS\", \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
}
|
||||
boolean bulkFileAlreadyExists = ElementParameterParser.getBooleanValue(node, "__BULK_FILE_ALREADY_EXIST__");
|
||||
String accessKey = ElementParameterParser.getValue(node, "__GS_ACCESS_KEY__");
|
||||
@@ -662,7 +671,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",ee_<%=cid%>.getMessage());
|
||||
}
|
||||
/* ----END-CREATING-JOB (OAuth 2.0)---- */
|
||||
<%
|
||||
} else if (authMode.equals("SERVICEACCOUNT")) {
|
||||
} else if (authMode.equals("SERVICEACCOUNT") || authMode.equals("APPLICATION_DEFAULT_CREDENTIALS")) {
|
||||
%>
|
||||
/* ----START-CREATING-JOB (Cloud API)---- */
|
||||
com.google.cloud.bigquery.TableId tableId_<%=cid%> = com.google.cloud.bigquery.TableId.of(<%=projectId%>, <%=dataset%>, <%=table%>);
|
||||
@@ -869,6 +878,6 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",ee_<%=cid%>.getMessage());
|
||||
/* ----END-CREATING-JOB (Cloud API)---- */
|
||||
<%
|
||||
} else {
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"APPLICATION_DEFAULT_CREDENTIALS\", \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
}
|
||||
%>
|
||||
|
||||
@@ -45,7 +45,8 @@
|
||||
<PARAMETER NAME="AUTH_MODE" FIELD="CLOSED_LIST" NUM_ROW="3" REQUIRED="true" GROUP="AUTHENTICATION" REPOSITORY_VALUE="AUTH_MODE">
|
||||
<ITEMS DEFAULT="SERVICEACCOUNT">
|
||||
<ITEM NAME="SERVICEACCOUNT" VALUE="SERVICEACCOUNT" />
|
||||
<ITEM NAME="OAUTH" VALUE="OAUTH" />
|
||||
<ITEM NAME="APPLICATION_DEFAULT_CREDENTIALS" VALUE="APPLICATION_DEFAULT_CREDENTIALS"/>
|
||||
<ITEM NAME="OAUTH" VALUE="OAUTH" />
|
||||
<ITEM NAME="TOKEN" VALUE="TOKEN" />
|
||||
</ITEMS>
|
||||
</PARAMETER>
|
||||
@@ -175,6 +176,7 @@
|
||||
>
|
||||
<ITEMS DEFAULT="GS_SERVICE_ACCOUNT">
|
||||
<ITEM NAME="GS_SERVICE_ACCOUNT" VALUE="GS_SERVICE_ACCOUNT"/>
|
||||
<ITEM NAME="GS_APPLICATION_DEFAULT_CREDENTIALS" VALUE="GS_APPLICATION_DEFAULT_CREDENTIALS"/>
|
||||
<ITEM NAME="TOKEN" VALUE="TOKEN" />
|
||||
</ITEMS>
|
||||
</PARAMETER>
|
||||
@@ -247,7 +249,7 @@
|
||||
EQUIRED="true"
|
||||
GROUP="REGION_ENDPOINT_GROUP"
|
||||
REPOSITORY_VALUE="USE_REGION_ENDPOINT"
|
||||
SHOW_IF="(AUTH_MODE == 'SERVICEACCOUNT')" >
|
||||
SHOW_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" >
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
<PARAMETER NAME="REGION_ENDPOINT_GS"
|
||||
@@ -255,7 +257,7 @@
|
||||
NUM_ROW="5"
|
||||
REQUIRED="false"
|
||||
GROUP="REGION_ENDPOINT_GROUP"
|
||||
SHOW_IF="(AUTH_MODE == 'SERVICEACCOUNT') AND (USE_REGION_ENDPOINT == 'true')" >
|
||||
SHOW_IF="((AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')) AND (USE_REGION_ENDPOINT == 'true')" >
|
||||
<DEFAULT>"https://storage.googleapis.com"</DEFAULT>
|
||||
</PARAMETER>
|
||||
<PARAMETER NAME="REGION_ENDPOINT_BQ"
|
||||
@@ -263,7 +265,7 @@
|
||||
NUM_ROW="6"
|
||||
REQUIRED="false"
|
||||
GROUP="REGION_ENDPOINT_GROUP" REPOSITORY_VALUE="REGION_ENDPOINT_BQ"
|
||||
SHOW_IF="(AUTH_MODE == 'SERVICEACCOUNT') AND (USE_REGION_ENDPOINT == 'true')" >
|
||||
SHOW_IF="((AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')) AND (USE_REGION_ENDPOINT == 'true')" >
|
||||
<DEFAULT>"https://bigquery.googleapis.com"</DEFAULT>
|
||||
</PARAMETER>
|
||||
<PARAMETER NAME="TOKEN_NAME" FIELD="FILE" NUM_ROW="8"
|
||||
@@ -299,45 +301,45 @@
|
||||
<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.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="guava-32.1.2-jre.jar" MODULE="guava-32.1.2-jre.jar" MVN="mvn:com.google.guava/guava/32.1.2-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" />
|
||||
<IMPORT NAME="jackson-core-2.13.4.jar" MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4" REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-core-2.14.3.jar" MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3" REQUIRED="true" />
|
||||
<!-- REQUIRED FOR GOOGLE STORAGE -->
|
||||
<IMPORT NAME="jets3t-0.9.1" MODULE="jets3t-0.9.1.jar" MVN="mvn:org.talend.libraries/jets3t-0.9.1/6.0.0" REQUIRED="true" />
|
||||
<IMPORT NAME="commons-logging-1.2" MODULE="commons-logging-1.2.jar" MVN="mvn:commons-logging/commons-logging/1.2" REQUIRED="true" />
|
||||
<IMPORT NAME="httpclient-4.5.13" MODULE="httpclient-4.5.13.jar" MVN="mvn:org.apache.httpcomponents/httpclient/4.5.13" REQUIRED="true" />
|
||||
<IMPORT NAME="httpcore-4.4.13" MODULE="httpcore-4.4.13.jar" MVN="mvn:org.apache.httpcomponents/httpcore/4.4.13" REQUIRED="true" />
|
||||
<IMPORT NAME="commons-codec-1.14" MODULE="commons-codec-1.14.jar" MVN="mvn:commons-codec/commons-codec/1.14" REQUIRED="true" />
|
||||
<IMPORT NAME="google-cloud-bigquery-1.126.3.jar" MODULE="google-cloud-bigquery-1.126.3.jar" MVN="mvn:com.google.cloud/google-cloud-bigquery/1.126.3" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="google-cloud-bigquery-1.126.3.jar" MODULE="google-cloud-bigquery-1.126.3.jar" MVN="mvn:com.google.cloud/google-cloud-bigquery/1.126.3" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
|
||||
<!-- TODO remove it -->
|
||||
<IMPORT NAME="google-http-client-jackson-1.25.0.jar" MODULE="google-http-client-jackson-1.25.0.jar" MVN="mvn:com.google.http-client/google-http-client-jackson/1.25.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="google-http-client-jackson-1.25.0.jar" MODULE="google-http-client-jackson-1.25.0.jar" MVN="mvn:com.google.http-client/google-http-client-jackson/1.25.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
|
||||
<IMPORT NAME="threetenbp-1.3.3.jar" MODULE="threetenbp-1.3.3.jar" MVN="mvn:org.threeten/threetenbp/1.3.3" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="google-auth-library-credentials-0.20.0.jar" MODULE="google-auth-library-credentials-0.20.0.jar" MVN="mvn:com.google.auth/google-auth-library-credentials/0.20.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="gax-httpjson-0.44.0.jar" MODULE="gax-httpjson-0.44.0.jar" MVN="mvn:com.google.api/gax-httpjson/0.44.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="jackson-core-asl-1.9.13.jar" MODULE="jackson-core-asl-1.9.13.jar" MVN="mvn:org.codehaus.jackson/jackson-core-asl/1.9.13" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="google-auth-library-oauth2-http-0.20.0.jar" MODULE="google-auth-library-oauth2-http-0.20.0.jar" MVN="mvn:com.google.auth/google-auth-library-oauth2-http/0.20.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<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_MODE == 'SERVICEACCOUNT') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="google-cloud-core-http-1.32.0.jar" MODULE="google-cloud-core-http-1.32.0.jar" MVN="mvn:com.google.cloud/google-cloud-core-http/1.32.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="gax-1.27.0.jar" MODULE="gax-1.27.0.jar" MVN="mvn:com.google.api/gax/1.27.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="google-http-client-appengine-1.38.0.jar" MODULE="google-http-client-appengine-1.38.0.jar" MVN="mvn:com.google.http-client/google-http-client-appengine/1.38.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="api-common-1.6.0.jar" MODULE="api-common-1.6.0.jar" MVN="mvn:com.google.api/api-common/1.6.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="threetenbp-1.3.3.jar" MODULE="threetenbp-1.3.3.jar" MVN="mvn:org.threeten/threetenbp/1.3.3" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="google-auth-library-credentials-0.20.0.jar" MODULE="google-auth-library-credentials-0.20.0.jar" MVN="mvn:com.google.auth/google-auth-library-credentials/0.20.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="gax-httpjson-0.44.0.jar" MODULE="gax-httpjson-0.44.0.jar" MVN="mvn:com.google.api/gax-httpjson/0.44.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="jackson-core-asl-1.9.13.jar" MODULE="jackson-core-asl-1.9.13.jar" MVN="mvn:org.codehaus.jackson/jackson-core-asl/1.9.13" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="google-auth-library-oauth2-http-0.20.0.jar" MODULE="google-auth-library-oauth2-http-0.20.0.jar" MVN="mvn:com.google.auth/google-auth-library-oauth2-http/0.20.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<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_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="google-cloud-core-http-1.32.0.jar" MODULE="google-cloud-core-http-1.32.0.jar" MVN="mvn:com.google.cloud/google-cloud-core-http/1.32.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="gax-1.27.0.jar" MODULE="gax-1.27.0.jar" MVN="mvn:com.google.api/gax/1.27.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_TYPE == 'APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_MODE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="google-http-client-appengine-1.38.0.jar" MODULE="google-http-client-appengine-1.38.0.jar" MVN="mvn:com.google.http-client/google-http-client-appengine/1.38.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="api-common-1.6.0.jar" MODULE="api-common-1.6.0.jar" MVN="mvn:com.google.api/api-common/1.6.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
|
||||
<IMPORT NAME="google-cloud-storage-1.104.0" MODULE="google-cloud-storage-1.104.0.jar" MVN="mvn:com.google.cloud/google-cloud-storage/1.104.0" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="google-cloud-storage-1.104.0" MODULE="google-cloud-storage-1.104.0.jar" MVN="mvn:com.google.cloud/google-cloud-storage/1.104.0" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<!-- Transitive dependencies of google-cloud-storage -->
|
||||
<IMPORT NAME="google-api-services-storage-v1-rev20201112-1.31.0" MODULE="google-api-services-storage-v1-rev20201112-1.31.0.jar" MVN="mvn:com.google.apis/google-api-services-storage/v1-rev20201112-1.31.0" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="google-api-services-storage-v1-rev20201112-1.31.0" MODULE="google-api-services-storage-v1-rev20201112-1.31.0.jar" MVN="mvn:com.google.apis/google-api-services-storage/v1-rev20201112-1.31.0" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') 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="true" />
|
||||
<IMPORT NAME="javax.annotation-api" MODULE="javax.annotation-api-1.3.jar" MVN="mvn:javax.annotation/javax.annotation-api/1.3" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="protobuf-java-3.19.6" MODULE="protobuf-java-3.19.6.jar" MVN="mvn:com.google.protobuf/protobuf-java/3.19.6" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="error_prone_annotation-2.1.3" MODULE="error_prone_annotation-2.1.3.jar" MVN="mvn:com.google.errorprone/error_prone_annotations/2.1.3" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="javax.annotation-api" MODULE="javax.annotation-api-1.3.jar" MVN="mvn:javax.annotation/javax.annotation-api/1.3" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="protobuf-java-3.19.6" MODULE="protobuf-java-3.19.6.jar" MVN="mvn:com.google.protobuf/protobuf-java/3.19.6" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="error_prone_annotation-2.1.3" MODULE="error_prone_annotation-2.1.3.jar" MVN="mvn:com.google.errorprone/error_prone_annotations/2.1.3" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="opencensus-api-0.24.0" MODULE="opencensus-api-0.24.0.jar" MVN="mvn:io.opencensus/opencensus-api/0.24.0" REQUIRED="true" />
|
||||
<IMPORT NAME="opencensus-contrib-http-util-0.24.0" MODULE="opencensus-contrib-http-util-0.24.0.jar" MVN="mvn:io.opencensus/opencensus-contrib-http-util/0.24.0" REQUIRED="true" />
|
||||
<IMPORT NAME="grpc-context-1.22.1" MODULE="grpc-context-1.22.1.jar" MVN="mvn:io.grpc/grpc-context/1.22.1" REQUIRED="true" />
|
||||
<IMPORT NAME="proto-google-common-protos-1.17.0" MODULE="proto-google-common-protos-1.17.0.jar" MVN="mvn:com.google.api.grpc/proto-google-common-protos/1.17.0" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="proto-google-iam-v1-0.13.0" MODULE="proto-google-iam-v1-0.13.0.jar" MVN="mvn:com.google.api.grpc/proto-google-iam-v1/0.13.0" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="protobuf-java-util-3.19.6" MODULE="protobuf-java-util-3.19.6.jar" MVN="mvn:com.google.protobuf/protobuf-java-util/3.19.6" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="annotation-1.1.0" MODULE="annotation-1.1.0.jar" MVN="mvn:androidx.annotation/annotation/1.1.0" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="proto-google-common-protos-1.17.0" MODULE="proto-google-common-protos-1.17.0.jar" MVN="mvn:com.google.api.grpc/proto-google-common-protos/1.17.0" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="proto-google-iam-v1-0.13.0" MODULE="proto-google-iam-v1-0.13.0.jar" MVN="mvn:com.google.api.grpc/proto-google-iam-v1/0.13.0" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="protobuf-java-util-3.19.6" MODULE="protobuf-java-util-3.19.6.jar" MVN="mvn:com.google.protobuf/protobuf-java-util/3.19.6" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
<IMPORT NAME="annotation-1.1.0" MODULE="annotation-1.1.0.jar" MVN="mvn:androidx.annotation/annotation/1.1.0" REQUIRED_IF="(AUTH_TYPE == 'GS_SERVICE_ACCOUNT') OR (AUTH_TYPE == 'GS_APPLICATION_DEFAULT_CREDENTIALS') OR (AUTH_TYPE == 'TOKEN')" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
<RETURNS>
|
||||
|
||||
@@ -4,6 +4,7 @@ AUTHENTICATION.NAME=Authentication
|
||||
SERVICE_ACCOUNT_CREDENTIALS_FILE.NAME=Service account credentials file
|
||||
AUTH_MODE.NAME=Authentication mode
|
||||
AUTH_MODE.ITEM.SERVICEACCOUNT=Service account
|
||||
AUTH_MODE.ITEM.APPLICATION_DEFAULT_CREDENTIALS=Application Default Credentials
|
||||
AUTH_MODE.ITEM.OAUTH=OAuth 2.0
|
||||
AUTH_MODE.ITEM.TOKEN=OAuth Access Token
|
||||
CLIENT_ID.NAME=Client Id
|
||||
@@ -38,6 +39,7 @@ DIE_ON_ERROR.NAME=Die on error
|
||||
AUTH_TYPE.NAME=Credential type
|
||||
AUTH_TYPE.ITEM.GS_SERVICE_ACCOUNT=Service account
|
||||
GS_SERVICE_ACCOUNT_KEY.NAME=Service account key
|
||||
AUTH_TYPE.ITEM.GS_APPLICATION_DEFAULT_CREDENTIALS=Application Default Credentials
|
||||
GS_ACCESS_TOKEN.NAME=OAuth Access Token
|
||||
AUTH_TYPE.ITEM.TOKEN=OAuth Access Token
|
||||
JOBID.NAME=BigQuery JobId
|
||||
|
||||
@@ -47,3 +47,5 @@ REGION_ENDPOINT_GROUP.NAME=Point de terminaison personnalis\u00E9
|
||||
USE_REGION_ENDPOINT.NAME=Utiliser un point de terminaison personnalis\u00E9
|
||||
REGION_ENDPOINT_GS.NAME=URL de l'API priv\u00E9e Google Storage
|
||||
REGION_ENDPOINT_BQ.NAME=URL de l'API priv\u00E9e Google BigQuery
|
||||
|
||||
PROPERTY.NAME=Type de propri\u00E9t\u00E9
|
||||
|
||||
@@ -47,3 +47,5 @@ REGION_ENDPOINT_GROUP.NAME=\u30AB\u30B9\u30BF\u30E0\u30A8\u30F3\u30C9\u30DD\u30A
|
||||
USE_REGION_ENDPOINT.NAME=\u30AB\u30B9\u30BF\u30E0\u30A8\u30F3\u30C9\u30DD\u30A4\u30F3\u30C8\u3092\u4F7F\u7528
|
||||
REGION_ENDPOINT_GS.NAME=Google Storage Private API URL
|
||||
REGION_ENDPOINT_BQ.NAME=Google BigQuery Private API URL
|
||||
|
||||
PROPERTY.NAME=\u30D7\u30ED\u30D1\u30C6\u30A3\u30BF\u30A4\u30D7
|
||||
|
||||
@@ -47,3 +47,5 @@ REGION_ENDPOINT_GROUP.NAME=\u81EA\u5B9A\u4E49\u7AEF\u70B9
|
||||
USE_REGION_ENDPOINT.NAME=\u4F7F\u7528\u81EA\u5B9A\u4E49\u7AEF\u70B9
|
||||
REGION_ENDPOINT_GS.NAME=Google Storage \u79C1\u6709 API URL
|
||||
REGION_ENDPOINT_BQ.NAME=Google BigQuery \u79C1\u6709 API URL
|
||||
|
||||
PROPERTY.NAME=\u5C5E\u6027\u7C7B\u578B
|
||||
|
||||
@@ -14,10 +14,14 @@ class ServiceAccountBigQueryUtil_<%=cid%> {
|
||||
return bigQuery;
|
||||
}
|
||||
com.google.auth.oauth2.GoogleCredentials credentials;
|
||||
java.io.File credentialsFile = new java.io.File(<%=credentialsFile%>);
|
||||
try(java.io.FileInputStream credentialsStream = new java.io.FileInputStream(credentialsFile)) {
|
||||
credentials = com.google.auth.oauth2.ServiceAccountCredentials.fromStream(credentialsStream);
|
||||
}
|
||||
<% if(authMode.equals("APPLICATION_DEFAULT_CREDENTIALS")) { %>
|
||||
credentials = com.google.auth.oauth2.GoogleCredentials.getApplicationDefault();
|
||||
<% } else { %>
|
||||
java.io.File credentialsFile = new java.io.File(<%=credentialsFile%>);
|
||||
try(java.io.FileInputStream credentialsStream = new java.io.FileInputStream(credentialsFile)) {
|
||||
credentials = com.google.auth.oauth2.ServiceAccountCredentials.fromStream(credentialsStream);
|
||||
}
|
||||
<% } %>
|
||||
|
||||
com.google.cloud.bigquery.BigQueryOptions.Builder bigQueryOptionsBuilder = com.google.cloud.bigquery.BigQueryOptions.newBuilder()
|
||||
.setCredentials(credentials)
|
||||
|
||||
@@ -295,7 +295,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",ee_<%=cid%>.getMessage());
|
||||
%>
|
||||
//Dynamic end
|
||||
<%
|
||||
} else if (authMode.equals("SERVICEACCOUNT")) {
|
||||
} else if (authMode.equals("SERVICEACCOUNT") || authMode.equals("APPLICATION_DEFAULT_CREDENTIALS")) {
|
||||
%>
|
||||
|
||||
<%@ include file="@{org.talend.designer.components.localprovider}/components/tBigQueryInput/ServiceAccountBigQueryHelper.javajet"%>
|
||||
@@ -390,7 +390,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",ee_<%=cid%>.getMessage());
|
||||
//Dynamic end
|
||||
<%
|
||||
} else {
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"APPLICATION_DEFAULT_CREDENTIALS\", \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
}
|
||||
|
||||
if (authMode.equals("OAUTH") || authMode.equals("TOKEN")) {
|
||||
@@ -441,14 +441,14 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",ee_<%=cid%>.getMessage());
|
||||
Object value_<%=cid%> = null;
|
||||
nb_line_<%=cid%> ++;
|
||||
<%
|
||||
} else if (authMode.equals("SERVICEACCOUNT")) {
|
||||
} else if (authMode.equals("SERVICEACCOUNT") || authMode.equals("APPLICATION_DEFAULT_CREDENTIALS")) {
|
||||
%>
|
||||
for (com.google.cloud.bigquery.FieldValueList field_<%=cid %> : result_<%=cid%>.iterateAll()) {
|
||||
Object value_<%=cid%>;
|
||||
nb_line_<%=cid%> ++;
|
||||
<%
|
||||
} else {
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"APPLICATION_DEFAULT_CREDENTIALS\", \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
}
|
||||
%>
|
||||
int fieldsCount_<%=cid %> = field_<%=cid %>.size();
|
||||
@@ -500,12 +500,12 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",ee_<%=cid%>.getMessage());
|
||||
%>
|
||||
value_<%=cid%> = field_<%=cid %>.get(column_index_<%=cid%>).getV();
|
||||
<%
|
||||
} else if (authMode.equals("SERVICEACCOUNT")) {
|
||||
} else if (authMode.equals("SERVICEACCOUNT") || authMode.equals("APPLICATION_DEFAULT_CREDENTIALS")) {
|
||||
%>
|
||||
value_<%=cid%> = field_<%=cid %>.get(column_index_<%=cid%>).getValue();
|
||||
<%
|
||||
} else {
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"APPLICATION_DEFAULT_CREDENTIALS\", \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
}
|
||||
%>
|
||||
if(com.google.api.client.util.Data.isNull(value_<%=cid%>)) value_<%=cid%> = null;
|
||||
|
||||
@@ -26,7 +26,7 @@ imports="
|
||||
}
|
||||
}
|
||||
<%
|
||||
} else if (authMode.equals("SERVICEACCOUNT")) {
|
||||
} else if (authMode.equals("SERVICEACCOUNT") || authMode.equals("APPLICATION_DEFAULT_CREDENTIALS")) {
|
||||
%>
|
||||
}
|
||||
if (child_statistics_<%=cid%> != null) {
|
||||
@@ -35,7 +35,7 @@ imports="
|
||||
//}
|
||||
<%
|
||||
} else {
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\" or \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"APPLICATION_DEFAULT_CREDENTIALS\" or \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
}
|
||||
log4jFileUtil.retrievedDataNumberInfo(node);
|
||||
// Else job has finished successfully with the results. Finish }.
|
||||
|
||||
@@ -62,7 +62,8 @@
|
||||
<PARAMETER NAME="AUTH_MODE" FIELD="CLOSED_LIST" NUM_ROW="3" REQUIRED="true" GROUP="AUTHENTICATION" REPOSITORY_VALUE="AUTH_MODE">
|
||||
<ITEMS DEFAULT="SERVICEACCOUNT">
|
||||
<ITEM NAME="SERVICEACCOUNT" VALUE="SERVICEACCOUNT" />
|
||||
<ITEM NAME="OAUTH" VALUE="OAUTH" />
|
||||
<ITEM NAME="APPLICATION_DEFAULT_CREDENTIALS" VALUE="APPLICATION_DEFAULT_CREDENTIALS"/>
|
||||
<ITEM NAME="OAUTH" VALUE="OAUTH" />
|
||||
<ITEM NAME="TOKEN" VALUE="TOKEN" />
|
||||
</ITEMS>
|
||||
</PARAMETER>
|
||||
@@ -188,7 +189,7 @@
|
||||
EQUIRED="true"
|
||||
GROUP="REGION_ENDPOINT_GROUP"
|
||||
REPOSITORY_VALUE="USE_REGION_ENDPOINT"
|
||||
SHOW_IF="(AUTH_MODE == 'SERVICEACCOUNT')" >
|
||||
SHOW_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" >
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
<PARAMETER NAME="REGION_ENDPOINT_BQ"
|
||||
@@ -196,7 +197,7 @@
|
||||
NUM_ROW="6"
|
||||
REQUIRED="false"
|
||||
GROUP="REGION_ENDPOINT_GROUP" REPOSITORY_VALUE="REGION_ENDPOINT_BQ"
|
||||
SHOW_IF="(AUTH_MODE == 'SERVICEACCOUNT') AND (USE_REGION_ENDPOINT == 'true')" >
|
||||
SHOW_IF="((AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')) AND (USE_REGION_ENDPOINT == 'true')" >
|
||||
<DEFAULT>"https://bigquery.googleapis.com"</DEFAULT>
|
||||
</PARAMETER>
|
||||
<PARAMETER NAME="TOKEN_NAME" FIELD="FILE" NUM_ROW="8"
|
||||
@@ -246,28 +247,28 @@
|
||||
<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.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="guava-32.1.2-jre.jar" MODULE="guava-32.1.2-jre.jar" MVN="mvn:com.google.guava/guava/32.1.2-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" />
|
||||
<IMPORT NAME="jackson-core-2.13.4.jar" MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4" REQUIRED="true" />
|
||||
<IMPORT NAME="google-cloud-bigquery-1.126.3.jar" MODULE="google-cloud-bigquery-1.126.3.jar" MVN="mvn:com.google.cloud/google-cloud-bigquery/1.126.3" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'" />
|
||||
<IMPORT NAME="jackson-core-2.14.3.jar" MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3" REQUIRED="true" />
|
||||
<IMPORT NAME="google-cloud-bigquery-1.126.3.jar" MODULE="google-cloud-bigquery-1.126.3.jar" MVN="mvn:com.google.cloud/google-cloud-bigquery/1.126.3" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" />
|
||||
|
||||
<!-- TODO remove it -->
|
||||
<IMPORT NAME="google-http-client-jackson-1.25.0.jar" MODULE="google-http-client-jackson-1.25.0.jar" MVN="mvn:com.google.http-client/google-http-client-jackson/1.25.0" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'" />
|
||||
<IMPORT NAME="google-http-client-jackson-1.25.0.jar" MODULE="google-http-client-jackson-1.25.0.jar" MVN="mvn:com.google.http-client/google-http-client-jackson/1.25.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" />
|
||||
|
||||
<IMPORT NAME="threetenbp-1.3.3.jar" MODULE="threetenbp-1.3.3.jar" MVN="mvn:org.threeten/threetenbp/1.3.3" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'" />
|
||||
<IMPORT NAME="google-auth-library-credentials-0.20.0.jar" MODULE="google-auth-library-credentials-0.20.0.jar" MVN="mvn:com.google.auth/google-auth-library-credentials/0.20.0" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'" />
|
||||
<IMPORT NAME="gax-httpjson-0.44.0.jar" MODULE="gax-httpjson-0.44.0.jar" MVN="mvn:com.google.api/gax-httpjson/0.44.0" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'" />
|
||||
<IMPORT NAME="jackson-core-asl-1.9.13.jar" MODULE="jackson-core-asl-1.9.13.jar" MVN="mvn:org.codehaus.jackson/jackson-core-asl/1.9.13" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'" />
|
||||
<IMPORT NAME="google-auth-library-oauth2-http-0.20.0.jar" MODULE="google-auth-library-oauth2-http-0.20.0.jar" MVN="mvn:com.google.auth/google-auth-library-oauth2-http/0.20.0" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'" />
|
||||
<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_MODE == 'SERVICEACCOUNT'" />
|
||||
<IMPORT NAME="google-cloud-core-http-1.32.0.jar" MODULE="google-cloud-core-http-1.32.0.jar" MVN="mvn:com.google.cloud/google-cloud-core-http/1.32.0" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'" />
|
||||
<IMPORT NAME="gax-1.27.0.jar" MODULE="gax-1.27.0.jar" MVN="mvn:com.google.api/gax/1.27.0" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'" />
|
||||
<IMPORT NAME="google-http-client-appengine-1.38.0.jar" MODULE="google-http-client-appengine-1.38.0.jar" MVN="mvn:com.google.http-client/google-http-client-appengine/1.38.0" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'" />
|
||||
<IMPORT NAME="api-common-1.6.0.jar" MODULE="api-common-1.6.0.jar" MVN="mvn:com.google.api/api-common/1.6.0" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'" />
|
||||
<IMPORT NAME="threetenbp-1.3.3.jar" MODULE="threetenbp-1.3.3.jar" MVN="mvn:org.threeten/threetenbp/1.3.3" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" />
|
||||
<IMPORT NAME="google-auth-library-credentials-0.20.0.jar" MODULE="google-auth-library-credentials-0.20.0.jar" MVN="mvn:com.google.auth/google-auth-library-credentials/0.20.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" />
|
||||
<IMPORT NAME="gax-httpjson-0.44.0.jar" MODULE="gax-httpjson-0.44.0.jar" MVN="mvn:com.google.api/gax-httpjson/0.44.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" />
|
||||
<IMPORT NAME="jackson-core-asl-1.9.13.jar" MODULE="jackson-core-asl-1.9.13.jar" MVN="mvn:org.codehaus.jackson/jackson-core-asl/1.9.13" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" />
|
||||
<IMPORT NAME="google-auth-library-oauth2-http-0.20.0.jar" MODULE="google-auth-library-oauth2-http-0.20.0.jar" MVN="mvn:com.google.auth/google-auth-library-oauth2-http/0.20.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" />
|
||||
<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_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" />
|
||||
<IMPORT NAME="google-cloud-core-http-1.32.0.jar" MODULE="google-cloud-core-http-1.32.0.jar" MVN="mvn:com.google.cloud/google-cloud-core-http/1.32.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" />
|
||||
<IMPORT NAME="gax-1.27.0.jar" MODULE="gax-1.27.0.jar" MVN="mvn:com.google.api/gax/1.27.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" />
|
||||
<IMPORT NAME="google-http-client-appengine-1.38.0.jar" MODULE="google-http-client-appengine-1.38.0.jar" MVN="mvn:com.google.http-client/google-http-client-appengine/1.38.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" />
|
||||
<IMPORT NAME="api-common-1.6.0.jar" MODULE="api-common-1.6.0.jar" MVN="mvn:com.google.api/api-common/1.6.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" />
|
||||
<IMPORT NAME="opencensus-api-0.24.0" MODULE="opencensus-api-0.24.0.jar" MVN="mvn:io.opencensus/opencensus-api/0.24.0" REQUIRED="true" />
|
||||
<IMPORT NAME="opencensus-contrib-http-util-0.24.0" MODULE="opencensus-contrib-http-util-0.24.0.jar" MVN="mvn:io.opencensus/opencensus-contrib-http-util/0.24.0" REQUIRED="true" />
|
||||
<IMPORT NAME="grpc-context-1.22.1" MODULE="grpc-context-1.22.1.jar" MVN="mvn:io.grpc/grpc-context/1.22.1" REQUIRED="true" />
|
||||
<IMPORT NAME="gson-2.8.9" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'" />
|
||||
<IMPORT NAME="gson-2.8.9" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
<RETURNS>
|
||||
|
||||
@@ -4,6 +4,7 @@ AUTHENTICATION.NAME=Authentication
|
||||
SERVICE_ACCOUNT_CREDENTIALS_FILE.NAME=Service account credentials file
|
||||
AUTH_MODE.NAME=Authentication mode
|
||||
AUTH_MODE.ITEM.SERVICEACCOUNT=Service account
|
||||
AUTH_MODE.ITEM.APPLICATION_DEFAULT_CREDENTIALS=Application Default Credentials
|
||||
AUTH_MODE.ITEM.OAUTH=OAuth 2.0
|
||||
AUTH_MODE.ITEM.TOKEN=OAuth Access Token
|
||||
CLIENT_ID.NAME=Client Id
|
||||
|
||||
@@ -35,3 +35,5 @@ REGION_ENDPOINT_GROUP.NAME=Point de terminaison personnalis\u00E9
|
||||
USE_REGION_ENDPOINT.NAME=Utiliser un point de terminaison personnalis\u00E9
|
||||
REGION_ENDPOINT_GS.NAME=URL de l'API priv\u00E9e Google Storage
|
||||
REGION_ENDPOINT_BQ.NAME=URL de l'API priv\u00E9e Google BigQuery
|
||||
|
||||
PROPERTY.NAME=Type de propri\u00E9t\u00E9
|
||||
|
||||
@@ -35,3 +35,5 @@ REGION_ENDPOINT_GROUP.NAME=\u30AB\u30B9\u30BF\u30E0\u30A8\u30F3\u30C9\u30DD\u30A
|
||||
USE_REGION_ENDPOINT.NAME=\u30AB\u30B9\u30BF\u30E0\u30A8\u30F3\u30C9\u30DD\u30A4\u30F3\u30C8\u3092\u4F7F\u7528
|
||||
REGION_ENDPOINT_GS.NAME=Google Storage Private API URL
|
||||
REGION_ENDPOINT_BQ.NAME=Google BigQuery Private API URL
|
||||
|
||||
PROPERTY.NAME=\u30D7\u30ED\u30D1\u30C6\u30A3\u30BF\u30A4\u30D7
|
||||
|
||||
@@ -35,3 +35,5 @@ REGION_ENDPOINT_GROUP.NAME=\u81EA\u5B9A\u4E49\u7AEF\u70B9
|
||||
USE_REGION_ENDPOINT.NAME=\u4F7F\u7528\u81EA\u5B9A\u4E49\u7AEF\u70B9
|
||||
REGION_ENDPOINT_GS.NAME=Google Storage \u79C1\u6709 API URL
|
||||
REGION_ENDPOINT_BQ.NAME=Google BigQuery \u79C1\u6709 API URL
|
||||
|
||||
PROPERTY.NAME=\u5C5E\u6027\u7C7B\u578B
|
||||
|
||||
@@ -58,7 +58,8 @@
|
||||
<PARAMETER NAME="AUTH_MODE" FIELD="CLOSED_LIST" NUM_ROW="15" REQUIRED="true" GROUP="AUTHENTICATION" REPOSITORY_VALUE="AUTH_MODE">
|
||||
<ITEMS DEFAULT="SERVICEACCOUNT">
|
||||
<ITEM NAME="SERVICEACCOUNT" VALUE="SERVICEACCOUNT" />
|
||||
<ITEM NAME="OAUTH" VALUE="OAUTH" />
|
||||
<ITEM NAME="APPLICATION_DEFAULT_CREDENTIALS" VALUE="APPLICATION_DEFAULT_CREDENTIALS"/>
|
||||
<ITEM NAME="OAUTH" VALUE="OAUTH" />
|
||||
<ITEM NAME="TOKEN" VALUE="TOKEN" />
|
||||
</ITEMS>
|
||||
</PARAMETER>
|
||||
@@ -186,6 +187,7 @@
|
||||
SHOW_IF="(BULK_FILE_ALREADY_EXIST=='false')">
|
||||
<ITEMS DEFAULT="GS_SERVICE_ACCOUNT">
|
||||
<ITEM NAME="GS_SERVICE_ACCOUNT" VALUE="GS_SERVICE_ACCOUNT"/>
|
||||
<ITEM NAME="GS_APPLICATION_DEFAULT_CREDENTIALS" VALUE="GS_APPLICATION_DEFAULT_CREDENTIALS"/>
|
||||
<ITEM NAME="TOKEN" VALUE="TOKEN" />
|
||||
</ITEMS>
|
||||
</PARAMETER>
|
||||
@@ -253,10 +255,10 @@
|
||||
NAME="USE_REGION_ENDPOINT"
|
||||
FIELD="CHECK"
|
||||
NUM_ROW="4"
|
||||
EQUIRED="true"
|
||||
EQUIRED="true"
|
||||
GROUP="REGION_ENDPOINT_GROUP"
|
||||
REPOSITORY_VALUE="USE_REGION_ENDPOINT"
|
||||
SHOW_IF="(AUTH_MODE == 'SERVICEACCOUNT')" >
|
||||
SHOW_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" >
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
<PARAMETER
|
||||
@@ -265,7 +267,7 @@
|
||||
NUM_ROW="5"
|
||||
REQUIRED="false"
|
||||
GROUP="REGION_ENDPOINT_GROUP"
|
||||
SHOW_IF="(AUTH_MODE == 'SERVICEACCOUNT') AND (USE_REGION_ENDPOINT == 'true')" >
|
||||
SHOW_IF="((AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')) AND (USE_REGION_ENDPOINT == 'true')" >
|
||||
<DEFAULT>"https://storage.googleapis.com"</DEFAULT>
|
||||
</PARAMETER>
|
||||
<PARAMETER
|
||||
@@ -275,7 +277,7 @@
|
||||
REQUIRED="false"
|
||||
GROUP="REGION_ENDPOINT_GROUP"
|
||||
REPOSITORY_VALUE="REGION_ENDPOINT_BQ"
|
||||
SHOW_IF="(AUTH_MODE == 'SERVICEACCOUNT') AND (USE_REGION_ENDPOINT == 'true')" >
|
||||
SHOW_IF="((AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')) AND (USE_REGION_ENDPOINT == 'true')" >
|
||||
<DEFAULT>"https://bigquery.googleapis.com"</DEFAULT>
|
||||
</PARAMETER>
|
||||
<PARAMETER NAME="TOKEN_NAME" FIELD="FILE" NUM_ROW="8"
|
||||
@@ -301,7 +303,7 @@
|
||||
<DEFAULT>","</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="DROP" FIELD="CHECK" REQUIRED="true" NUM_ROW="33" SHOW_IF="AUTH_MODE == 'SERVICEACCOUNT'">
|
||||
<PARAMETER NAME="DROP" FIELD="CHECK" REQUIRED="true" NUM_ROW="33" SHOW_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')">
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
|
||||
@@ -19,6 +19,7 @@ AUTHENTICATION.NAME=Authentication
|
||||
SERVICE_ACCOUNT_CREDENTIALS_FILE.NAME=Service account credentials file
|
||||
AUTH_MODE.NAME=Authentication mode
|
||||
AUTH_MODE.ITEM.SERVICEACCOUNT=Service account
|
||||
AUTH_MODE.ITEM.APPLICATION_DEFAULT_CREDENTIALS=Application Default Credentials
|
||||
AUTH_MODE.ITEM.OAUTH=OAuth 2.0
|
||||
AUTH_MODE.ITEM.TOKEN=OAuth Access Token
|
||||
CLIENT_ID.NAME=Client Id
|
||||
@@ -49,6 +50,7 @@ CHECK_DISK_SPACE.NAME=Check disk space
|
||||
DIE_ON_ERROR.NAME=Die on error
|
||||
AUTH_TYPE.NAME=Credential type
|
||||
AUTH_TYPE.ITEM.GS_SERVICE_ACCOUNT=Service account
|
||||
AUTH_TYPE.ITEM.GS_APPLICATION_DEFAULT_CREDENTIALS=Application Default Credentials
|
||||
AUTH_TYPE.ITEM.TOKEN=OAuth Access Token
|
||||
GS_SERVICE_ACCOUNT_KEY.NAME=Service account key
|
||||
GS_ACCESS_TOKEN.NAME=OAuth Access Token
|
||||
|
||||
@@ -62,3 +62,5 @@ REGION_ENDPOINT_GROUP.NAME=Point de terminaison personnalis\u00E9
|
||||
USE_REGION_ENDPOINT.NAME=Utiliser un point de terminaison personnalis\u00E9
|
||||
REGION_ENDPOINT_GS.NAME=URL de l'API priv\u00E9e Google Storage
|
||||
REGION_ENDPOINT_BQ.NAME=URL de l'API priv\u00E9e Google BigQuery
|
||||
|
||||
PROPERTY.NAME=Type de propri\u00E9t\u00E9
|
||||
|
||||
@@ -62,3 +62,5 @@ REGION_ENDPOINT_GROUP.NAME=\u30AB\u30B9\u30BF\u30E0\u30A8\u30F3\u30C9\u30DD\u30A
|
||||
USE_REGION_ENDPOINT.NAME=\u30AB\u30B9\u30BF\u30E0\u30A8\u30F3\u30C9\u30DD\u30A4\u30F3\u30C8\u3092\u4F7F\u7528
|
||||
REGION_ENDPOINT_GS.NAME=Google Storage Private API URL
|
||||
REGION_ENDPOINT_BQ.NAME=Google BigQuery Private API URL
|
||||
|
||||
PROPERTY.NAME=\u30D7\u30ED\u30D1\u30C6\u30A3\u30BF\u30A4\u30D7
|
||||
|
||||
@@ -62,3 +62,5 @@ REGION_ENDPOINT_GROUP.NAME=\u81EA\u5B9A\u4E49\u7AEF\u70B9
|
||||
USE_REGION_ENDPOINT.NAME=\u4F7F\u7528\u81EA\u5B9A\u4E49\u7AEF\u70B9
|
||||
REGION_ENDPOINT_GS.NAME=Google Storage \u79C1\u6709 API URL
|
||||
REGION_ENDPOINT_BQ.NAME=Google BigQuery \u79C1\u6709 API URL
|
||||
|
||||
PROPERTY.NAME=\u5C5E\u6027\u7C7B\u578B
|
||||
|
||||
@@ -179,13 +179,17 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",ee.getMessage());
|
||||
|
||||
BigQueryUtil_<%=cid%> bigQueryUtil_<%=cid%> = new BigQueryUtil_<%=cid%>(PROJECT_ID_<%=cid%>, bigqueryclient_<%=cid%>, <% if (authMode.equals("OAUTH")) { %> tokenFile_<%=cid%> <% } else { %> null <%}%>);
|
||||
<%
|
||||
} else if (authMode.equals("SERVICEACCOUNT")) {
|
||||
} else if (authMode.equals("SERVICEACCOUNT") || authMode.equals("APPLICATION_DEFAULT_CREDENTIALS")) {
|
||||
%>
|
||||
com.google.auth.oauth2.GoogleCredentials credentials_<%=cid%>;
|
||||
<% if(authMode.equals("APPLICATION_DEFAULT_CREDENTIALS")) { %>
|
||||
credentials_<%=cid%> = com.google.auth.oauth2.GoogleCredentials.getApplicationDefault();
|
||||
<% } else { %>
|
||||
java.io.File credentialsFile_<%=cid%> = new java.io.File(<%=credentialsFile%>);
|
||||
try(java.io.FileInputStream credentialsStream_<%=cid%> = new java.io.FileInputStream(credentialsFile_<%=cid%>)) {
|
||||
credentials_<%=cid%> = com.google.auth.oauth2.ServiceAccountCredentials.fromStream(credentialsStream_<%=cid%>);
|
||||
}
|
||||
<% } %>
|
||||
|
||||
com.google.cloud.bigquery.BigQueryOptions.Builder bigQueryOptionsBuilder_<%=cid%> = com.google.cloud.bigquery.BigQueryOptions.newBuilder().setCredentials(credentials_<%=cid%>).setProjectId(<%=projectId%>);
|
||||
<% if( "true".equals(ElementParameterParser.getValue(node, "__USE_REGION_ENDPOINT__")) ){ %>
|
||||
@@ -195,6 +199,6 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",ee.getMessage());
|
||||
|
||||
<%
|
||||
} else {
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\" or \"OAUTH\", but it is " + authMode);
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"APPLICATION_DEFAULT_CREDENTIALS\" or \"OAUTH\", but it is " + authMode);
|
||||
}
|
||||
%>
|
||||
|
||||
@@ -50,6 +50,7 @@
|
||||
REPOSITORY_VALUE="AUTH_MODE">
|
||||
<ITEMS DEFAULT="SERVICEACCOUNT">
|
||||
<ITEM NAME="SERVICEACCOUNT" VALUE="SERVICEACCOUNT"/>
|
||||
<ITEM NAME="APPLICATION_DEFAULT_CREDENTIALS" VALUE="APPLICATION_DEFAULT_CREDENTIALS"/>
|
||||
<ITEM NAME="OAUTH" VALUE="OAUTH"/>
|
||||
<ITEM NAME="TOKEN" VALUE="TOKEN" />
|
||||
</ITEMS>
|
||||
@@ -156,7 +157,7 @@
|
||||
NUM_ROW="4"
|
||||
EQUIRED="true"
|
||||
GROUP="REGION_ENDPOINT_GROUP" REPOSITORY_VALUE="USE_REGION_ENDPOINT"
|
||||
SHOW_IF="(AUTH_MODE == 'SERVICEACCOUNT')" >
|
||||
SHOW_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" >
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
<PARAMETER NAME="REGION_ENDPOINT_BQ"
|
||||
@@ -164,7 +165,7 @@
|
||||
NUM_ROW="6"
|
||||
REQUIRED="false"
|
||||
GROUP="REGION_ENDPOINT_GROUP" REPOSITORY_VALUE="REGION_ENDPOINT_BQ"
|
||||
SHOW_IF="(AUTH_MODE == 'SERVICEACCOUNT') AND (USE_REGION_ENDPOINT == 'true')" >
|
||||
SHOW_IF="((AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')) AND (USE_REGION_ENDPOINT == 'true')" >
|
||||
<DEFAULT>"https://bigquery.googleapis.com"</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
@@ -223,28 +224,28 @@
|
||||
<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.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="guava-32.1.2-jre.jar" MODULE="guava-32.1.2-jre.jar" MVN="mvn:com.google.guava/guava/32.1.2-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" />
|
||||
<IMPORT NAME="jackson-core-2.13.4.jar" MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4" REQUIRED="true"/>
|
||||
<IMPORT NAME="google-cloud-bigquery-1.126.3.jar" MODULE="google-cloud-bigquery-1.126.3.jar" MVN="mvn:com.google.cloud/google-cloud-bigquery/1.126.3" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'"/>
|
||||
<IMPORT NAME="jackson-core-2.14.3.jar" MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3" REQUIRED="true"/>
|
||||
<IMPORT NAME="google-cloud-bigquery-1.126.3.jar" MODULE="google-cloud-bigquery-1.126.3.jar" MVN="mvn:com.google.cloud/google-cloud-bigquery/1.126.3" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')"/>
|
||||
|
||||
<!-- TODO remove it -->
|
||||
<IMPORT NAME="google-http-client-jackson-1.25.0.jar" MODULE="google-http-client-jackson-1.25.0.jar" MVN="mvn:com.google.http-client/google-http-client-jackson/1.25.0" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'"/>
|
||||
<IMPORT NAME="google-http-client-jackson-1.25.0.jar" MODULE="google-http-client-jackson-1.25.0.jar" MVN="mvn:com.google.http-client/google-http-client-jackson/1.25.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')"/>
|
||||
|
||||
<IMPORT NAME="threetenbp-1.3.3.jar" MODULE="threetenbp-1.3.3.jar" MVN="mvn:org.threeten/threetenbp/1.3.3" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'"/>
|
||||
<IMPORT NAME="google-auth-library-credentials-0.20.0.jar" MODULE="google-auth-library-credentials-0.20.0.jar" MVN="mvn:com.google.auth/google-auth-library-credentials/0.20.0" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'"/>
|
||||
<IMPORT NAME="gax-httpjson-0.44.0.jar" MODULE="gax-httpjson-0.44.0.jar" MVN="mvn:com.google.api/gax-httpjson/0.44.0" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'"/>
|
||||
<IMPORT NAME="jackson-core-asl-1.9.13.jar" MODULE="jackson-core-asl-1.9.13.jar" MVN="mvn:org.codehaus.jackson/jackson-core-asl/1.9.13" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'"/>
|
||||
<IMPORT NAME="google-auth-library-oauth2-http-0.20.0.jar" MODULE="google-auth-library-oauth2-http-0.20.0.jar" MVN="mvn:com.google.auth/google-auth-library-oauth2-http/0.20.0" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'"/>
|
||||
<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_MODE == 'SERVICEACCOUNT'"/>
|
||||
<IMPORT NAME="google-cloud-core-http-1.32.0.jar" MODULE="google-cloud-core-http-1.32.0.jar" MVN="mvn:com.google.cloud/google-cloud-core-http/1.32.0" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'"/>
|
||||
<IMPORT NAME="gax-1.27.0.jar" MODULE="gax-1.27.0.jar" MVN="mvn:com.google.api/gax/1.27.0" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'"/>
|
||||
<IMPORT NAME="google-http-client-appengine-1.38.0.jar" MODULE="google-http-client-appengine-1.38.0.jar" MVN="mvn:com.google.http-client/google-http-client-appengine/1.38.0" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'"/>
|
||||
<IMPORT NAME="api-common-1.6.0.jar" MODULE="api-common-1.6.0.jar" MVN="mvn:com.google.api/api-common/1.6.0" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'"/>
|
||||
<IMPORT NAME="threetenbp-1.3.3.jar" MODULE="threetenbp-1.3.3.jar" MVN="mvn:org.threeten/threetenbp/1.3.3" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')"/>
|
||||
<IMPORT NAME="google-auth-library-credentials-0.20.0.jar" MODULE="google-auth-library-credentials-0.20.0.jar" MVN="mvn:com.google.auth/google-auth-library-credentials/0.20.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')"/>
|
||||
<IMPORT NAME="gax-httpjson-0.44.0.jar" MODULE="gax-httpjson-0.44.0.jar" MVN="mvn:com.google.api/gax-httpjson/0.44.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')"/>
|
||||
<IMPORT NAME="jackson-core-asl-1.9.13.jar" MODULE="jackson-core-asl-1.9.13.jar" MVN="mvn:org.codehaus.jackson/jackson-core-asl/1.9.13" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')"/>
|
||||
<IMPORT NAME="google-auth-library-oauth2-http-0.20.0.jar" MODULE="google-auth-library-oauth2-http-0.20.0.jar" MVN="mvn:com.google.auth/google-auth-library-oauth2-http/0.20.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')"/>
|
||||
<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_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')"/>
|
||||
<IMPORT NAME="google-cloud-core-http-1.32.0.jar" MODULE="google-cloud-core-http-1.32.0.jar" MVN="mvn:com.google.cloud/google-cloud-core-http/1.32.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')"/>
|
||||
<IMPORT NAME="gax-1.27.0.jar" MODULE="gax-1.27.0.jar" MVN="mvn:com.google.api/gax/1.27.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')"/>
|
||||
<IMPORT NAME="google-http-client-appengine-1.38.0.jar" MODULE="google-http-client-appengine-1.38.0.jar" MVN="mvn:com.google.http-client/google-http-client-appengine/1.38.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')"/>
|
||||
<IMPORT NAME="api-common-1.6.0.jar" MODULE="api-common-1.6.0.jar" MVN="mvn:com.google.api/api-common/1.6.0" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')"/>
|
||||
<IMPORT NAME="opencensus-api-0.24.0" MODULE="opencensus-api-0.24.0.jar" MVN="mvn:io.opencensus/opencensus-api/0.24.0" REQUIRED="true" />
|
||||
<IMPORT NAME="opencensus-contrib-http-util-0.24.0" MODULE="opencensus-contrib-http-util-0.24.0.jar" MVN="mvn:io.opencensus/opencensus-contrib-http-util/0.24.0" REQUIRED="true" />
|
||||
<IMPORT NAME="grpc-context-1.22.1" MODULE="grpc-context-1.22.1.jar" MVN="mvn:io.grpc/grpc-context/1.22.1" REQUIRED="true" />
|
||||
<IMPORT NAME="gson-2.8.9" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="AUTH_MODE == 'SERVICEACCOUNT'" />
|
||||
<IMPORT NAME="gson-2.8.9" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="(AUTH_MODE == 'SERVICEACCOUNT') OR (AUTH_MODE == 'APPLICATION_DEFAULT_CREDENTIALS')" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
<RETURNS>
|
||||
|
||||
@@ -78,7 +78,7 @@
|
||||
insert_jobs_<%=cid%> = java.util.Collections.singletonList(insert_<%=cid%>);
|
||||
}
|
||||
<%
|
||||
} else if (authMode.equals("SERVICEACCOUNT")) {
|
||||
} else if (authMode.equals("SERVICEACCOUNT") || authMode.equals("APPLICATION_DEFAULT_CREDENTIALS")) {
|
||||
%>
|
||||
com.google.cloud.bigquery.QueryJobConfiguration queryConfiguration_<%=cid%> = com.google.cloud.bigquery.QueryJobConfiguration.newBuilder(<%=query%>).setUseLegacySql(<%=useLegacySql%>).build();
|
||||
com.google.cloud.bigquery.JobId jobId_<%=cid%> = com.google.cloud.bigquery.JobId.of(java.util.UUID.randomUUID().toString());
|
||||
@@ -143,7 +143,7 @@
|
||||
%>
|
||||
<%
|
||||
} else {
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"APPLICATION_DEFAULT_CREDENTIALS\", \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
}
|
||||
|
||||
List< ? extends IConnection> conns = node.getOutgoingSortedConnections();
|
||||
@@ -184,7 +184,7 @@
|
||||
Object value_<%=cid%> = null;
|
||||
nb_line_<%=cid%> ++;
|
||||
<%
|
||||
} else if (authMode.equals("SERVICEACCOUNT")) {
|
||||
} else if (authMode.equals("SERVICEACCOUNT") || authMode.equals("APPLICATION_DEFAULT_CREDENTIALS")) {
|
||||
%>
|
||||
long nb_line_<%=cid%> = 0;
|
||||
for (com.google.cloud.bigquery.Job job_iterable_<%=cid%> : childJobs_<%=cid%>) {
|
||||
@@ -202,7 +202,7 @@
|
||||
nb_line_<%=cid%> ++;
|
||||
<%
|
||||
} else {
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"APPLICATION_DEFAULT_CREDENTIALS\", \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
}
|
||||
|
||||
List<IMetadataTable> metadatas = node.getMetadataList();
|
||||
@@ -228,12 +228,12 @@
|
||||
%>
|
||||
value_<%=cid%> = field_<%=cid %>.get(<%=i%>).getV();
|
||||
<%
|
||||
} else if (authMode.equals("SERVICEACCOUNT")) {
|
||||
} else if (authMode.equals("SERVICEACCOUNT") || authMode.equals("APPLICATION_DEFAULT_CREDENTIALS")) {
|
||||
%>
|
||||
value_<%=cid%> = field_<%=cid %>.get(<%=i%>).getValue();
|
||||
<%
|
||||
} else {
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"APPLICATION_DEFAULT_CREDENTIALS\", \"OAUTH\" or \"TOKEN\", but it is " + authMode);
|
||||
}
|
||||
%>
|
||||
if(com.google.api.client.util.Data.isNull(value_<%=cid%>)) value_<%=cid%> = null;
|
||||
|
||||
@@ -4,6 +4,7 @@ AUTHENTICATION.NAME=Authentication
|
||||
SERVICE_ACCOUNT_CREDENTIALS_FILE.NAME=Service account credentials file
|
||||
AUTH_MODE.NAME=Authentication mode
|
||||
AUTH_MODE.ITEM.SERVICEACCOUNT=Service account
|
||||
AUTH_MODE.ITEM.APPLICATION_DEFAULT_CREDENTIALS=Application Default Credentials
|
||||
AUTH_MODE.ITEM.OAUTH=OAuth 2.0
|
||||
AUTH_MODE.ITEM.TOKEN=OAuth Access Token
|
||||
CLIENT_ID.NAME=Client Id
|
||||
|
||||
@@ -32,3 +32,5 @@ REGION_ENDPOINT_GROUP.NAME=Point de terminaison personnalis\u00E9
|
||||
USE_REGION_ENDPOINT.NAME=Utiliser un point de terminaison personnalis\u00E9
|
||||
REGION_ENDPOINT_GS.NAME=URL de l'API priv\u00E9e Google Storage
|
||||
REGION_ENDPOINT_BQ.NAME=URL de l'API priv\u00E9e Google BigQuery
|
||||
|
||||
PROPERTY.NAME=Type de propri\u00E9t\u00E9
|
||||
|
||||
@@ -32,3 +32,5 @@ REGION_ENDPOINT_GROUP.NAME=\u30AB\u30B9\u30BF\u30E0\u30A8\u30F3\u30C9\u30DD\u30A
|
||||
USE_REGION_ENDPOINT.NAME=\u30AB\u30B9\u30BF\u30E0\u30A8\u30F3\u30C9\u30DD\u30A4\u30F3\u30C8\u3092\u4F7F\u7528
|
||||
REGION_ENDPOINT_GS.NAME=Google Storage Private API URL
|
||||
REGION_ENDPOINT_BQ.NAME=Google BigQuery Private API URL
|
||||
|
||||
PROPERTY.NAME=\u30D7\u30ED\u30D1\u30C6\u30A3\u30BF\u30A4\u30D7
|
||||
|
||||
@@ -32,3 +32,5 @@ REGION_ENDPOINT_GROUP.NAME=\u81EA\u5B9A\u4E49\u7AEF\u70B9
|
||||
USE_REGION_ENDPOINT.NAME=\u4F7F\u7528\u81EA\u5B9A\u4E49\u7AEF\u70B9
|
||||
REGION_ENDPOINT_GS.NAME=Google Storage \u79C1\u6709 API URL
|
||||
REGION_ENDPOINT_BQ.NAME=Google BigQuery \u79C1\u6709 API URL
|
||||
|
||||
PROPERTY.NAME=\u5C5E\u6027\u7C7B\u578B
|
||||
|
||||
@@ -31,20 +31,20 @@ imports="
|
||||
}
|
||||
}
|
||||
<%
|
||||
} else if (authMode.equals("SERVICEACCOUNT")) {
|
||||
} else if (authMode.equals("SERVICEACCOUNT") || authMode.equals("APPLICATION_DEFAULT_CREDENTIALS")) {
|
||||
%>
|
||||
}
|
||||
}
|
||||
|
||||
<%
|
||||
} else {
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\" or \"OAUTH\"or \"TOKEN\", but it is " + authMode);
|
||||
throw new IllegalArgumentException("authentication mode should be either \"SERVICEACCOUNT\", \"APPLICATION_DEFAULT_CREDENTIALS\" or \"OAUTH\"or \"TOKEN\", but it is " + authMode);
|
||||
}
|
||||
log4jFileUtil.retrievedDataNumberInfo(node);
|
||||
}
|
||||
}
|
||||
}
|
||||
if (authMode.equals("SERVICEACCOUNT")) {
|
||||
if (authMode.equals("SERVICEACCOUNT") || authMode.equals("APPLICATION_DEFAULT_CREDENTIALS")) {
|
||||
%>
|
||||
if (job_<%=cid%>.getStatistics().getNumChildJobs() != null) {
|
||||
globalMap.put("<%=cid%>_STATISTICS_CHILD", childJobs_<%=cid%>.stream()
|
||||
|
||||
@@ -72,13 +72,13 @@
|
||||
MODULE="boxjavalibv2-v3.0.10.jar" MVN="mvn:net.box/boxjavalibv2/v3.0.10"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-core"
|
||||
MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4"
|
||||
MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-databind"
|
||||
MODULE="jackson-databind-2.13.4.2.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2"
|
||||
MODULE="jackson-databind-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-annotations"
|
||||
MODULE="jackson-annotations-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4"
|
||||
MODULE="jackson-annotations-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="apache-http-client"
|
||||
MODULE="httpclient-4.5.13.jar" MVN="mvn:org.apache.httpcomponents/httpclient/4.5.13"
|
||||
|
||||
@@ -127,13 +127,13 @@
|
||||
MODULE="boxjavalibv2-v3.0.10.jar" MVN="mvn:net.box/boxjavalibv2/v3.0.10"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-core"
|
||||
MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4"
|
||||
MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-databind"
|
||||
MODULE="jackson-databind-2.13.4.2.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2"
|
||||
MODULE="jackson-databind-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-annotations"
|
||||
MODULE="jackson-annotations-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4"
|
||||
MODULE="jackson-annotations-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="apache-http-client"
|
||||
MODULE="httpclient-4.5.13.jar" MVN="mvn:org.apache.httpcomponents/httpclient/4.5.13"
|
||||
|
||||
@@ -88,13 +88,13 @@
|
||||
MODULE="boxjavalibv2-v3.0.10.jar" MVN="mvn:net.box/boxjavalibv2/v3.0.10"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-core"
|
||||
MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4"
|
||||
MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-databind"
|
||||
MODULE="jackson-databind-2.13.4.2.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2"
|
||||
MODULE="jackson-databind-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-annotations"
|
||||
MODULE="jackson-annotations-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4"
|
||||
MODULE="jackson-annotations-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="apache-http-client"
|
||||
MODULE="httpclient-4.5.13.jar" MVN="mvn:org.apache.httpcomponents/httpclient/4.5.13"
|
||||
|
||||
@@ -98,13 +98,13 @@
|
||||
MODULE="boxjavalibv2-v3.0.10.jar" MVN="mvn:net.box/boxjavalibv2/v3.0.10"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-core"
|
||||
MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4"
|
||||
MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-databind"
|
||||
MODULE="jackson-databind-2.13.4.2.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2"
|
||||
MODULE="jackson-databind-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-annotations"
|
||||
MODULE="jackson-annotations-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4"
|
||||
MODULE="jackson-annotations-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="apache-http-client"
|
||||
MODULE="httpclient-4.5.13.jar" MVN="mvn:org.apache.httpcomponents/httpclient/4.5.13"
|
||||
|
||||
@@ -106,13 +106,13 @@
|
||||
MODULE="boxjavalibv2-v3.0.10.jar" MVN="mvn:net.box/boxjavalibv2/v3.0.10"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-core"
|
||||
MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4"
|
||||
MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-databind"
|
||||
MODULE="jackson-databind-2.13.4.2.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2"
|
||||
MODULE="jackson-databind-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-annotations"
|
||||
MODULE="jackson-annotations-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4"
|
||||
MODULE="jackson-annotations-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="apache-http-client"
|
||||
MODULE="httpclient-4.5.13.jar" MVN="mvn:org.apache.httpcomponents/httpclient/4.5.13"
|
||||
|
||||
@@ -109,13 +109,13 @@
|
||||
MODULE="boxjavalibv2-v3.0.10.jar" MVN="mvn:net.box/boxjavalibv2/v3.0.10"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-core"
|
||||
MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4"
|
||||
MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-databind"
|
||||
MODULE="jackson-databind-2.13.4.2.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2"
|
||||
MODULE="jackson-databind-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-annotations"
|
||||
MODULE="jackson-annotations-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4"
|
||||
MODULE="jackson-annotations-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="apache-http-client"
|
||||
MODULE="httpclient-4.5.13.jar" MVN="mvn:org.apache.httpcomponents/httpclient/4.5.13"
|
||||
|
||||
@@ -168,7 +168,7 @@ COMPATIBILITY="ALL"
|
||||
<IMPORT NAME="sts" MODULE="sts-2.5.0.jar" MVN="mvn:org.apache.jclouds.api/sts/2.5.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-core" MODULE="jclouds-core-2.5.0.jar" MVN="mvn:org.apache.jclouds/jclouds-core/2.5.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="gson" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="guava" MODULE="guava-30.0-jre.jar" MVN="mvn:com.google.guava/guava/30.0-jre" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="guava" MODULE="guava-32.1.2-jre.jar" MVN="mvn:com.google.guava/guava/32.1.2-jre" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="failureaccess" MODULE="failureaccess-1.0.1.jar" MVN="mvn:com.google.guava/failureaccess/1.0.1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="listenablefuture" MODULE="listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar" MVN="mvn:com.google.guava/listenablefuture/9999.0-empty-to-avoid-conflict-with-guava" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jsr305" MODULE="jsr305-3.0.2.jar" MVN="mvn:com.google.code.findbugs/jsr305/3.0.2" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
|
||||
@@ -77,7 +77,7 @@ COMPATIBILITY="ALL"
|
||||
<IMPORT NAME="sts" MODULE="sts-2.5.0.jar" MVN="mvn:org.apache.jclouds.api/sts/2.5.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jclouds-core" MODULE="jclouds-core-2.5.0.jar" MVN="mvn:org.apache.jclouds/jclouds-core/2.5.0" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="gson" MODULE="gson-2.8.9.jar" MVN="mvn:com.google.code.gson/gson/2.8.9" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="guava" MODULE="guava-30.0-jre.jar" MVN="mvn:com.google.guava/guava/30.0-jre" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="guava" MODULE="guava-32.1.2-jre.jar" MVN="mvn:com.google.guava/guava/32.1.2-jre" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="failureaccess" MODULE="failureaccess-1.0.1.jar" MVN="mvn:com.google.guava/failureaccess/1.0.1" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="listenablefuture" MODULE="listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar" MVN="mvn:com.google.guava/listenablefuture/9999.0-empty-to-avoid-conflict-with-guava" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
<IMPORT NAME="jsr305" MODULE="jsr305-3.0.2.jar" MVN="mvn:com.google.code.findbugs/jsr305/3.0.2" REQUIRED_IF="PROVIDER=='AWS_EC2'"/>
|
||||
|
||||
@@ -49,7 +49,6 @@
|
||||
<ITEM NAME="MYSQL" VALUE="MYSQL" />
|
||||
<ITEM NAME="DBORACLE" VALUE="DBORACLE" />
|
||||
<ITEM NAME="PARACCEL" VALUE="PARACCEL" />
|
||||
<ITEM NAME="POSTGREPLUS" VALUE="POSTGREPLUS" />
|
||||
<ITEM NAME="POSTGRE" VALUE="POSTGRE" />
|
||||
<ITEM NAME="SQLITE" VALUE="SQLITE" />
|
||||
<ITEM NAME="SYBASE" VALUE="SYBASE" />
|
||||
@@ -63,7 +62,7 @@
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_AS400"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="REGEXP:^tAS400Connection|tJDBCConnection$"
|
||||
FILTER="REGEXP:^tAS400Connection|JDBCConnection$"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="3"
|
||||
SHOW_IF="DBTYPE=='AS400'"
|
||||
@@ -73,7 +72,7 @@
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_DB2"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="REGEXP:^tDB2Connection|tJDBCConnection$"
|
||||
FILTER="REGEXP:^tDB2Connection|JDBCConnection$"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="3"
|
||||
SHOW_IF="DBTYPE=='DB2'"
|
||||
@@ -83,7 +82,7 @@
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_FIREBIRD"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="REGEXP:^tFirebirdConnection|tJDBCConnection$"
|
||||
FILTER="REGEXP:^tFirebirdConnection|JDBCConnection$"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="3"
|
||||
SHOW_IF="DBTYPE=='FIREBIRD'"
|
||||
@@ -93,7 +92,7 @@
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_GREENPLUM"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="REGEXP:^tGreenplumConnection|tJDBCConnection$"
|
||||
FILTER="REGEXP:^tGreenplumConnection|JDBCConnection$"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="3"
|
||||
SHOW_IF="DBTYPE=='GREENPLUM'"
|
||||
@@ -103,7 +102,7 @@
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_HIVE"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="REGEXP:^tHiveConnection|tJDBCConnection$"
|
||||
FILTER="REGEXP:^tHiveConnection|JDBCConnection$"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="3"
|
||||
SHOW_IF="DBTYPE=='HIVE'"
|
||||
@@ -113,7 +112,7 @@
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_INGRES"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="REGEXP:^tIngresConnection|tJDBCConnection$"
|
||||
FILTER="REGEXP:^tIngresConnection|JDBCConnection$"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="3"
|
||||
SHOW_IF="DBTYPE=='INGRES'"
|
||||
@@ -123,7 +122,7 @@
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_INTERBASE"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="REGEXP:^tInterbaseConnection|tJDBCConnection$"
|
||||
FILTER="REGEXP:^tInterbaseConnection|JDBCConnection$"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="3"
|
||||
SHOW_IF="DBTYPE=='INTERBASE'"
|
||||
@@ -133,7 +132,7 @@
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_MSSQL"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="REGEXP:^tMSSqlConnection|tJDBCConnection$"
|
||||
FILTER="REGEXP:^tMSSqlConnection|JDBCConnection$"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="3"
|
||||
SHOW_IF="DBTYPE=='MSSQL'"
|
||||
@@ -143,7 +142,7 @@
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_MYSQL"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="REGEXP:^tMysqlConnection|tJDBCConnection$"
|
||||
FILTER="REGEXP:^tMysqlConnection|JDBCConnection$"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="3"
|
||||
SHOW_IF="DBTYPE=='MYSQL'"
|
||||
@@ -153,7 +152,7 @@
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_DBORACLE"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="REGEXP:^tOracleConnection|tJDBCConnection$"
|
||||
FILTER="REGEXP:^tOracleConnection|JDBCConnection$"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="3"
|
||||
SHOW_IF="DBTYPE=='DBORACLE'"
|
||||
@@ -163,27 +162,17 @@
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_PARACCEL"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="REGEXP:^tParAccelConnection|tJDBCConnection$"
|
||||
FILTER="REGEXP:^tParAccelConnection|JDBCConnection$"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="3"
|
||||
SHOW_IF="DBTYPE=='PARACCEL'"
|
||||
/>
|
||||
|
||||
<!-- Postgreplus -->
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_POSTGREPLUS"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="REGEXP:^tPostgresPlusConnection|tJDBCConnection$"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="3"
|
||||
SHOW_IF="DBTYPE=='POSTGREPLUS'"
|
||||
/>
|
||||
|
||||
/>
|
||||
|
||||
<!-- PostgreSQL -->
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_POSTGRE"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="REGEXP:^tPostgresqlConnection|tJDBCConnection$"
|
||||
FILTER="REGEXP:^tPostgresqlConnection|JDBCConnection$"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="3"
|
||||
SHOW_IF="DBTYPE=='POSTGRE'"
|
||||
@@ -193,7 +182,7 @@
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_SQLITE"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="REGEXP:^tSQLiteConnection|tJDBCConnection$"
|
||||
FILTER="REGEXP:^tSQLiteConnection|JDBCConnection$"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="3"
|
||||
SHOW_IF="DBTYPE=='SQLITE'"
|
||||
@@ -203,7 +192,7 @@
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_SYBASE"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="REGEXP:^tSybaseConnection|tJDBCConnection$"
|
||||
FILTER="REGEXP:^tSybaseConnection|JDBCConnection$"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="3"
|
||||
SHOW_IF="DBTYPE=='SYBASE'"
|
||||
@@ -213,7 +202,7 @@
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_TERADATA"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="REGEXP:^tTeradataConnection|tJDBCConnection$"
|
||||
FILTER="REGEXP:^tTeradataConnection|JDBCConnection$"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="3"
|
||||
SHOW_IF="DBTYPE=='TERADATA'"
|
||||
@@ -223,7 +212,7 @@
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_VERTICA"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="REGEXP:^tVerticaConnection|tJDBCConnection$"
|
||||
FILTER="REGEXP:^tVerticaConnection|JDBCConnection$"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="3"
|
||||
SHOW_IF="DBTYPE=='VERTICA'"
|
||||
@@ -247,7 +236,6 @@
|
||||
<DEFAULT IF="DBTYPE=='MYSQL'">mysql_id</DEFAULT>
|
||||
<DEFAULT IF="DBTYPE=='DBORACLE'">oracle_id</DEFAULT>
|
||||
<DEFAULT IF="DBTYPE=='POSTGRE'">postgres_id</DEFAULT>
|
||||
<DEFAULT IF="DBTYPE=='POSTGREPLUS'">postgresplus_id</DEFAULT>
|
||||
<DEFAULT IF="DBTYPE=='SQLITE'">sqlite_id</DEFAULT>
|
||||
<DEFAULT IF="DBTYPE=='PARACCEL'">paraccel_id</DEFAULT>
|
||||
<DEFAULT IF="DBTYPE=='SYBASE'">sybase_id</DEFAULT>
|
||||
|
||||
@@ -46,9 +46,9 @@
|
||||
or (DBTYPE=='INGRES' and USE_EXISTING_CONNECTION == 'true') or (DBTYPE=='INTERBASE' and USE_EXISTING_CONNECTION == 'true')
|
||||
or (DBTYPE=='SQLITE' and USE_EXISTING_CONNECTION == 'true') or (DBTYPE=='SYBASE' and USE_EXISTING_CONNECTION == 'true')
|
||||
or (DBTYPE=='TERADATA' and USE_EXISTING_CONNECTION == 'true') or (DBTYPE=='NETEZZA' and USE_EXISTING_CONNECTION == 'true')
|
||||
or (DBTYPE=='POSTGREPLUS' and USE_EXISTING_CONNECTION == 'true') or (DBTYPE=='ACCESS' and USE_EXISTING_CONNECTION == 'true')
|
||||
or (DBTYPE=='GREENPLUM' and USE_EXISTING_CONNECTION == 'true')or (DBTYPE=='VERTICA' and USE_EXISTING_CONNECTION == 'true')
|
||||
or (DBTYPE=='REDSHIFT' and USE_EXISTING_CONNECTION == 'true') or (DBTYPE=='SNOWFLAKE' and USE_EXISTING_CONNECTION == 'true')"
|
||||
or (DBTYPE=='ACCESS' and USE_EXISTING_CONNECTION == 'true') or (DBTYPE=='GREENPLUM' and USE_EXISTING_CONNECTION == 'true')
|
||||
or (DBTYPE=='VERTICA' and USE_EXISTING_CONNECTION == 'true') or (DBTYPE=='REDSHIFT' and USE_EXISTING_CONNECTION == 'true')
|
||||
or (DBTYPE=='SNOWFLAKE' and USE_EXISTING_CONNECTION == 'true')"
|
||||
/>
|
||||
|
||||
<PARAMETER
|
||||
@@ -74,7 +74,6 @@
|
||||
<ITEM NAME="NETEZZA" VALUE="NETEZZA"/>
|
||||
<ITEM NAME="ODBC" VALUE="ODBC"/>
|
||||
<ITEM NAME="DBORACLE" VALUE="DBORACLE"/>
|
||||
<ITEM NAME="POSTGREPLUS" VALUE="POSTGREPLUS"/>
|
||||
<ITEM NAME="POSTGRE" VALUE="POSTGRE"/>
|
||||
<ITEM NAME="REDSHIFT" VALUE="REDSHIFT"/>
|
||||
<ITEM NAME="SNOWFLAKE" VALUE="SNOWFLAKE"/>
|
||||
@@ -109,7 +108,7 @@
|
||||
|
||||
<PARAMETER NAME="USE_EXISTING_CONNECTION" FIELD="CHECK" NUM_ROW="30"
|
||||
SHOW_IF="(DBTYPE=='MSSQL') or (DBTYPE=='MYSQL') or (DBTYPE=='DBORACLE') or (DBTYPE=='POSTGRE')
|
||||
or (DBTYPE=='POSTGREPLUS') or (DBTYPE=='TERADATA') or (DBTYPE=='NETEZZA') or (DBTYPE=='AS400')
|
||||
or (DBTYPE=='TERADATA') or (DBTYPE=='NETEZZA') or (DBTYPE=='AS400')
|
||||
or (DBTYPE=='DB2') or (DBTYPE=='FIREBIRD') or (DBTYPE=='INFORMIX') or (DBTYPE=='INGRES')
|
||||
or (DBTYPE=='SQLITE') or (DBTYPE=='SYBASE') or (DBTYPE=='ACCESS') or (DBTYPE=='GREENPLUM') or (DBTYPE=='VERTICA')
|
||||
or (DBTYPE=='EXASOL') or (DBTYPE=='REDSHIFT') or (DBTYPE=='SNOWFLAKE')">
|
||||
@@ -121,7 +120,7 @@
|
||||
NOT_SHOW_IF="(DBTYPE=='ACCESS') or (DBTYPE=='SQLITE') or (DBTYPE == 'ODBC') or (DBTYPE == 'JAVADB' and FRAMEWORK_TYPE=='EMBEDED')
|
||||
or (DBTYPE == 'HSQLDB' and RUNNING_MODE == 'HSQLDB_INPROGRESS_PERSISTENT') or (DBTYPE=='MYSQL' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='MSSQL' and USE_EXISTING_CONNECTION == 'true') or (DBTYPE=='DBORACLE' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='POSTGRE' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='POSTGREPLUS' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='POSTGRE' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='TERADATA' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='NETEZZA' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='AS400' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='DB2' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='FIREBIRD' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='INFORMIX' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
@@ -138,7 +137,7 @@
|
||||
NOT_SHOW_IF="(DBTYPE=='FIREBIRD') or (DBTYPE=='ACCESS') or (DBTYPE=='SQLITE') or (DBTYPE == 'HSQLDB')
|
||||
or (DBTYPE == 'JAVADB') or (DBTYPE == 'ODBC') or (DBTYPE=='MYSQL' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='MSSQL' and USE_EXISTING_CONNECTION == 'true') or (DBTYPE=='DBORACLE' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='POSTGRE' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='POSTGREPLUS' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='POSTGRE' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='TERADATA' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='NETEZZA' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='AS400' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='DB2' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='INFORMIX' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='INGRES' and USE_EXISTING_CONNECTION == 'true')
|
||||
@@ -174,7 +173,7 @@
|
||||
REPOSITORY_VALUE="USERNAME" REQUIRED="true"
|
||||
NOT_SHOW_IF="(DBTYPE=='SQLITE') or (DBTYPE=='MSSQL' and USE_EXISTING_CONNECTION == 'true') or (DBTYPE=='MYSQL' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='DBORACLE' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='POSTGRE' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='POSTGREPLUS' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='TERADATA' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='TERADATA' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='NETEZZA' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='AS400' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='DB2' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='FIREBIRD' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='INFORMIX' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='INGRES' and USE_EXISTING_CONNECTION == 'true')
|
||||
@@ -190,7 +189,7 @@
|
||||
REPOSITORY_VALUE="PASSWORD" REQUIRED="true"
|
||||
NOT_SHOW_IF="(DBTYPE=='SQLITE') or (DBTYPE=='MSSQL' and USE_EXISTING_CONNECTION == 'true') or (DBTYPE=='MYSQL' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='DBORACLE' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='POSTGRE' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='POSTGREPLUS' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='TERADATA' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='TERADATA' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='NETEZZA' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='AS400' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='DB2' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='FIREBIRD' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='INFORMIX' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='INGRES' and USE_EXISTING_CONNECTION == 'true')
|
||||
@@ -211,7 +210,7 @@
|
||||
NOT_SHOW_IF="(DBTYPE=='AS400') or (DBTYPE=='FIREBIRD') or (DBTYPE=='ACCESS') or (DBTYPE=='SQLITE') or (DBTYPE=='TERADATA')
|
||||
or (DBTYPE=='MSSQL' and USE_EXISTING_CONNECTION == 'true') or (DBTYPE=='MYSQL' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='DBORACLE' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='NETEZZA' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='POSTGRE' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='POSTGREPLUS' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE=='POSTGRE' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
or (DBTYPE == 'JAVADB' and FRAMEWORK_TYPE=='EMBEDED') or (DBTYPE == 'ODBC')
|
||||
or (DBTYPE == 'HSQLDB' and RUNNING_MODE == 'HSQLDB_INPROGRESS_PERSISTENT')
|
||||
or (DBTYPE=='DB2' and USE_EXISTING_CONNECTION=='TRUE') or (DBTYPE=='INFORMIX' and USE_EXISTING_CONNECTION=='TRUE')
|
||||
@@ -229,7 +228,7 @@
|
||||
FIELD="TEXT"
|
||||
NUM_ROW="70"
|
||||
REPOSITORY_VALUE="SCHEMA"
|
||||
SHOW_IF="(DBTYPE=='DBORACLE' or DBTYPE=='POSTGRE' or DBTYPE=='POSTGREPLUS' or DBTYPE=='INFORMIX' or DBTYPE=='DB2' or DBTYPE=='GREENPLUM' or DBTYPE=='VERTICA' or DBTYPE=='MSSQL' or DBTYPE=='SYBASE'
|
||||
SHOW_IF="(DBTYPE=='DBORACLE' or DBTYPE=='POSTGRE' or DBTYPE=='INFORMIX' or DBTYPE=='DB2' or DBTYPE=='GREENPLUM' or DBTYPE=='VERTICA' or DBTYPE=='MSSQL' or DBTYPE=='SYBASE'
|
||||
or DBTYPE=='EXASOL' or DBTYPE=='REDSHIFT' or DBTYPE=='SNOWFLAKE')
|
||||
and (USE_EXISTING_CONNECTION == 'false')"
|
||||
>
|
||||
@@ -543,7 +542,7 @@
|
||||
FIELD="CLOSED_LIST"
|
||||
NUM_ROW="50"
|
||||
REPOSITORY_VALUE="DB_VERSION"
|
||||
SHOW_IF="((DBTYPE=='POSTGRE') or (DBTYPE=='POSTGREPLUS')) and (USE_EXISTING_CONNECTION == 'false')">
|
||||
SHOW_IF="(DBTYPE=='POSTGRE') and (USE_EXISTING_CONNECTION == 'false')">
|
||||
<ITEMS DEFAULT="V9_X">
|
||||
<ITEM NAME="PRIOR_TO_V9" VALUE="PRIOR_TO_V9" />
|
||||
<ITEM NAME="V9_X" VALUE="V9_X" />
|
||||
@@ -560,17 +559,6 @@
|
||||
</PARAMETER>
|
||||
<!--Postgre configuration end-->
|
||||
|
||||
<!--PostgrePlus configuration start-->
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_POSTGREPLUS"
|
||||
FIELD="COMPONENT_LIST"
|
||||
FILTER="tPostgresPlusConnection"
|
||||
REQUIRED="true"
|
||||
NUM_ROW="30"
|
||||
SHOW_IF="(DBTYPE=='POSTGREPLUS') and (USE_EXISTING_CONNECTION == 'true')"
|
||||
/>
|
||||
<!--PostgrePlus configuration end-->
|
||||
|
||||
<!--SQLite configuration start-->
|
||||
<PARAMETER
|
||||
NAME="CONNECTION_SQLITE"
|
||||
@@ -739,7 +727,6 @@
|
||||
<DEFAULT IF="DBTYPE=='MYSQL'">mysql_id</DEFAULT>
|
||||
<DEFAULT IF="DBTYPE=='DBORACLE'">oracle_id</DEFAULT>
|
||||
<DEFAULT IF="DBTYPE=='POSTGRE'">postgres_id</DEFAULT>
|
||||
<DEFAULT IF="DBTYPE=='POSTGREPLUS'">postgresplus_id</DEFAULT>
|
||||
<DEFAULT IF="DBTYPE=='SQLITE'">sqlite_id</DEFAULT>
|
||||
<DEFAULT IF="DBTYPE=='TERADATA'">teradata_id</DEFAULT>
|
||||
<DEFAULT IF="DBTYPE=='NETEZZA'">netezza_id</DEFAULT>
|
||||
@@ -850,9 +837,9 @@
|
||||
<IMPORT NAME="Driver-MSSQL-prop" MODULE="mssql-jdbc.jar" MVN="mvn:com.microsoft.sqlserver/mssql-jdbc/actual" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP')" />
|
||||
<!--Active directory dependency module: msal4j and transitive -->
|
||||
<IMPORT NAME="msal4j" MODULE="msal4j-1.11.0.jar" MVN="mvn:com.microsoft.azure/msal4j/1.11.0" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="jackson-core" MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="jackson-databind" MODULE="jackson-databind-2.13.4.2.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="jackson-annotations" MODULE="jackson-annotations-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="jackson-core" MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="jackson-databind" MODULE="jackson-databind-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="jackson-annotations" MODULE="jackson-annotations-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="oauth2-oidc-sdk" MODULE="oauth2-oidc-sdk-9.7.jar" MVN="mvn:com.nimbusds/oauth2-oidc-sdk/9.7" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="jcip-annotations" MODULE="jcip-annotations-1.0-1.jar" MVN="mvn:com.github.stephenc.jcip/jcip-annotations/1.0-1" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="json-smart" MODULE="json-smart-2.4.11.jar" MVN="mvn:net.minidev/json-smart/2.4.11" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
@@ -860,7 +847,7 @@
|
||||
<IMPORT NAME="asm" MODULE="asm-9.5.jar" MVN="mvn:org.ow2.asm/asm/9.5" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="content-type" MODULE="content-type-2.1.jar" MVN="mvn:com.nimbusds/content-type/2.1" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="lang-tag" MODULE="lang-tag-1.5.jar" MVN="mvn:com.nimbusds/lang-tag/1.5" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.22.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.22" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.30.2.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.30.2" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MSSQL') AND (MSSQL_DRIVER=='MSSQL_PROP') AND (MSSQL_ACTIVE_DIR_AUTH == 'true')" />
|
||||
|
||||
<IMPORT NAME="Driver-MYSQL5" MODULE="mysql-connector-java-5.1.49.jar" MVN="mvn:mysql/mysql-connector-java/5.1.49" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') and (DBTYPE=='MYSQL') and (DB_MYSQL_VERSION=='MYSQL_5')"/>
|
||||
<IMPORT NAME="Driver-MYSQL8" MODULE="mysql-connector-j-8.0.33.jar" MVN="mvn:com.mysql/mysql-connector-j/8.0.33" REQUIRED_IF="(DB_MYSQL_VERSION == 'MYSQL_8') AND (USE_EXISTING_CONNECTION == 'false') AND (DBTYPE=='MYSQL')" />
|
||||
@@ -868,8 +855,8 @@
|
||||
<IMPORT NAME="Driver-Oracle11g" MODULE="ojdbc6.jar" MVN="mvn:org.talend.libraries/ojdbc6/6.0.0" REQUIRED_IF="(DBTYPE=='DBORACLE') AND (DB_VERSION == 'ORACLE_11') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<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.19.0.0.jar" MVN="mvn:com.oracle.database.jdbc/ojdbc8/19.19.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.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-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') AND (DB_POSTGRE_VERSION =='PRIOR_TO_V9')) or (DBTYPE=='GREENPLUM'))" />
|
||||
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.6.0.jar" MVN="mvn:org.postgresql/postgresql/42.6.0" REQUIRED_IF="(USE_EXISTING_CONNECTION == 'false') AND ((DBTYPE=='POSTGRE') 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-2.7.1.jar" MVN="mvn:org.hsqldb/hsqldb/2.7.1" 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')" />
|
||||
|
||||
@@ -176,7 +176,7 @@ abstract class Manager {
|
||||
}
|
||||
createTableSQL.append(suffix);
|
||||
} else {
|
||||
boolean isPostgresishDB = ("postgres_id".equalsIgnoreCase(getDBMSId()) || "postgresplus_id".equalsIgnoreCase(getDBMSId()) || "greenplum_id".equalsIgnoreCase(getDBMSId()) );
|
||||
boolean isPostgresishDB = ("postgres_id".equalsIgnoreCase(getDBMSId()) || "greenplum_id".equalsIgnoreCase(getDBMSId()) );
|
||||
if(!lengthIgnored) {
|
||||
if (isPostgresishDB && metadataColumn.getLength() == null) {
|
||||
}else {
|
||||
@@ -1354,69 +1354,6 @@ class PostgreManager extends Manager {
|
||||
return javaCode.toString();
|
||||
}
|
||||
}
|
||||
class PostgrePlusManager extends Manager {
|
||||
private String host;
|
||||
private String port;
|
||||
private String dbSchema;
|
||||
private boolean useExistingConnection;
|
||||
private String connection;
|
||||
|
||||
public PostgrePlusManager(String host, String port, String dbName, String tableName, String dbSchema, String userName, boolean useExistingConnection, String connection, String cid, String additionalParams) {
|
||||
super(dbName, tableName, userName, cid, additionalParams);
|
||||
this.host = host;
|
||||
this.port = port;
|
||||
this.dbSchema = dbSchema;
|
||||
this.useExistingConnection = useExistingConnection;
|
||||
this.connection = connection;
|
||||
}
|
||||
protected String getDriver() {
|
||||
return "org.postgresql.Driver";
|
||||
}
|
||||
public String getSpecificConnectionURL() {
|
||||
return "\"jdbc:postgresql://\" + " + host + " + \":\" + " + port + " + \"/\" + " + dbName;
|
||||
}
|
||||
public String getConnection() {
|
||||
StringBuilder javaCode = new StringBuilder();
|
||||
if(useExistingConnection) {
|
||||
javaCode.append(retrieveTable());
|
||||
javaCode.append("java.sql.Connection conn_" + cid + " = (java.sql.Connection)globalMap.get(\"conn_" + connection + "\");");
|
||||
} else {
|
||||
javaCode.append(super.getConnection());
|
||||
}
|
||||
return javaCode.toString();
|
||||
}
|
||||
protected String getDBMSId() {
|
||||
return "postgresplus_id";
|
||||
}
|
||||
protected String getLProtectedChar() {
|
||||
return "\\\"";
|
||||
}
|
||||
protected String getRProtectedChar() {
|
||||
return "\\\"";
|
||||
}
|
||||
public String closeConnection() {
|
||||
StringBuilder javaCode = new StringBuilder();
|
||||
if(useExistingConnection) {
|
||||
javaCode.append("");
|
||||
} else {
|
||||
javaCode.append(super.closeConnection());
|
||||
}
|
||||
return javaCode.toString();
|
||||
}
|
||||
protected String retrieveTable() {
|
||||
StringBuilder javaCode = new StringBuilder();
|
||||
javaCode.append(super.retrieveTable());
|
||||
if(useExistingConnection) {
|
||||
javaCode.append("String dbSchema_" + cid + " = (String)globalMap.get(\"schema_" + connection + "\");\r\n");
|
||||
} else {
|
||||
javaCode.append("String dbSchema_" + cid + " = " + dbSchema + ";\r\n");
|
||||
}
|
||||
javaCode.append("if(dbSchema_" + cid + " != null && dbSchema_" + cid + ".trim().length() != 0) {");
|
||||
javaCode.append("tableName_" + cid + " = dbSchema_" + cid + " + \"" + getLProtectedChar() + "." + getRProtectedChar() + "\" + tableName_" + cid + ";\r\n");
|
||||
javaCode.append("}");
|
||||
return javaCode.toString();
|
||||
}
|
||||
}
|
||||
class SQLiteManager extends Manager {
|
||||
private boolean useExistingConnection;
|
||||
private String connection;
|
||||
@@ -1695,7 +1632,7 @@ class TeradataManager extends Manager {
|
||||
createTableSQL.append(suffix);
|
||||
} else {
|
||||
if(!lengthIgnored) {
|
||||
if (("postgres_id".equalsIgnoreCase(getDBMSId()) || "postgresplus_id".equalsIgnoreCase(getDBMSId()) || "greenplum_id".equalsIgnoreCase(getDBMSId()) ) && metadataColumn.getLength() == null) {
|
||||
if (("postgres_id".equalsIgnoreCase(getDBMSId()) || "greenplum_id".equalsIgnoreCase(getDBMSId()) ) && metadataColumn.getLength() == null) {
|
||||
}else {
|
||||
prefix = "(";
|
||||
suffix = ") ";
|
||||
@@ -1714,7 +1651,7 @@ class TeradataManager extends Manager {
|
||||
createTableSQL.append(comma + precision);
|
||||
}
|
||||
|
||||
if (("postgres_id".equalsIgnoreCase(getDBMSId()) || "postgresplus_id".equalsIgnoreCase(getDBMSId()) ||"greenplum_id".equalsIgnoreCase(getDBMSId()) ) && metadataColumn.getLength() == null) {
|
||||
if (("postgres_id".equalsIgnoreCase(getDBMSId()) ||"greenplum_id".equalsIgnoreCase(getDBMSId()) ) && metadataColumn.getLength() == null) {
|
||||
} else {
|
||||
createTableSQL.append(suffix);
|
||||
}
|
||||
@@ -2339,15 +2276,6 @@ class ManagerFactory {
|
||||
boolean tempTable = ("true").equals(ElementParameterParser.getValue(node, "__TEMPTABLE__"));
|
||||
boolean unloggedTable = ("true").equals(ElementParameterParser.getValue(node, "__UNLOGGED__"));
|
||||
manager = new PostgreManager(host, port, dbName, tableName, dbSchema, userName, useExistingConnection, connection, cid, tempTable, unloggedTable, additionalParams);
|
||||
} else if(("POSTGREPLUS").equals(dbType)) {
|
||||
String host = ElementParameterParser.getValue(node, "__HOST__");
|
||||
String port = ElementParameterParser.getValue(node, "__PORT__");
|
||||
String dbSchema = ElementParameterParser.getValue(node, "__SCHEMA_DB__");
|
||||
String dbName = ElementParameterParser.getValue(node, "__DBNAME__");
|
||||
String userName = ElementParameterParser.getValue(node, "__USER__");
|
||||
boolean useExistingConnection = ("true").equals(ElementParameterParser.getValue(node, "__USE_EXISTING_CONNECTION__"));
|
||||
String connection = stringUtil.getString(ElementParameterParser.getValue(node, "__CONNECTION_POSTGREPLUS__"));
|
||||
manager = new PostgrePlusManager(host, port, dbName, tableName, dbSchema, userName, useExistingConnection, connection, cid, additionalParams);
|
||||
} else if(("SQLITE").equals(dbType)) {
|
||||
String dbName = ElementParameterParser.getValue(node, "__DBFILE_SQLITE__");
|
||||
String userName = ElementParameterParser.getValue(node, "__USER__");
|
||||
@@ -2446,7 +2374,7 @@ if(columnList != null && columnList.size() > 0) {
|
||||
String cid = node.getUniqueName();
|
||||
boolean isLog4jEnabled = ("true").equals(ElementParameterParser.getValue(node.getProcess(), "__LOG4J_ACTIVATE__"));
|
||||
boolean tableNameCaseSensitive=false;
|
||||
if("DB2".equalsIgnoreCase(dbType)||"POSTGRE".equalsIgnoreCase(dbType)||"POSTGREPLUS".equalsIgnoreCase(dbType)||"GREENPLUM".equalsIgnoreCase(dbType)){
|
||||
if("DB2".equalsIgnoreCase(dbType)||"POSTGRE".equalsIgnoreCase(dbType)||"GREENPLUM".equalsIgnoreCase(dbType)){
|
||||
tableNameCaseSensitive=true;
|
||||
}
|
||||
if(("HSQLDB").equals(dbType)){
|
||||
@@ -2555,7 +2483,7 @@ if(columnList != null && columnList.size() > 0) {
|
||||
}
|
||||
}
|
||||
<%
|
||||
} else if ("GREENPLUM".equalsIgnoreCase(dbType) || "POSTGRE".equalsIgnoreCase(dbType) || "POSTGREPLUS".equalsIgnoreCase(dbType)) {
|
||||
} else if ("GREENPLUM".equalsIgnoreCase(dbType) || "POSTGRE".equalsIgnoreCase(dbType)) {
|
||||
if ("true".equals(ElementParameterParser.getValue(node, "__TEMPTABLE__"))) {
|
||||
%>
|
||||
java.sql.PreparedStatement tempTablePs_<%=cid %> = conn_<%=cid %>.prepareStatement("SELECT * FROM information_schema.tables WHERE table_type='LOCAL TEMPORARY' AND table_name = ?");
|
||||
|
||||
@@ -96,7 +96,7 @@ DB_MYSQL_VERSION.ITEM.MYSQL_5=Mysql 5
|
||||
DB_MYSQL_VERSION.ITEM.MYSQL_8=Mysql 8
|
||||
DB_MYSQL_VERSION.ITEM.MARIADB=MariaDB
|
||||
DB_POSTGRE_VERSION.NAME=DB Version
|
||||
DB_POSTGRE_VERSION.ITEM.PRIOR_TO_V9=Prior to v9
|
||||
DB_POSTGRE_VERSION.ITEM.PRIOR_TO_V9=Prior to v9 (Deprecated)
|
||||
DB_POSTGRE_VERSION.ITEM.V9_X=v9 and later
|
||||
QUERY.NAME=Query
|
||||
CREATE_TABLE_TYPE.NAME=Create
|
||||
|
||||
@@ -96,7 +96,7 @@ DB_MYSQL_VERSION.ITEM.MYSQL_5=MySQL 5
|
||||
DB_MYSQL_VERSION.ITEM.MYSQL_8=MySQL 8
|
||||
DB_MYSQL_VERSION.ITEM.MARIADB=MariaDB
|
||||
DB_POSTGRE_VERSION.NAME=Version de la base de donn\u00E9es
|
||||
DB_POSTGRE_VERSION.ITEM.PRIOR_TO_V9=Ant\u00E9rieure \u00E0 la v9
|
||||
DB_POSTGRE_VERSION.ITEM.PRIOR_TO_V9=Ant\u00E9rieure \u00E0 la v9 (d\u00E9pr\u00E9ci\u00E9e)
|
||||
DB_POSTGRE_VERSION.ITEM.V9_X=V9 et plus
|
||||
QUERY.NAME=Requ\u00EAte
|
||||
CREATE_TABLE_TYPE.NAME=Cr\u00E9er
|
||||
|
||||
@@ -96,7 +96,7 @@ DB_MYSQL_VERSION.ITEM.MYSQL_5=Mysql 5
|
||||
DB_MYSQL_VERSION.ITEM.MYSQL_8=Mysql8
|
||||
DB_MYSQL_VERSION.ITEM.MARIADB=MariaDB
|
||||
DB_POSTGRE_VERSION.NAME=\u30C7\u30FC\u30BF\u30D9\u30FC\u30B9\u30D0\u30FC\u30B8\u30E7\u30F3
|
||||
DB_POSTGRE_VERSION.ITEM.PRIOR_TO_V9=v9\u4EE5\u524D
|
||||
DB_POSTGRE_VERSION.ITEM.PRIOR_TO_V9=v9\u4EE5\u524D(\u975E\u63A8\u5968)
|
||||
DB_POSTGRE_VERSION.ITEM.V9_X=v9\u4EE5\u964D
|
||||
QUERY.NAME=\u30AF\u30A8\u30EA\u30FC
|
||||
CREATE_TABLE_TYPE.NAME=\u306E\u4F5C\u6210
|
||||
|
||||
@@ -96,7 +96,7 @@ DB_MYSQL_VERSION.ITEM.MYSQL_5=Mysql 5
|
||||
DB_MYSQL_VERSION.ITEM.MYSQL_8=Mysql 8
|
||||
DB_MYSQL_VERSION.ITEM.MARIADB=MariaDB
|
||||
DB_POSTGRE_VERSION.NAME=\u6570\u636E\u5E93\u7248\u672C
|
||||
DB_POSTGRE_VERSION.ITEM.PRIOR_TO_V9=v9 \u4E4B\u524D\u7248\u672C
|
||||
DB_POSTGRE_VERSION.ITEM.PRIOR_TO_V9=v9 \u4E4B\u524D\u7684\u7248\u672C (\u5DF2\u5F03\u7528)
|
||||
DB_POSTGRE_VERSION.ITEM.V9_X=v9 \u53CA\u66F4\u65B0\u7248\u672C
|
||||
QUERY.NAME=\u67E5\u8BE2
|
||||
CREATE_TABLE_TYPE.NAME=\u521B\u5EFA
|
||||
|
||||
@@ -61,7 +61,7 @@
|
||||
MODULE="dropbox-core-sdk-2.1.2.jar" MVN="mvn:org.talend.libraries/dropbox-core-sdk-2.1.2/6.3.0"
|
||||
REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-core"
|
||||
MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4"
|
||||
MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3"
|
||||
REQUIRED="true" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
@@ -71,7 +71,7 @@
|
||||
MODULE="dropbox-core-sdk-2.1.2.jar" MVN="mvn:org.talend.libraries/dropbox-core-sdk-2.1.2/6.3.0"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-core"
|
||||
MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4"
|
||||
MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
@@ -85,7 +85,7 @@
|
||||
MODULE="dropbox-core-sdk-2.1.2.jar" MVN="mvn:org.talend.libraries/dropbox-core-sdk-2.1.2/6.3.0"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-core"
|
||||
MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4"
|
||||
MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
@@ -83,7 +83,7 @@
|
||||
MODULE="dropbox-core-sdk-2.1.2.jar" MVN="mvn:org.talend.libraries/dropbox-core-sdk-2.1.2/6.3.0"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-core"
|
||||
MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4"
|
||||
MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
@@ -110,7 +110,7 @@
|
||||
MODULE="dropbox-core-sdk-2.1.2.jar" MVN="mvn:org.talend.libraries/dropbox-core-sdk-2.1.2/6.3.0"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
<IMPORT NAME="jackson-core"
|
||||
MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4"
|
||||
MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3"
|
||||
REQUIRED_IF="USE_EXISTING_CONNECTION == 'false'" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
@@ -36,9 +36,9 @@
|
||||
|
||||
<CODEGENERATION>
|
||||
<IMPORTS>
|
||||
<IMPORT NAME="jackson-databind-2.13.4.2.jar" MODULE="jackson-databind-2.13.4.2.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2" REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-core-2.13.4.jar" MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4" REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-annotations-2.13.4.jar" MODULE="jackson-annotations-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4" REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-databind-2.14.3.jar" MODULE="jackson-databind-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3" REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-core-2.14.3.jar" MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3" REQUIRED="true" />
|
||||
<IMPORT NAME="jackson-annotations-2.14.3.jar" MODULE="jackson-annotations-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3" REQUIRED="true" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
|
||||
@@ -200,9 +200,9 @@
|
||||
<IMPORT NAME="Driver-mssql-jdbc" MODULE="mssql-jdbc.jar" MVN="mvn:com.microsoft.sqlserver/mssql-jdbc/actual" REQUIRED_IF="(DRIVER == 'MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<!--Active directory dependency module: msal4j and transitive -->
|
||||
<IMPORT NAME="msal4j" MODULE="msal4j-1.11.0.jar" MVN="mvn:com.microsoft.azure/msal4j/1.11.0" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-core" MODULE="jackson-core-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.13.4" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-databind" MODULE="jackson-databind-2.13.4.2.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.13.4.2" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-annotations" MODULE="jackson-annotations-2.13.4.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.13.4" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-core" MODULE="jackson-core-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-core/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-databind" MODULE="jackson-databind-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-databind/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jackson-annotations" MODULE="jackson-annotations-2.14.3.jar" MVN="mvn:com.fasterxml.jackson.core/jackson-annotations/2.14.3" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="oauth2-oidc-sdk" MODULE="oauth2-oidc-sdk-9.7.jar" MVN="mvn:com.nimbusds/oauth2-oidc-sdk/9.7" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="jcip-annotations" MODULE="jcip-annotations-1.0-1.jar" MVN="mvn:com.github.stephenc.jcip/jcip-annotations/1.0-1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="json-smart" MODULE="json-smart-2.4.11.jar" MVN="mvn:net.minidev/json-smart/2.4.11" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
@@ -212,7 +212,7 @@
|
||||
<IMPORT NAME="content-type" MODULE="content-type-2.1.jar" MVN="mvn:com.nimbusds/content-type/2.1" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="lang-tag" MODULE="lang-tag-1.5.jar" MVN="mvn:com.nimbusds/lang-tag/1.5" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.22.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.22" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
<IMPORT NAME="nimbus-jose-jwt" MODULE="nimbus-jose-jwt-9.30.2.jar" MVN="mvn:com.nimbusds/nimbus-jose-jwt/9.30.2" REQUIRED_IF="(ACTIVE_DIR_AUTH == 'true') AND (DRIVER=='MSSQL_PROP') AND (USE_EXISTING_CONNECTION == 'false')" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
|
||||
@@ -56,7 +56,7 @@
|
||||
<PARAMETER
|
||||
NAME="CONNECTION"
|
||||
FIELD="COMPONENT_LIST"
|
||||
REQUIRED="true" FILTER="REGEXP:^tJDBCConnection|tSnowflakeConnection|tSAPHanaConnection|tDeltaLakeConnection$"
|
||||
REQUIRED="true" FILTER="REGEXP:^JDBCConnection|tSnowflakeConnection|tSAPHanaConnection|tDeltaLakeConnection$"
|
||||
NUM_ROW="2"
|
||||
SHOW_IF="(#LINK@CONNECTOR.OUT.TABLE_REF == '0') AND (USE_EXISTING_CONNECTION == 'true')"
|
||||
DYNAMIC_SETTINGS="true"/>
|
||||
|
||||
@@ -221,7 +221,7 @@
|
||||
} else if("MYSQL".equals(dbType)){
|
||||
return "`";
|
||||
}
|
||||
String[] array_types = new String[]{"DB2","GREENPLUM","POSTGRE","POSTGREPLUS","PARACCEL","INGRES","SQLITE","TERADATA","INTERBASE"};
|
||||
String[] array_types = new String[]{"DB2","GREENPLUM","POSTGRE","PARACCEL","INGRES","SQLITE","TERADATA","INTERBASE"};
|
||||
for(String db :array_types){
|
||||
if(db.equals(dbType)){
|
||||
return "\\\"";
|
||||
|
||||
@@ -189,7 +189,7 @@
|
||||
|
||||
<CODEGENERATION>
|
||||
<IMPORTS>
|
||||
<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-Postgres9" MODULE="postgresql-42.6.0.jar" MVN="mvn:org.postgresql/postgresql/42.6.0" 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>
|
||||
|
||||
@@ -35,5 +35,5 @@ LINK_STYLE.ITEM.BEZIER_CURVE=Bezier curve
|
||||
LINK_STYLE.ITEM.LINE=Line (fastest)
|
||||
CONNECTION.NAME=Component List
|
||||
DB_VERSION.NAME=DB Version
|
||||
DB_VERSION.ITEM.PRIOR_TO_V9=Prior to v9
|
||||
DB_VERSION.ITEM.PRIOR_TO_V9=Prior to v9 (Deprecated)
|
||||
DB_VERSION.ITEM.V9_X=v9 and later
|
||||
|
||||
@@ -35,5 +35,5 @@ LINK_STYLE.ITEM.BEZIER_CURVE=Courbe de B\u00E9zier
|
||||
LINK_STYLE.ITEM.LINE=Ligne (rapide)
|
||||
CONNECTION.NAME=Liste des composants
|
||||
DB_VERSION.NAME=Version de la base de donn\u00E9es
|
||||
DB_VERSION.ITEM.PRIOR_TO_V9=Ant\u00E9rieure \u00E0 la V9
|
||||
DB_VERSION.ITEM.PRIOR_TO_V9=Ant\u00E9rieure \u00E0 la v9 (d\u00E9pr\u00E9ci\u00E9e)
|
||||
DB_VERSION.ITEM.V9_X=V9 et plus
|
||||
|
||||
@@ -35,5 +35,5 @@ LINK_STYLE.ITEM.BEZIER_CURVE=\u30D9\u30B8\u30A7\u66F2\u7DDA
|
||||
LINK_STYLE.ITEM.LINE=\u76F4\u7DDA(\u6700\u901F)
|
||||
CONNECTION.NAME=\u30B3\u30F3\u30DD\u30FC\u30CD\u30F3\u30C8\u30EA\u30B9\u30C8
|
||||
DB_VERSION.NAME=\u30C7\u30FC\u30BF\u30D9\u30FC\u30B9\u30D0\u30FC\u30B8\u30E7\u30F3
|
||||
DB_VERSION.ITEM.PRIOR_TO_V9=v9\u4EE5\u524D
|
||||
DB_VERSION.ITEM.PRIOR_TO_V9=v9\u4EE5\u524D(\u975E\u63A8\u5968)
|
||||
DB_VERSION.ITEM.V9_X=v9\u4EE5\u964D
|
||||
|
||||
@@ -35,5 +35,5 @@ LINK_STYLE.ITEM.BEZIER_CURVE=\u8D1D\u585E\u5C14\u66F2\u7EBF
|
||||
LINK_STYLE.ITEM.LINE=\u76F4\u7EBF (\u6700\u5FEB)
|
||||
CONNECTION.NAME=\u7EC4\u4EF6\u5217\u8868
|
||||
DB_VERSION.NAME=\u6570\u636E\u5E93\u7248\u672C
|
||||
DB_VERSION.ITEM.PRIOR_TO_V9=v9 \u4E4B\u524D\u7248\u672C
|
||||
DB_VERSION.ITEM.PRIOR_TO_V9=v9 \u4E4B\u524D\u7684\u7248\u672C (\u5DF2\u5F03\u7528)
|
||||
DB_VERSION.ITEM.V9_X=v9 \u53CA\u66F4\u65B0\u7248\u672C
|
||||
|
||||
@@ -65,5 +65,5 @@ USE_EXISTING_CONNECTION.NAME=\u65E2\u5B58\u306E\u63A5\u7D9A\u3092\u4F7F\u7528
|
||||
USE_FIELD_OPTIONS.NAME=\u30D5\u30A3\u30FC\u30EB\u30C9\u30AA\u30D7\u30B7\u30E7\u30F3\u3092\u4F7F\u7528
|
||||
ENABLE_DEBUG_MODE.NAME=\u30C7\u30D0\u30C3\u30B0\u30AF\u30A8\u30EA\u30FC\u30E2\u30FC\u30C9
|
||||
CONNECTION.NAME=\u63A5\u7D9A
|
||||
USE_BATCH_SIZE.NAME=\u30D0\u30C3\u30C1\u30E2\u30FC\u30C9\u306E\u4F7F\u7528
|
||||
USE_BATCH_SIZE.NAME=\u30D0\u30C3\u30C1\u30E2\u30FC\u30C9\u3092\u4F7F\u7528
|
||||
BATCH_SIZE.NAME=\u30D0\u30C3\u30C1\u30B5\u30A4\u30BA
|
||||
|
||||
@@ -346,7 +346,15 @@ COMPATIBILITY="ALL"
|
||||
NUM_ROW="100" SHOW_IF="USE_EXISTING_CONNECTION == 'false'" REPOSITORY_VALUE="USE_STRICT_REPLY_PARSING">
|
||||
<DEFAULT>true</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
|
||||
<PARAMETER
|
||||
NAME="RENAME_AFTER"
|
||||
FIELD="CHECK"
|
||||
NUM_ROW="105"
|
||||
SHOW="true"
|
||||
>
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
<PARAMETER
|
||||
NAME="CONFIG_CLIENT"
|
||||
FIELD="CHECK"
|
||||
|
||||
@@ -21,6 +21,7 @@
|
||||
String connection = ElementParameterParser.getValue(node, "__CONNECTION__");
|
||||
String useExistingConn = ElementParameterParser.getValue(node, "__USE_EXISTING_CONNECTION__");
|
||||
boolean sftp = false;
|
||||
boolean renameAfterUpload = ("true").equals(ElementParameterParser.getValue(node, "__RENAME_AFTER__"));
|
||||
boolean ftps = false;
|
||||
boolean isLog4jEnabled = ("true").equals(ElementParameterParser.getValue(node.getProcess(), "__LOG4J_ACTIVATE__"));
|
||||
boolean useGlob = ("true").equals(ElementParameterParser.getValue(node, "__PERL5_REGEX__"));
|
||||
@@ -105,12 +106,21 @@ try{
|
||||
}
|
||||
String destRename_<%= cid %> = map<%=cid %>.get(key<%=cid %>);
|
||||
final String dest_<%=cid%>;
|
||||
if (destRename_<%= cid %> == null || destRename_<%= cid %>.isEmpty()) {
|
||||
dest_<%=cid%> = remoteDir_<%=cid%> + "/" + listings<%=cid %>[m<%=cid %>].getName();
|
||||
}
|
||||
else {
|
||||
dest_<%=cid%> = remoteDir_<%=cid%> + "/" + destRename_<%= cid %>;
|
||||
}
|
||||
<%
|
||||
if (renameAfterUpload) {
|
||||
%>
|
||||
dest_<%=cid%> = remoteDir_<%=cid%>+"/"+listings<%=cid %>[m<%=cid %>].getName();
|
||||
<%
|
||||
} else {
|
||||
%>
|
||||
if (destRename_<%= cid %> == null || destRename_<%= cid %>.isEmpty()) {
|
||||
dest_<%=cid%> = remoteDir_<%=cid%> + "/" + listings<%=cid %>[m<%=cid %>].getName();
|
||||
} else {
|
||||
dest_<%=cid%> = remoteDir_<%=cid%> + "/" + destRename_<%= cid %>;
|
||||
}
|
||||
<%
|
||||
}
|
||||
%>
|
||||
|
||||
try{
|
||||
c_<%=cid%>.put(listings<%=cid %>[m<%=cid %>].getAbsolutePath(), dest_<%=cid%>, monitor<%=cid%>, mode<%=cid%>);
|
||||
@@ -171,6 +181,32 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e_<%=cid%>.getMessage());
|
||||
<%}%>
|
||||
System.err.println("No matches found for mask '" + key<%=cid %> + "'!");
|
||||
}
|
||||
<%
|
||||
if (renameAfterUpload) {
|
||||
%>
|
||||
//do rename
|
||||
if (!((map<%=cid %>.get(key<%=cid %>) == null) || map<%=cid %>.get(key<%=cid %>).isEmpty() || key<%=cid %>.equals(map<%=cid %>.get(key<%=cid %>)))){
|
||||
<%
|
||||
if(("overwrite").equals(sftpoverwrite) || ("resume").equals(sftpoverwrite)){
|
||||
%>
|
||||
try{
|
||||
c_<%=cid%>.rm(<%=remotedir %>+"/"+map<%=cid %>.get(key<%=cid %>));
|
||||
}catch(com.jcraft.jsch.SftpException e_<%=cid%>){
|
||||
}
|
||||
<%
|
||||
}
|
||||
%>
|
||||
try{
|
||||
c_<%=cid%>.rename(<%=remotedir %>+"/"+key<%=cid %>, <%=remotedir %>+"/"+map<%=cid %>.get(key<%=cid %>));
|
||||
globalMap.put("<%=cid %>_CURRENT_STATUS", "File rename OK.");
|
||||
}catch(com.jcraft.jsch.SftpException e_<%=cid%>){
|
||||
globalMap.put("<%=cid %>_CURRENT_STATUS", "File rename fail.");
|
||||
throw e_<%=cid%>;
|
||||
}
|
||||
}
|
||||
<%
|
||||
}
|
||||
%>
|
||||
}
|
||||
|
||||
<%
|
||||
@@ -292,12 +328,21 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e_<%=cid%>.getMessage());
|
||||
|
||||
final String destRename_<%= cid %> = map<%=cid %>.get(key<%=cid %>);
|
||||
final String dest_<%=cid%>;
|
||||
if (destRename_<%= cid %> == null || destRename_<%= cid %>.isEmpty()) {
|
||||
<%
|
||||
if (renameAfterUpload) {
|
||||
%>
|
||||
dest_<%=cid%> = listings<%=cid %>[m<%=cid %>].getName();
|
||||
<%
|
||||
} else {
|
||||
%>
|
||||
if (destRename_<%= cid %> == null || destRename_<%= cid %>.isEmpty()) {
|
||||
dest_<%=cid%> = listings<%=cid %>[m<%=cid %>].getName();
|
||||
} else {
|
||||
dest_<%=cid%> = destRename_<%= cid %>;
|
||||
}
|
||||
<%
|
||||
}
|
||||
else {
|
||||
dest_<%=cid%> = destRename_<%= cid %>;
|
||||
}
|
||||
%>
|
||||
globalMap.put("<%=cid %>_CURRENT_FILE_EXISTS", remoteExistsFiles_<%=cid%>.contains(dest_<%=cid%>));
|
||||
|
||||
<%
|
||||
@@ -360,6 +405,26 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e_<%=cid%>.getMessage());
|
||||
+ file_in_localDir_<%=cid%>.length() + " bytes upload successfully");
|
||||
<%
|
||||
}
|
||||
%>
|
||||
<%
|
||||
if (renameAfterUpload) {
|
||||
%>
|
||||
//do rename
|
||||
if (destRename_<%= cid %> != null && !destRename_<%= cid %>.isEmpty() && ! destRename_<%= cid %>.equals(dest_<%=cid%>)) {
|
||||
<%
|
||||
if(!"never".equals(ftpsoverwrite)){
|
||||
%>
|
||||
if ((remoteExistsFiles_<%=cid%>.contains(destRename_<%=cid%>))){
|
||||
ftpExecutorAndChecker_<%=cid %>.executeAndCheckResult(() -> effectivelyFinalFtp_<%=cid %>.deleteFile(destRename_<%= cid %>));
|
||||
}
|
||||
<%
|
||||
}
|
||||
%>
|
||||
ftpExecutorAndChecker_<%=cid %>.executeAndCheckResult(() -> effectivelyFinalFtp_<%=cid %>.rename(dest_<%=cid%>, destRename_<%= cid %>));
|
||||
globalMap.put("<%=cid %>_CURRENT_STATUS", "File rename OK.");
|
||||
}
|
||||
<%
|
||||
}
|
||||
%>
|
||||
nb_file_<%=cid%>++;
|
||||
}
|
||||
|
||||
@@ -71,3 +71,4 @@ CONFIG_CLIENT.NAME=Config client
|
||||
CLIENT_PARAMETERS.NAME=
|
||||
CLIENT_PARAMETERS.ITEM.PARAMETER=Client parameter
|
||||
CLIENT_PARAMETERS.ITEM.VALUE=Value
|
||||
RENAME_AFTER.NAME=Rename after upload/on remote
|
||||
@@ -38,6 +38,10 @@
|
||||
int dynamic_index = -1;
|
||||
boolean hasDynamic = false;
|
||||
int dynamicColumnlength = 100;
|
||||
String dynamic = ElementParameterParser.getValue(node, "__DYNAMIC__");
|
||||
final boolean useExistingDynamic = "true".equals(ElementParameterParser.getValue(node, "__USE_EXISTING_DYNAMIC__"));
|
||||
final String useHeaderAsIs = ElementParameterParser.getValue(node, "__USE_HEADER_AS_IS__");
|
||||
final String dyn = dynamic+"_DYNAMIC";
|
||||
List<IMetadataColumn> columnList = null;
|
||||
List<IMetadataTable> metadatas = node.getMetadataList();
|
||||
IMetadataTable metadata = null;
|
||||
@@ -73,32 +77,46 @@
|
||||
%>
|
||||
if(isFirstCheckDyn_<%=cid %>){// for the header line
|
||||
<%
|
||||
if(isCsv){
|
||||
if(useExistingDynamic){
|
||||
%>
|
||||
int colsLen_<%=cid %> = row<%=cid %>.length;
|
||||
dynamic_<%=cid %> = (routines.system.Dynamic)globalMap.get("<%=dyn%>");
|
||||
isFirstCheckDyn_<%=cid %> = false;
|
||||
<%
|
||||
}else{
|
||||
%>
|
||||
int colsLen_<%=cid %> = fid_<%=cid %>.getColumnsCountOfCurrentRow();
|
||||
} else {
|
||||
if(isCsv){
|
||||
%>
|
||||
int colsLen_<%=cid %> = row<%=cid %>.length;
|
||||
<%
|
||||
}else{
|
||||
%>
|
||||
int colsLen_<%=cid %> = fid_<%=cid %>.getColumnsCountOfCurrentRow();
|
||||
<%
|
||||
}
|
||||
%>
|
||||
for (int i = <%=dynamic_index-1%>; i < colsLen_<%=cid %>-<%=colLen-dynamic_index%>; i++) {
|
||||
routines.system.DynamicMetadata dynamicMetadata_<%=cid%> = new routines.system.DynamicMetadata();
|
||||
if(<%=useHeaderAsIs%>) {
|
||||
dynamicMetadata_<%=cid%>.setName(<%if(isCsv){%>row<%=cid %>[i]<%}else{%>fid_<%=cid %>.get(i)<%}%>);
|
||||
} else {
|
||||
dynamicMetadata_<%=cid%>.setName(<%if(isCsv){%>row<%=cid %>[i]<%}else{%>fid_<%=cid %>.get(i)<%}%>.replaceAll("[ .-]+", "_"));
|
||||
}
|
||||
dynamicMetadata_<%=cid%>.setDbName(dynamicMetadata_<%=cid%>.getName());
|
||||
dynamicMetadata_<%=cid%>.setType("id_String");
|
||||
dynamicMetadata_<%=cid%>.setDbType("VARCHAR");
|
||||
dynamicMetadata_<%=cid%>.setLength(<%=dynamicColumnlength%>);
|
||||
dynamicMetadata_<%=cid%>.setPrecision(0);
|
||||
dynamicMetadata_<%=cid%>.setNullable(true);
|
||||
dynamicMetadata_<%=cid%>.setKey(false);
|
||||
dynamicMetadata_<%=cid%>.setSourceType(routines.system.DynamicMetadata.sourceTypes.demilitedFile);
|
||||
dynamicMetadata_<%=cid%>.setColumnPosition(i);
|
||||
dynamic_<%=cid%>.metadatas.add(dynamicMetadata_<%=cid%>);
|
||||
}
|
||||
|
||||
isFirstCheckDyn_<%=cid %> = false;
|
||||
continue;
|
||||
<%
|
||||
}
|
||||
%>
|
||||
for (int i = <%=dynamic_index-1%>; i < colsLen_<%=cid %>-<%=colLen-dynamic_index%>; i++) {
|
||||
routines.system.DynamicMetadata dynamicMetadata_<%=cid%> = new routines.system.DynamicMetadata();
|
||||
dynamicMetadata_<%=cid%>.setName(<%if(isCsv){%>row<%=cid %>[i]<%}else{%>fid_<%=cid %>.get(i)<%}%>.replaceAll("[ .-]+", "_"));
|
||||
dynamicMetadata_<%=cid%>.setDbName(dynamicMetadata_<%=cid%>.getName());
|
||||
dynamicMetadata_<%=cid%>.setType("id_String");
|
||||
dynamicMetadata_<%=cid%>.setDbType("VARCHAR");
|
||||
dynamicMetadata_<%=cid%>.setLength(<%=dynamicColumnlength%>);
|
||||
dynamicMetadata_<%=cid%>.setPrecision(0);
|
||||
dynamicMetadata_<%=cid%>.setNullable(true);
|
||||
dynamicMetadata_<%=cid%>.setKey(false);
|
||||
dynamicMetadata_<%=cid%>.setSourceType(routines.system.DynamicMetadata.sourceTypes.demilitedFile);
|
||||
dynamicMetadata_<%=cid%>.setColumnPosition(i);
|
||||
dynamic_<%=cid%>.metadatas.add(dynamicMetadata_<%=cid%>);
|
||||
}
|
||||
isFirstCheckDyn_<%=cid %> = false;
|
||||
continue;
|
||||
}
|
||||
<%
|
||||
}
|
||||
@@ -236,7 +254,9 @@
|
||||
|
||||
int fieldCount = <%=sourceValueName%>.getColumnsCountOfCurrentRow();
|
||||
dynamic_column_count_<%=cid%> = <%=dynamicName%>.getColumnCount();
|
||||
for (int i = 0; i < dynamic_column_count_<%=cid%> ; i++) {
|
||||
|
||||
<%if(!useExistingDynamic){%>
|
||||
for (int i = 0; i < dynamic_column_count_<%=cid%>; i++) {
|
||||
if ((<%=dynamic_index%>+i) < fieldCount){
|
||||
<%=targetConnName %>.<%=column.getLabel() %>.addColumnValue(<%=sourceValueName%>.get(<%=dynamic_index%>+i)<%=(isTrimAll || (!trimSelects.isEmpty() && ("true").equals(trimSelects.get(valueN).get("TRIM"))))?".trim()":"" %>);
|
||||
}
|
||||
@@ -244,6 +264,20 @@
|
||||
<%=targetConnName %>.<%=column.getLabel() %>.addColumnValue("");
|
||||
}
|
||||
}
|
||||
<%} else {%>
|
||||
int maxColumnNumberInDynamicColumn_<%=cid%> = fieldCount - <%=sizeListColumns - 1%>;
|
||||
for (int i = 0; i < dynamic_column_count_<%=cid%>; i++) {
|
||||
Object v_<%=cid%> = null;
|
||||
final routines.system.DynamicMetadata dynamicMetadata_<%=cid%> = <%=dynamicName%>.getColumnMetadata(i);
|
||||
if ((<%=dynamic_index%>+i) < fieldCount && i < maxColumnNumberInDynamicColumn_<%=cid%>){<%//B1 start%>
|
||||
final String tempValue_<%=cid%> = <%=sourceValueName%>.get(<%=dynamic_index%>+i)<%=(isTrimAll || (!trimSelects.isEmpty() && ("true").equals(trimSelects.get(valueN).get("TRIM"))))?".trim()":"" %>;
|
||||
final String separator_<%=cid%> = <%= fieldSeparator %>;
|
||||
|
||||
<%@ include file="./use_existing_schema.javajet"%>
|
||||
}
|
||||
|
||||
dynamic_column_count_<%=cid%> = maxColumnNumberInDynamicColumn_<%=cid%>;
|
||||
<%}%>
|
||||
<%
|
||||
}else{
|
||||
|
||||
@@ -498,8 +532,8 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
|
||||
continue;
|
||||
}
|
||||
try {
|
||||
fid_<%=cid %> = new org.talend.fileprocess.FileInputDelimited(zis_<%=cid %>, <%=encoding %>,<%=fieldSeparator %>,<%=rowSeparator %>,<%=removeEmptyRowFlag %>,<%=header %><%=hasDynamic?"-1":""%>,<%=footer %>,
|
||||
<%if(hasDynamic){%>
|
||||
fid_<%=cid %> = new org.talend.fileprocess.FileInputDelimited(zis_<%=cid %>, <%=encoding %>,<%=fieldSeparator %>,<%=rowSeparator %>,<%=removeEmptyRowFlag %>,<%=header %><%=(hasDynamic&&!useExistingDynamic)?"-1":""%>,<%=footer %>,
|
||||
<%if(hasDynamic&&!useExistingDynamic){%>
|
||||
(limit_<%=cid%> > 0) ? limit_<%=cid%>+1 : limit_<%=cid%>
|
||||
<%} else {%>
|
||||
limit_<%=cid%>
|
||||
@@ -525,7 +559,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
|
||||
%>
|
||||
}
|
||||
try {
|
||||
fid_<%=cid %> = new org.talend.fileprocess.FileInputDelimited(<%=filename %>, <%=encoding %>,<%=fieldSeparator %>,<%=rowSeparator %>,<%=removeEmptyRowFlag %>,<%=header %><%=hasDynamic?"-1":""%>,<%=footer %>,<%if(hasDynamic){%>
|
||||
fid_<%=cid %> = new org.talend.fileprocess.FileInputDelimited(<%=filename %>, <%=encoding %>,<%=fieldSeparator %>,<%=rowSeparator %>,<%=removeEmptyRowFlag %>,<%=header %><%=(hasDynamic&&!useExistingDynamic)?"-1":""%>,<%=footer %>,<%if(hasDynamic&&!useExistingDynamic){%>
|
||||
(limit_<%=cid%> > 0) ? limit_<%=cid%>+1 : limit_<%=cid%>
|
||||
<%} else {%>
|
||||
limit_<%=cid%>
|
||||
@@ -884,6 +918,8 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",ex_<%=cid%>.getMessage());
|
||||
<%=targetConnName %>.<%=column.getLabel() %> = <%=dynamicName%>.copyMetadata();
|
||||
}
|
||||
int fieldCount = <%=sourceValueName%>.length;
|
||||
|
||||
<%if(!useExistingDynamic){%>
|
||||
for (int i = 0; i < dynamic_column_count_<%=cid%>; i++) {
|
||||
if ((<%=dynamic_index%>+i) < fieldCount) {
|
||||
<%=targetConnName %>.<%=column.getLabel() %>.addColumnValue(<%=sourceValueName%>[<%=dynamic_index%>+i]);
|
||||
@@ -891,6 +927,21 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",ex_<%=cid%>.getMessage());
|
||||
<%=targetConnName %>.<%=column.getLabel() %>.addColumnValue("");
|
||||
}
|
||||
}
|
||||
<%} else {%>
|
||||
int maxColumnNumberInDynamicColumn_<%=cid%> = fieldCount - <%=columnSize - 1%>;
|
||||
for (int i = 0; i < dynamic_column_count_<%=cid%>; i++) {
|
||||
Object v_<%=cid%> = null;
|
||||
final routines.system.DynamicMetadata dynamicMetadata_<%=cid%> = <%=dynamicName%>.getColumnMetadata(i);
|
||||
if ((<%=dynamic_index%>+i) < fieldCount && i < maxColumnNumberInDynamicColumn_<%=cid%>){<%//B1 start%>
|
||||
final String tempValue_<%=cid%> = <%=sourceValueName%>[<%=dynamic_index%>+i];
|
||||
final String separator_<%=cid%> = String.valueOf(fieldSeparator_<%=cid %>_ListType[0]);
|
||||
|
||||
<%@ include file="./use_existing_schema.javajet"%>
|
||||
}
|
||||
|
||||
dynamic_column_count_<%=cid%> = maxColumnNumberInDynamicColumn_<%=cid%>;
|
||||
<%}%>
|
||||
|
||||
<%
|
||||
}
|
||||
}
|
||||
@@ -1285,7 +1336,7 @@ globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
|
||||
}
|
||||
|
||||
if(limit<%=cid%> != 0){
|
||||
for(currentLine<%=cid %>=0;currentLine<%=cid %> < <%= header %><%=hasDynamic?"-1":""%>;currentLine<%=cid %>++){
|
||||
for(currentLine<%=cid %>=0;currentLine<%=cid %> < <%= header %><%=(hasDynamic&&!useExistingDynamic)?"-1":""%>;currentLine<%=cid %>++){
|
||||
csvReader<%=cid %>.readNext();
|
||||
}
|
||||
}
|
||||
|
||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user