Compare commits
2 Commits
hzhao/mast
...
codegen_ba
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
2645eb4660 | ||
|
|
db9444fc54 |
@@ -7,5 +7,4 @@ Huge thanks to these people who contributed in making Talend product better:
|
||||
- [overpackaging](https://github.com/overpackaging) (Steeve Dreux)
|
||||
- [brazabr](https://github.com/brazabr) (Thiago Benvenuto)
|
||||
- [phoflack](https://jira.talendforge.org/secure/ViewProfile.jspa?name=phoflack) (Philip Hoflack)
|
||||
- [bgunics-talend](https://github.com/bgunics-talend) (Balasz Gunics)
|
||||
- [cflamain](https://github.com/cflamain) (Christophe Flamain)
|
||||
- [bgunics-talend](https://github.com/bgunics-talend) (Balasz Gunics)
|
||||
14
SECURITY.md
14
SECURITY.md
@@ -1,14 +0,0 @@
|
||||
# Security Policy
|
||||
|
||||
## Supported Versions
|
||||
|
||||
| Version | Supported |
|
||||
| ------- | ------------------ |
|
||||
| 8.0.x | :white_check_mark: |
|
||||
| 7.3.x | :white_check_mark: |
|
||||
| < 7.3.x | :x: |
|
||||
|
||||
## Reporting a Vulnerability
|
||||
|
||||
For information on how to report a new security problem please see [here](https://www.talend.com/security/vulnerability-disclosure/).
|
||||
Our existing security advisories are published [here](https://www.talend.com/security/incident-response/).
|
||||
@@ -10,12 +10,13 @@
|
||||
</url>
|
||||
<requires>
|
||||
<import feature="org.eclipse.gef" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import feature="org.talend.m2e.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import feature="org.eclipse.m2e.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import feature="org.eclipse.equinox.p2.discovery.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import feature="org.talend.utils.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="javax.xml.rpc-api" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="javax.xml.rpc" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="net.jeeeyul.eclipse.themes" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="net.jeeeyul.swtend" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="org.apache.axis" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="org.eclipse.gmf.runtime.draw2d.ui" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="org.eclipse.gmf.runtime.common.core" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="org.eclipse.gmf.runtime.common.ui" version="0.0.0" match="greaterOrEqual"/>
|
||||
@@ -32,5 +33,4 @@
|
||||
<plugin id="org.talend.libraries.mozilla" download-size="0" install-size="0" version="0.0.0"/>
|
||||
<plugin id="org.talend.libraries.sqlbuilder" download-size="0" install-size="0" version="0.0.0" unpack="false"/>
|
||||
<plugin id="org.talend.sqlbuilder" download-size="0" install-size="0" version="0.0.0" unpack="false"/>
|
||||
<plugin id="org.talend.designer.core.swt" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
</feature>
|
||||
|
||||
@@ -17,15 +17,415 @@
|
||||
</license>
|
||||
|
||||
<requires>
|
||||
<import feature="org.eclipse.gmf.runtime.notation" version="0.0.0"/>
|
||||
<import feature="org.eclipse.gef" version="0.0.0"/>
|
||||
<import feature="org.eclipse.emf.common" version="0.0.0"/>
|
||||
<import feature="org.eclipse.emf.ecore" version="0.0.0"/>
|
||||
<import feature="org.eclipse.emf.ecore.edit" version="0.0.0"/>
|
||||
<import feature="org.eclipse.emf.edit" version="0.0.0"/>
|
||||
<import feature="org.eclipse.emf.transaction" version="0.0.0"/>
|
||||
<import feature="org.eclipse.emf.validation" version="0.0.0"/>
|
||||
<import feature="org.eclipse.emf.workspace" version="0.0.0"/>
|
||||
<import feature="org.eclipse.gmf.runtime.notation" version="1.8.0"/>
|
||||
<import feature="org.eclipse.gef" version="3.9.2"/>
|
||||
<import feature="org.eclipse.emf.common" version="2.10.0"/>
|
||||
<import feature="org.eclipse.emf.ecore" version="2.10.0"/>
|
||||
<import feature="org.eclipse.emf.ecore.edit" version="2.8.0"/>
|
||||
<import feature="org.eclipse.emf.edit" version="2.10.0"/>
|
||||
<import feature="org.eclipse.emf.transaction" version="1.8.0"/>
|
||||
<import feature="org.eclipse.emf.validation" version="1.8.0"/>
|
||||
<import feature="org.eclipse.emf.workspace" version="1.8.0"/>
|
||||
</requires>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.common.core"
|
||||
download-size="117"
|
||||
install-size="226"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.common.ui"
|
||||
download-size="257"
|
||||
install-size="509"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.common.ui.action"
|
||||
download-size="101"
|
||||
install-size="173"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.common.ui.action.ide"
|
||||
download-size="39"
|
||||
install-size="66"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.common.ui.services"
|
||||
download-size="100"
|
||||
install-size="208"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.common.ui.services.action"
|
||||
download-size="120"
|
||||
install-size="293"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.common.ui.services.dnd"
|
||||
download-size="92"
|
||||
install-size="190"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.common.ui.services.dnd.ide"
|
||||
download-size="24"
|
||||
install-size="38"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.common.ui.services.properties"
|
||||
download-size="76"
|
||||
install-size="146"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.diagram.core"
|
||||
download-size="133"
|
||||
install-size="284"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.diagram.ui"
|
||||
download-size="1190"
|
||||
install-size="2486"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.diagram.ui.actions"
|
||||
download-size="218"
|
||||
install-size="391"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.diagram.ui.dnd"
|
||||
download-size="19"
|
||||
install-size="29"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.diagram.ui.geoshapes"
|
||||
download-size="99"
|
||||
install-size="179"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.diagram.ui.properties"
|
||||
download-size="215"
|
||||
install-size="430"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.diagram.ui.providers"
|
||||
download-size="137"
|
||||
install-size="318"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.diagram.ui.providers.ide"
|
||||
download-size="23"
|
||||
install-size="38"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.diagram.ui.render"
|
||||
download-size="117"
|
||||
install-size="236"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.diagram.ui.resources.editor"
|
||||
download-size="123"
|
||||
install-size="251"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.diagram.ui.resources.editor.ide"
|
||||
download-size="69"
|
||||
install-size="146"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.draw2d.ui"
|
||||
download-size="318"
|
||||
install-size="619"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.draw2d.ui.render"
|
||||
download-size="49"
|
||||
install-size="87"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.draw2d.ui.render.awt"
|
||||
download-size="196"
|
||||
install-size="396"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.emf.clipboard.core"
|
||||
download-size="110"
|
||||
install-size="223"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.emf.commands.core"
|
||||
download-size="28"
|
||||
install-size="48"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.emf.core"
|
||||
download-size="114"
|
||||
install-size="229"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.emf.type.core"
|
||||
download-size="190"
|
||||
install-size="439"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.emf.type.ui"
|
||||
download-size="18"
|
||||
install-size="25"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.emf.ui"
|
||||
download-size="93"
|
||||
install-size="177"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.emf.ui.properties"
|
||||
download-size="62"
|
||||
install-size="118"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.gef.ui"
|
||||
download-size="101"
|
||||
install-size="182"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.notation.providers"
|
||||
download-size="29"
|
||||
install-size="53"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf"
|
||||
download-size="13"
|
||||
install-size="17"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.common.ui.printing"
|
||||
download-size="14"
|
||||
install-size="19"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.common.ui.printing.win32"
|
||||
download-size="752"
|
||||
install-size="3091"
|
||||
version="0.0.0"
|
||||
fragment="true"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.diagram.ui.printing"
|
||||
download-size="90"
|
||||
install-size="172"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.eclipse.gmf.runtime.diagram.ui.printing.render"
|
||||
download-size="92"
|
||||
install-size="196"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.apache.batik.dom.svg"
|
||||
download-size="453"
|
||||
install-size="1509"
|
||||
version="1.6.0.v201011041432"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.apache.batik.bridge"
|
||||
download-size="504"
|
||||
install-size="1013"
|
||||
version="1.6.0.v201011041432"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.apache.batik.dom"
|
||||
download-size="107"
|
||||
install-size="203"
|
||||
version="1.6.1.v201505192100"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.apache.batik.ext.awt"
|
||||
download-size="387"
|
||||
install-size="760"
|
||||
version="1.6.0.v201011041432"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.apache.batik.transcoder"
|
||||
download-size="79"
|
||||
install-size="151"
|
||||
version="1.6.0.v201011041432"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.apache.batik.svggen"
|
||||
download-size="183"
|
||||
install-size="338"
|
||||
version="1.6.0.v201011041432"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.apache.batik.util"
|
||||
download-size="99"
|
||||
install-size="192"
|
||||
version="1.6.0.v201011041432"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.w3c.dom.svg"
|
||||
download-size="95"
|
||||
install-size="140"
|
||||
version="1.1.0.v201011041433"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.apache.xerces"
|
||||
download-size="0"
|
||||
install-size="0"
|
||||
version="2.12.1.v20210115-0812"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.apache.xml.resolver"
|
||||
download-size="94"
|
||||
install-size="201"
|
||||
version="1.2.0.v201005080400"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.apache.batik.css"
|
||||
download-size="259"
|
||||
install-size="512"
|
||||
version="1.6.0.v201011041432"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.apache.batik.util.gui"
|
||||
download-size="161"
|
||||
install-size="281"
|
||||
version="1.6.0.v201011041432"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.apache.batik.parser"
|
||||
download-size="54"
|
||||
install-size="112"
|
||||
version="1.6.0.v201011041432"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.apache.batik.xml"
|
||||
download-size="35"
|
||||
install-size="92"
|
||||
version="1.6.0.v201011041432"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.w3c.css.sac"
|
||||
download-size="37"
|
||||
install-size="65"
|
||||
version="1.3.1.v200903091627"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.w3c.dom.smil"
|
||||
download-size="19"
|
||||
install-size="37"
|
||||
version="1.0.1.v200903091627"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="javax.xml"
|
||||
download-size="246"
|
||||
install-size="413"
|
||||
version="1.3.4.v201005080400"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.apache.xml.serializer"
|
||||
download-size="286"
|
||||
install-size="577"
|
||||
version="2.7.1.v201005080400"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.apache.batik.pdf"
|
||||
download-size="498"
|
||||
install-size="989"
|
||||
version="1.6.0.v201105071520"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.w3c.dom.events"
|
||||
download-size="17"
|
||||
install-size="26"
|
||||
version="3.0.0.draft20060413_v201105210656"
|
||||
unpack="false"/>
|
||||
|
||||
</feature>
|
||||
|
||||
@@ -16,7 +16,6 @@
|
||||
<import plugin="org.talend.repository" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="org.talend.utils" version="0.0.0" match="greaterOrEqual"/>
|
||||
</requires>
|
||||
<plugin id="org.talend.common.ui.runtime.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.commons.runtime.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.commons.ui.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.core.repository.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
@@ -44,14 +43,12 @@
|
||||
<plugin id="org.talend.migrationTool.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.model.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.repository.generic.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.repository.json.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.repository.items.importexport.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.repository.items.importexport.ui.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.repository.localprovider.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.repository.metadata.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.repository.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.sqlbuilder.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.presentation.onboarding.resource.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.repository.view.di.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.repository.view.test" download-size="0" install-size="0" version="0.0.0" fragment="true" unpack="false"/>
|
||||
<plugin id="org.talend.testutils" download-size="0" install-size="0" version="0.0.0" unpack="false"/>
|
||||
|
||||
@@ -1,23 +0,0 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<projectDescription>
|
||||
<name>org.talend.studio.components.tck.jdbc.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>
|
||||
@@ -1,41 +0,0 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<feature
|
||||
id="org.talend.studio.components.tck.jdbc.feature"
|
||||
label="JDBC"
|
||||
version="8.8.8.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"/>
|
||||
<import plugin="org.talend.components.jdbc.definition"/>
|
||||
</requires>
|
||||
|
||||
</feature>
|
||||
@@ -1,12 +0,0 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
<parent>
|
||||
<groupId>org.talend.studio</groupId>
|
||||
<artifactId>tdi-studio-se</artifactId>
|
||||
<version>8.8.8-SNAPSHOT</version>
|
||||
<relativePath>../../../</relativePath>
|
||||
</parent>
|
||||
<artifactId>org.talend.studio.components.tck.jdbc.feature</artifactId>
|
||||
<packaging>eclipse-feature</packaging>
|
||||
</project>
|
||||
@@ -1,17 +0,0 @@
|
||||
<?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>
|
||||
@@ -1,2 +0,0 @@
|
||||
bin.includes = feature.xml,\
|
||||
p2.inf
|
||||
@@ -1,91 +0,0 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<feature
|
||||
id="org.talend.studio.components.tck.jira.feature"
|
||||
label="Jira"
|
||||
version="8.8.8.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>
|
||||
@@ -1,4 +0,0 @@
|
||||
properties.0.name=TALEND_COMPONENT_tJIRAInput
|
||||
properties.0.value=
|
||||
properties.1.name=TALEND_COMPONENT_tJIRAOutput
|
||||
properties.1.value=
|
||||
@@ -1,12 +0,0 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
<parent>
|
||||
<groupId>org.talend.studio</groupId>
|
||||
<artifactId>tdi-studio-se</artifactId>
|
||||
<version>8.8.8-SNAPSHOT</version>
|
||||
<relativePath>../../../</relativePath>
|
||||
</parent>
|
||||
<artifactId>org.talend.studio.components.tck.jira.feature</artifactId>
|
||||
<packaging>eclipse-feature</packaging>
|
||||
</project>
|
||||
@@ -1,17 +0,0 @@
|
||||
<?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>
|
||||
@@ -1,2 +0,0 @@
|
||||
bin.includes = feature.xml,\
|
||||
p2.inf
|
||||
@@ -1,91 +0,0 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<feature
|
||||
id="org.talend.studio.components.tck.splunk.feature"
|
||||
label="Splunk"
|
||||
version="8.8.8.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>
|
||||
@@ -1,2 +0,0 @@
|
||||
properties.0.name=TALEND_COMPONENT_tSplunkEventCollector
|
||||
properties.0.value=
|
||||
@@ -1,12 +0,0 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
<parent>
|
||||
<groupId>org.talend.studio</groupId>
|
||||
<artifactId>tdi-studio-se</artifactId>
|
||||
<version>8.8.8-SNAPSHOT</version>
|
||||
<relativePath>../../../</relativePath>
|
||||
</parent>
|
||||
<artifactId>org.talend.studio.components.tck.splunk.feature</artifactId>
|
||||
<packaging>eclipse-feature</packaging>
|
||||
</project>
|
||||
@@ -0,0 +1,23 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<projectDescription>
|
||||
<name>org.talend.studio.components.tcompv0.jdbc.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>
|
||||
@@ -0,0 +1,31 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<feature
|
||||
id="org.talend.studio.components.tcompv0.jdbc.feature"
|
||||
label="JDBC_feature"
|
||||
version="8.8.8.qualifier">
|
||||
|
||||
<description url="http://www.example.com/description">
|
||||
[Enter Feature Description here.]
|
||||
</description>
|
||||
|
||||
<copyright url="http://www.example.com/copyright">
|
||||
[Enter Copyright Description here.]
|
||||
</copyright>
|
||||
|
||||
<license url="http://www.example.com/license">
|
||||
[Enter License Description here.]
|
||||
</license>
|
||||
<plugin
|
||||
id="org.talend.studio.components.tcompv0.jdbc"
|
||||
download-size="0"
|
||||
install-size="0"
|
||||
version="0.0.0"/>
|
||||
|
||||
<plugin
|
||||
id="org.talend.components.jdbc.definition"
|
||||
download-size="0"
|
||||
install-size="0"
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
</feature>
|
||||
@@ -0,0 +1,12 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
<parent>
|
||||
<groupId>org.talend.studio</groupId>
|
||||
<artifactId>tdi-studio-se</artifactId>
|
||||
<version>8.8.8-SNAPSHOT</version>
|
||||
<relativePath>../../../</relativePath>
|
||||
</parent>
|
||||
<artifactId>org.talend.studio.components.tcompv0.jdbc.feature</artifactId>
|
||||
<packaging>eclipse-feature</packaging>
|
||||
</project>
|
||||
@@ -0,0 +1,23 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<projectDescription>
|
||||
<name>org.talend.studio.components.tcompv0.jira.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>
|
||||
@@ -0,0 +1 @@
|
||||
bin.includes = feature.xml
|
||||
@@ -0,0 +1,102 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<feature
|
||||
id="org.talend.studio.components.tcompv0.jira.feature"
|
||||
label="Jira"
|
||||
version="8.8.8.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>
|
||||
@@ -0,0 +1,12 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
<parent>
|
||||
<groupId>org.talend.studio</groupId>
|
||||
<artifactId>tdi-studio-se</artifactId>
|
||||
<version>8.8.8-SNAPSHOT</version>
|
||||
<relativePath>../../../</relativePath>
|
||||
</parent>
|
||||
<artifactId>org.talend.studio.components.tcompv0.jira.feature</artifactId>
|
||||
<packaging>eclipse-feature</packaging>
|
||||
</project>
|
||||
@@ -0,0 +1,23 @@
|
||||
<?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>
|
||||
@@ -0,0 +1 @@
|
||||
bin.includes = feature.xml
|
||||
@@ -0,0 +1,102 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<feature
|
||||
id="org.talend.studio.components.tcompv0.splunk.feature"
|
||||
label="Splunk"
|
||||
version="8.8.8.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>
|
||||
@@ -0,0 +1,12 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
<parent>
|
||||
<groupId>org.talend.studio</groupId>
|
||||
<artifactId>tdi-studio-se</artifactId>
|
||||
<version>8.8.8-SNAPSHOT</version>
|
||||
<relativePath>../../../</relativePath>
|
||||
</parent>
|
||||
<artifactId>org.talend.studio.components.tcompv0.splunk.feature</artifactId>
|
||||
<packaging>eclipse-feature</packaging>
|
||||
</project>
|
||||
@@ -17,13 +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"/>
|
||||
@@ -83,7 +84,7 @@
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.talend.studio.components.tck.jira"
|
||||
id="org.talend.components.jira"
|
||||
download-size="0"
|
||||
install-size="0"
|
||||
version="0.0.0"
|
||||
@@ -118,7 +119,7 @@
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.talend.studio.components.tck.splunk"
|
||||
id="org.talend.components.splunk"
|
||||
download-size="0"
|
||||
install-size="0"
|
||||
version="0.0.0"
|
||||
@@ -138,6 +139,12 @@
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.talend.designer.components.exchange"
|
||||
download-size="0"
|
||||
install-size="0"
|
||||
version="0.0.0"/>
|
||||
|
||||
<plugin
|
||||
id="org.talend.designer.components.localprovider"
|
||||
download-size="0"
|
||||
@@ -186,14 +193,6 @@
|
||||
version="0.0.0"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.talend.designer.mapper.swt"
|
||||
download-size="0"
|
||||
install-size="0"
|
||||
version="0.0.0"
|
||||
fragment="true"
|
||||
unpack="false"/>
|
||||
|
||||
<plugin
|
||||
id="org.talend.designer.rowgenerator"
|
||||
download-size="0"
|
||||
@@ -250,10 +249,4 @@
|
||||
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>
|
||||
|
||||
@@ -13,6 +13,9 @@
|
||||
<import feature="org.talend.repository.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import feature="org.talend.tos.components.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import feature="org.talend.updates.feature" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="javax.transaction" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="javax.xml.rpc" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="org.apache.axis" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="org.apache.log4j" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="org.eclipse.core.runtime" version="0.0.0" match="greaterOrEqual"/>
|
||||
<import plugin="org.eclipse.ui" version="0.0.0" match="greaterOrEqual"/>
|
||||
|
||||
@@ -29,6 +29,8 @@
|
||||
<plugin id="org.talend.libraries.ehcache" download-size="0" install-size="0" version="0.0.0"/>
|
||||
<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"/>
|
||||
@@ -44,6 +46,4 @@
|
||||
<plugin id="org.talend.libraries.slf4j" download-size="0" install-size="0" version="0.0.0"/>
|
||||
<plugin id="org.talend.libraries.xml" download-size="0" install-size="0" version="0.0.0"/>
|
||||
<plugin id="org.talend.libraries.zmq" download-size="0" install-size="0" version="0.0.0"/>
|
||||
<plugin id="org.talend.libraries.bigquery" download-size="0" install-size="0" version="0.0.0"/>
|
||||
<plugin id="org.talend.repository.bigquery" download-size="0" install-size="0" version="0.0.0"/>
|
||||
</feature>
|
||||
|
||||
@@ -13,9 +13,7 @@ Require-Bundle: org.eclipse.core.runtime,
|
||||
org.eclipse.jface,
|
||||
org.apache.log4j,
|
||||
org.talend.libraries.apache,
|
||||
org.talend.components.api,
|
||||
org.talend.common.ui.runtime,
|
||||
org.talend.commons.runtime
|
||||
org.talend.components.api
|
||||
Eclipse-LazyStart: true
|
||||
Export-Package: org.talend.designer.abstractmap,
|
||||
org.talend.designer.abstractmap.managers,
|
||||
@@ -29,4 +27,3 @@ Export-Package: org.talend.designer.abstractmap,
|
||||
org.talend.designer.abstractmap.ui.visualmap.link,
|
||||
org.talend.designer.abstractmap.ui.visualmap.zone
|
||||
Bundle-Vendor: .Talend SA.
|
||||
Automatic-Module-Name: org.talend.designer.abstractmap
|
||||
|
||||
@@ -2,7 +2,7 @@ prefs.configuration.title=\u30DE\u30C3\u30D7\u30B3\u30F3\u30DD\u30FC\u30CD\u30F3
|
||||
prefs.configuration.LINK_STYLE=\u30C7\u30D5\u30A9\u30EB\u30C8\u30DE\u30C3\u30D4\u30F3\u30B0\u30EA\u30F3\u30AF\u306E\u8868\u793A:
|
||||
prefs.configuration.LINK_STYLE.AUTO=\u81EA\u52D5
|
||||
prefs.configuration.LINK_STYLE.BEZIER_CURVE=\u66F2\u7DDA
|
||||
prefs.configuration.LINK_STYLE.LINE=\u76F4\u7DDA(\u9AD8\u901F)
|
||||
prefs.configuration.LINK_STYLE.LINE=\u76F4\u7DDA\uFF08\u9AD8\u901F\uFF09
|
||||
DraggingInfosPopup.draggingEntry={0}\u30A8\u30F3\u30C8\u30EA\u30FC\u3092\u30C9\u30E9\u30C3\u30B0\u3057\u3066\u3044\u307E\u3059\u3002
|
||||
DraggingInfosPopup.dropInvalid=\n<< \u7121\u52B9\u306A\u30C9\u30ED\u30C3\u30D7 >>\n
|
||||
DraggingInfosPopup.draggingEntries={0}\u30A8\u30F3\u30C8\u30EA\u30FC\u3092\u30C9\u30E9\u30C3\u30B0\u3057\u3066\u3044\u307E\u3059\u3002
|
||||
|
||||
@@ -13,10 +13,6 @@
|
||||
package org.talend.designer.abstractmap.managers;
|
||||
|
||||
import org.apache.log4j.Level;
|
||||
import org.eclipse.swt.SWT;
|
||||
import org.eclipse.swt.graphics.Color;
|
||||
import org.eclipse.swt.widgets.Display;
|
||||
import org.talend.commons.ui.runtime.ITalendThemeService;
|
||||
import org.talend.commons.ui.runtime.exception.ExceptionHandler;
|
||||
import org.talend.designer.abstractmap.ui.dnd.DraggingInfosPopup;
|
||||
import org.talend.designer.abstractmap.ui.properties.LINK_STYLE;
|
||||
|
||||
@@ -77,7 +77,7 @@ public final class DraggingInfosPopup {
|
||||
private Label labelDropInvalid;
|
||||
|
||||
public Popup(Shell parent) {
|
||||
super(parent, SWT.ON_TOP, false, false, false, false, false, null, null);
|
||||
super(parent, SWT.ON_TOP, false, false, false, false, null, null);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
@@ -13,8 +13,5 @@ Require-Bundle: org.eclipse.core.runtime,
|
||||
org.talend.core.runtime,
|
||||
org.talend.model,
|
||||
org.eclipse.jface,
|
||||
org.talend.components.api,
|
||||
org.talend.common.ui.runtime,
|
||||
org.talend.commons.runtime
|
||||
org.talend.components.api
|
||||
Eclipse-LazyStart: true
|
||||
Automatic-Module-Name: org.talend.designer.alfrescooutput
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
AlfrescoOutputManager.failedLoadModel=\u30B3\u30F3\u30DD\u30FC\u30CD\u30F3\u30C8\u30E1\u30BF\u30C7\u30FC\u30BF\u304B\u3089\u30E2\u30C7\u30EB\u30ED\u30FC\u30C9\u306B\u5931\u6557\u3057\u307E\u3057\u305F\u3002\u518D\u521D\u671F\u5316\u4E2D
|
||||
AlfrescoOutputManager.failedLoadModel=\u30B3\u30F3\u30DD\u30FC\u30CD\u30F3\u30C8\u30E1\u30BF\u30C7\u30FC\u30BF\u304B\u3089\u30E2\u30C7\u30EB\u30ED\u30FC\u30C9\u306B\u5931\u6557\u3057\u307E\u3057\u305F\u3002\u518D\u521D\u671F\u5316\u4E2D,
|
||||
AlfrescoOutputManager.schemaError.title=\u30B9\u30AD\u30FC\u30DE\u306E\u30A8\u30E9\u30FC
|
||||
AlfrescoOutputManager.schemaError.msg=\u6700\u521D\u306B\u30B9\u30AD\u30FC\u30DE\u3092\u540C\u671F\u3057\u3066\u304F\u3060\u3055\u3044\u3002
|
||||
AlfrescoOutputModelManager.alreadyAdded=\u3053\u306E\u30E2\u30C7\u30EB\u306F\u65E2\u306B\u8FFD\u52A0\u6E08\u307F\u3067\u3059\u3002
|
||||
|
||||
@@ -1,4 +1,3 @@
|
||||
#Thu Jan 06 14:39:43 CST 2011
|
||||
eclipse.preferences.version=1
|
||||
encoding//src/main/java/org/talend/designer/codegen/components/model/ComponentsFactory.java=UTF-8
|
||||
encoding//src/main/java/org/talend/designer/codegen/components/ui/ComponentsPreferencePage.java=UTF-8
|
||||
|
||||
@@ -24,14 +24,7 @@ Require-Bundle: org.talend.core.repository,
|
||||
org.talend.daikon,
|
||||
org.talend.daikon.crypto.utils,
|
||||
org.talend.designer.core.generic,
|
||||
org.talend.updates.runtime,
|
||||
org.talend.commons.runtime,
|
||||
org.eclipse.equinox.common,
|
||||
org.eclipse.core.runtime,
|
||||
org.eclipse.core.resources,
|
||||
org.talend.common.ui.runtime,
|
||||
org.eclipse.jface,
|
||||
org.talend.core.runtime
|
||||
org.talend.updates.runtime
|
||||
Eclipse-LazyStart: true
|
||||
Bundle-ClassPath: .
|
||||
Export-Package: org.talend.designer.codegen,
|
||||
@@ -40,10 +33,11 @@ Export-Package: org.talend.designer.codegen,
|
||||
org.talend.designer.codegen.components.ui,
|
||||
org.talend.designer.codegen.config,
|
||||
org.talend.designer.codegen.exception,
|
||||
org.talend.designer.codegen.i18n,
|
||||
org.talend.designer.codegen.model,
|
||||
org.talend.designer.codegen.proxy
|
||||
org.talend.designer.codegen.proxy,
|
||||
org.talend.designer.codegen.stigma
|
||||
Bundle-Vendor: .Talend SA.
|
||||
Bundle-Activator: org.talend.designer.codegen.CodeGeneratorActivator
|
||||
Import-Package: org.apache.commons.lang
|
||||
Eclipse-BundleShape: dir
|
||||
Automatic-Module-Name: org.talend.designer.codegen
|
||||
|
||||
@@ -0,0 +1,232 @@
|
||||
<%@ jet
|
||||
imports="
|
||||
org.talend.core.model.process.INode
|
||||
org.talend.core.model.process.ElementParameterParser
|
||||
org.talend.core.model.process.IConnection
|
||||
org.talend.core.model.process.IConnectionCategory
|
||||
org.talend.designer.codegen.config.CodeGeneratorArgument
|
||||
org.talend.core.model.metadata.IMetadataTable
|
||||
org.talend.core.model.metadata.IMetadataColumn
|
||||
org.talend.core.model.metadata.types.JavaTypesManager
|
||||
org.talend.core.model.metadata.types.JavaType
|
||||
java.util.List
|
||||
java.util.Map
|
||||
"
|
||||
%>
|
||||
|
||||
<%
|
||||
CodeGeneratorArgument codeGenArgument = (CodeGeneratorArgument) argument;
|
||||
INode node = (INode)codeGenArgument.getArgument();
|
||||
String cid = node.getUniqueName();
|
||||
|
||||
String nbRows = ElementParameterParser.getValue(node, "__NB_ROWS__");
|
||||
|
||||
List<Map<String, String>> tableValues =
|
||||
(List<Map<String,String>>)ElementParameterParser.getObjectValue(
|
||||
node,
|
||||
"__VALUES__"
|
||||
);
|
||||
|
||||
boolean use_singleMode = ("true").equals(ElementParameterParser.getValue(node, "__USE_SINGLEMODE__"));
|
||||
boolean use_inTable = ("true").equals(ElementParameterParser.getValue(node, "__USE_INTABLE__"));
|
||||
boolean use_inlineContent = ("true").equals(ElementParameterParser.getValue(node, "__USE_INLINECONTENT__"));
|
||||
|
||||
String fieldSeparator = ElementParameterParser.getValue(node, "__FIELDSEPARATOR__");
|
||||
String rowSeparator = ElementParameterParser.getValue(node, "__ROWSEPARATOR__");
|
||||
|
||||
List<Map<String, String>> inTableValues =
|
||||
(List<Map<String,String>>)ElementParameterParser.getObjectValue(
|
||||
node,
|
||||
"__INTABLE__"
|
||||
);
|
||||
|
||||
List<IMetadataTable> metadatas = node.getMetadataList();
|
||||
IMetadataTable metadata = null;
|
||||
if ((metadatas!=null)&&(metadatas.size()>0)) {
|
||||
metadata = metadatas.get(0);
|
||||
}
|
||||
|
||||
List< ? extends IConnection> conns = node.getOutgoingSortedConnections();
|
||||
|
||||
//************** the original part that get only one value for each column ********************
|
||||
if(use_singleMode){
|
||||
if(tableValues != null && tableValues.size() > 0 && conns != null && conns.size() > 0) {
|
||||
%>
|
||||
for (int i_<%=cid%> = 0 ; i_<%=cid%> < <%=nbRows%> ; i_<%=cid%>++) {
|
||||
<%
|
||||
String firstConnName = "";
|
||||
for(IConnection conn : conns) {
|
||||
if(conn.getLineStyle().hasConnectionCategory(IConnectionCategory.DATA)) {
|
||||
firstConnName = conn.getName();
|
||||
break;
|
||||
} // if(conn) end
|
||||
} // for(conns) end
|
||||
if (firstConnName !=null && !"".equals(firstConnName)) {
|
||||
for(Map<String, String> tableValue : tableValues) {
|
||||
String lable = tableValue.get("SCHEMA_COLUMN");
|
||||
String value = tableValue.get("VALUE");
|
||||
if(value == null || value.length() == 0){ //use the default value
|
||||
IMetadataColumn column = metadata.getColumn(lable);
|
||||
String typeToGenerate = JavaTypesManager.getTypeToGenerate(column.getTalendType(), column.isNullable());
|
||||
String defaultValue = JavaTypesManager.getDefaultValueFromJavaType(typeToGenerate, column.getDefault());
|
||||
%>
|
||||
<%=firstConnName%>.<%=lable %> = <%=defaultValue %>;
|
||||
<%
|
||||
}else{
|
||||
%>
|
||||
<%=firstConnName%>.<%=lable %> = <%=value %>;
|
||||
<%
|
||||
}
|
||||
} // for (map) end
|
||||
} // if(firstConnName) end
|
||||
}
|
||||
//***************************the original part end ***************************************
|
||||
}else if(use_inTable){
|
||||
//******************the new part ---get several values for each column*********************
|
||||
if(inTableValues != null && inTableValues.size() > 0 && conns != null && conns.size() > 0) {
|
||||
%>
|
||||
int nb_line_<%=cid %> = 0;
|
||||
<%
|
||||
String firstConnName = "";
|
||||
for(IConnection conn : conns) {
|
||||
if(conn.getLineStyle().hasConnectionCategory(IConnectionCategory.DATA)) {
|
||||
firstConnName = conn.getName();
|
||||
break;
|
||||
}
|
||||
}
|
||||
if(firstConnName!=null && !firstConnName.equals("")){//XXX
|
||||
%>
|
||||
List<<%=firstConnName%>Struct> cacheList_<%=cid %> = new java.util.ArrayList<<%=firstConnName%>Struct>();
|
||||
<%
|
||||
for(Map<String, String> tableValue : inTableValues) {
|
||||
%>
|
||||
<%=firstConnName%> = new <%=firstConnName%>Struct();
|
||||
<%
|
||||
for(IMetadataColumn column: metadata.getListColumns()){
|
||||
String label = column.getLabel();
|
||||
String value = tableValue.get(label);
|
||||
if(value == null || value.length() == 0){ //use the default value
|
||||
String typeToGenerate = JavaTypesManager.getTypeToGenerate(column.getTalendType(), column.isNullable());
|
||||
String defaultValue = JavaTypesManager.getDefaultValueFromJavaType(typeToGenerate, column.getDefault());
|
||||
%>
|
||||
<%=firstConnName%>.<%=label %> = <%=defaultValue %>;
|
||||
<%
|
||||
}else{
|
||||
%>
|
||||
<%=firstConnName%>.<%=label %> = <%=value %>;
|
||||
<%
|
||||
}
|
||||
}
|
||||
%>
|
||||
cacheList_<%=cid %>.add(<%=firstConnName%>);
|
||||
<%
|
||||
}
|
||||
}
|
||||
%>
|
||||
for (int i_<%=cid%> = 0 ; i_<%=cid%> < <%=nbRows%> ; i_<%=cid%>++) {
|
||||
<%
|
||||
if(firstConnName!=null && !firstConnName.equals("")){
|
||||
%>
|
||||
for(<%=firstConnName%>Struct tmpRow_<%=cid %> : cacheList_<%=cid %>){
|
||||
<%
|
||||
}
|
||||
%>
|
||||
nb_line_<%=cid %> ++;
|
||||
<%
|
||||
if(firstConnName!=null && !firstConnName.equals("")){
|
||||
%>
|
||||
<%=firstConnName%> = tmpRow_<%=cid %>;
|
||||
<%
|
||||
}
|
||||
}
|
||||
//********************the new part end*****************************************************
|
||||
}else if(use_inlineContent){
|
||||
|
||||
String fileContent = ElementParameterParser.getValue(node,"__INLINECONTENT__");
|
||||
|
||||
String lineSeparator = "\r\n";
|
||||
|
||||
String fileContentEnCodeStr = "";
|
||||
try {
|
||||
fileContentEnCodeStr = java.util.Base64.getMimeEncoder().encodeToString(fileContent.getBytes("UTF-8"));
|
||||
} catch (java.io.UnsupportedEncodingException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
%>
|
||||
|
||||
StringBuilder result_<%=cid %> = new StringBuilder();
|
||||
<%
|
||||
String[] arrayStr = fileContentEnCodeStr.split(lineSeparator);
|
||||
for(String item : arrayStr){
|
||||
%>
|
||||
result_<%=cid %>.append("<%=item %>");
|
||||
<%}%>
|
||||
String originalFileContent_<%=cid %> = "";
|
||||
try {
|
||||
originalFileContent_<%=cid %> = new String(java.util.Base64.getMimeDecoder().decode(result_<%=cid %>.toString()), utf8Charset);
|
||||
} catch (java.lang.Exception e) {
|
||||
globalMap.put("<%=cid%>_ERROR_MESSAGE",e.getMessage());
|
||||
e.printStackTrace();
|
||||
}
|
||||
|
||||
int nb_line_<%=cid %> = 0;
|
||||
|
||||
for (int i_<%=cid%> = 0 ; i_<%=cid%> < <%=nbRows%> ; i_<%=cid%>++) {
|
||||
|
||||
java.io.InputStream ins_<%=cid %> = new java.io.ByteArrayInputStream(originalFileContent_<%=cid %>.getBytes(utf8Charset));
|
||||
org.talend.fileprocess.FileInputDelimited fid_<%=cid %> = new org.talend.fileprocess.FileInputDelimited(ins_<%=cid %>, utf8Charset,<%=fieldSeparator %>,<%=rowSeparator %>,true, 0, 0, -1, -1, false);
|
||||
|
||||
while (fid_<%=cid %>.nextRecord()) {
|
||||
nb_line_<%=cid %>++;
|
||||
<%
|
||||
String firstConnName = "";
|
||||
for(IConnection conn : conns) {
|
||||
if(conn.getLineStyle().hasConnectionCategory(IConnectionCategory.DATA)) {
|
||||
firstConnName = conn.getName();
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
if(!firstConnName.equals("")){//XXX
|
||||
%>
|
||||
<%=firstConnName %> = new <%=firstConnName %>Struct();
|
||||
<%
|
||||
List<IMetadataColumn> columns = metadata.getListColumns();
|
||||
int sizeListColumns = columns.size();
|
||||
|
||||
for (int i=0;i<sizeListColumns;i++) {//AAA
|
||||
IMetadataColumn column=columns.get(i);
|
||||
String label = column.getLabel();
|
||||
String typeToGenerate = JavaTypesManager.getTypeToGenerate(column.getTalendType(), column.isNullable());
|
||||
JavaType javaType = JavaTypesManager.getJavaTypeFromId(column.getTalendType());
|
||||
String patternValue = column.getPattern() == null || column.getPattern().trim().length() == 0 ? null : column.getPattern();
|
||||
String defaultValue = JavaTypesManager.getDefaultValueFromJavaType(typeToGenerate, column.getDefault());
|
||||
%>
|
||||
|
||||
if(<%=i %> < fid_<%=cid %>.getColumnsCountOfCurrentRow()){
|
||||
String colContent = fid_<%=cid %>.get(<%=i %>);
|
||||
<%if(javaType == JavaTypesManager.STRING || javaType == JavaTypesManager.OBJECT) {%>
|
||||
<%=firstConnName %>.<%=label %> = (colContent == null || colContent.length() == 0) ? <%=defaultValue %>: colContent;
|
||||
<%}else if(javaType == JavaTypesManager.DATE){%>
|
||||
<%=firstConnName %>.<%=label %> = (colContent == null || colContent.length() == 0) ? ParserUtils.parseTo_Date(<% if((defaultValue==null)||"".equals(defaultValue) || "null".equals(defaultValue)){%>(String)<%}%> <%=defaultValue %>, <%= patternValue %>) : ParserUtils.parseTo_Date(colContent, <%= patternValue %>);
|
||||
<%}else if(javaType == JavaTypesManager.BYTE_ARRAY){%>
|
||||
<%=firstConnName %>.<%=label %> = (colContent == null || colContent.length() == 0) ? <%=defaultValue %> : colContent.getBytes();
|
||||
<%}else{%>
|
||||
<%=firstConnName %>.<%=label %> = (colContent == null || colContent.trim().length() == 0) ? <%=defaultValue %> : ParserUtils.parseTo_<%= typeToGenerate %>(colContent);
|
||||
<%}%>
|
||||
} else {
|
||||
<%if(javaType != JavaTypesManager.DATE){%>
|
||||
<%=firstConnName %>.<%=label %> = <%=defaultValue %>;
|
||||
<%}else {%>
|
||||
<%=firstConnName %>.<%=label %> = ParserUtils.parseTo_Date(<% if(defaultValue==null||"".equals(defaultValue)|| "null".equals(defaultValue)){%>(String)<%}%><%=defaultValue %>, <%= patternValue %>);
|
||||
<%}%>
|
||||
}
|
||||
|
||||
<%
|
||||
}//AAA
|
||||
%>
|
||||
<%
|
||||
}//XXX
|
||||
//********************the use_inTable part end*****************************************************
|
||||
}
|
||||
%>
|
||||
@@ -0,0 +1,80 @@
|
||||
<%@ jet
|
||||
imports="
|
||||
org.talend.core.model.process.INode
|
||||
org.talend.core.model.process.ElementParameterParser
|
||||
org.talend.core.model.process.IConnection
|
||||
org.talend.designer.codegen.config.CodeGeneratorArgument
|
||||
org.talend.core.model.process.IConnectionCategory
|
||||
java.util.List
|
||||
java.util.Map"
|
||||
%>
|
||||
|
||||
<%
|
||||
CodeGeneratorArgument codeGenArgument = (CodeGeneratorArgument) argument;
|
||||
INode node = (INode)codeGenArgument.getArgument();
|
||||
String cid = node.getUniqueName();
|
||||
|
||||
String nbRows = ElementParameterParser.getValue(node, "__NB_ROWS__");
|
||||
|
||||
boolean use_singleMode = ("true").equals(ElementParameterParser.getValue(node, "__USE_SINGLEMODE__"));
|
||||
boolean use_inTable = ("true").equals(ElementParameterParser.getValue(node, "__USE_INTABLE__"));
|
||||
boolean use_inlineContent = ("true").equals(ElementParameterParser.getValue(node, "__USE_INLINECONTENT__"));
|
||||
|
||||
List<Map<String, String>> tableValues =
|
||||
(List<Map<String,String>>)ElementParameterParser.getObjectValue(
|
||||
node,
|
||||
"__VALUES__"
|
||||
);
|
||||
|
||||
List<Map<String, String>> inTableValues =
|
||||
(List<Map<String,String>>)ElementParameterParser.getObjectValue(
|
||||
node,
|
||||
"__INTABLE__"
|
||||
);
|
||||
|
||||
List< ? extends IConnection> conns = node.getOutgoingSortedConnections();
|
||||
if(use_singleMode){
|
||||
if(tableValues != null && tableValues.size() > 0 && conns != null && conns.size() > 0) {
|
||||
%>
|
||||
}
|
||||
globalMap.put("<%=cid%>_NB_LINE", <%=nbRows%>);
|
||||
<%
|
||||
}
|
||||
//********************the new part*****************************************************
|
||||
}else if(use_inTable){
|
||||
if(inTableValues != null && inTableValues.size() > 0 && conns != null && conns.size() > 0) {
|
||||
String firstConnName = null;
|
||||
for(IConnection conn : conns) {
|
||||
if(conn.getLineStyle().hasConnectionCategory(IConnectionCategory.DATA)) {
|
||||
firstConnName = conn.getName();
|
||||
break;
|
||||
}
|
||||
}
|
||||
if(firstConnName!=null && !firstConnName.equals("")){
|
||||
%>
|
||||
}
|
||||
<%
|
||||
}
|
||||
%>
|
||||
}
|
||||
<%
|
||||
if(firstConnName!=null && !firstConnName.equals("")){
|
||||
%>
|
||||
cacheList_<%=cid %>.clear();
|
||||
<%
|
||||
}
|
||||
%>
|
||||
globalMap.put("<%=cid%>_NB_LINE", nb_line_<%=cid %>);
|
||||
<%
|
||||
}
|
||||
//********************the new part*****************************************************
|
||||
} else if(use_inlineContent){
|
||||
%>
|
||||
}
|
||||
fid_<%=cid %>.close();
|
||||
}
|
||||
|
||||
globalMap.put("<%=cid%>_NB_LINE", nb_line_<%=cid %>);
|
||||
<%
|
||||
}
|
||||
%>
|
||||
Binary file not shown.
|
After Width: | Height: | Size: 2.1 KiB |
@@ -0,0 +1,90 @@
|
||||
<COMPONENT>
|
||||
<HEADER PLATEFORM="ALL" SERIAL="" VERSION="0.102" STATUS="ALPHA"
|
||||
COMPATIBILITY="ALL" AUTHOR="Talend" RELEASE_DATE="20050320A"
|
||||
STARTABLE="true">
|
||||
<SIGNATURE />
|
||||
</HEADER>
|
||||
|
||||
<FAMILIES>
|
||||
<FAMILY>Misc</FAMILY>
|
||||
</FAMILIES>
|
||||
|
||||
<DOCUMENTATION>
|
||||
<URL />
|
||||
</DOCUMENTATION>
|
||||
|
||||
<CONNECTORS>
|
||||
<CONNECTOR CTYPE="FLOW" MAX_INPUT="0" MAX_OUTPUT="1"/>
|
||||
<CONNECTOR CTYPE="ITERATE" MAX_OUTPUT="1" MAX_INPUT="1" />
|
||||
<CONNECTOR CTYPE="SUBJOB_OK" MAX_INPUT="1" />
|
||||
<CONNECTOR CTYPE="SUBJOB_ERROR" MAX_INPUT="1" />
|
||||
<CONNECTOR CTYPE="COMPONENT_OK" />
|
||||
<CONNECTOR CTYPE="COMPONENT_ERROR" />
|
||||
<CONNECTOR CTYPE="RUN_IF" />
|
||||
</CONNECTORS>
|
||||
|
||||
<PARAMETERS>
|
||||
<PARAMETER NAME="SCHEMA" FIELD="SCHEMA_TYPE" REQUIRED="true"
|
||||
NUM_ROW="10">
|
||||
<DEFAULT />
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="NB_ROWS" FIELD="TEXT" NUM_ROW="20">
|
||||
<DEFAULT>1</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="USE_SINGLEMODE" FIELD="RADIO" REQUIRED="true"
|
||||
NUM_ROW="30" GROUP="MODE">
|
||||
<DEFAULT>true</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="VALUES" FIELD="TABLE" REQUIRED="true"
|
||||
NUM_ROW="35" NB_LINES="5" SHOW_IF="USE_SINGLEMODE=='true'" GROUP="MODE">
|
||||
<ITEMS BASED_ON_SCHEMA="true">
|
||||
<ITEM NAME="VALUE" />
|
||||
</ITEMS>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="USE_INTABLE" FIELD="RADIO" REQUIRED="true"
|
||||
NUM_ROW="40" GROUP="MODE">
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="INTABLE" FIELD="TABLE" REQUIRED="true"
|
||||
NUM_ROW="45" NB_LINES="5" SHOW_IF="USE_INTABLE=='true'" GROUP="MODE">
|
||||
<ITEMS COLUMNS_BASED_ON_SCHEMA="true">
|
||||
</ITEMS>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="USE_INLINECONTENT" FIELD="RADIO" REQUIRED="true"
|
||||
NUM_ROW="50" GROUP="MODE">
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="ROWSEPARATOR" FIELD="TEXT" NUM_ROW="52"
|
||||
REQUIRED="true" SHOW_IF="USE_INLINECONTENT=='true'" GROUP="MODE">
|
||||
<DEFAULT>"\n"</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="FIELDSEPARATOR" FIELD="TEXT" NUM_ROW="52"
|
||||
REQUIRED="true" SHOW_IF="USE_INLINECONTENT=='true'" GROUP="MODE">
|
||||
<DEFAULT>";"</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="INLINECONTENT" FIELD="MEMO" RAW="true" REQUIRED="true"
|
||||
NUM_ROW="55" NB_LINES="10" SHOW_IF="USE_INLINECONTENT=='true'" GROUP="MODE">
|
||||
</PARAMETER>
|
||||
|
||||
</PARAMETERS>
|
||||
|
||||
<CODEGENERATION>
|
||||
<IMPORTS>
|
||||
<IMPORT NAME="Talen File Enhanced" MODULE="talend_file_enhanced-1.1.jar" MVN="mvn:org.talend.components.lib/talend_file_enhanced/1.1" UrlPath="platform:/plugin/org.talend.libraries.custom/lib/talend_file_enhanced-1.1.jar" REQUIRED="true" />
|
||||
</IMPORTS>
|
||||
</CODEGENERATION>
|
||||
|
||||
<RETURNS>
|
||||
<RETURN NAME="NB_LINE" TYPE="id_Integer" AVAILABILITY="AFTER" />
|
||||
</RETURNS>
|
||||
|
||||
</COMPONENT>
|
||||
@@ -0,0 +1,14 @@
|
||||
LONG_NAME=Creates a fixed flow from internal variables
|
||||
HELP=org.talend.help.tFixedFlowInput
|
||||
NB_LINE.NAME=Number of lines
|
||||
NB_ROWS.NAME=Number of rows
|
||||
VALUES.NAME=Values
|
||||
VALUES.ITEM.VALUE=Value
|
||||
INTABLE.NAME=Inline Table
|
||||
MODE.NAME=Mode
|
||||
USE_SINGLEMODE.NAME=Use Single Table
|
||||
USE_INTABLE.NAME=Use Inline Table
|
||||
USE_INLINECONTENT.NAME=Use Inline Content(delimited file)
|
||||
INLINECONTENT.NAME=Content
|
||||
ROWSEPARATOR.NAME=Row Separator
|
||||
FIELDSEPARATOR.NAME=Field Separator
|
||||
@@ -0,0 +1,7 @@
|
||||
NB_LINE.NAME=Anzahl an Zeilen
|
||||
VALUES.NAME=Wert
|
||||
VALUES.ITEM.VALUE=Wert
|
||||
MODE.NAME=Modus
|
||||
INLINECONTENT.NAME=Inhalt
|
||||
ROWSEPARATOR.NAME=Zeilenseparator
|
||||
FIELDSEPARATOR.NAME=Feldseparator
|
||||
@@ -0,0 +1,6 @@
|
||||
NB_ROWS.NAME=N\u00FAmero de filas
|
||||
VALUES.NAME=Valores
|
||||
VALUES.ITEM.VALUE=Valor
|
||||
INLINECONTENT.NAME=Contenido
|
||||
ROWSEPARATOR.NAME=Separador de Fila
|
||||
FIELDSEPARATOR.NAME=Separador de Campo
|
||||
@@ -0,0 +1,14 @@
|
||||
LONG_NAME=Cr\u00E9e un flux fixe \u00E0 partir de variables internes
|
||||
HELP=org.talend.help.tFixedFlowInput
|
||||
NB_LINE.NAME=Nombre de lignes
|
||||
NB_ROWS.NAME=Nombre de lignes
|
||||
VALUES.NAME=Valeurs
|
||||
VALUES.ITEM.VALUE=Valeur
|
||||
INTABLE.NAME=Utiliser le tableau
|
||||
MODE.NAME=Mode
|
||||
USE_SINGLEMODE.NAME=Utiliser une table seule
|
||||
USE_INTABLE.NAME=Utiliser le tableau
|
||||
USE_INLINECONTENT.NAME=Utiliser du contenu align\u00E9 (fichier d\u00E9limit\u00E9)
|
||||
INLINECONTENT.NAME=Contenu
|
||||
ROWSEPARATOR.NAME=S\u00E9parateur de lignes
|
||||
FIELDSEPARATOR.NAME=S\u00E9parateur de champs
|
||||
@@ -0,0 +1,13 @@
|
||||
LONG_NAME=Crea un flusso fisso da variabili interne
|
||||
NB_LINE.NAME=Numero di linee
|
||||
NB_ROWS.NAME=Numero di righe
|
||||
VALUES.NAME=Valori
|
||||
VALUES.ITEM.VALUE=Valore
|
||||
INTABLE.NAME=Tabella InLine
|
||||
MODE.NAME=Modo
|
||||
USE_SINGLEMODE.NAME=Utilizza tabella singola
|
||||
USE_INTABLE.NAME=Utilizza tabella InLine
|
||||
USE_INLINECONTENT.NAME=Utilizza contenuto Inline (file delimitato)
|
||||
INLINECONTENT.NAME=contenuto
|
||||
ROWSEPARATOR.NAME=Separatore riga
|
||||
FIELDSEPARATOR.NAME=Separatore di campo
|
||||
@@ -0,0 +1,14 @@
|
||||
LONG_NAME=\u5185\u90E8\u5909\u6570\u304B\u3089\u56FA\u5B9A\u30D5\u30ED\u30FC\u3092\u751F\u6210\u3057\u307E\u3059\u3002
|
||||
HELP=org.talend.help.tFixedFlowInput
|
||||
NB_LINE.NAME=\u884C\u6570
|
||||
NB_ROWS.NAME=\u884C\u6570
|
||||
VALUES.NAME=\u5024
|
||||
VALUES.ITEM.VALUE=\u5024
|
||||
INTABLE.NAME=\u30A4\u30F3\u30E9\u30A4\u30F3\u30C6\u30FC\u30D6\u30EB
|
||||
MODE.NAME=\u30E2\u30FC\u30C9
|
||||
USE_SINGLEMODE.NAME=\u30B7\u30F3\u30B0\u30EB\u30C6\u30FC\u30D6\u30EB\u306E\u4F7F\u7528
|
||||
USE_INTABLE.NAME=\u30A4\u30F3\u30E9\u30A4\u30F3\u30C6\u30FC\u30D6\u30EB\u306E\u4F7F\u7528
|
||||
USE_INLINECONTENT.NAME=\u30A4\u30F3\u30E9\u30A4\u30F3\u30B3\u30F3\u30C6\u30F3\u30C4\u3092\u4F7F\u7528
|
||||
INLINECONTENT.NAME=\u30B3\u30F3\u30C6\u30F3\u30C4
|
||||
ROWSEPARATOR.NAME=\u884C\u533A\u5207\u308A
|
||||
FIELDSEPARATOR.NAME=\u30D5\u30A3\u30FC\u30EB\u30C9\u533A\u5207\u308A
|
||||
@@ -0,0 +1,10 @@
|
||||
LONG_NAME=\u5185\u90E8\u5909\u6570\u304B\u3089\u56FA\u5B9A\u30D5\u30ED\u30FC\u3092\u4F5C\u6210
|
||||
HELP=org.talend.help.tFixedFlowInput
|
||||
NB_LINE.NAME=\u884c\u6570
|
||||
NB_ROWS.NAME=\u30ed\u30a6\u6570
|
||||
VALUES.NAME=\u5024
|
||||
VALUES.ITEM.VALUE=\u5024
|
||||
MODE.NAME=\u30E2\u30FC\u30C9
|
||||
INLINECONTENT.NAME=\u30B3\u30F3\u30C6\u30F3\u30C4
|
||||
ROWSEPARATOR.NAME=\u30ED\u30A6\u30BB\u30D1\u30EC\u30FC\u30BF
|
||||
FIELDSEPARATOR.NAME=\u30D5\u30A3\u30FC\u30EB\u30C9\u30BB\u30D1\u30EC\u30FC\u30BF
|
||||
@@ -0,0 +1,6 @@
|
||||
NB_LINE.NAME=\u0427\u0438\u0441\u043B\u043E \u0441\u0442\u0440\u043E\u043A
|
||||
VALUES.NAME=\u0417\u043D\u0430\u0447\u0435\u043D\u0438\u044F
|
||||
VALUES.ITEM.VALUE=\u0417\u043D\u0430\u0447\u0435\u043D\u0438\u0435
|
||||
INLINECONTENT.NAME=\u0441\u043E\u0434\u0435\u0440\u0436\u0438\u043C\u043E\u0435
|
||||
ROWSEPARATOR.NAME=\u0420\u0430\u0437\u0434\u0435\u043B\u0438\u0442\u0435\u043B\u044C \u0441\u0442\u0440\u043E\u043A
|
||||
FIELDSEPARATOR.NAME=\u0420\u0430\u0437\u0434\u0435\u043B\u0438\u0442\u0435\u043B\u044C \u043F\u043E\u043B\u0435\u0439
|
||||
@@ -0,0 +1,3 @@
|
||||
VALUES.ITEM.VALUE=Hodnota
|
||||
MODE.NAME=M\u00F3d
|
||||
INLINECONTENT.NAME=Obsah
|
||||
@@ -0,0 +1,3 @@
|
||||
VALUES.ITEM.VALUE=Hodnota
|
||||
MODE.NAME=Mód
|
||||
INLINECONTENT.NAME=Obsah
|
||||
@@ -0,0 +1,14 @@
|
||||
LONG_NAME=\u4ECE\u5185\u90E8\u53D8\u91CF\u521B\u5EFA\u56FA\u5B9A\u6D41
|
||||
HELP=org.talend.help.tFixedFlowInput
|
||||
NB_LINE.NAME=\u884C\u6570
|
||||
NB_ROWS.NAME=\u884C\u6570
|
||||
VALUES.NAME=\u503C
|
||||
VALUES.ITEM.VALUE=\u503C
|
||||
INTABLE.NAME=\u5185\u8054\u8868
|
||||
MODE.NAME=\u6A21\u5F0F
|
||||
USE_SINGLEMODE.NAME=\u4F7F\u7528\u5355\u8868
|
||||
USE_INTABLE.NAME=\u4F7F\u7528\u5185\u8054\u8868
|
||||
USE_INLINECONTENT.NAME=\u4F7F\u7528\u5185\u8054\u5185\u5BB9 (\u5206\u9694\u6587\u4EF6)
|
||||
INLINECONTENT.NAME=\u5185\u5BB9
|
||||
ROWSEPARATOR.NAME=\u884C\u5206\u9694\u7B26
|
||||
FIELDSEPARATOR.NAME=\u5B57\u6BB5\u5206\u9694\u7B26
|
||||
@@ -0,0 +1,14 @@
|
||||
<%@ jet
|
||||
imports="
|
||||
org.talend.core.model.process.INode
|
||||
org.talend.core.model.process.ElementParameterParser
|
||||
org.talend.designer.codegen.config.CodeGeneratorArgument
|
||||
"
|
||||
%>
|
||||
|
||||
<%
|
||||
CodeGeneratorArgument codeGenArgument = (CodeGeneratorArgument) argument;
|
||||
INode node = (INode)codeGenArgument.getArgument();
|
||||
%>
|
||||
|
||||
<%=ElementParameterParser.getValue(node, "__CODE__") %>
|
||||
Binary file not shown.
|
After Width: | Height: | Size: 2.5 KiB |
@@ -0,0 +1,52 @@
|
||||
<COMPONENT>
|
||||
<HEADER
|
||||
PLATEFORM="ALL"
|
||||
SERIAL=""
|
||||
VERSION="0.101"
|
||||
STATUS="ALPHA"
|
||||
|
||||
COMPATIBILITY="ALL"
|
||||
AUTHOR="Talend"
|
||||
RELEASE_DATE="20070210A"
|
||||
STARTABLE="true"
|
||||
PARTITIONING="AUTO"
|
||||
>
|
||||
<SIGNATURE></SIGNATURE>
|
||||
</HEADER>
|
||||
|
||||
<FAMILIES>
|
||||
<FAMILY>Custom_Code</FAMILY>
|
||||
</FAMILIES>
|
||||
|
||||
<DOCUMENTATION>
|
||||
<URL/>
|
||||
</DOCUMENTATION>
|
||||
|
||||
<CONNECTORS>
|
||||
<CONNECTOR CTYPE="FLOW" MAX_INPUT="1" MAX_OUTPUT="1"/>
|
||||
<CONNECTOR CTYPE="ITERATE" MAX_OUTPUT="1" MAX_INPUT="1"/>
|
||||
<CONNECTOR CTYPE="SUBJOB_OK" MAX_INPUT="1" />
|
||||
<CONNECTOR CTYPE="SUBJOB_ERROR" MAX_INPUT="1" />
|
||||
<CONNECTOR CTYPE="COMPONENT_OK"/>
|
||||
<CONNECTOR CTYPE="COMPONENT_ERROR"/>
|
||||
<CONNECTOR CTYPE="RUN_IF"/>
|
||||
</CONNECTORS>
|
||||
|
||||
<PARAMETERS>
|
||||
<PARAMETER NAME="CODE" FIELD="MEMO_JAVA" RAW="true" REQUIRED="false" NUM_ROW="2" NB_LINES="9" CONTEXT="begin">
|
||||
<DEFAULT>String foo = "bar";</DEFAULT>
|
||||
</PARAMETER>
|
||||
</PARAMETERS>
|
||||
|
||||
|
||||
<ADVANCED_PARAMETERS>
|
||||
<PARAMETER NAME="IMPORT" FIELD="MEMO_IMPORT" RAW="true" REQUIRED="false" NUM_ROW="1" NB_LINES="3">
|
||||
<DEFAULT>//import java.util.List;</DEFAULT>
|
||||
</PARAMETER>
|
||||
</ADVANCED_PARAMETERS>
|
||||
|
||||
<CODEGENERATION/>
|
||||
|
||||
<RETURNS/>
|
||||
|
||||
</COMPONENT>
|
||||
@@ -0,0 +1,4 @@
|
||||
CODE.NAME=Code
|
||||
HELP=org.talend.help.tJava
|
||||
LONG_NAME=Allows to enter manually the start Java-code part of a component
|
||||
IMPORT.NAME=Import
|
||||
@@ -0,0 +1,3 @@
|
||||
CODE.NAME=Code
|
||||
LONG_NAME=Erm\u00F6glich die manuelle Eingabe des Java-Codes f\u00FCr den Start Bereich der Komponente
|
||||
IMPORT.NAME=Importiere
|
||||
@@ -0,0 +1 @@
|
||||
CODE.NAME=Codigo
|
||||
@@ -0,0 +1,4 @@
|
||||
CODE.NAME=Code
|
||||
HELP=org.talend.help.tJava
|
||||
LONG_NAME=Permet de saisir manuellement le code Java initial d'un composant
|
||||
IMPORT.NAME=Import
|
||||
@@ -0,0 +1,3 @@
|
||||
CODE.NAME=Codice
|
||||
LONG_NAME=Permetti di inserire manualmente lo start Java-code in un componente
|
||||
IMPORT.NAME=Importa
|
||||
@@ -0,0 +1,4 @@
|
||||
CODE.NAME=\u30B3\u30FC\u30C9
|
||||
HELP=org.talend.help.tJava
|
||||
LONG_NAME=Java\u30B3\u30FC\u30C9\u306B\u3066\u3001\u30B3\u30F3\u30DD\u30FC\u30CD\u30F3\u30C8\u306E\u958B\u59CB\u51E6\u7406(begin)\u306E\u30B9\u30AF\u30EA\u30D7\u30C8\u3092\u30DE\u30CB\u30E5\u30A2\u30EB\u4F5C\u6210
|
||||
IMPORT.NAME=\u30A4\u30F3\u30DD\u30FC\u30C8
|
||||
@@ -0,0 +1,4 @@
|
||||
CODE.NAME=\u30B3\u30FC\u30C9
|
||||
HELP=org.talend.help.tJava
|
||||
LONG_NAME=Java\u30B3\u30FC\u30C9\u306B\u3066\u3001\u30B3\u30F3\u30DD\u30FC\u30CD\u30F3\u30C8\u306E\u958B\u59CB\u51E6\u7406(begin)\u306E\u30B9\u30AF\u30EA\u30D7\u30C8\u3092\u30DE\u30CB\u30E5\u30A2\u30EB\u4F5C\u6210
|
||||
IMPORT.NAME=\u30A4\u30F3\u30DD\u30FC\u30C8
|
||||
@@ -0,0 +1 @@
|
||||
CODE.NAME=\u041A\u043E\u0434
|
||||
@@ -0,0 +1 @@
|
||||
CODE.NAME=K\u00F3d
|
||||
@@ -0,0 +1 @@
|
||||
CODE.NAME=Kód
|
||||
@@ -0,0 +1,4 @@
|
||||
CODE.NAME=\u4EE3\u7801
|
||||
HELP=org.talend.help.tJava
|
||||
LONG_NAME=\u5141\u8BB8\u624B\u52A8\u8F93\u5165\u7EC4\u4EF6\u7684 Java \u4EE3\u7801\u7684\u5F00\u59CB\u90E8\u5206\u3002
|
||||
IMPORT.NAME=\u5BFC\u5165
|
||||
@@ -0,0 +1,441 @@
|
||||
<%@ jet
|
||||
imports="
|
||||
org.talend.core.model.process.INode
|
||||
org.talend.core.model.process.ElementParameterParser
|
||||
org.talend.designer.codegen.config.CodeGeneratorArgument
|
||||
org.talend.core.model.metadata.IMetadataTable
|
||||
org.talend.core.model.metadata.IMetadataColumn
|
||||
org.talend.core.model.metadata.types.JavaType
|
||||
org.talend.core.model.process.IConnection
|
||||
org.talend.core.model.process.IConnectionCategory
|
||||
org.talend.core.model.metadata.types.JavaTypesManager
|
||||
org.talend.core.model.utils.NodeUtil
|
||||
java.util.List
|
||||
java.util.Map
|
||||
"
|
||||
%>
|
||||
|
||||
<%
|
||||
CodeGeneratorArgument codeGenArgument = (CodeGeneratorArgument) argument;
|
||||
INode node = (INode)codeGenArgument.getArgument();
|
||||
|
||||
List<IMetadataTable> metadatas = node.getMetadataList();
|
||||
if ((metadatas!=null)&&(metadatas.size()>0)) {//1
|
||||
IMetadataTable metadata = metadatas.get(0);
|
||||
if (metadata!=null) {//2
|
||||
|
||||
String cid = node.getUniqueName();
|
||||
String label = ElementParameterParser.getValue(node, "__LABEL__");
|
||||
if(("__UNIQUE_NAME__").equals(label))
|
||||
label=cid;
|
||||
boolean tablePrint = ("true").equals(ElementParameterParser.getValue(node,"__TABLE_PRINT__"));
|
||||
String printHeader = ElementParameterParser.getValue(node,"__PRINT_HEADER__");
|
||||
boolean vertical = ("true").equals(ElementParameterParser.getValue(node,"__VERTICAL__"));
|
||||
boolean uniquePrint = ("true").equals(ElementParameterParser.getValue(node,"__PRINT_UNIQUE__"));
|
||||
boolean titlePrint = ("true").equals(ElementParameterParser.getValue(node,"__PRINT_LABEL__"));
|
||||
boolean uniqueTitlePrint = ("true").equals(ElementParameterParser.getValue(node,"__PRINT_UNIQUE_LABEL__"));
|
||||
boolean basic = !(tablePrint||vertical);
|
||||
boolean isLog4jEnabled = ("true").equals(ElementParameterParser.getValue(node.getProcess(), "__LOG4J_ACTIVATE__"));
|
||||
boolean isLogContent = ("true").equals(ElementParameterParser.getValue(node,"__PRINT_CONTENT_WITH_LOG4J__"));
|
||||
|
||||
List<IMetadataColumn> columns = metadata.getListColumns();
|
||||
int sizeColumns = columns.size();
|
||||
%>
|
||||
///////////////////////
|
||||
<%
|
||||
if(tablePrint) { // table display mode
|
||||
%>
|
||||
<%@ include file="@{org.talend.designer.components.localprovider}/components/templates/tablePrintLogUtil.javajet"%>
|
||||
<%
|
||||
}
|
||||
// vertical display mode
|
||||
if(vertical) {
|
||||
%>
|
||||
|
||||
|
||||
class Util_<%=cid %> {
|
||||
|
||||
String[] des_top = { ".", "-" };
|
||||
|
||||
String[] des_data = { "-", "+" };
|
||||
|
||||
String[] des_frame = { "|" };
|
||||
|
||||
public void printLine(StringBuilder sb, int titleWidth, int dataWidth){
|
||||
|
||||
sb.append("+");
|
||||
for(int i=0; i<titleWidth+2; i++)
|
||||
sb.append("-");
|
||||
sb.append("+");
|
||||
for(int i=0; i<dataWidth+2; i++)
|
||||
sb.append("-");
|
||||
sb.append("+" + "\n");
|
||||
}
|
||||
|
||||
public String print(String[] row, int nbLine){
|
||||
|
||||
StringBuilder sb = new StringBuilder();
|
||||
<%
|
||||
if(uniquePrint) {
|
||||
%>
|
||||
String title = "#" + nbLine + ". " + "<%=cid%>";
|
||||
<%
|
||||
} else if(titlePrint) {
|
||||
%>
|
||||
String title = "#" + nbLine + ". " + "<%=label%>";
|
||||
<%
|
||||
} else if(uniqueTitlePrint) {
|
||||
%>
|
||||
String title = "#" + nbLine + ". " + "<%=cid%>--<%=label%>";
|
||||
<%
|
||||
}
|
||||
%>
|
||||
|
||||
//step 1: get the max length of all the row[] member;
|
||||
int dataWidth = 5; //the length of the string "value"
|
||||
for(int i=0;i<row.length;i++) {
|
||||
if(row[i] == null && 4 > dataWidth) {
|
||||
dataWidth = 4;
|
||||
}
|
||||
else if(row[i] != null && row[i].length()>dataWidth)
|
||||
dataWidth = row[i].length();
|
||||
}
|
||||
<%
|
||||
int titleWidth = 3; //the length of the string 'key'
|
||||
for(IMetadataColumn column:columns)
|
||||
if(column.getLabel().length()>titleWidth) titleWidth = column.getLabel().length();
|
||||
%>
|
||||
int titleWidth = <%=titleWidth%>;
|
||||
|
||||
int totalWidth = dataWidth + titleWidth + 5;
|
||||
|
||||
//step 2: print the header with line number
|
||||
sb.append(".");
|
||||
for(int i=0 ; i<totalWidth ; i++)
|
||||
sb.append("-");
|
||||
sb.append("." + "\n" + "|");
|
||||
|
||||
int emptyCenterWidth = (totalWidth-title.length())/2;
|
||||
for(int i=0 ; i<emptyCenterWidth; i++)
|
||||
sb.append(" ");
|
||||
sb.append(title);
|
||||
for(int i=0 ; i<totalWidth - emptyCenterWidth - title.length() ; i++)
|
||||
sb.append(" ");
|
||||
sb.append("|" + "\n");
|
||||
|
||||
//step 3: print "key" and "value"
|
||||
printLine(sb,titleWidth,dataWidth);
|
||||
|
||||
sb.append("|" + " key");
|
||||
for(int i=0; i<titleWidth-2; i++)
|
||||
sb.append(" ");
|
||||
sb.append("|" + " value");
|
||||
for(int i=0; i<dataWidth-4; i++)
|
||||
sb.append(" ");
|
||||
sb.append("|" + "\n");
|
||||
|
||||
printLine(sb,titleWidth,dataWidth);
|
||||
|
||||
//step 4: print dataset
|
||||
<%
|
||||
int count = 0;
|
||||
for(IMetadataColumn column:columns){
|
||||
%>
|
||||
//for(int i=0; i<row.length; i++){
|
||||
sb.append("| " + "<%=column.getLabel()%>");
|
||||
for(int i=0; i<titleWidth -"<%=column.getLabel()%>".length()+ 1 ;i++)
|
||||
sb.append(" ");
|
||||
sb.append("| " + row[<%=count%>]);
|
||||
for(int i=0; row[<%=count%>] == null && i<dataWidth - 3 || row[<%=count%>] != null && i<dataWidth -row[<%=count%>].length()+ 1 ;i++)
|
||||
sb.append(" ");
|
||||
sb.append("|" + "\n");
|
||||
|
||||
//}
|
||||
|
||||
<%
|
||||
count++;
|
||||
}%>
|
||||
//step 5: print a line gap
|
||||
printLine(sb,titleWidth,dataWidth);
|
||||
return sb.toString();
|
||||
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
Util_<%=cid %> util_<%=cid %> = new Util_<%=cid %>();
|
||||
|
||||
|
||||
|
||||
|
||||
java.io.PrintStream consoleOut_<%=cid%> = null;
|
||||
if (globalMap.get("tLogRow_CONSOLE")!=null){
|
||||
consoleOut_<%=cid%> = (java.io.PrintStream) globalMap.get("tLogRow_CONSOLE");
|
||||
}else{
|
||||
consoleOut_<%=cid%> = new java.io.PrintStream(new java.io.BufferedOutputStream(System.out));
|
||||
globalMap.put("tLogRow_CONSOLE",consoleOut_<%=cid%>);
|
||||
}
|
||||
|
||||
<%
|
||||
}
|
||||
|
||||
if(basic) {// basic display mode
|
||||
%>
|
||||
final String OUTPUT_FIELD_SEPARATOR_<%=cid %> = <%=ElementParameterParser.getValue(node, "__FIELDSEPARATOR__") %>;
|
||||
java.io.PrintStream consoleOut_<%=cid%> = null;
|
||||
<%
|
||||
if (("true").equals(printHeader)) {
|
||||
%>
|
||||
|
||||
|
||||
StringBuilder sbHeader_<%=cid%> = new StringBuilder();
|
||||
<%
|
||||
for (int i = 0; i < sizeColumns; i++) {
|
||||
IMetadataColumn column = columns.get(i);
|
||||
%>
|
||||
|
||||
sbHeader_<%=cid%>.append("<%=column.getLabel() %>");
|
||||
|
||||
<%
|
||||
if(i == sizeColumns-1) break;
|
||||
%>
|
||||
sbHeader_<%=cid%>.append("\t");
|
||||
<%
|
||||
}
|
||||
%>
|
||||
|
||||
if (globalMap.get("tLogRow_CONSOLE")!=null)
|
||||
{
|
||||
consoleOut_<%=cid%> = (java.io.PrintStream) globalMap.get("tLogRow_CONSOLE");
|
||||
}
|
||||
else
|
||||
{
|
||||
consoleOut_<%=cid%> = new java.io.PrintStream(new java.io.BufferedOutputStream(System.out));
|
||||
globalMap.put("tLogRow_CONSOLE",consoleOut_<%=cid%>);
|
||||
}
|
||||
<%
|
||||
if(isLogContent && isLog4jEnabled){
|
||||
%>
|
||||
log.info("<%=cid%> - Header names: " + sbHeader_<%=cid%>.toString());
|
||||
<%
|
||||
}
|
||||
%>
|
||||
consoleOut_<%=cid%>.println(sbHeader_<%=cid%>.toString());
|
||||
consoleOut_<%=cid%>.flush();
|
||||
|
||||
<%
|
||||
}
|
||||
%>
|
||||
|
||||
<%
|
||||
}
|
||||
%>
|
||||
StringBuilder strBuffer_<%=cid%> = null;
|
||||
int nb_line_<%=cid%> = 0;
|
||||
///////////////////////
|
||||
|
||||
<%
|
||||
String printColumnNames = ElementParameterParser.getValue(node,"__PRINT_COLNAMES__");
|
||||
String useFixedLength = ElementParameterParser.getValue(node,"__USE_FIXED_LENGTH__");
|
||||
List<Map<String, String>> lengths = (List<Map<String,String>>)ElementParameterParser.getObjectValue(node,"__LENGTHS__");
|
||||
List< ? extends IConnection> conns = node.getIncomingConnections();
|
||||
for (IConnection conn : conns) {//3
|
||||
if (conn.getLineStyle().hasConnectionCategory(IConnectionCategory.DATA)) {//4
|
||||
int schemaOptNum=100;
|
||||
String schemaOptNumStr=ElementParameterParser.getValue(node, "__SCHEMA_OPT_NUM__");
|
||||
if(schemaOptNumStr!=null && !"".equals(schemaOptNumStr) && !"\"\"".equals(schemaOptNumStr)){
|
||||
schemaOptNum = Integer.parseInt(schemaOptNumStr);
|
||||
}
|
||||
boolean isOptimizeCode = false;
|
||||
if(schemaOptNum < sizeColumns){
|
||||
isOptimizeCode = true;
|
||||
}
|
||||
if(isOptimizeCode){//5
|
||||
%>
|
||||
class LogRowUtil_<%=cid%>{
|
||||
<%
|
||||
if (basic||vertical) { // A1
|
||||
for (int i = 0; i < sizeColumns; i++) {//B1
|
||||
IMetadataColumn column = columns.get(i);
|
||||
JavaType javaType = JavaTypesManager.getJavaTypeFromId(column.getTalendType());
|
||||
if(i%schemaOptNum==0){
|
||||
%>
|
||||
public void putBasicVerticalValue_<%=i/schemaOptNum%>(final <%=NodeUtil.getPrivateConnClassName(conn)%>Struct <%=conn.getName() %>,StringBuilder strBuffer_<%=cid%>){
|
||||
<%
|
||||
}
|
||||
if (("true").equals(useFixedLength)) {//fix the column length
|
||||
%>
|
||||
java.util.Formatter formatter_<%=column.getLabel() %>_<%=cid%> = new java.util.Formatter(new StringBuilder());
|
||||
<%
|
||||
}
|
||||
if (("true").equals(printColumnNames)) {//print the schema name
|
||||
%>
|
||||
strBuffer_<%=cid%>.append("<%=column.getLabel() %>: ");
|
||||
<%
|
||||
}
|
||||
boolean isPrimitive = JavaTypesManager.isJavaPrimitiveType( javaType, column.isNullable());
|
||||
if(!isPrimitive) { //begin
|
||||
%>
|
||||
if(<%=conn.getName() %>.<%=column.getLabel() %> != null) { //
|
||||
<%
|
||||
}
|
||||
if (("true").equals(useFixedLength)) {//AAA
|
||||
%>
|
||||
strBuffer_<%=cid%>.append(formatter_<%=column.getLabel() %>_<%=cid%>.format("%1$"+<%=lengths.get(i).get("LENGTH") %>+"s",
|
||||
<%
|
||||
String pattern = column.getPattern() == null || column.getPattern().trim().length() == 0 ? null : column.getPattern();
|
||||
if (javaType == JavaTypesManager.DATE && pattern != null && pattern.trim().length() != 0) {//Date
|
||||
%>
|
||||
FormatterUtils.format_Date(<%=conn.getName() %>.<%=column.getLabel() %>, <%= pattern %>)
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.BYTE_ARRAY) {//byte[]
|
||||
%>
|
||||
java.nio.charset.Charset.defaultCharset().decode(java.nio.ByteBuffer.wrap(<%=conn.getName() %>.<%=column.getLabel() %>)).toString()
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.BIGDECIMAL) {
|
||||
%>
|
||||
<%=column.getPrecision() == null? conn.getName() + "." + column.getLabel() : conn.getName() + "." + column.getLabel() + ".setScale(" + column.getPrecision() + ", java.math.RoundingMode.HALF_UP)" %>.toPlainString()
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.DOUBLE || javaType == JavaTypesManager.FLOAT ) {
|
||||
%>
|
||||
FormatterUtils.formatUnwithE(<%=conn.getName() %>.<%=column.getLabel() %>)
|
||||
<%
|
||||
} else {//others
|
||||
%>
|
||||
String.valueOf(<%=conn.getName() %>.<%=column.getLabel() %>)
|
||||
<%
|
||||
}
|
||||
%>
|
||||
).toString());
|
||||
<%
|
||||
} else {//AAA
|
||||
%>
|
||||
strBuffer_<%=cid%>.append(
|
||||
<%
|
||||
String pattern = column.getPattern() == null || column.getPattern().trim().length() == 0 ? null : column.getPattern();
|
||||
if (javaType == JavaTypesManager.DATE && pattern != null && pattern.trim().length() != 0) {//Date
|
||||
%>
|
||||
FormatterUtils.format_Date(<%=conn.getName() %>.<%=column.getLabel() %>, <%= pattern %>)
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.BYTE_ARRAY) {//byte[]
|
||||
%>
|
||||
java.nio.charset.Charset.defaultCharset().decode(java.nio.ByteBuffer.wrap(<%=conn.getName() %>.<%=column.getLabel() %>)).toString()
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.BIGDECIMAL) {
|
||||
%>
|
||||
<%=column.getPrecision() == null? conn.getName() + "." + column.getLabel() : conn.getName() + "." + column.getLabel() + ".setScale(" + column.getPrecision() + ", java.math.RoundingMode.HALF_UP)" %>.toPlainString()
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.DOUBLE || javaType == JavaTypesManager.FLOAT ) {
|
||||
%>
|
||||
FormatterUtils.formatUnwithE(<%=conn.getName() %>.<%=column.getLabel() %>)
|
||||
<%
|
||||
} else {//others
|
||||
%>
|
||||
String.valueOf(<%=conn.getName() %>.<%=column.getLabel() %>)
|
||||
<%
|
||||
}
|
||||
%>
|
||||
);
|
||||
<%
|
||||
}//AAA
|
||||
if(!isPrimitive) {//end
|
||||
%>
|
||||
} //
|
||||
<%
|
||||
}
|
||||
if(i == sizeColumns-1){
|
||||
if((i+1)%schemaOptNum==0){
|
||||
%>
|
||||
}
|
||||
<%
|
||||
}
|
||||
break;
|
||||
}else{
|
||||
%>
|
||||
strBuffer_<%=cid%>.append(<%=ElementParameterParser.getValue(node, "__FIELDSEPARATOR__") %>);
|
||||
<%
|
||||
}
|
||||
if((i+1)%schemaOptNum==0){
|
||||
%>
|
||||
}
|
||||
<%
|
||||
}
|
||||
}//B1
|
||||
if(sizeColumns>0 && (sizeColumns%schemaOptNum)>0){
|
||||
%>
|
||||
}
|
||||
<%
|
||||
}
|
||||
}//A1
|
||||
if(tablePrint || vertical) { //C1
|
||||
for (int i = 0; i < sizeColumns; i++) {//D1
|
||||
IMetadataColumn column = columns.get(i);
|
||||
JavaType javaType = JavaTypesManager.getJavaTypeFromId(column.getTalendType());
|
||||
boolean isPrimitive = JavaTypesManager.isJavaPrimitiveType( javaType, column.isNullable());
|
||||
if(i%schemaOptNum==0){
|
||||
%>
|
||||
public void putTableVerticalValue_<%=i/schemaOptNum%>(final <%=NodeUtil.getPrivateConnClassName(conn) %>Struct <%=conn.getName() %>,String[] row_<%=cid%>){
|
||||
<%
|
||||
}
|
||||
if(!isPrimitive) { //begin
|
||||
%>
|
||||
if(<%=conn.getName() %>.<%=column.getLabel() %> != null) { //
|
||||
<%
|
||||
}
|
||||
%>
|
||||
row_<%=cid%>[<%=i %>]=
|
||||
<%
|
||||
String pattern = column.getPattern() == null || column.getPattern().trim().length() == 0 ? null : column.getPattern();
|
||||
if (javaType == JavaTypesManager.DATE && pattern != null && pattern.trim().length() != 0) {//Date
|
||||
%>
|
||||
FormatterUtils.format_Date(<%=conn.getName() %>.<%=column.getLabel() %>, <%= pattern %>)
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.BYTE_ARRAY) {//byte[]
|
||||
%>
|
||||
java.nio.charset.Charset.defaultCharset().decode(java.nio.ByteBuffer.wrap(<%=conn.getName() %>.<%=column.getLabel() %>)).toString()
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.BIGDECIMAL) {
|
||||
%>
|
||||
<%=column.getPrecision() == null? conn.getName() + "." + column.getLabel() : conn.getName() + "." + column.getLabel() + ".setScale(" + column.getPrecision() + ", java.math.RoundingMode.HALF_UP)" %>.toPlainString()
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.DOUBLE || javaType == JavaTypesManager.FLOAT ) {
|
||||
%>
|
||||
FormatterUtils.formatUnwithE(<%=conn.getName() %>.<%=column.getLabel() %>)
|
||||
<%
|
||||
} else {//others
|
||||
%>
|
||||
String.valueOf(<%=conn.getName() %>.<%=column.getLabel() %>)
|
||||
<%
|
||||
}
|
||||
%>
|
||||
;
|
||||
<%
|
||||
if(!isPrimitive) {//end
|
||||
%>
|
||||
} //
|
||||
<%
|
||||
}
|
||||
if((i+1)%schemaOptNum==0){
|
||||
%>
|
||||
}
|
||||
<%
|
||||
}
|
||||
}//D1
|
||||
if(sizeColumns>0&&(sizeColumns%schemaOptNum)>0){
|
||||
%>
|
||||
}
|
||||
<%
|
||||
}
|
||||
}//C1
|
||||
%>
|
||||
}
|
||||
LogRowUtil_<%=cid%> logRowUtil_<%=cid%>=new LogRowUtil_<%=cid%>();
|
||||
<%
|
||||
}//5
|
||||
}//4
|
||||
}//3
|
||||
}//2
|
||||
}//1
|
||||
%>
|
||||
|
||||
@@ -0,0 +1,54 @@
|
||||
<%@ jet
|
||||
imports="
|
||||
org.talend.core.model.process.INode
|
||||
org.talend.core.model.process.ElementParameterParser
|
||||
org.talend.designer.codegen.config.CodeGeneratorArgument
|
||||
org.talend.core.model.metadata.IMetadataTable
|
||||
java.util.List
|
||||
"
|
||||
%>
|
||||
<%@ include file="@{org.talend.designer.components.localprovider}/components/templates/Log4j/LogUtil.javajet"%>
|
||||
<%
|
||||
CodeGeneratorArgument codeGenArgument = (CodeGeneratorArgument) argument;
|
||||
INode node = (INode)codeGenArgument.getArgument();
|
||||
log = new LogUtil(node);
|
||||
List<IMetadataTable> metadatas = node.getMetadataList();
|
||||
if ((metadatas!=null)&&(metadatas.size()>0)) {//1
|
||||
IMetadataTable metadata = metadatas.get(0);
|
||||
if (metadata!=null) {//2
|
||||
|
||||
String cid = node.getUniqueName();
|
||||
String tablePrint = ElementParameterParser.getValue(node,"__TABLE_PRINT__");
|
||||
%>
|
||||
|
||||
//////
|
||||
<%
|
||||
if (("true").equals(tablePrint)) {//print all records one time
|
||||
%>
|
||||
|
||||
|
||||
java.io.PrintStream consoleOut_<%=cid%> = null;
|
||||
if (globalMap.get("tLogRow_CONSOLE")!=null)
|
||||
{
|
||||
consoleOut_<%=cid%> = (java.io.PrintStream) globalMap.get("tLogRow_CONSOLE");
|
||||
}
|
||||
else
|
||||
{
|
||||
consoleOut_<%=cid%> = new java.io.PrintStream(new java.io.BufferedOutputStream(System.out));
|
||||
globalMap.put("tLogRow_CONSOLE",consoleOut_<%=cid%>);
|
||||
}
|
||||
|
||||
consoleOut_<%=cid%>.println(util_<%=cid %>.format().toString());
|
||||
consoleOut_<%=cid%>.flush();
|
||||
<%
|
||||
}
|
||||
%>
|
||||
//////
|
||||
globalMap.put("<%=cid %>_NB_LINE",nb_line_<%=cid %>);
|
||||
<%log.info(log.str("Printed row count: "), log.var("nb_line"), log.str("."));%>
|
||||
|
||||
///////////////////////
|
||||
<%
|
||||
}//2
|
||||
}//1
|
||||
%>
|
||||
Binary file not shown.
|
After Width: | Height: | Size: 2.6 KiB |
@@ -0,0 +1,103 @@
|
||||
<!-- $Id: tLogRow_perl.xml 1528 2007-01-19 17:03:36 +0000 (星期五, 19 一月 2007) smallet $ -->
|
||||
<COMPONENT>
|
||||
<HEADER PLATEFORM="ALL" SERIAL="" VERSION="0.101" STATUS="ALPHA"
|
||||
COMPATIBILITY="ALL" AUTHOR="Talend" RELEASE_DATE="20050320A"
|
||||
STARTABLE="false" PARTITIONING="AUTO" LOG4J_ENABLED="true">
|
||||
<SIGNATURE></SIGNATURE>
|
||||
</HEADER>
|
||||
|
||||
<FAMILIES>
|
||||
<FAMILY>Logs_Errors</FAMILY>
|
||||
</FAMILIES>
|
||||
<DOCUMENTATION>
|
||||
<URL />
|
||||
</DOCUMENTATION>
|
||||
<CONNECTORS>
|
||||
<CONNECTOR CTYPE="FLOW" MAX_INPUT="1" MAX_OUTPUT="1"/>
|
||||
<CONNECTOR CTYPE="ITERATE" MAX_OUTPUT="0" MAX_INPUT="0" />
|
||||
<CONNECTOR CTYPE="SUBJOB_OK" MAX_INPUT="1" />
|
||||
<CONNECTOR CTYPE="SUBJOB_ERROR" MAX_INPUT="1" />
|
||||
<CONNECTOR CTYPE="COMPONENT_OK" />
|
||||
<CONNECTOR CTYPE="COMPONENT_ERROR" />
|
||||
<CONNECTOR CTYPE="RUN_IF" />
|
||||
</CONNECTORS>
|
||||
|
||||
<PARAMETERS>
|
||||
<PARAMETER NAME="SCHEMA" FIELD="SCHEMA_TYPE" REQUIRED="true"
|
||||
NUM_ROW="10" />
|
||||
|
||||
|
||||
<PARAMETER NAME="BASIC_MODE" FIELD="RADIO" NUM_ROW="11" GROUP="MODE">
|
||||
<DEFAULT>true</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="TABLE_PRINT" FIELD="RADIO" NUM_ROW="12" GROUP="MODE">
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="VERTICAL" FIELD="RADIO" NUM_ROW="13" GROUP="MODE">
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="PRINT_UNIQUE" FIELD="RADIO" GROUP="TITLE_PRINT" NUM_ROW="15"
|
||||
SHOW_IF="(BASIC_MODE == 'false') and (VERTICAL == 'true')">
|
||||
<DEFAULT>true</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="PRINT_LABEL" FIELD="RADIO" GROUP="TITLE_PRINT" NUM_ROW="15"
|
||||
SHOW_IF="(BASIC_MODE == 'false') and (VERTICAL == 'true')">
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="PRINT_UNIQUE_LABEL" FIELD="RADIO" GROUP="TITLE_PRINT" NUM_ROW="15"
|
||||
SHOW_IF="(BASIC_MODE == 'false') and (VERTICAL == 'true')">
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="FIELDSEPARATOR" FIELD="TEXT" NUM_ROW="20"
|
||||
SHOW_IF="(TABLE_PRINT == 'false') and (VERTICAL == 'false')">
|
||||
<DEFAULT>"|"</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="PRINT_HEADER" FIELD="CHECK" NUM_ROW="25"
|
||||
SHOW_IF="(TABLE_PRINT == 'false') and (VERTICAL == 'false')">
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="PRINT_UNIQUE_NAME" FIELD="CHECK" NUM_ROW="30"
|
||||
SHOW_IF="(TABLE_PRINT == 'false') and (VERTICAL == 'false')">
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="PRINT_COLNAMES" FIELD="CHECK" NUM_ROW="40"
|
||||
SHOW_IF="(TABLE_PRINT == 'false') and (VERTICAL == 'false')">
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="USE_FIXED_LENGTH" FIELD="CHECK" NUM_ROW="50"
|
||||
SHOW_IF="(TABLE_PRINT == 'false') and (VERTICAL == 'false')">
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="LENGTHS" FIELD="TABLE" REQUIRED="true"
|
||||
NUM_ROW="60" NB_LINES="5"
|
||||
SHOW_IF="(USE_FIXED_LENGTH == 'true') and ((TABLE_PRINT == 'false') and (VERTICAL == 'false'))">
|
||||
<ITEMS BASED_ON_SCHEMA="true">
|
||||
<ITEM NAME="LENGTH" VALUE="10" />
|
||||
</ITEMS>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="PRINT_CONTENT_WITH_LOG4J" FIELD="CHECK" NUM_ROW="70" >
|
||||
<DEFAULT>true</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="SCHEMA_OPT_NUM" FIELD="TEXT" NUM_ROW="100" REQUIRED="true" SHOW="false">
|
||||
<DEFAULT>100</DEFAULT>
|
||||
</PARAMETER>
|
||||
</PARAMETERS>
|
||||
|
||||
<CODEGENERATION />
|
||||
<RETURNS>
|
||||
<RETURN NAME="NB_LINE" TYPE="id_Integer" AVAILABILITY="AFTER" />
|
||||
</RETURNS>
|
||||
</COMPONENT>
|
||||
@@ -0,0 +1,313 @@
|
||||
<%@ jet
|
||||
imports="
|
||||
org.talend.core.model.process.INode
|
||||
org.talend.core.model.process.ElementParameterParser
|
||||
org.talend.core.model.metadata.IMetadataTable
|
||||
org.talend.core.model.metadata.IMetadataColumn
|
||||
org.talend.designer.codegen.config.CodeGeneratorArgument
|
||||
org.talend.core.model.process.IConnection
|
||||
org.talend.core.model.process.IConnectionCategory
|
||||
org.talend.core.model.metadata.types.JavaTypesManager
|
||||
org.talend.core.model.metadata.types.JavaType
|
||||
java.util.List
|
||||
java.util.Map
|
||||
"
|
||||
%>
|
||||
<%
|
||||
CodeGeneratorArgument codeGenArgument = (CodeGeneratorArgument) argument;
|
||||
INode node = (INode)codeGenArgument.getArgument();
|
||||
|
||||
List<IMetadataTable> metadatas = node.getMetadataList();
|
||||
if ((metadatas!=null)&&(metadatas.size()>0)) {//1
|
||||
IMetadataTable metadata = metadatas.get(0);
|
||||
if (metadata!=null) {//2
|
||||
|
||||
String cid = node.getUniqueName();
|
||||
|
||||
boolean tablePrint = ("true").equals(ElementParameterParser.getValue(node,"__TABLE_PRINT__"));
|
||||
boolean vertical = ("true").equals(ElementParameterParser.getValue(node,"__VERTICAL__"));
|
||||
boolean basic = !(tablePrint||vertical);
|
||||
|
||||
String printUniqueName = ElementParameterParser.getValue(node,"__PRINT_UNIQUE_NAME__");
|
||||
String printColumnNames = ElementParameterParser.getValue(node,"__PRINT_COLNAMES__");
|
||||
String useFixedLength = ElementParameterParser.getValue(node,"__USE_FIXED_LENGTH__");
|
||||
List<Map<String, String>> lengths = (List<Map<String,String>>)ElementParameterParser.getObjectValue(node,"__LENGTHS__");
|
||||
boolean isLog4jEnabled = ("true").equals(ElementParameterParser.getValue(node.getProcess(), "__LOG4J_ACTIVATE__"));
|
||||
boolean isLogContent = ("true").equals(ElementParameterParser.getValue(node,"__PRINT_CONTENT_WITH_LOG4J__"));
|
||||
|
||||
List< ? extends IConnection> conns = node.getIncomingConnections();
|
||||
for (IConnection conn : conns) {//3
|
||||
if (conn.getLineStyle().hasConnectionCategory(IConnectionCategory.DATA)) {//4
|
||||
%>
|
||||
///////////////////////
|
||||
|
||||
<%
|
||||
List<IMetadataColumn> columns = metadata.getListColumns();
|
||||
int sizeColumns = columns.size();
|
||||
int schemaOptNum=100;
|
||||
String schemaOptNumStr=ElementParameterParser.getValue(node, "__SCHEMA_OPT_NUM__");
|
||||
if(schemaOptNumStr!=null && !"".equals(schemaOptNumStr) && !"\"\"".equals(schemaOptNumStr)){
|
||||
schemaOptNum = Integer.parseInt(schemaOptNumStr);
|
||||
}
|
||||
boolean isOptimizeCode = false;
|
||||
if(schemaOptNum < sizeColumns){
|
||||
isOptimizeCode = true;
|
||||
}
|
||||
%>
|
||||
|
||||
<%
|
||||
if (basic||vertical) { // don't print the table form//***
|
||||
%>
|
||||
|
||||
|
||||
strBuffer_<%=cid%> = new StringBuilder();
|
||||
<%
|
||||
if (("true").equals(printUniqueName)) {//print the component name.
|
||||
%>
|
||||
strBuffer_<%=cid%>.append("[<%=cid%>] ");
|
||||
<%
|
||||
}
|
||||
%>
|
||||
|
||||
|
||||
<%
|
||||
for (int i = 0; i < sizeColumns; i++) {//5
|
||||
|
||||
IMetadataColumn column = columns.get(i);
|
||||
JavaType javaType = JavaTypesManager.getJavaTypeFromId(column.getTalendType());
|
||||
if(isOptimizeCode){
|
||||
if(i%schemaOptNum == 0){
|
||||
%>
|
||||
logRowUtil_<%=cid%>.putBasicVerticalValue_<%=i/schemaOptNum%>(<%=conn.getName() %>,strBuffer_<%=cid%>);
|
||||
<%
|
||||
}
|
||||
}else{
|
||||
if (("true").equals(useFixedLength)) {//fix the column length
|
||||
%>
|
||||
java.util.Formatter formatter_<%=column.getLabel() %>_<%=cid%> = new java.util.Formatter(new StringBuilder());
|
||||
<%
|
||||
}
|
||||
%>
|
||||
|
||||
|
||||
<%
|
||||
if (("true").equals(printColumnNames)) {//print the schema name
|
||||
%>
|
||||
strBuffer_<%=cid%>.append("<%=column.getLabel() %>: ");
|
||||
<%
|
||||
}
|
||||
%>
|
||||
|
||||
<%
|
||||
boolean isPrimitive = JavaTypesManager.isJavaPrimitiveType( javaType, column.isNullable());
|
||||
if(!isPrimitive) { //begin
|
||||
%>
|
||||
if(<%=conn.getName() %>.<%=column.getLabel() %> != null) { //
|
||||
<%
|
||||
}
|
||||
%>
|
||||
|
||||
<%
|
||||
if (("true").equals(useFixedLength)) {//fixed the column length
|
||||
%>
|
||||
strBuffer_<%=cid%>.append(formatter_<%=column.getLabel() %>_<%=cid%>.format("%1$"+<%=lengths.get(i).get("LENGTH") %>+"s",
|
||||
<%
|
||||
String pattern = column.getPattern() == null || column.getPattern().trim().length() == 0 ? null : column.getPattern();
|
||||
if (javaType == JavaTypesManager.DATE && pattern != null && pattern.trim().length() != 0) {//Date
|
||||
%>
|
||||
FormatterUtils.format_Date(<%=conn.getName() %>.<%=column.getLabel() %>, <%= pattern %>)
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.BYTE_ARRAY) {//byte[]
|
||||
%>
|
||||
java.nio.charset.Charset.defaultCharset().decode(java.nio.ByteBuffer.wrap(<%=conn.getName() %>.<%=column.getLabel() %>)).toString()
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.BIGDECIMAL) {
|
||||
%>
|
||||
<%=column.getPrecision() == null? conn.getName() + "." + column.getLabel() : conn.getName() + "." + column.getLabel() + ".setScale(" + column.getPrecision() + ", java.math.RoundingMode.HALF_UP)" %>.toPlainString()
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.DOUBLE || javaType == JavaTypesManager.FLOAT ) {
|
||||
%>
|
||||
FormatterUtils.formatUnwithE(<%=conn.getName() %>.<%=column.getLabel() %>)
|
||||
<%
|
||||
} else {//others
|
||||
%>
|
||||
String.valueOf(<%=conn.getName() %>.<%=column.getLabel() %>)
|
||||
<%
|
||||
}
|
||||
%>
|
||||
).toString());
|
||||
|
||||
<%
|
||||
} else {
|
||||
%>
|
||||
|
||||
strBuffer_<%=cid%>.append(
|
||||
<%
|
||||
String pattern = column.getPattern() == null || column.getPattern().trim().length() == 0 ? null : column.getPattern();
|
||||
if (javaType == JavaTypesManager.DATE && pattern != null && pattern.trim().length() != 0) {//Date
|
||||
%>
|
||||
FormatterUtils.format_Date(<%=conn.getName() %>.<%=column.getLabel() %>, <%= pattern %>)
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.BYTE_ARRAY) {//byte[]
|
||||
%>
|
||||
java.nio.charset.Charset.defaultCharset().decode(java.nio.ByteBuffer.wrap(<%=conn.getName() %>.<%=column.getLabel() %>)).toString()
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.BIGDECIMAL) {
|
||||
%>
|
||||
<%=column.getPrecision() == null? conn.getName() + "." + column.getLabel() : conn.getName() + "." + column.getLabel() + ".setScale(" + column.getPrecision() + ", java.math.RoundingMode.HALF_UP)" %>.toPlainString()
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.DOUBLE || javaType == JavaTypesManager.FLOAT ) {
|
||||
%>
|
||||
FormatterUtils.formatUnwithE(<%=conn.getName() %>.<%=column.getLabel() %>)
|
||||
<%
|
||||
} else {//others
|
||||
%>
|
||||
String.valueOf(<%=conn.getName() %>.<%=column.getLabel() %>)
|
||||
<%
|
||||
}
|
||||
%>
|
||||
);
|
||||
<%
|
||||
}
|
||||
%>
|
||||
|
||||
|
||||
|
||||
<%
|
||||
if(!isPrimitive) {//end
|
||||
%>
|
||||
} //
|
||||
<%
|
||||
}
|
||||
%>
|
||||
|
||||
<%
|
||||
if(i == sizeColumns-1) break;
|
||||
%>
|
||||
strBuffer_<%=cid%>.append(<%=ElementParameterParser.getValue(node, "__FIELDSEPARATOR__") %>);
|
||||
|
||||
<%
|
||||
}
|
||||
}//5
|
||||
}
|
||||
|
||||
|
||||
if (basic) {
|
||||
%>
|
||||
|
||||
if (globalMap.get("tLogRow_CONSOLE")!=null)
|
||||
{
|
||||
consoleOut_<%=cid%> = (java.io.PrintStream) globalMap.get("tLogRow_CONSOLE");
|
||||
}
|
||||
else
|
||||
{
|
||||
consoleOut_<%=cid%> = new java.io.PrintStream(new java.io.BufferedOutputStream(System.out));
|
||||
globalMap.put("tLogRow_CONSOLE",consoleOut_<%=cid%>);
|
||||
}
|
||||
<%
|
||||
if(isLogContent && isLog4jEnabled){
|
||||
%>
|
||||
log.info("<%=cid%> - Content of row "+(nb_line_<%=cid %>+1)+": " + strBuffer_<%=cid%>.toString());
|
||||
<%
|
||||
}
|
||||
%>
|
||||
consoleOut_<%=cid%>.println(strBuffer_<%=cid%>.toString());
|
||||
consoleOut_<%=cid%>.flush();
|
||||
nb_line_<%=cid %>++;
|
||||
<%
|
||||
}
|
||||
|
||||
|
||||
if(tablePrint || vertical) { //print the table and vertical model//***
|
||||
%>
|
||||
|
||||
String[] row_<%=cid%> = new String[<%=sizeColumns %>];
|
||||
|
||||
<%
|
||||
for (int i = 0; i < sizeColumns; i++) {//5
|
||||
|
||||
IMetadataColumn column = columns.get(i);
|
||||
JavaType javaType = JavaTypesManager.getJavaTypeFromId(column.getTalendType());
|
||||
if(isOptimizeCode){
|
||||
if(i%schemaOptNum == 0){
|
||||
%>
|
||||
logRowUtil_<%=cid%>.putTableVerticalValue_<%=i/schemaOptNum%>(<%=conn.getName() %>,row_<%=cid%>);
|
||||
<%
|
||||
}
|
||||
}else{
|
||||
boolean isPrimitive = JavaTypesManager.isJavaPrimitiveType( javaType, column.isNullable());
|
||||
if(!isPrimitive) { //begin
|
||||
%>
|
||||
if(<%=conn.getName() %>.<%=column.getLabel() %> != null) { //
|
||||
<%
|
||||
}
|
||||
%>
|
||||
row_<%=cid%>[<%=i %>]=
|
||||
<%
|
||||
String pattern = column.getPattern() == null || column.getPattern().trim().length() == 0 ? null : column.getPattern();
|
||||
if (javaType == JavaTypesManager.DATE && pattern != null && pattern.trim().length() != 0) {//Date
|
||||
%>
|
||||
FormatterUtils.format_Date(<%=conn.getName() %>.<%=column.getLabel() %>, <%= pattern %>)
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.BYTE_ARRAY) {//byte[]
|
||||
%>
|
||||
java.nio.charset.Charset.defaultCharset().decode(java.nio.ByteBuffer.wrap(<%=conn.getName() %>.<%=column.getLabel() %>)).toString()
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.BIGDECIMAL) {
|
||||
%>
|
||||
<%=column.getPrecision() == null? conn.getName() + "." + column.getLabel() : conn.getName() + "." + column.getLabel() + ".setScale(" + column.getPrecision() + ", java.math.RoundingMode.HALF_UP)" %>.toPlainString()
|
||||
<%
|
||||
} else if (javaType == JavaTypesManager.DOUBLE || javaType == JavaTypesManager.FLOAT ) {
|
||||
%>
|
||||
FormatterUtils.formatUnwithE(<%=conn.getName() %>.<%=column.getLabel() %>)
|
||||
<%
|
||||
} else {//others
|
||||
%>
|
||||
String.valueOf(<%=conn.getName() %>.<%=column.getLabel() %>)
|
||||
<%
|
||||
}
|
||||
%>
|
||||
;
|
||||
|
||||
<%
|
||||
if(!isPrimitive) {//end
|
||||
%>
|
||||
} //
|
||||
<%
|
||||
}
|
||||
%>
|
||||
|
||||
<%
|
||||
}
|
||||
}//5
|
||||
if(tablePrint){
|
||||
%>
|
||||
|
||||
util_<%=cid %>.addRow(row_<%=cid%>);
|
||||
nb_line_<%=cid %>++;
|
||||
<%
|
||||
}else{
|
||||
%>
|
||||
nb_line_<%=cid %>++;
|
||||
consoleOut_<%=cid%>.println(util_<%=cid %>.print(row_<%=cid%>,nb_line_<%=cid%>));
|
||||
consoleOut_<%=cid%>.flush();
|
||||
<%
|
||||
}
|
||||
if(isLogContent && isLog4jEnabled){
|
||||
%>
|
||||
log.info("<%=cid%> - Content of row "+nb_line_<%=cid %>+": " + TalendString.unionString("|",row_<%=cid%>));
|
||||
<%
|
||||
}
|
||||
}//***
|
||||
%>
|
||||
//////
|
||||
|
||||
//////
|
||||
|
||||
///////////////////////
|
||||
<%
|
||||
}//4
|
||||
}//3
|
||||
}//2
|
||||
}//1
|
||||
%>
|
||||
@@ -0,0 +1,20 @@
|
||||
LONG_NAME=Displays the flow content (rows) on the Run Job console
|
||||
HELP=org.talend.help.tLogRow
|
||||
MODE.NAME=Mode
|
||||
BASIC_MODE.NAME=Basic
|
||||
TABLE_PRINT.NAME=Table (print values in cells of a table)
|
||||
VERTICAL.NAME=Vertical (each row is a key/value list)
|
||||
FIELDSEPARATOR.NAME=Field Separator
|
||||
NB_LINE.NAME=Number of lines
|
||||
PRINT_UNIQUE_NAME.NAME=Print component unique name in front of each output row
|
||||
PRINT_COLNAMES.NAME=Print schema column name in front of each value
|
||||
USE_FIXED_LENGTH.NAME=Use fixed length for values
|
||||
LENGTHS.NAME=Lengths
|
||||
LENGTHS.ITEM.LENGTH=Length
|
||||
PRINT_HEADER.NAME=Print header
|
||||
PRINT_UNIQUE.NAME=Print unique name
|
||||
PRINT_LABEL.NAME=Print label
|
||||
PRINT_UNIQUE_LABEL.NAME=Print unique name and label
|
||||
TITLE_PRINT.NAME=Title printing mode
|
||||
SCHEMA_OPT_NUM.NAME=Min column number of optimize code
|
||||
PRINT_CONTENT_WITH_LOG4J.NAME=Print content with log4j
|
||||
@@ -0,0 +1,10 @@
|
||||
LONG_NAME=Zeigt den Inhalt (Zeilen) des Datenflusses auf der RunJob-Konsole an.
|
||||
MODE.NAME=Modus
|
||||
BASIC_MODE.NAME=Einfach
|
||||
VERTICAL.NAME=Vertikal (wobei jede Zeile eine Schl\u00FCssel/Wertliste ist)
|
||||
FIELDSEPARATOR.NAME=Feldseparator
|
||||
NB_LINE.NAME=Anzahl an Zeilen
|
||||
USE_FIXED_LENGTH.NAME=Feste L\u00E4nge f\u00FCr Werte verwenden
|
||||
LENGTHS.ITEM.LENGTH=L\u00E4nge
|
||||
PRINT_HEADER.NAME=Kopfzeile ausgeben
|
||||
PRINT_LABEL.NAME=Beschriftungen ausgeben
|
||||
@@ -0,0 +1,3 @@
|
||||
BASIC_MODE.NAME=Basico
|
||||
FIELDSEPARATOR.NAME=Separador de Campo
|
||||
LENGTHS.ITEM.LENGTH=Longitud
|
||||
@@ -0,0 +1,20 @@
|
||||
LONG_NAME=Affiche le contenu du flux (lignes) dans la console d'ex\u00E9cution du Job
|
||||
HELP=org.talend.help.tLogRow
|
||||
MODE.NAME=Mode
|
||||
BASIC_MODE.NAME=Simple
|
||||
TABLE_PRINT.NAME=Table (afficher les valeurs dans des cellules)
|
||||
VERTICAL.NAME=Vertical (chaque ligne est une liste cl\u00E9/valeur)
|
||||
FIELDSEPARATOR.NAME=S\u00E9parateur de champs
|
||||
NB_LINE.NAME=Nombre de lignes
|
||||
PRINT_UNIQUE_NAME.NAME=Afficher le nom unique du composant devant chaque ligne de sortie
|
||||
PRINT_COLNAMES.NAME=Afficher le nom de la colonne du sch\u00E9ma en face de chaque valeur
|
||||
USE_FIXED_LENGTH.NAME=Utiliser une longueur fixe pour les valeurs
|
||||
LENGTHS.NAME=Longueurs
|
||||
LENGTHS.ITEM.LENGTH=Longueur
|
||||
PRINT_HEADER.NAME=Afficher l'en-t\u00EAte
|
||||
PRINT_UNIQUE.NAME=Afficher le nom unique
|
||||
PRINT_LABEL.NAME=Afficher le libell\u00E9
|
||||
PRINT_UNIQUE_LABEL.NAME=Afficher le nom unique et le libell\u00E9
|
||||
TITLE_PRINT.NAME=Mode d'affichage du titre
|
||||
SCHEMA_OPT_NUM.NAME=Nombre minimum de colonnes au code optimis\u00E9
|
||||
PRINT_CONTENT_WITH_LOG4J.NAME=Afficher le contenu avec Log4j
|
||||
@@ -0,0 +1,17 @@
|
||||
LONG_NAME=Mostra il contenuto del flusso (righe) nella console del Run Job
|
||||
MODE.NAME=Modalit\u00E0
|
||||
BASIC_MODE.NAME=Base
|
||||
TABLE_PRINT.NAME=Tabella (stampa valori nelle celle di una tabella)
|
||||
VERTICAL.NAME=Verticale (ogni riga \u00E8 una lista chiave/valore)
|
||||
FIELDSEPARATOR.NAME=Separatore di campo
|
||||
NB_LINE.NAME=Numero riga
|
||||
PRINT_UNIQUE_NAME.NAME=Stampa nome componenti univoci all'inizio di ogni riga di output
|
||||
PRINT_COLNAMES.NAME=Stampa nome colonna dello schema all'inizio di ogni valore
|
||||
USE_FIXED_LENGTH.NAME=Usa lunghezza fissa per valori
|
||||
LENGTHS.NAME=Lunghezze
|
||||
LENGTHS.ITEM.LENGTH=Lunghezza
|
||||
PRINT_HEADER.NAME=Stampa Header
|
||||
PRINT_UNIQUE.NAME=Stampa nome univoco
|
||||
PRINT_LABEL.NAME=Stampa etichetta
|
||||
PRINT_UNIQUE_LABEL.NAME=Stampa etichetta e nome univoco
|
||||
TITLE_PRINT.NAME=Titolo modalit\u00E0 stampa
|
||||
@@ -0,0 +1,20 @@
|
||||
LONG_NAME=[\u30B8\u30E7\u30D6\u5B9F\u884C]\u30B3\u30F3\u30BD\u30FC\u30EB\u3067\u30D5\u30ED\u30FC\u30B3\u30F3\u30C6\u30F3\u30C4(\u884C)\u3092\u8868\u793A\u3057\u307E\u3059\u3002
|
||||
HELP=org.talend.help.tLogRow
|
||||
MODE.NAME=\u30E2\u30FC\u30C9
|
||||
BASIC_MODE.NAME=\u30D9\u30FC\u30B7\u30C3\u30AF
|
||||
TABLE_PRINT.NAME=\u30C6\u30FC\u30D6\u30EB\uFF08\u8868\u306E\u30BB\u30EB\u3067\u5024\u3092\u8868\u793A\uFF09
|
||||
VERTICAL.NAME=\u7E26\u306B\u51FA\u529B\uFF08\u5404\u884C\u3092\u30AD\u30FC/\u5024\u306E\u30EA\u30B9\u30C8\u3067\u8868\u793A\uFF09
|
||||
FIELDSEPARATOR.NAME=\u30D5\u30A3\u30FC\u30EB\u30C9\u533A\u5207\u308A
|
||||
NB_LINE.NAME=\u884C\u6570
|
||||
PRINT_UNIQUE_NAME.NAME=\u30B3\u30F3\u30DD\u30FC\u30CD\u30F3\u30C8\u30E6\u30CB\u30FC\u30AF\u540D\u3092\u51FA\u529B\u306E\u5404\u884C\u306E\u524D\u306B\u8868\u793A
|
||||
PRINT_COLNAMES.NAME=\u30AB\u30E9\u30E0\u540D\u3092\u5024\u306E\u524D\u306B\u8868\u793A
|
||||
USE_FIXED_LENGTH.NAME=\u5024\u3092\u56FA\u5B9A\u9577\u3067\u8868\u793A
|
||||
LENGTHS.NAME=\u9577\u3055
|
||||
LENGTHS.ITEM.LENGTH=\u9577\u3055
|
||||
PRINT_HEADER.NAME=\u30D8\u30C3\u30C0\u30FC\u306E\u8868\u793A
|
||||
PRINT_UNIQUE.NAME=\u30E6\u30CB\u30FC\u30AF\u540D\u306E\u8868\u793A
|
||||
PRINT_LABEL.NAME=\u30E9\u30D9\u30EB\u306E\u8868\u793A
|
||||
PRINT_UNIQUE_LABEL.NAME=\u30E6\u30CB\u30FC\u30AF\u540D\u3068\u30E9\u30D9\u30EB\u306E\u8868\u793A
|
||||
TITLE_PRINT.NAME=\u30BF\u30A4\u30C8\u30EB\u8868\u793A\u30E2\u30FC\u30C9
|
||||
SCHEMA_OPT_NUM.NAME=\u6700\u9069\u5316\u30B3\u30FC\u30C9\u306E\u6700\u5C0F\u30AB\u30E9\u30E0\u6570
|
||||
PRINT_CONTENT_WITH_LOG4J.NAME=log4j\u3067\u30B3\u30F3\u30C6\u30F3\u30C4\u3092\u5370\u5237
|
||||
@@ -0,0 +1,7 @@
|
||||
HELP=org.talend.help.tLogRow
|
||||
MODE.NAME=\u30E2\u30FC\u30C9
|
||||
BASIC_MODE.NAME=\u30D9\u30FC\u30B7\u30C3\u30AF
|
||||
FIELDSEPARATOR.NAME=\u30D5\u30A3\u30FC\u30EB\u30C9\u30BB\u30D1\u30EC\u30FC\u30BF
|
||||
NB_LINE.NAME=\u30E9\u30A4\u30F3\u6570
|
||||
LENGTHS.NAME=\u9577\u3055
|
||||
LENGTHS.ITEM.LENGTH=\u9577\u3055
|
||||
@@ -0,0 +1,5 @@
|
||||
BASIC_MODE.NAME=\u041E\u0441\u043D\u043E\u0432\u043D\u043E\u0439
|
||||
VERTICAL.NAME=\u0412\u0435\u0440\u0442\u0438\u043A\u0430\u043B\u044C\u043D\u044B\u0439 (\u043A\u0430\u0436\u0434\u044B\u0439 \u0440\u044F\u0434 - \u043F\u0430\u0440\u0430 \u043A\u043B\u044E\u0447/\u0437\u043D\u0430\u0447\u0435\u043D\u0438\u0435)
|
||||
FIELDSEPARATOR.NAME=\u0420\u0430\u0437\u0434\u0435\u043B\u0438\u0442\u0435\u043B\u044C \u043F\u043E\u043B\u0435\u0439
|
||||
NB_LINE.NAME=\u0427\u0438\u0441\u043B\u043E \u0441\u0442\u0440\u043E\u043A
|
||||
LENGTHS.ITEM.LENGTH=\u0414\u043B\u0438\u043D\u0430
|
||||
@@ -0,0 +1,2 @@
|
||||
MODE.NAME=M\u00F3d
|
||||
LENGTHS.ITEM.LENGTH=D\u013A\u017Eka
|
||||
@@ -0,0 +1,2 @@
|
||||
MODE.NAME=Mód
|
||||
LENGTHS.ITEM.LENGTH=D\u013A\u017Eka
|
||||
@@ -0,0 +1,20 @@
|
||||
LONG_NAME=\u5728\u8FD0\u884C\u4F5C\u4E1A\u63A7\u5236\u53F0\u4E0A\u663E\u793A\u6D41\u5185\u5BB9 (\u884C)
|
||||
HELP=org.talend.help.tLogRow
|
||||
MODE.NAME=\u6A21\u5F0F
|
||||
BASIC_MODE.NAME=\u57FA\u672C
|
||||
TABLE_PRINT.NAME=\u8868 (\u5728\u8868\u7684\u5355\u5143\u683C\u4E2D\u6253\u5370\u503C)
|
||||
VERTICAL.NAME=\u5782\u76F4 (\u6BCF\u884C\u90FD\u662F\u4E00\u4E2A\u952E/\u503C\u5217\u8868)
|
||||
FIELDSEPARATOR.NAME=\u5B57\u6BB5\u5206\u9694\u7B26
|
||||
NB_LINE.NAME=\u884C\u6570
|
||||
PRINT_UNIQUE_NAME.NAME=\u5728\u6BCF\u4E00\u4E2A\u8F93\u51FA\u884C\u524D\u6253\u5370\u552F\u4E00\u7EC4\u4EF6\u540D
|
||||
PRINT_COLNAMES.NAME=\u5C06 schema \u5217\u540D\u6253\u5370\u5728\u6BCF\u4E2A\u503C\u7684\u524D\u9762
|
||||
USE_FIXED_LENGTH.NAME=\u4F7F\u7528\u56FA\u5B9A\u957F\u5EA6\u7684\u503C
|
||||
LENGTHS.NAME=\u957F\u5EA6
|
||||
LENGTHS.ITEM.LENGTH=\u957F\u5EA6
|
||||
PRINT_HEADER.NAME=\u6253\u5370\u6587\u4EF6\u5934
|
||||
PRINT_UNIQUE.NAME=\u6253\u5370\u552F\u4E00\u540D\u79F0
|
||||
PRINT_LABEL.NAME=\u6253\u5370\u6807\u7B7E
|
||||
PRINT_UNIQUE_LABEL.NAME=\u6253\u5370\u552F\u4E00\u540D\u79F0\u548C\u6807\u7B7E
|
||||
TITLE_PRINT.NAME=\u6807\u9898\u6253\u5370\u6A21\u5F0F
|
||||
SCHEMA_OPT_NUM.NAME=\u4F18\u5316\u4EE3\u7801\u7684\u6700\u5C0F\u5217\u6570
|
||||
PRINT_CONTENT_WITH_LOG4J.NAME=\u7528 log4j \u6253\u5370\u5185\u5BB9
|
||||
@@ -0,0 +1,57 @@
|
||||
<%@ jet
|
||||
%>
|
||||
|
||||
<%
|
||||
JavaType[] commonTypes = {
|
||||
JavaTypesManager.STRING,
|
||||
JavaTypesManager.INTEGER,
|
||||
JavaTypesManager.LONG,
|
||||
JavaTypesManager.SHORT,
|
||||
JavaTypesManager.BOOLEAN,
|
||||
JavaTypesManager.CHARACTER,
|
||||
JavaTypesManager.BYTE,
|
||||
JavaTypesManager.BYTE_ARRAY,
|
||||
JavaTypesManager.DATE,
|
||||
JavaTypesManager.DOUBLE,
|
||||
JavaTypesManager.FLOAT,
|
||||
JavaTypesManager.OBJECT,
|
||||
JavaTypesManager.LIST,
|
||||
JavaTypesManager.BIGDECIMAL
|
||||
};
|
||||
|
||||
for(JavaType sourceType : commonTypes) {
|
||||
for(JavaType targetType : commonTypes) {
|
||||
if(sourceType == targetType) {
|
||||
continue;
|
||||
}
|
||||
|
||||
String sourceTypeToGenerate = JavaTypesManager.getTypeToGenerate(sourceType.getId(), true);
|
||||
sourceTypeToGenerate = sourceTypeToGenerate.contains(".") ? sourceTypeToGenerate.substring(sourceTypeToGenerate.lastIndexOf(".") + 1) : sourceTypeToGenerate;
|
||||
if (("byte[]").equals(sourceTypeToGenerate)){
|
||||
sourceTypeToGenerate = "byteArray";
|
||||
}
|
||||
|
||||
String targetTypeToGenerate = JavaTypesManager.getTypeToGenerate(targetType.getId(), true);
|
||||
targetTypeToGenerate = targetTypeToGenerate.contains(".") ? targetTypeToGenerate.substring(targetTypeToGenerate.lastIndexOf(".") + 1) : targetTypeToGenerate;
|
||||
if (("byte[]").equals(targetTypeToGenerate)){
|
||||
targetTypeToGenerate = "byteArray";
|
||||
}
|
||||
|
||||
String function = null;
|
||||
if("Date".equals(targetTypeToGenerate) && ("String".equals(sourceTypeToGenerate)||"Object".equals(sourceTypeToGenerate))) {
|
||||
function = contact("routines.system.TypeConvert.", sourceTypeToGenerate, "2", targetTypeToGenerate, "(${0}, ${1})");
|
||||
} else if("String".equals(targetTypeToGenerate) && "Date".equals(sourceTypeToGenerate)) {
|
||||
function = contact("routines.system.TypeConvert.", sourceTypeToGenerate, "2", targetTypeToGenerate, "(${0}, ${1})");
|
||||
} else {
|
||||
function = contact("routines.system.TypeConvert.", sourceTypeToGenerate, "2", targetTypeToGenerate, "(${0})");
|
||||
}
|
||||
|
||||
autoConverterMap.put(contact(sourceType.getId(), ":", targetType.getId()), function);
|
||||
}
|
||||
}
|
||||
|
||||
autoConverterMap.put(contact("id_Dynamic", ":", JavaTypesManager.STRING.getId()), "String.valueOf(${0})");
|
||||
autoConverterMap.put(contact("id_Document", ":", JavaTypesManager.STRING.getId()), "String.valueOf(${0})");
|
||||
autoConverterMap.put(contact(JavaTypesManager.STRING.getId(), ":", "id_Document"), "routines.system.ParserUtils.parseTo_Document(${0})");
|
||||
%>
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
@@ -0,0 +1,40 @@
|
||||
<%@ jet
|
||||
imports="
|
||||
java.util.ArrayList
|
||||
java.util.List
|
||||
java.util.Map
|
||||
java.util.HashMap
|
||||
org.talend.core.model.metadata.IMetadataTable
|
||||
org.talend.core.model.metadata.IMetadataColumn
|
||||
org.talend.core.model.metadata.types.JavaTypesManager
|
||||
org.talend.core.model.metadata.types.JavaType
|
||||
org.talend.designer.codegen.config.CodeGeneratorArgument
|
||||
org.talend.designer.mapper.MapperComponent
|
||||
org.talend.designer.mapper.external.data.ExternalMapperData
|
||||
org.talend.designer.mapper.external.data.ExternalMapperTable
|
||||
org.talend.designer.mapper.external.data.ExternalMapperTableEntry
|
||||
org.talend.core.model.process.IConnection
|
||||
org.talend.designer.mapper.language.ILanguage
|
||||
org.talend.designer.mapper.language.generation.GenerationManagerFactory
|
||||
org.talend.designer.mapper.language.generation.JavaGenerationManager
|
||||
org.talend.designer.mapper.language.LanguageProvider
|
||||
org.talend.core.model.process.ElementParameterParser
|
||||
org.talend.core.model.process.EConnectionType
|
||||
org.talend.core.model.process.INode
|
||||
org.talend.core.model.utils.TalendTextUtils
|
||||
org.talend.designer.mapper.model.tableentry.TableEntryLocation
|
||||
org.talend.designer.mapper.utils.DataMapExpressionParser
|
||||
"
|
||||
skeleton="tMap_commons.skeleton"
|
||||
%>
|
||||
|
||||
|
||||
<%@ include file="tMap_begin.inc.javajet" %>
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -0,0 +1,259 @@
|
||||
public class CLASS {
|
||||
|
||||
|
||||
public boolean hasConcurrencyContext(List<IConnection> inputConnections, List<? extends INode> graphicalNodes) {
|
||||
|
||||
for(IConnection connection : inputConnections) {
|
||||
EConnectionType connectionType = connection.getLineStyle();
|
||||
if (connectionType == EConnectionType.FLOW_MAIN) {
|
||||
INode node = connection.getSource();
|
||||
return recursiveSearchIterateForConcurrency(node, graphicalNodes);
|
||||
}
|
||||
}
|
||||
return false;
|
||||
|
||||
}
|
||||
|
||||
public boolean hasIterateConnectionBefore(List<IConnection> inputConnections, List<? extends INode> graphicalNodes) {
|
||||
|
||||
for(IConnection connection : inputConnections) {
|
||||
EConnectionType connectionType = connection.getLineStyle();
|
||||
if (connectionType == EConnectionType.FLOW_MAIN) {
|
||||
INode node = connection.getSource();
|
||||
return recursiveSearchIterate(node, graphicalNodes);
|
||||
}
|
||||
}
|
||||
return false;
|
||||
|
||||
}
|
||||
|
||||
public boolean recursiveSearchIterate(INode node, List<? extends INode> graphicalNodes) {
|
||||
|
||||
//System.out.println(node);
|
||||
|
||||
List<IConnection> connections = (List<IConnection>) node.getIncomingConnections();
|
||||
|
||||
for(IConnection connection : connections) {
|
||||
EConnectionType connectionType = connection.getLineStyle();
|
||||
if (connectionType == EConnectionType.FLOW_MAIN) {
|
||||
node = connection.getSource();
|
||||
//System.out.println(connection.getName() + " connectionType=" + connectionType + " connection=" + String.valueOf(connection));
|
||||
return recursiveSearchIterate(node, graphicalNodes);
|
||||
} else if(connectionType == EConnectionType.ITERATE) {
|
||||
//System.out.println("ITERATE return true");
|
||||
return true;
|
||||
}else{
|
||||
//for virtual component
|
||||
boolean find = false;
|
||||
for(INode loopNode : graphicalNodes) {
|
||||
if(loopNode.getUniqueName().equals(node.getUniqueName())){
|
||||
find = true;
|
||||
}
|
||||
}
|
||||
if(!find){
|
||||
List<IConnection> vConnections = (List<IConnection>) node.getIncomingConnections();
|
||||
for(IConnection vConnection : vConnections) {
|
||||
node = vConnection.getSource();
|
||||
break;
|
||||
}
|
||||
return recursiveSearchIterate(node, graphicalNodes);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
//System.out.println("return false");
|
||||
return false;
|
||||
|
||||
}
|
||||
|
||||
private boolean recursiveSearchIterateForConcurrency(INode node, List<? extends INode> graphicalNodes) {
|
||||
List<IConnection> connections = (List<IConnection>) node.getIncomingConnections();
|
||||
|
||||
for(IConnection connection : connections) {
|
||||
EConnectionType connectionType = connection.getLineStyle();
|
||||
if (connectionType == EConnectionType.FLOW_MAIN) {
|
||||
node = connection.getSource();
|
||||
return recursiveSearchIterateForConcurrency(node, graphicalNodes);
|
||||
} else if(connectionType == EConnectionType.ITERATE) {
|
||||
boolean parallelIterate = "true".equals(ElementParameterParser.getValue(connection, "__ENABLE_PARALLEL__"));
|
||||
if(parallelIterate) {
|
||||
return true;
|
||||
} else {
|
||||
node = connection.getSource();
|
||||
return recursiveSearchIterateForConcurrency(node, graphicalNodes);
|
||||
}
|
||||
}else{
|
||||
//for virtual component
|
||||
boolean find = false;
|
||||
for(INode loopNode : graphicalNodes) {
|
||||
if(loopNode.getUniqueName().equals(node.getUniqueName())){
|
||||
find = true;
|
||||
}
|
||||
}
|
||||
if(!find){
|
||||
List<IConnection> vConnections = (List<IConnection>) node.getIncomingConnections();
|
||||
for(IConnection vConnection : vConnections) {
|
||||
node = vConnection.getSource();
|
||||
break;
|
||||
}
|
||||
return recursiveSearchIterateForConcurrency(node, graphicalNodes);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return false;
|
||||
|
||||
}
|
||||
|
||||
public INode searchSubProcessStartNode(IConnection connection) {
|
||||
INode source = connection.getSource();
|
||||
//System.out.println(" source=" + source);
|
||||
INode subprocessStartNode = null;
|
||||
if(source != null) {
|
||||
String searchedComponentName = source.getUniqueName();
|
||||
//System.out.println(" searchedComponentName=" + searchedComponentName);
|
||||
List<? extends INode> generatedNodes = source.getProcess().getGeneratingNodes();
|
||||
for(INode loopNode : generatedNodes) {
|
||||
if(loopNode.getUniqueName().equals(searchedComponentName)) {
|
||||
subprocessStartNode = loopNode.getSubProcessStartNode(false);
|
||||
//System.out.println(" subprocessStartNode=" + subprocessStartNode.getUniqueName());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return subprocessStartNode;
|
||||
}
|
||||
public boolean hasJoinedTable(String tableNameToTest, ExternalMapperData data) {
|
||||
for (ExternalMapperTable table : data.getOutputTables()) {
|
||||
if (table.getIsJoinTableOf() != null && table.getIsJoinTableOf().equals(tableNameToTest)) {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
|
||||
public boolean isErrorReject(ExternalMapperTable table){
|
||||
String errorMessage = null;
|
||||
String errorStackTrace = null;
|
||||
if(table!=null&&table.getName()!=null&&table.getName().endsWith("ErrorReject")){
|
||||
for(ExternalMapperTableEntry entry:table.getMetadataTableEntries()){
|
||||
if("errorMessage".equals(entry.getName())){
|
||||
errorMessage = entry.getName();
|
||||
}else if("errorStackTrace".equals(entry.getName())){
|
||||
errorStackTrace = entry.getName();
|
||||
}
|
||||
}
|
||||
if(errorMessage!=null&&errorStackTrace!=null){
|
||||
return true;
|
||||
}
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
public String getExpressionWithAutoConvertFunction(
|
||||
String expression,
|
||||
ExternalMapperTableEntry targetTableEntry,
|
||||
IMetadataColumn targetColumn,
|
||||
DataMapExpressionParser expressionParser,
|
||||
Map<TableEntryLocation, ExternalMapperTableEntry> locationMap4Entry,
|
||||
Map<TableEntryLocation, IMetadataColumn> locationMap4Column,
|
||||
Map<String,String> autoConverterMap,
|
||||
boolean enable_auto_convert_type) {
|
||||
|
||||
if(!enable_auto_convert_type) {
|
||||
return expression;
|
||||
}
|
||||
|
||||
if(expression == null || expression.isEmpty()) {
|
||||
return expression;
|
||||
}
|
||||
|
||||
TableEntryLocation uniqueLocation = getUniqueEntryLocation(expression);
|
||||
|
||||
if(uniqueLocation == null) {
|
||||
return expression;
|
||||
}
|
||||
|
||||
ExternalMapperTableEntry uniqueSourceEntry = locationMap4Entry.get(uniqueLocation);
|
||||
|
||||
if(uniqueSourceEntry == null) {
|
||||
return expression;
|
||||
}
|
||||
|
||||
String source_talend_type = uniqueSourceEntry.getType();
|
||||
String target_talend_type = targetTableEntry.getType();
|
||||
|
||||
String convertFunction = autoConverterMap.get(contact(source_talend_type, ":", target_talend_type));
|
||||
|
||||
if(convertFunction!=null && !convertFunction.isEmpty()) {
|
||||
StringBuilder strbuilder = new StringBuilder();
|
||||
|
||||
if(uniqueSourceEntry.isNullable()) {
|
||||
strbuilder.append("(((").append(expression).append(") == null) ? null : (");
|
||||
}
|
||||
|
||||
expression = convertFunction.replace("${0}", expression);
|
||||
|
||||
String pattern = null;
|
||||
if((JavaTypesManager.STRING.getId().equals(source_talend_type)||JavaTypesManager.OBJECT.getId().equals(source_talend_type)) && JavaTypesManager.DATE.getId().equals(target_talend_type)) {
|
||||
if(targetColumn!=null) {
|
||||
pattern = targetColumn.getPattern();
|
||||
}
|
||||
|
||||
if(pattern == null || pattern.isEmpty()) {
|
||||
pattern = "\"dd-MM-yyyy\"";
|
||||
}
|
||||
|
||||
} else if(JavaTypesManager.DATE.getId().equals(source_talend_type) && JavaTypesManager.STRING.getId().equals(target_talend_type)) {
|
||||
IMetadataColumn sourceColumn = locationMap4Column.get(uniqueLocation);
|
||||
|
||||
if(sourceColumn!=null) {
|
||||
pattern = sourceColumn.getPattern();
|
||||
}
|
||||
|
||||
if(pattern == null || pattern.isEmpty()) {
|
||||
pattern = "\"dd-MM-yyyy\"";
|
||||
}
|
||||
}
|
||||
|
||||
if(pattern != null) {
|
||||
expression = expression.replace("${1}", pattern);
|
||||
}
|
||||
|
||||
strbuilder.append(expression);
|
||||
|
||||
if(uniqueSourceEntry.isNullable()) {
|
||||
strbuilder.append("))");
|
||||
}
|
||||
|
||||
return strbuilder.toString();
|
||||
}
|
||||
|
||||
return expression;
|
||||
}
|
||||
|
||||
java.util.regex.Pattern locationPattern = java.util.regex.Pattern.compile(LanguageProvider.getJavaLanguage().getLocationPattern());
|
||||
|
||||
private TableEntryLocation getUniqueEntryLocation(String expression) {
|
||||
java.util.regex.Matcher matcher = locationPattern.matcher(expression);
|
||||
if(matcher.matches()) {
|
||||
return new TableEntryLocation(matcher.group(1), matcher.group(2));
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
StringBuilder strbuilder = new StringBuilder(20);
|
||||
|
||||
private String contact(String... content) {
|
||||
strbuilder.setLength(0);
|
||||
for(String each : content) {
|
||||
strbuilder.append(each);
|
||||
}
|
||||
return strbuilder.toString();
|
||||
}
|
||||
|
||||
public String generate(Object argument) {
|
||||
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,169 @@
|
||||
<%@ jet
|
||||
imports="
|
||||
java.util.ArrayList
|
||||
java.util.List
|
||||
org.talend.designer.mapper.external.data.ExternalMapperData
|
||||
org.talend.designer.mapper.external.data.ExternalMapperTable
|
||||
org.talend.designer.mapper.external.data.ExternalMapperTableEntry
|
||||
org.talend.designer.codegen.config.CodeGeneratorArgument
|
||||
org.talend.designer.mapper.MapperComponent
|
||||
org.talend.core.model.process.IElementParameter
|
||||
org.talend.core.model.process.INode
|
||||
org.talend.core.model.process.IConnection
|
||||
java.util.HashMap
|
||||
java.util.Map
|
||||
org.talend.core.model.process.ElementParameterParser
|
||||
"
|
||||
skeleton="tMap_commons.skeleton"
|
||||
%>
|
||||
|
||||
<%
|
||||
|
||||
CodeGeneratorArgument codeGenArgument = (CodeGeneratorArgument) argument;
|
||||
MapperComponent node = (MapperComponent) codeGenArgument.getArgument();
|
||||
boolean stats = codeGenArgument.isStatistics();
|
||||
|
||||
/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
|
||||
|
||||
ExternalMapperData data = (ExternalMapperData) node.getExternalData();
|
||||
|
||||
String componentName = node.getUniqueName();
|
||||
boolean isVirtualIn = componentName.endsWith("TMAP_IN");
|
||||
boolean isVirtualOut = componentName.endsWith("TMAP_OUT");
|
||||
|
||||
List<IConnection> inputConnections = (List<IConnection>) node.getIncomingConnections();
|
||||
|
||||
boolean isLog4jEnabled = ("true").equals(ElementParameterParser.getValue(node.getProcess(), "__LOG4J_ACTIVATE__"));
|
||||
|
||||
String uniqueNameComponent = componentName.replaceAll("_TMAP_IN", "");
|
||||
uniqueNameComponent = uniqueNameComponent.replaceAll("_TMAP_OUT", "");
|
||||
|
||||
if(isVirtualIn) {
|
||||
String searchedComponentName = componentName.replaceAll("TMAP_IN", "TMAP_OUT");
|
||||
List<? extends INode> generatedNodes = node.getProcess().getGeneratingNodes();
|
||||
for(INode loopNode : generatedNodes) {
|
||||
if(loopNode.getUniqueName().equals(searchedComponentName)) {
|
||||
inputConnections = (List<IConnection>) loopNode.getIncomingConnections();
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
// Bug partially fixed, see bug:785
|
||||
// Bug partially fixed, see bug:3966
|
||||
|
||||
boolean hasIterate = hasIterateConnectionBefore(inputConnections, node.getProcess().getGraphicalNodes());
|
||||
|
||||
|
||||
%>
|
||||
// ###############################
|
||||
// # Lookup hashes releasing
|
||||
<%
|
||||
|
||||
if(!isVirtualOut) {
|
||||
|
||||
HashMap<String, IConnection> hNameToConnection = new HashMap<String, IConnection>();
|
||||
for (IConnection connection : inputConnections) {
|
||||
hNameToConnection.put(connection.getName(), connection);
|
||||
}
|
||||
|
||||
List<ExternalMapperTable> inputTablesList = new ArrayList<ExternalMapperTable>(data.getInputTables());
|
||||
int lstSizeInputs = inputTablesList.size();
|
||||
|
||||
if(lstSizeInputs > 1) {
|
||||
String mainTableName = inputTablesList.get(0).getName();
|
||||
|
||||
int joinedTableIndex = 0;
|
||||
int tmpJoinedTableIndex = 0;
|
||||
boolean hasPersistentLookup = false;
|
||||
for (int i = 0; i < lstSizeInputs; i++) {
|
||||
ExternalMapperTable inputTable = (ExternalMapperTable) inputTablesList.get(i);
|
||||
|
||||
if(hNameToConnection.get(inputTable.getName()) != null) {
|
||||
if(inputTable.isPersistent()
|
||||
&& !"ALL_ROWS".equals(inputTable.getMatchingMode())
|
||||
) {
|
||||
joinedTableIndex = tmpJoinedTableIndex;
|
||||
hasPersistentLookup = true;
|
||||
}
|
||||
|
||||
tmpJoinedTableIndex++;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
if(hasPersistentLookup) {
|
||||
%>
|
||||
fsi_<%=uniqueNameComponent%>_<%=joinedTableIndex%>.endGet();
|
||||
<%
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
for (int i = 1; i < lstSizeInputs; i++) {
|
||||
ExternalMapperTable inputTable = (ExternalMapperTable) inputTablesList.get(i);
|
||||
|
||||
|
||||
List<ExternalMapperTableEntry> tableEntries = inputTable.getMetadataTableEntries();
|
||||
if (tableEntries == null) {
|
||||
continue;
|
||||
}
|
||||
String tableName = inputTable.getName();
|
||||
IConnection connection = hNameToConnection.get(tableName);
|
||||
if(connection == null) {
|
||||
continue;
|
||||
}
|
||||
|
||||
String lookupMode = inputTable.getLookupMode();
|
||||
boolean isCacheOrReload = org.talend.designer.mapper.model.table.LOOKUP_MODE.CACHE_OR_RELOAD.name().equals(lookupMode);
|
||||
|
||||
if(!hasIterate) {
|
||||
%>
|
||||
if(tHash_Lookup_<%=tableName%> != null) {
|
||||
tHash_Lookup_<%=tableName%>.endGet();
|
||||
}
|
||||
globalMap.remove( "tHash_Lookup_<%=tableName%>" );
|
||||
|
||||
<%
|
||||
if(isCacheOrReload) {
|
||||
%>
|
||||
|
||||
tHash_Lookup_Cache_<%=tableName%>.endGet();
|
||||
tHash_Lookup_Cache_<%=tableName%> = null;
|
||||
tHash_Lookup_Real_<%=tableName%> = null;
|
||||
|
||||
<%
|
||||
}
|
||||
%>
|
||||
|
||||
<%
|
||||
}
|
||||
}
|
||||
}
|
||||
%>
|
||||
// ###############################
|
||||
<%
|
||||
List<IConnection> outputConnections = (List<IConnection>) node.getOutgoingConnections();
|
||||
Map<String, IConnection> nameToOutputConnection = new HashMap<String, IConnection>();
|
||||
for (IConnection connection : outputConnections) {
|
||||
nameToOutputConnection.put(connection.getName(), connection);
|
||||
}
|
||||
|
||||
List<ExternalMapperTable> outputTables = data.getOutputTables();
|
||||
for(ExternalMapperTable outputTable : outputTables){
|
||||
String outputTableName = outputTable.getName();
|
||||
List<ExternalMapperTableEntry> tableEntries = outputTable.getMetadataTableEntries();
|
||||
if (tableEntries == null || nameToOutputConnection.get(outputTable.getName()) == null) {
|
||||
continue;
|
||||
}
|
||||
|
||||
if(isLog4jEnabled){
|
||||
if(!isVirtualOut) {
|
||||
%>
|
||||
log.debug("<%=uniqueNameComponent%> - Written records count in the table '<%=outputTableName%>': " + count_<%=outputTableName%>_<%=uniqueNameComponent%> + ".");
|
||||
<%
|
||||
}
|
||||
}
|
||||
}
|
||||
%>
|
||||
@@ -0,0 +1,29 @@
|
||||
<%@ jet
|
||||
imports="
|
||||
java.util.ArrayList
|
||||
java.util.List
|
||||
org.talend.designer.mapper.external.data.ExternalMapperData
|
||||
org.talend.designer.mapper.external.data.ExternalMapperTable
|
||||
org.talend.designer.mapper.external.data.ExternalMapperTableEntry
|
||||
org.talend.designer.codegen.config.CodeGeneratorArgument
|
||||
org.talend.designer.mapper.MapperComponent
|
||||
org.talend.core.model.process.INode
|
||||
java.util.HashMap
|
||||
java.util.Map
|
||||
org.talend.core.model.process.IConnection
|
||||
org.talend.core.model.process.EConnectionType
|
||||
org.talend.core.model.process.ElementParameterParser
|
||||
org.talend.designer.mapper.model.tableentry.TableEntryLocation
|
||||
org.talend.designer.mapper.utils.DataMapExpressionParser
|
||||
org.talend.designer.mapper.language.LanguageProvider
|
||||
org.talend.core.model.metadata.IMetadataColumn
|
||||
org.talend.core.model.metadata.types.JavaTypesManager
|
||||
"
|
||||
skeleton="tMap_commons.skeleton"
|
||||
%>
|
||||
|
||||
<%@ include file="tMap_end.inc.javajet" %>
|
||||
|
||||
|
||||
|
||||
|
||||
Binary file not shown.
|
After Width: | Height: | Size: 2.1 KiB |
@@ -0,0 +1,143 @@
|
||||
<COMPONENT>
|
||||
<HEADER PLATEFORM="ALL"
|
||||
SERIAL=""
|
||||
VERSION="2.1"
|
||||
STATUS="ALPHA"
|
||||
COMPATIBILITY="WIN32"
|
||||
AUTHOR="Talend"
|
||||
RELEASE_DATE="20070703A"
|
||||
STARTABLE="false"
|
||||
EXTENSION="org.talend.designer.mapper"
|
||||
SCHEMA_AUTO_PROPAGATE="false"
|
||||
DATA_AUTO_PROPAGATE="false"
|
||||
HAS_CONDITIONAL_OUTPUTS="true"
|
||||
PARTITIONING="AUTO"
|
||||
LOG4J_ENABLED="true"
|
||||
>
|
||||
<SIGNATURE></SIGNATURE>
|
||||
</HEADER>
|
||||
|
||||
<FAMILIES>
|
||||
<FAMILY>Processing</FAMILY>
|
||||
</FAMILIES>
|
||||
<DOCUMENTATION>
|
||||
<URL/>
|
||||
</DOCUMENTATION>
|
||||
<CONNECTORS>
|
||||
<CONNECTOR BUILTIN="true" CTYPE="FLOW" MIN_INPUT="1" MIN_OUTPUT="1"/>
|
||||
<CONNECTOR CTYPE="LOOKUP" COMPONENT="tAdvancedHash"/>
|
||||
<CONNECTOR CTYPE="ITERATE" MAX_OUTPUT="0" MAX_INPUT="0"/>
|
||||
<CONNECTOR CTYPE="SUBJOB_OK" MAX_INPUT="0"/>
|
||||
<CONNECTOR CTYPE="SUBJOB_ERROR" MAX_INPUT="0"/>
|
||||
<CONNECTOR CTYPE="COMPONENT_OK" MAX_OUTPUT="0"/>
|
||||
<CONNECTOR CTYPE="COMPONENT_ERROR" MAX_OUTPUT="0"/>
|
||||
<CONNECTOR CTYPE="RUN_IF" MAX_OUTPUT="0"/>
|
||||
</CONNECTORS>
|
||||
<PARAMETERS>
|
||||
<PARAMETER NAME="MAP" FIELD="EXTERNAL" NUM_ROW="1">
|
||||
<DEFAULT/>
|
||||
</PARAMETER>
|
||||
<PARAMETER
|
||||
NAME="LINK_STYLE"
|
||||
FIELD="CLOSED_LIST"
|
||||
NUM_ROW="1"
|
||||
>
|
||||
<ITEMS DEFAULT="">
|
||||
<ITEM NAME="AUTO" VALUE="AUTO" />
|
||||
<ITEM NAME="BEZIER_CURVE" VALUE="BEZIER_CURVE" />
|
||||
<ITEM NAME="LINE" VALUE="LINE" />
|
||||
</ITEMS>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER NAME="TEMPORARY_DATA_DIRECTORY" FIELD="DIRECTORY"
|
||||
NUM_ROW="2" GROUP="STORE_ON_DISK"
|
||||
>
|
||||
<!--<DEFAULT>"__COMP_DEFAULT_FILE_DIR__/temp"</DEFAULT>
|
||||
--></PARAMETER>
|
||||
|
||||
<PARAMETER NAME="PREVIEW" FIELD="IMAGE" SHOW="true" NUM_ROW="4">
|
||||
<DEFAULT/>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER
|
||||
NAME="DIE_ON_ERROR"
|
||||
FIELD="CHECK"
|
||||
NUM_ROW="100"
|
||||
SHOW="false"
|
||||
>
|
||||
<DEFAULT>true</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER
|
||||
NAME="LKUP_PARALLELIZE"
|
||||
FIELD="CHECK"
|
||||
NUM_ROW="100"
|
||||
SHOW="false"
|
||||
>
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
|
||||
<PARAMETER
|
||||
NAME="LEVENSHTEIN"
|
||||
FIELD = "TEXT"
|
||||
NUM_ROW="120"
|
||||
SHOW="false"
|
||||
>
|
||||
<DEFAULT>0</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER
|
||||
NAME="JACCARD"
|
||||
FIELD = "TEXT"
|
||||
NUM_ROW="120"
|
||||
SHOW="false"
|
||||
>
|
||||
<DEFAULT>0</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER
|
||||
NAME="ENABLE_AUTO_CONVERT_TYPE"
|
||||
FIELD="CHECK"
|
||||
NUM_ROW="110"
|
||||
SHOW="false"
|
||||
>
|
||||
<DEFAULT>false</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
</PARAMETERS>
|
||||
|
||||
<ADVANCED_PARAMETERS>
|
||||
<PARAMETER NAME="ROWS_BUFFER_SIZE" FIELD="TEXT"
|
||||
REQUIRED="true" NUM_ROW="1" SHOW="true" GROUP="STORE_ON_DISK"
|
||||
>
|
||||
<DEFAULT>2000000</DEFAULT>
|
||||
</PARAMETER>
|
||||
|
||||
<PARAMETER
|
||||
NAME="CHANGE_HASH_AND_EQUALS_FOR_BIGDECIMAL"
|
||||
FIELD="CHECK"
|
||||
NUM_ROW="10"
|
||||
>
|
||||
<DEFAULT>true</DEFAULT>
|
||||
</PARAMETER>
|
||||
</ADVANCED_PARAMETERS>
|
||||
|
||||
<CODEGENERATION>
|
||||
<TEMPLATES INPUT="TMAP_OUT" OUTPUT="TMAP_IN">
|
||||
|
||||
<TEMPLATE NAME="TMAP_OUT" COMPONENT="tMapOut">
|
||||
<LINK_TO NAME="TMAP_IN" CTYPE="ROWS_END"/>
|
||||
</TEMPLATE>
|
||||
|
||||
<TEMPLATE NAME="TMAP_IN" COMPONENT="tMapIn"/>
|
||||
|
||||
</TEMPLATES>
|
||||
</CODEGENERATION>
|
||||
<RETURNS/>
|
||||
|
||||
<PLUGINDEPENDENCIES>
|
||||
<PLUGINDEPENDENCY ID="org.talend.designer.abstractmap" />
|
||||
</PLUGINDEPENDENCIES>
|
||||
|
||||
</COMPONENT>
|
||||
File diff suppressed because it is too large
Load Diff
@@ -0,0 +1,46 @@
|
||||
<%@ jet
|
||||
imports="
|
||||
java.util.ArrayList
|
||||
java.util.Collections
|
||||
java.util.Comparator
|
||||
java.util.List
|
||||
java.util.HashMap
|
||||
java.util.Map
|
||||
org.talend.designer.codegen.config.CodeGeneratorArgument
|
||||
org.talend.commons.utils.generation.CodeGenerationUtils
|
||||
org.talend.designer.mapper.MapperComponent
|
||||
org.talend.designer.mapper.external.data.ExternalMapperData
|
||||
org.talend.designer.mapper.external.data.ExternalMapperTable
|
||||
org.talend.designer.mapper.external.data.ExternalMapperTableEntry
|
||||
org.talend.designer.mapper.language.ILanguage
|
||||
org.talend.designer.mapper.language.generation.JavaGenerationManager
|
||||
org.talend.designer.mapper.language.generation.HashedMetadataTable
|
||||
org.talend.designer.mapper.language.LanguageProvider
|
||||
org.talend.designer.mapper.model.tableentry.TableEntryLocation
|
||||
org.talend.designer.mapper.utils.DataMapExpressionParser
|
||||
org.talend.core.model.process.IConnection
|
||||
org.talend.core.model.process.EConnectionType
|
||||
org.talend.core.model.metadata.IMetadataTable
|
||||
org.talend.core.model.metadata.IMetadataColumn
|
||||
org.talend.core.model.metadata.types.JavaTypesManager
|
||||
org.talend.core.model.metadata.types.JavaType
|
||||
org.talend.core.model.process.BlockCode
|
||||
org.talend.core.model.process.INode
|
||||
org.talend.core.model.process.ElementParameterParser
|
||||
org.talend.core.GlobalServiceRegister
|
||||
org.talend.core.model.metadata.IAutoConvertTypesService
|
||||
org.talend.core.model.metadata.types.AutoConversionType
|
||||
"
|
||||
|
||||
skeleton="tMap_commons.skeleton"
|
||||
|
||||
%>
|
||||
|
||||
<%@ include file="tMap_main.inc.javajet" %>
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -0,0 +1,12 @@
|
||||
HELP=org.talend.help.tMap
|
||||
LONG_NAME=Allows joins, column or row filtering, transformations, and multiple outputs
|
||||
MAP.NAME=Map Editor:
|
||||
PREVIEW.NAME=Preview
|
||||
STORE_ON_DISK.NAME=Store on disk
|
||||
TEMPORARY_DATA_DIRECTORY.NAME=Temp data directory path:
|
||||
ROWS_BUFFER_SIZE.NAME=Max buffer size (nb of rows):
|
||||
LINK_STYLE.NAME=Mapping links display as:
|
||||
LINK_STYLE.ITEM.AUTO=Auto
|
||||
LINK_STYLE.ITEM.BEZIER_CURVE=Curves
|
||||
LINK_STYLE.ITEM.LINE=Lines (fast)
|
||||
CHANGE_HASH_AND_EQUALS_FOR_BIGDECIMAL.NAME=Ignore trailing zeros for BigDecimal
|
||||
@@ -0,0 +1,10 @@
|
||||
LONG_NAME=Erm\u00F6glicht Joins, Spalten- oder Zeilenfilter, Transformationen und multiple Ausgaben
|
||||
MAP.NAME=Map Editor\:
|
||||
PREVIEW.NAME=Vorschau
|
||||
STORE_ON_DISK.NAME=Speichere auf Festplatte
|
||||
TEMPORARY_DATA_DIRECTORY.NAME=Verzeichnis f\u00FCr tempor\u00E4re Daten:
|
||||
ROWS_BUFFER_SIZE.NAME=Maximale Puffergr\u00F6\u00DFe (Anzahl Zeilen)
|
||||
LINK_STYLE.NAME=Mapping Verbindungen anzeigen als:
|
||||
LINK_STYLE.ITEM.AUTO=Auto
|
||||
LINK_STYLE.ITEM.BEZIER_CURVE=Kurven
|
||||
LINK_STYLE.ITEM.LINE=Linien (schnell)
|
||||
@@ -0,0 +1,12 @@
|
||||
HELP=org.talend.help.tMap
|
||||
LONG_NAME=Permet d'effectuer des jointures, des filtres de colonnes ou de lignes, des transformations et de multiples sorties
|
||||
MAP.NAME=\u00C9diteur de mapping
|
||||
PREVIEW.NAME=Aper\u00E7u
|
||||
STORE_ON_DISK.NAME=Stocker sur le disque
|
||||
TEMPORARY_DATA_DIRECTORY.NAME=Chemin du r\u00E9pertoire des donn\u00E9es temporaires :
|
||||
ROWS_BUFFER_SIZE.NAME=Taille maximale de la m\u00E9moire tampon (nombre de lignes) :
|
||||
LINK_STYLE.NAME=Les liens de mapping s'affichent comme\u00A0:
|
||||
LINK_STYLE.ITEM.AUTO=Auto
|
||||
LINK_STYLE.ITEM.BEZIER_CURVE=Courbes
|
||||
LINK_STYLE.ITEM.LINE=Lignes (rapide)
|
||||
CHANGE_HASH_AND_EQUALS_FOR_BIGDECIMAL.NAME=Ignorer les z\u00E9ros de fin pour BigDecimal
|
||||
@@ -0,0 +1,10 @@
|
||||
LONG_NAME=Permetti join, colonne o righe filtrate, trasforazioni, e output multipli
|
||||
MAP.NAME=Editor Map:
|
||||
PREVIEW.NAME=Anteprima
|
||||
STORE_ON_DISK.NAME=Salva su disco
|
||||
TEMPORARY_DATA_DIRECTORY.NAME=Temp data directory path:
|
||||
ROWS_BUFFER_SIZE.NAME=Grandezza buffer (n. di record)
|
||||
LINK_STYLE.NAME=Mappa collegameti come:
|
||||
LINK_STYLE.ITEM.AUTO=Auto
|
||||
LINK_STYLE.ITEM.BEZIER_CURVE=Curve
|
||||
LINK_STYLE.ITEM.LINE=Linee (veloce)
|
||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user