Compare commits

...

16 Commits

Author SHA1 Message Date
Jill Yan
482556ffbd Revert "APPINT-34618 add jtds driver support (#7637)" (#7638)
This reverts commit a4effc8e00.
2022-06-08 19:18:51 +08:00
Jill Yan
a4effc8e00 APPINT-34618 add jtds driver support (#7637)
Co-authored-by: jillyan <yan955599@gmail.com>
2022-06-08 19:08:33 +08:00
apoltavtsev
1567eefcd5 fix(APPINT-34416) Migrate to CXF 3.4.7 (#7628) 2022-06-07 15:41:22 +02:00
sbieliaievl
64fb10f2c6 bugfix(APPINT-33830) - migration for demos (#7617)
* Added rename timeout parameters for tRESTClient migration

* Added rename timeout parameters for tRESTClient migration

* Comment changes for RenameTimeoutParameterstRESTClient

* Code refactoring in RenameTimeoutParameterstRESTClient
2022-06-06 10:07:25 +03:00
wang wei
b2ce9e2ee2 fix(TDI-48037): CVE: org.postgresql:postgresql:42.2.14 (#7574) 2022-06-02 16:37:38 +08:00
Jill Yan
25d0a3c978 jill/fix-m73/APPINT-34618 add mssql driver to import-package for child job (#7606)
* APPINT-34618 add mssql driver to import-package for child job

* APPINT-34618 remove mssql-jdbc in build lib

Co-authored-by: jillyan <yan955599@gmail.com>
2022-06-02 14:36:39 +08:00
sbliu
1d4e07ebd0 chore(TUP-35245) upgrade cxf to 3.4.7 (#7475) 2022-06-02 09:30:45 +08:00
wang wei
2a591f79ce fix(TDI-47803): Compile error after applying Patch_20220107_R2022-01_v1-7.3.1 (#7474) 2022-06-01 11:29:36 +08:00
sbliu
30d42547e5 chore(TUP-35684) upgrade xmlbeans. (#7590) 2022-05-31 16:12:28 +08:00
bhe-talendbj
fe468cbf15 chore(TUP-35685): upgrade database driver (#7575) 2022-05-31 11:39:04 +08:00
vyu-talend
ce2b399fe4 chore(TDI-47796):upgrade cxf to 3.4.7 (#7570)
* fix(TDI-47796):backport talend-ws from master to 7.3 to align

* chore(TDI-47796):bump cxf version to 3.4.7

* chore(TDI-47796):upgrade talend-ws version for twebservice comps
2022-05-30 15:51:59 +08:00
Chao MENG
55aba706f6 Cmeng/fix/tup 35608 db version 7 (#7572)
* fix(TUP-35608): Stat and Logs screen - Database connection dropdown
incorrect
https://jira.talendforge.org/browse/TUP-35608

* fix(TUP-35608): Stat and Logs screen - Database connection dropdown
incorrect
https://jira.talendforge.org/browse/TUP-35608
2022-05-26 19:45:11 +08:00
Zhiwei Xue
4ee53f979e fix(TUP-31233):Routine pom is not updated after installed the required (#7547)
* fix(TUP-31233):Routine pom is not updated after installed the required
jar of user routine

* fix(TUP-31233):Routine pom is not updated after installed the required
jar of user routine

* fix(TUP-31233):Routine pom is not updated after installed the required
jar of user routine
2022-05-25 18:04:51 +08:00
Dmytro Sylaiev
51142f7983 fix(TDI-47452): Fix codegen for not valid xpath expression (#7175) 2022-05-16 12:50:26 +03:00
jiezhang-tlnd
e2697a8226 fix(TUP-33047)Help links in Studio (#7472) 2022-05-09 10:38:41 +08:00
sponomarova
86eb6ab2fe fix(TBD-13798): CVE: Replace log4j1.x by reload4j for org.talend.libraries.hadoop.mapr.5.0.0 (#7450) 2022-05-05 16:56:39 +03:00
60 changed files with 1437 additions and 402 deletions

View File

@@ -11,7 +11,7 @@
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<cxf.version>3.3.10</cxf.version>
<cxf.version>3.4.7</cxf.version>
</properties>
<build>
@@ -77,8 +77,8 @@
<artifactId>maven-compiler-plugin</artifactId>
<version>2.5.1</version>
<configuration>
<source>1.7</source>
<target>1.7</target>
<source>1.8</source>
<target>1.8</target>
<encoding>UTF-8</encoding>
</configuration>
</plugin>

View File

@@ -2,17 +2,28 @@
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>
<groupId>org.talend.libraries</groupId>
<groupId>org.talend.components</groupId>
<artifactId>talend-ws</artifactId>
<version>1.0.1-20191112</version>
<version>1.0.7-20220526</version>
<packaging>jar</packaging>
<licenses>
<license>
<name>Apache License, Version 2.0</name>
<url>https://www.talendforge.org/modules/licenses/APACHE_v2.txt</url>
<distribution>may be downloaded from the Maven repository</distribution>
</license>
</licenses>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<cxf.version>3.3.4</cxf.version>
<talend.nexus.url>https://artifacts-oss.talend.com</talend.nexus.url>
<cxf.version>3.4.7</cxf.version>
<odata.version>4.3.0</odata.version>
<slf4j.version>1.7.12</slf4j.version>
<talend.nexus.url>https://artifacts-oss.talend.com</talend.nexus.url>
<httpclient.version>4.5.13</httpclient.version>
</properties>
<distributionManagement>
@@ -43,13 +54,19 @@
<dependency>
<groupId>commons-codec</groupId>
<artifactId>commons-codec</artifactId>
<version>1.10</version>
<version>1.14</version>
</dependency>
<!-- https://mvnrepository.com/artifact/commons-httpclient/commons-httpclient -->
<!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpclient -->
<dependency>
<groupId>commons-httpclient</groupId>
<artifactId>commons-httpclient</artifactId>
<version>3.1</version>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>${httpclient.version}</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpcore -->
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpcore</artifactId>
<version>4.4.13</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.codehaus.woodstox/stax2-api -->
<dependency>
@@ -91,6 +108,12 @@
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-core</artifactId>
<version>${cxf.version}</version>
<exclusions>
<exclusion>
<groupId>org.glassfish.jaxb</groupId>
<artifactId>jaxb-runtime</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
@@ -101,6 +124,16 @@
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-tools-common</artifactId>
<version>${cxf.version}</version>
<exclusions>
<exclusion>
<groupId>org.glassfish.jaxb</groupId>
<artifactId>jaxb-xjc</artifactId>
</exclusion>
<exclusion>
<groupId>org.glassfish.jaxb</groupId>
<artifactId>jaxb-runtime</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
@@ -127,6 +160,16 @@
<artifactId>cxf-rt-transports-http</artifactId>
<version>${cxf.version}</version>
</dependency>
<dependency>
<groupId>javax.xml.bind</groupId>
<artifactId>jaxb-api</artifactId>
<version>2.2.6</version>
</dependency>
<dependency>
<groupId>org.talend.libraries</groupId>
<artifactId>jaxb-impl-2.2.6-modified</artifactId>
<version>6.0.0</version>
</dependency>
<dependency>
<groupId>org.talend.libraries</groupId>
<artifactId>jaxb-xjc-2.2.6-modified</artifactId>
@@ -244,6 +287,7 @@
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.8.1</version>
<configuration>
<source>1.8</source>
<target>1.8</target>
@@ -251,4 +295,4 @@
</plugin>
</plugins>
</build>
</project>
</project>

View File

@@ -48,4 +48,6 @@ please @see org\talend\ws\helper\ServiceDiscoveryHelper.java
please @see org\talend\ws\helper\ServiceInvokerHelper.java
org\talend\ws\mapper\MapperFactory.java
10.(2019-01-18 modified by dchmyga) fixed TDI-41647
10.(2019-01-18 modified by dchmyga) fixed TDI-41647
11.(2020-08-24 modified by ozhelezniak) updated commons-codec to 1.14 in scope of TDI-44145

View File

@@ -1,6 +1,6 @@
// ============================================================================
//
// Copyright (C) 2006-2019 Talend Inc. - www.talend.com
// Copyright (C) 2006-2021 Talend Inc. - www.talend.com
//
// This source code is available under agreement available at
// %InstallDIR%\features\org.talend.rcp.branding.%PRODUCTNAME%\%PRODUCTNAME%license.txt

View File

@@ -3,29 +3,22 @@
*/
package org.talend.webservice.helper;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.MalformedURLException;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.Vector;
import com.ibm.wsdl.Constants;
import com.ibm.wsdl.extensions.schema.SchemaConstants;
import com.ibm.wsdl.util.xml.DOMUtils;
import com.ibm.wsdl.util.xml.QNameUtils;
import org.apache.ws.commons.schema.XmlSchema;
import org.apache.ws.commons.schema.XmlSchemaCollection;
import org.talend.webservice.helper.conf.ServiceHelperConfiguration;
import org.talend.webservice.helper.conf.WSDLLocatorImpl;
import org.w3c.dom.Element;
import javax.wsdl.Definition;
import javax.wsdl.Import;
import javax.wsdl.Types;
import javax.wsdl.WSDLException;
import javax.wsdl.extensions.ExtensibilityElement;
import javax.wsdl.extensions.UnknownExtensibilityElement;
import javax.wsdl.extensions.schema.Schema;
import javax.wsdl.extensions.schema.SchemaImport;
import javax.wsdl.extensions.schema.SchemaReference;
@@ -37,16 +30,15 @@ import javax.xml.transform.TransformerException;
import javax.xml.transform.TransformerFactory;
import javax.xml.transform.dom.DOMSource;
import javax.xml.transform.stream.StreamResult;
import org.apache.ws.commons.schema.XmlSchemaCollection;
import org.talend.webservice.helper.conf.ServiceHelperConfiguration;
import org.talend.webservice.helper.conf.WSDLLocatorImpl;
import org.w3c.dom.Element;
import com.ibm.wsdl.Constants;
import com.ibm.wsdl.extensions.schema.SchemaConstants;
import com.ibm.wsdl.util.xml.DOMUtils;
import com.ibm.wsdl.util.xml.QNameUtils;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.MalformedURLException;
import java.net.URI;
import java.net.URISyntaxException;
import java.net.URL;
import java.util.*;
/**
* This helper allow easy discovery of services and types
@@ -70,26 +62,36 @@ public class ServiceDiscoveryHelper {
private Set<String> namespaces;
private final String LOCAL_WSDL_NAME = "mainWSDL.wsdl";
private boolean createTempFiles = true;
public ServiceDiscoveryHelper(String wsdlUri) throws WSDLException, IOException, TransformerException, URISyntaxException {
this(wsdlUri, null, null);
this(wsdlUri, null, null, true);
}
public ServiceDiscoveryHelper(String wsdlUri, String tempPath) throws WSDLException, IOException, TransformerException,
URISyntaxException {
this(wsdlUri, null, tempPath);
this(wsdlUri, null, tempPath, true);
}
public ServiceDiscoveryHelper(String wsdlUri, ServiceHelperConfiguration configuration) throws WSDLException, IOException,
TransformerException, URISyntaxException {
this(wsdlUri, configuration, null);
this(wsdlUri, configuration, null, true);
}
public ServiceDiscoveryHelper(String wsdlUri, ServiceHelperConfiguration configuration, String tempPath)
throws WSDLException, IOException, TransformerException, URISyntaxException {
this(wsdlUri, configuration, tempPath, true);
}
public ServiceDiscoveryHelper(String wsdlUri, ServiceHelperConfiguration configuration, String tempPath, boolean createTempFiles)
throws WSDLException, IOException, TransformerException, URISyntaxException {
this.wsdlUri = wsdlUri;
this.configuration = configuration;
this.wsdlTmpDir = createTempWsdlDir(tempPath);
this.createTempFiles = createTempFiles;
if(createTempFiles) {
this.wsdlTmpDir = createTempWsdlDir(tempPath);
}
init();
}
@@ -139,7 +141,9 @@ public class ServiceDiscoveryHelper {
namespaces = collectNamespaces();
generateTempWsdlFile();
if(this.createTempFiles) {
generateTempWsdlFile();
}
}
@@ -436,6 +440,10 @@ public class ServiceDiscoveryHelper {
return definitions.get(this.LOCAL_WSDL_NAME);
}
Collection<Definition> getDefinitions() {
return definitions.values();
}
/**
* Return the xml schema collection
*
@@ -450,7 +458,11 @@ public class ServiceDiscoveryHelper {
}
public String getLocalWsdlUri() {
return new File(wsdlTmpDir, this.LOCAL_WSDL_NAME).toURI().toString();
if(createTempFiles) {
return new File(wsdlTmpDir, this.LOCAL_WSDL_NAME).toURI().toString();
} else {
return this.wsdlUri;
}
}
public Set<String> getNamespaces() {
@@ -464,4 +476,33 @@ public class ServiceDiscoveryHelper {
return "NOLOCATION";
}
}
public static void main(String[] args) throws Exception {
System.setProperty("javax.xml.transform.TransformerFactory", "org.apache.xalan.processor.TransformerFactoryImpl");
System.setProperty("org.apache.commons.logging.Log", "org.apache.commons.logging.impl.NoOpLog");
System.setProperty("javax.xml.accessExternalSchema", "all");
//shade the log level for DynamicClientFactory.class
java.util.logging.Logger LOG = org.apache.cxf.common.logging.LogUtils.getL7dLogger(org.apache.cxf.endpoint.dynamic.DynamicClientFactory.class);
LOG.setLevel(java.util.logging.Level.WARNING);
ServiceDiscoveryHelper helper = new ServiceDiscoveryHelper("http://gcomputer.net/webservices/knowledge.asmx?WSDL", null, null, false);
//ServiceDiscoveryHelper helper = new ServiceDiscoveryHelper("/Users/wangwei/Downloads/knowledge.wsdl", null, null, false);
/*
WSDLMetadataUtils utils = new WSDLMetadataUtils();
//WSDLMetadataUtils.OperationInfo info = utils.parseOperationInfo(helper, "KnowledgeLeakSoap12", "Knowledge");
WSDLMetadataUtils.OperationInfo info = utils.parseOperationInfo(helper, null, "Knowledge");
System.out.println(info.operationName);
System.out.println(info.port);
System.out.println(info.service);
System.out.println(info.inputParameters);
System.out.println(info.outputParameter);
System.out.println("done");
*/
org.talend.webservice.helper.ServiceInvokerHelper serviceInvokerHelper = new org.talend.webservice.helper.ServiceInvokerHelper(helper, null);
Map<String, Object> result = serviceInvokerHelper.invokeDynamic("Knowledge", Arrays.asList(1));
System.out.println(result);
}
}

View File

@@ -3,30 +3,6 @@
*/
package org.talend.webservice.helper;
import java.beans.PropertyDescriptor;
import java.io.File;
import java.io.IOException;
import java.net.URISyntaxException;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Random;
import java.util.Set;
import javax.wsdl.Input;
import javax.wsdl.Message;
import javax.wsdl.Operation;
import javax.wsdl.Output;
import javax.wsdl.Port;
import javax.wsdl.Service;
import javax.wsdl.WSDLException;
import javax.xml.bind.annotation.XmlSchema;
import javax.xml.bind.annotation.XmlType;
import javax.xml.namespace.QName;
import javax.xml.transform.TransformerException;
import org.apache.commons.beanutils.PropertyUtils;
import org.apache.commons.lang.StringUtils;
import org.apache.cxf.endpoint.Client;
@@ -39,11 +15,18 @@ import org.talend.webservice.helper.conf.ServiceHelperConfiguration;
import org.talend.webservice.helper.map.MapConverter;
import org.talend.webservice.jaxb.JAXBUtils;
import org.talend.webservice.jaxb.JAXBUtils.IdentifierType;
import org.talend.webservice.mapper.AnyPropertyMapper;
import org.talend.webservice.mapper.ClassMapper;
import org.talend.webservice.mapper.EmptyMessageMapper;
import org.talend.webservice.mapper.MapperFactory;
import org.talend.webservice.mapper.MessageMapper;
import org.talend.webservice.mapper.*;
import javax.wsdl.*;
import javax.xml.bind.annotation.XmlSchema;
import javax.xml.bind.annotation.XmlType;
import javax.xml.namespace.QName;
import javax.xml.transform.TransformerException;
import java.beans.PropertyDescriptor;
import java.io.File;
import java.io.IOException;
import java.net.URISyntaxException;
import java.util.*;
/**
*
@@ -261,6 +244,61 @@ public class ServiceInvokerHelper implements ClassMapper {
return MapConverter.deepMapToMap(result);
}
//auto decide the service, port, and operation name and params are necessary
public Map<String, Object> invokeDynamic(String operationNameAndPortName, List<Object> param_values)
throws Exception, LocalizedException {
String portName = null;
String operationName = operationNameAndPortName;
try {
portName = operationName.substring(operationName.indexOf("(") + 1, operationName.indexOf(")"));
operationName = operationName.substring(0, operationName.indexOf("("));
} catch (Exception ignored) {
}
WSDLMetadataUtils utils = new WSDLMetadataUtils();
WSDLMetadataUtils.OperationInfo info = utils.parseOperationInfo(this.serviceDiscoveryHelper, portName, operationName);
Map<String, Object> paramsMap = null;
if(param_values!=null && !param_values.isEmpty()) {
List<String> paths = new ArrayList<>();
flat(paths, info.inputParameters, null);
int size = Math.min(paths.size(), param_values.size());
paramsMap = new HashMap<>();
for(int i=0;i<size;i++) {
paramsMap.put(paths.get(i), param_values.get(i));
}
if (!paramsMap.isEmpty()) {
paramsMap = MapConverter.mapToDeepMap(paramsMap);
}
if (paramsMap.isEmpty()) {
paramsMap = null;
}
}
Map<String, Object> result = invoke(info.service, info.port, info.operationName, paramsMap);
if(result==null || result.isEmpty()) return null;
return MapConverter.deepMapToMap(result, true);
}
private void flat(List<String> paths, List<WSDLMetadataUtils.ParameterInfo> inputParameters, String path) {
if(inputParameters==null || inputParameters.isEmpty()) {
if(path!=null) {
paths.add(path);
}
return;
}
for(WSDLMetadataUtils.ParameterInfo info : inputParameters) {
flat(paths, info.childParameters, path!=null? path + "." + info.name : info.name);
}
}
protected String getClassNameForType(QName xmlSchemaTypeMapperQname) {
StringBuilder sb = new StringBuilder();
sb.append(getPackageForNamespaceURI(xmlSchemaTypeMapperQname.getNamespaceURI()));

View File

@@ -0,0 +1,640 @@
package org.talend.webservice.helper;
import org.apache.ws.commons.schema.*;
import org.w3c.dom.Element;
import javax.wsdl.*;
import javax.wsdl.extensions.ExtensibilityElement;
import javax.wsdl.extensions.UnknownExtensibilityElement;
import javax.wsdl.extensions.soap.SOAPBinding;
import javax.wsdl.extensions.soap.SOAPBody;
import javax.wsdl.extensions.soap.SOAPOperation;
import javax.wsdl.extensions.soap12.SOAP12Binding;
import javax.wsdl.extensions.soap12.SOAP12Body;
import javax.wsdl.extensions.soap12.SOAP12Operation;
import javax.wsdl.factory.WSDLFactory;
import javax.xml.namespace.QName;
import java.io.File;
import java.net.URL;
import java.util.*;
public class WSDLMetadataUtils {
WSDLFactory wsdlFactory = null;
private Vector<XmlSchema> wsdlTypes = new Vector<XmlSchema>();
private List<String> parametersName = new ArrayList<String>();
private List<String> schemaNames = new ArrayList<String>();
private List<String> documentBaseList = new ArrayList<String>();
private List<XmlSchemaElement> allXmlSchemaElement = new ArrayList<XmlSchemaElement>();
private List<XmlSchemaType> allXmlSchemaType = new ArrayList<XmlSchemaType>();
public final static String DEFAULT_SOAP_ENCODING_STYLE = "http://schemas.xmlsoap.org/soap/encoding/";
public WSDLMetadataUtils() throws WSDLException {
wsdlFactory = WSDLFactory.newInstance();
}
public static class OperationInfo {
QName port;
QName service;
String operationName;
List<ParameterInfo> inputParameters = new ArrayList<ParameterInfo>();
List<ParameterInfo> outputParameter = new ArrayList<ParameterInfo>();
}
public class ParameterInfo {
String name;
/* list of parameters, only filled if complex type */
List<ParameterInfo> childParameters = new ArrayList<ParameterInfo>();
}
//not thread safe
private List<OperationInfo> operations;
private String targetOperationName;
private String currentPort;
private QName currentService;
public OperationInfo parseOperationInfo(ServiceDiscoveryHelper sdh, String port, String operationName) throws Exception {
this.targetOperationName = operationName;
Collection<Definition> defs = sdh.getDefinitions();
wsdlTypes = createSchemaFromTypes(defs);
collectAllXmlSchemaElement();
collectAllXmlSchemaType();
//only fetch services from main wsdl/definition, others for elements and type definition
Map services = defs.iterator().next().getServices();
if (services != null) {
Iterator iter = services.values().iterator();
while (iter.hasNext()) {
List<OperationInfo> operations = getOperations((Service) iter.next());
for(OperationInfo info : operations) {
if(port==null) {
return info;
}
if(port.equals(info.port.getLocalPart())) {
return info;
}
}
}
}
throw new RuntimeException("can't find the operation : " + operationName + " with port : " + port);
}
private void collectAllXmlSchemaElement() {
for (int i = 0; i < wsdlTypes.size(); i++) {
XmlSchema xmlSchema = (wsdlTypes.elementAt(i));
if (xmlSchema == null) {
continue;
}
Map<QName, XmlSchemaElement> elements = xmlSchema.getElements();
Iterator elementsItr = elements.values().iterator();
while (elementsItr.hasNext()) {
XmlSchemaElement xmlSchemaElement = (XmlSchemaElement) elementsItr.next();
allXmlSchemaElement.add(xmlSchemaElement);
}
}
}
private void collectAllXmlSchemaType() {
for (int i = 0; i < wsdlTypes.size(); i++) {
XmlSchema xmlSchema = (wsdlTypes.elementAt(i));
if (xmlSchema == null) {
continue;
}
Map<QName, XmlSchemaType> xmlSchemaObjectTable = xmlSchema.getSchemaTypes();
Iterator typesItr = xmlSchemaObjectTable.values().iterator();
while (typesItr.hasNext()) {
XmlSchemaType xmlSchemaType = (XmlSchemaType) typesItr.next();
allXmlSchemaType.add(xmlSchemaType);
}
}
}
protected Vector<XmlSchema> createSchemaFromTypes(Collection<Definition> wsdlDefinitions) throws WSDLException {
Vector<XmlSchema> schemas = new Vector<XmlSchema>();
Set<String> imports = new HashSet<String>();
Element schemaElementt = null;
Map importElement = null;
List includeElement = null;
for (Definition def : wsdlDefinitions) {
if (def.getTypes() != null) {
List schemaExtElem = findExtensibilityElement(def.getTypes().getExtensibilityElements(), "schema");
for (int i = 0; i < schemaExtElem.size(); i++) {
ExtensibilityElement schemaElement = (ExtensibilityElement) schemaExtElem.get(i);
if (schemaElement != null && schemaElement instanceof UnknownExtensibilityElement) {
schemaElementt = ((UnknownExtensibilityElement) schemaElement).getElement();
String documentBase = ((javax.wsdl.extensions.schema.Schema) schemaElement).getDocumentBaseURI();
XmlSchema schema = createschemafromtype(schemaElementt, def, documentBase);
if (schema != null) {
schemas.add(schema);
if (schema.getTargetNamespace() != null) {
schemaNames.add(schema.getTargetNamespace());
}
}
importElement = ((javax.wsdl.extensions.schema.Schema) schemaElement).getImports();
if (importElement != null && importElement.size() > 0) {
findImportSchema(def, schemas, importElement, imports);
}
}
if (schemaElement != null && schemaElement instanceof javax.wsdl.extensions.schema.Schema) {
schemaElementt = ((javax.wsdl.extensions.schema.Schema) schemaElement).getElement();
String documentBase = ((javax.wsdl.extensions.schema.Schema) schemaElement).getDocumentBaseURI();
Boolean isHaveImport = false;
importElement = ((javax.wsdl.extensions.schema.Schema) schemaElement).getImports();
if (importElement != null && importElement.size() > 0) {
Iterator keyIterator = importElement.keySet().iterator();
if (importElement.size() > 0) {
isHaveImport = true;
}
}
XmlSchema schema = createschemafromtype(schemaElementt, def, documentBase);
if (schema != null) {
schemas.add(schema);
if (schema.getTargetNamespace() != null) {
schemaNames.add(schema.getTargetNamespace());
}
}
if (isHaveImport) {
findImportSchema(def, schemas, importElement, imports);
}
}
}
}
}
return schemas;
}
private void findIncludesSchema(Definition wsdlDefinition, Vector schemas, List includeElement) throws WSDLException {
Element schemaElementt;
for (int i = 0; i < includeElement.size(); i++) {
schemaElementt = ((com.ibm.wsdl.extensions.schema.SchemaReferenceImpl) includeElement.get(i)).getReferencedSchema()
.getElement();
String documentBase = ((com.ibm.wsdl.extensions.schema.SchemaReferenceImpl) includeElement.get(i))
.getReferencedSchema().getDocumentBaseURI();
XmlSchema schemaInclude = createschemafromtype(schemaElementt, wsdlDefinition, documentBase);
if (schemaInclude != null) {
schemas.add(schemaInclude);
if (schemaInclude.getTargetNamespace() != null) {
schemaNames.add(schemaInclude.getTargetNamespace());
}
}
}
}
private void findImportSchema(Definition wsdlDefinition, Vector schemas, Map importElement, Set<String> imports)
throws WSDLException {
Element schemaElementt;
List includeElement = null;
Iterator keyIterator = importElement.keySet().iterator();
Boolean isHaveImport = false;
while (keyIterator.hasNext()) {
Object object = keyIterator.next();
if (object != null) {
String key = object.toString();
Vector importEle = (Vector) importElement.get(key);
for (int i = 0; i < importEle.size(); i++) {
Map importChildElement = null;
com.ibm.wsdl.extensions.schema.SchemaImportImpl importImpl = (com.ibm.wsdl.extensions.schema.SchemaImportImpl) importEle
.elementAt(i);
// to avoid import cycle
String importLocation = importImpl.getSchemaLocationURI() + ":" + importImpl.getNamespaceURI();
if (imports.contains(importLocation)) {
continue;
} else {
imports.add(importLocation);
}
if (importImpl.getReferencedSchema() != null) {
schemaElementt = importImpl.getReferencedSchema().getElement();
String documentBase = importImpl.getReferencedSchema().getDocumentBaseURI();
if ((com.ibm.wsdl.extensions.schema.SchemaImportImpl) importEle.elementAt(i) != null) {
if (((com.ibm.wsdl.extensions.schema.SchemaImportImpl) importEle.elementAt(i)).getReferencedSchema() != null) {
importChildElement = ((com.ibm.wsdl.extensions.schema.SchemaImportImpl) importEle.elementAt(i))
.getReferencedSchema().getImports();
if (importChildElement != null && importChildElement.size() > 0 && !isIncludeSchema(documentBase)) {
isHaveImport = true;
documentBaseList.add(documentBase);
// validateImportUrlPath(importElement);
}
}
}
XmlSchema schemaImport = createschemafromtype(schemaElementt, wsdlDefinition, documentBase);
if (schemaImport != null) {
schemas.add(schemaImport);
if (schemaImport.getTargetNamespace() != null) {
schemaNames.add(schemaImport.getTargetNamespace());
}
}
}
if (isHaveImport) {
findImportSchema(wsdlDefinition, schemas, importChildElement, imports);
}
if ((com.ibm.wsdl.extensions.schema.SchemaImportImpl) importEle.elementAt(i) != null) {
if (((com.ibm.wsdl.extensions.schema.SchemaImportImpl) importEle.elementAt(i)).getReferencedSchema() != null) {
includeElement = ((com.ibm.wsdl.extensions.schema.SchemaImportImpl) importEle.elementAt(i))
.getReferencedSchema().getIncludes();
if (includeElement != null && includeElement.size() > 0) {
findIncludesSchema(wsdlDefinition, schemas, includeElement);
}
}
}
}
}
}
}
private List findExtensibilityElement(List extensibilityElements, String elementType) {
List elements = new ArrayList();
if (extensibilityElements != null) {
Iterator iter = extensibilityElements.iterator();
while (iter.hasNext()) {
ExtensibilityElement element = (ExtensibilityElement) iter.next();
if (element.getElementType().getLocalPart().equalsIgnoreCase(elementType)) {
elements.add(element);
}
}
}
return elements;
}
private XmlSchema createschemafromtype(Element schemaElement, Definition wsdlDefinition, String documentBase)
throws WSDLException {
if (schemaElement == null) {
throw new WSDLException(WSDLException.INVALID_WSDL, "Unable to find schema extensibility element in WSDL");
}
XmlSchema xmlSchema = null;
XmlSchemaCollection xmlSchemaCollection = new XmlSchemaCollection();
xmlSchemaCollection.setBaseUri(fixDocumentBase(documentBase));
xmlSchema = xmlSchemaCollection.read(schemaElement);
return xmlSchema;
}
private String fixDocumentBase(String documentBase) {
String fixedPath = documentBase;
try {
URL url = new URL(documentBase);
File file = new File(url.getFile());
fixedPath = file.toURI().toString();
} catch (Exception e) {
fixedPath = documentBase;
}
return fixedPath;
}
private Boolean isIncludeSchema(String documentBase) {
Boolean isHaveSchema = false;
for (int i = 0; i < documentBaseList.size(); i++) {
String documentBaseTem = documentBaseList.get(i);
if (documentBaseTem.equals(documentBase)) {
isHaveSchema = true;
}
}
return isHaveSchema;
}
private List<OperationInfo> getOperations(Service service) {
currentService = service.getQName();
List<OperationInfo> result = new ArrayList<>();
Map ports = service.getPorts();
Iterator portIter = ports.values().iterator();
while (portIter.hasNext()) {
Port port = (Port) portIter.next();
Binding binding = port.getBinding();
currentPort = port.getName();
result.addAll(buildOperations(binding));
}
return result;
}
private List<OperationInfo> buildOperations(Binding binding) {
List<OperationInfo> result = new ArrayList<>();
List operations = binding.getBindingOperations();
if (operations != null && !operations.isEmpty()) {
List soapBindingElems = findExtensibilityElement(binding.getExtensibilityElements(), "binding");
String style = "document"; // default
ExtensibilityElement soapBindingElem = (ExtensibilityElement) soapBindingElems.get(0);
if (soapBindingElem != null && soapBindingElem instanceof SOAPBinding) {
SOAPBinding soapBinding = (SOAPBinding) soapBindingElem;
style = soapBinding.getStyle();
} else if (soapBindingElem != null && soapBindingElem instanceof SOAP12Binding) {
SOAP12Binding soapBinding = (SOAP12Binding) soapBindingElem;
style = soapBinding.getStyle();
}
Iterator opIter = operations.iterator();
while (opIter.hasNext()) {
BindingOperation oper = (BindingOperation) opIter.next();
List operElems = findExtensibilityElement(oper.getExtensibilityElements(), "operation");
ExtensibilityElement operElem = (ExtensibilityElement) operElems.get(0);
if(!targetOperationName.equals(oper.getName())) {
continue;
}
OperationInfo operationInfo = new OperationInfo();
operationInfo.service = currentService;
operationInfo.port = new QName(currentService.getNamespaceURI(), currentPort);
operationInfo.operationName = oper.getName();
//TODO do different?
if (operElem != null && operElem instanceof SOAPOperation) {
buildOperation(operationInfo, oper);
} else if (operElem != null && operElem instanceof SOAP12Operation) {
buildOperation(operationInfo, oper);
}
result.add(operationInfo);
}
}
return result;
}
private void buildOperation(OperationInfo operationInfo, BindingOperation bindingOper) {
Operation oper = bindingOper.getOperation();
List operElems = findExtensibilityElement(bindingOper.getExtensibilityElements(), "operation");
ExtensibilityElement operElem = (ExtensibilityElement) operElems.get(0);
if (operElem != null && operElem instanceof SOAPOperation) {//TODO do different?
SOAPOperation soapOperation = (SOAPOperation) operElem;
} else if (operElem != null && operElem instanceof SOAP12Operation) {
SOAP12Operation soapOperation = (SOAP12Operation) operElem;
}
BindingInput bindingInput = bindingOper.getBindingInput();
BindingOutput bindingOutput = bindingOper.getBindingOutput();
List bodyElems = findExtensibilityElement(bindingInput.getExtensibilityElements(), "body");
ExtensibilityElement bodyElem = (ExtensibilityElement) bodyElems.get(0);
if (bodyElem != null && bodyElem instanceof SOAPBody) {
SOAPBody soapBody = (SOAPBody) bodyElem;
List styles = soapBody.getEncodingStyles();
String encodingStyle = null;
if (styles != null) {
encodingStyle = styles.get(0).toString();
}
if (encodingStyle == null) {
encodingStyle = DEFAULT_SOAP_ENCODING_STYLE;
}
//TODO get namespace uri here?
//soapBody.getNamespaceURI();
} else if (bodyElem != null && bodyElem instanceof SOAP12Body) {
SOAP12Body soapBody = (SOAP12Body) bodyElem;
String encodingStyle = null;
if (soapBody.getEncodingStyle() != null) {
encodingStyle = soapBody.getEncodingStyle().toString();
}
if (encodingStyle == null) {
encodingStyle = DEFAULT_SOAP_ENCODING_STYLE;
}
//TODO get namespace uri here?
//soapBody.getNamespaceURI();
}
Input inDef = oper.getInput();
if (inDef != null) {
Message inMsg = inDef.getMessage();
if (inMsg != null) {
getParameterFromMessage(operationInfo, inMsg, 1);
}
}
//don't need output parameter struct now
/*
Output outDef = oper.getOutput();
if (outDef != null) {
Message outMsg = outDef.getMessage();
if (outMsg != null) {
getParameterFromMessage(operationInfo, outMsg, 2);
}
}
*/
}
private void getParameterFromMessage(OperationInfo operationInfo, Message msg, int manner) {
List msgParts = msg.getOrderedParts(null);
Iterator iter = msgParts.iterator();
while (iter.hasNext()) {
Part part = (Part) iter.next();
String partName = part.getName();
String partElement = null;
String namespace = null;
if (part.getElementName() != null) {
partElement = part.getElementName().getLocalPart();
namespace = part.getElementName().getNamespaceURI();
} else if (part.getTypeName() != null) {
partElement = part.getTypeName().getLocalPart();
namespace = part.getTypeName().getNamespaceURI();
}
// add root parameter from message.
ParameterInfo parameterRoot = new ParameterInfo();
parameterRoot.name = partName;
if (manner == 1) {
operationInfo.inputParameters.add(parameterRoot);
} else {
operationInfo.outputParameter.add(parameterRoot);
}
if (allXmlSchemaElement.size() > 0) {
buildParameterFromElements(partElement, parameterRoot, manner);
} else if (allXmlSchemaType.size() > 0) {
buileParameterFromTypes(namespace, partElement, parameterRoot, manner);
}
}
}
private void buildParameterFromElements(String partElement, ParameterInfo parameterRoot, int ioOrRecursion) {
if (ioOrRecursion < 3) {
parametersName.clear();
parametersName.add(parameterRoot.name);
} else if (ioOrRecursion == 3) {
parametersName.add(parameterRoot.name);
}
Iterator elementsItr = allXmlSchemaElement.iterator();
if (partElement != null) {
while (elementsItr.hasNext()) {
XmlSchemaElement xmlSchemaElement = (XmlSchemaElement) elementsItr.next();
if (partElement.equals(xmlSchemaElement.getName())) {
if (xmlSchemaElement.getSchemaType() != null) {
if (xmlSchemaElement.getSchemaType() instanceof XmlSchemaComplexType) {
XmlSchemaComplexType xmlElementComplexType = (XmlSchemaComplexType) xmlSchemaElement.getSchemaType();
XmlSchemaParticle xmlSchemaParticle = xmlElementComplexType.getParticle();
if (xmlSchemaParticle instanceof XmlSchemaGroupParticle) {
XmlSchemaGroupParticle xmlSchemaGroupBase = (XmlSchemaGroupParticle) xmlSchemaParticle;
if (xmlSchemaGroupBase != null) {
buildParameterFromCollection(xmlSchemaGroupBase, parameterRoot, ioOrRecursion);
}
} else if (xmlSchemaElement.getSchemaTypeName() != null) {
String paraTypeName = xmlSchemaElement.getSchemaTypeName().getLocalPart();
String paraTypeNamespace = xmlSchemaElement.getSchemaTypeName().getNamespaceURI();
if (paraTypeName != null) {
buileParameterFromTypes(paraTypeNamespace, paraTypeName, parameterRoot, ioOrRecursion);
}
}
} else if (xmlSchemaElement.getSchemaType() instanceof XmlSchemaSimpleType) {
XmlSchemaSimpleType xmlSchemaSimpleType = (XmlSchemaSimpleType) xmlSchemaElement.getSchemaType();
String typeName = xmlSchemaSimpleType.getName();
if (typeName != null && typeName.equals("anyType")) {
ParameterInfo parameterSon = new ParameterInfo();
parameterSon.name = "anyType";
parameterRoot.childParameters.add(parameterSon);
}
}
} else if (xmlSchemaElement.getSchemaTypeName() != null) {
String paraTypeName = xmlSchemaElement.getSchemaTypeName().getLocalPart();
String paraTypeNamespace = xmlSchemaElement.getSchemaTypeName().getNamespaceURI();
if (paraTypeName != null) {
buileParameterFromTypes(paraTypeNamespace, paraTypeName, parameterRoot, ioOrRecursion);
}
}
}
}
}
}
private void buileParameterFromTypes(String paraNamespace, String paraType, ParameterInfo parameter, int ioOrRecursion) {
if (ioOrRecursion < 3) {
parametersName.clear();
parametersName.add(parameter.name);
} else if (ioOrRecursion == 3) {
parametersName.add(parameter.name);
}
//twebserviceinput need auto metadata fetch for input parameters, but it only support very easy, not support custom defined type usage like this:
//<element type="tns="s:anyCustomDefinedSimpleOrComplexType"">
//so nothing to do here, TODO make sure it
}
private void buildParameterFromCollection(XmlSchemaGroupParticle xmlSchemaGroupParticle, ParameterInfo parameter,
int ioOrRecursion) {
if (!(xmlSchemaGroupParticle instanceof XmlSchemaSequence)) {
throw new RuntimeException("don't support that complex parameter type, only support xsd:sequence");
}
XmlSchemaSequence xmlSchemaSequence = (XmlSchemaSequence) xmlSchemaGroupParticle;
List<XmlSchemaSequenceMember> sequences = xmlSchemaSequence.getItems();
for (XmlSchemaSequenceMember sequence : sequences) {
if (sequence instanceof XmlSchemaAny) {//TODO remove it as not support too
ParameterInfo parameterSon = new ParameterInfo();
parameterSon.name = "_content_";
parameter.childParameters.add(parameterSon);
} else if (sequence instanceof XmlSchemaElement) {//this is the major part we support
XmlSchemaElement xmlSchemaElement = (XmlSchemaElement) sequence;
String elementName = xmlSchemaElement.getName();
ParameterInfo parameterSon = new ParameterInfo();
parameterSon.name= elementName;
parameter.childParameters.add(parameterSon);
Boolean isHave = false;
if (!parametersName.isEmpty() && parameterSon.name != null) {
for (int p = 0; p < parametersName.size(); p++) {
if (parameterSon.name.equals(parametersName.get(p))) {
isHave = true;
}
}
}
if (xmlSchemaElement.getSchemaTypeName() != null) {
String elementTypeName = xmlSchemaElement.getSchemaTypeName().getLocalPart();
String elementTypeNamespace = xmlSchemaElement.getSchemaTypeName().getNamespaceURI();
if (elementTypeName != null && elementTypeName.equals("anyType")) {//TODO remove it
parameterSon.name = xmlSchemaElement.getName() + ":anyType";
}
if (!isHave && !WsdlTypeUtil.isJavaBasicType(elementTypeName)) {
buileParameterFromTypes(elementTypeNamespace, elementTypeName, parameterSon, ioOrRecursion);
}
} else if (xmlSchemaElement.getSchemaType() != null) {
if (xmlSchemaElement.getSchemaType() instanceof XmlSchemaComplexType) {
throw new RuntimeException("don't support nested or ref complex type in xsd:sequence");
} else if (xmlSchemaElement.getSchemaType() instanceof XmlSchemaSimpleType) {
XmlSchemaSimpleType xmlSchemaSimpleType = (XmlSchemaSimpleType) xmlSchemaElement.getSchemaType();
String typeName = xmlSchemaSimpleType.getName();
if (typeName != null && typeName.equals("anyType")) {
ParameterInfo pSon = new ParameterInfo();
pSon.name = "anyType";
parameter.childParameters.add(pSon);
}
}
} else if (xmlSchemaElement.getRef() != null) {//TODO twebserviceinput support it before?
String elementTypeName = xmlSchemaElement.getRef().getTargetQName().getLocalPart();
if (!isHave && !WsdlTypeUtil.isJavaBasicType(elementTypeName)) {
buildParameterFromElements(elementTypeName, parameterSon, ioOrRecursion);
}
}
} else if (sequence instanceof XmlSchemaAttribute) {
XmlSchemaAttribute xmlSchemaAttribute = (XmlSchemaAttribute) sequence;
String elementName = xmlSchemaAttribute.getName();
ParameterInfo parameterSon = new ParameterInfo();
parameterSon.name = elementName;
parameter.childParameters.add(parameterSon);
Boolean isHave = false;
if (!parametersName.isEmpty() && parameterSon.name != null) {
for (int p = 0; p < parametersName.size(); p++) {
if (parameterSon.name.equals(parametersName.get(p))) {
isHave = true;
}
}
}
if (xmlSchemaAttribute.getSchemaTypeName() != null) {
String elementTypeName = xmlSchemaAttribute.getSchemaTypeName().getLocalPart();
String elementTypeNamespace = xmlSchemaAttribute.getSchemaTypeName().getNamespaceURI();
if (!isHave && !WsdlTypeUtil.isJavaBasicType(elementTypeName)) {
buileParameterFromTypes(elementTypeNamespace, elementTypeName, parameterSon, ioOrRecursion);
}
} else if (xmlSchemaAttribute.getRef() != null) {//TODO twebserviceinput support it before?
String refName = xmlSchemaAttribute.getRef().getTargetQName().getLocalPart();
if (!isHave) {
buildParameterFromElements(refName, parameterSon, ioOrRecursion);
}
}
} else {
throw new RuntimeException("don't support the nest type in xsd:sequence");
}
}
}
}

View File

@@ -0,0 +1,39 @@
// ============================================================================
//
// Copyright (C) 2006-2021 Talend Inc. - www.talend.com
//
// This source code is available under agreement available at
// %InstallDIR%\features\org.talend.rcp.branding.%PRODUCTNAME%\%PRODUCTNAME%license.txt
//
// You should have received a copy of the agreement
// along with this program; if not, write to Talend SA
// 9 rue Pages 92150 Suresnes, France
//
// ============================================================================
package org.talend.webservice.helper;
public class WsdlTypeUtil {
public static Boolean isJavaBasicType(String typeName) {
Boolean isJavaBasicType = false;
if (typeName == null) {
return false;
}
if ("String".equalsIgnoreCase(typeName)) {
isJavaBasicType = true;
} else if ("int".equalsIgnoreCase(typeName)) {
isJavaBasicType = true;
} else if ("long".equalsIgnoreCase(typeName)) {
isJavaBasicType = true;
} else if ("double".equalsIgnoreCase(typeName)) {
isJavaBasicType = true;
} else if ("float".equalsIgnoreCase(typeName)) {
isJavaBasicType = true;
} else if ("char".equalsIgnoreCase(typeName)) {
isJavaBasicType = true;
}
return isJavaBasicType;
}
}

View File

@@ -15,12 +15,17 @@ import java.util.logging.Logger;
import javax.wsdl.xml.WSDLLocator;
import org.apache.commons.httpclient.Credentials;
import org.apache.commons.httpclient.HostConfiguration;
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.UsernamePasswordCredentials;
import org.apache.commons.httpclient.auth.AuthScope;
import org.apache.commons.httpclient.methods.GetMethod;
import org.apache.http.HttpHost;
import org.apache.http.HttpResponse;
import org.apache.http.auth.AuthScope;
import org.apache.http.auth.UsernamePasswordCredentials;
import org.apache.http.client.CredentialsProvider;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpRequestBase;
import org.apache.http.impl.client.BasicCredentialsProvider;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.impl.client.HttpClients;
import org.xml.sax.InputSource;
/**
@@ -49,10 +54,10 @@ public class WSDLLocatorImpl implements WSDLLocator {
}
public InputSource getBaseInputSource() {
GetMethod get = createGetMethod(wsdlUri);
HttpRequestBase get = createGetMethod(wsdlUri);
try {
httpClient.executeMethod(get);
InputStream is = get.getResponseBodyAsStream();
HttpResponse response = httpClient.execute(get);
InputStream is = response.getEntity().getContent();
inputStreams.add(is);
return new InputSource(is);
} catch (IOException ex) {
@@ -64,9 +69,9 @@ public class WSDLLocatorImpl implements WSDLLocator {
try {
URL url = getURL(parentLocation, importLocation);
latestImportUri = url.toExternalForm();
GetMethod get = createGetMethod(latestImportUri);
httpClient.executeMethod(get);
InputStream is = get.getResponseBodyAsStream();
HttpRequestBase get = createGetMethod(latestImportUri);
HttpResponse response = httpClient.execute(get);
InputStream is = response.getEntity().getContent();
inputStreams.add(is);
return new InputSource(is);
} catch (MalformedURLException ex) {
@@ -110,36 +115,44 @@ public class WSDLLocatorImpl implements WSDLLocator {
inputStreams.clear();
}
private GetMethod createGetMethod(String uri) {
GetMethod get = new GetMethod(uri);
private HttpRequestBase createGetMethod(String uri) {
HttpGet get = new HttpGet(uri);
if (configuration.getCookie() != null) {
get.setRequestHeader(HTTP_HEADER_COOKIE, configuration.getCookie());
get.setHeader(HTTP_HEADER_COOKIE, configuration.getCookie());
}
return get;
}
private HttpClient createHttpClient() {
HttpClient httpClient = new HttpClient();
HttpClientBuilder builder = HttpClients.custom();
CredentialsProvider credentialsProvider = null;
if (configuration.getProxyServer() != null) {
HostConfiguration hostConfiguration = new HostConfiguration();
hostConfiguration.setProxy(configuration.getProxyServer(), configuration.getProxyPort());
httpClient.setHostConfiguration(hostConfiguration);
builder.setProxy(new HttpHost(configuration.getProxyServer(), configuration.getProxyPort()));
}
if (configuration.getUsername() != null) {
Credentials credentials = new UsernamePasswordCredentials(configuration.getUsername(), configuration.getPassword());
httpClient.getState().setCredentials(AuthScope.ANY, credentials);
if (credentialsProvider == null) {
credentialsProvider = new BasicCredentialsProvider();
}
credentialsProvider
.setCredentials(AuthScope.ANY,
new UsernamePasswordCredentials(configuration.getUsername(), configuration.getPassword()));
}
if (configuration.getProxyUsername() != null) {
Credentials credentials = new UsernamePasswordCredentials(configuration.getProxyUsername(),
configuration.getProxyPassword());
httpClient.getState().setProxyCredentials(AuthScope.ANY, credentials);
httpClient.getHostConfiguration().setProxy(configuration.getProxyServer(), configuration.getProxyPort());
if (credentialsProvider == null) {
credentialsProvider = new BasicCredentialsProvider();
}
credentialsProvider
.setCredentials(new AuthScope(configuration.getProxyServer(), configuration.getProxyPort()),
new UsernamePasswordCredentials(configuration.getProxyUsername(),
configuration.getProxyPassword()));
builder.setProxy(new HttpHost(configuration.getProxyServer(), configuration.getProxyPort()));
}
return httpClient;
if (credentialsProvider != null) {
builder.setDefaultCredentialsProvider(credentialsProvider);
}
return builder.build();
}
}

View File

@@ -4,15 +4,13 @@
*/
package org.talend.webservice.helper.map;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.*;
import javax.xml.namespace.QName;
import org.talend.webservice.helper.PathUtil;
import org.talend.webservice.mapper.AnyTypeMapper;
import sun.awt.image.ImageWatched;
/**
*
@@ -24,35 +22,44 @@ public class MapConverter {
public static final String LEFT_SQUARE_BRACKET = "[";
public static final String RIGHT_SQUARE_BRACKET = "]";
private static Map<String, Object> newMap(boolean keepOrder) {
if(keepOrder) return new LinkedHashMap<>();
return new HashMap<>();
}
public static Map<String, Object> deepMapToMap(Map<String, Object> map) {
return deepMapToMap(map, null, SEPARATOR);
return deepMapToMap(map, null, SEPARATOR, false);
}
public static Map<String, Object> deepMapToMap(Map<String, Object> map, boolean keepOrder) {
return deepMapToMap(map, null, SEPARATOR, keepOrder);
}
public static Map<String, Object> mapToDeepMap(Map<String, Object> map) {
return mapToDeepMap(map, SEPARATOR);
}
private static Map<String, Object> deepMapToMap(Object value, String k, String sep) {
private static Map<String, Object> deepMapToMap(Object value, String k, String sep, boolean keepOrder) {
if (value instanceof Map) {
Map<String, Object> map = (Map<String, Object>) value;
Map<String, Object> out = new HashMap<String, Object>();
Map<String, Object> out = newMap(keepOrder);
for (Map.Entry<String, Object> entry : map.entrySet()) {
if (k == null) {
out.putAll(deepMapToMap(entry.getValue(), entry.getKey(), sep));
out.putAll(deepMapToMap(entry.getValue(), entry.getKey(), sep, keepOrder));
} else {
out.putAll(deepMapToMap(entry.getValue(), k + sep + entry.
getKey(), sep));
getKey(), sep, keepOrder));
}
}
return out;
} else if (value instanceof List) {
List<Object> list = (List<Object>) value;
Map<String, Object> out = new HashMap<String, Object>();
Map<String, Object> out = newMap(keepOrder);
int i = 0;
for (Object val : list) {
StringBuffer sb = new StringBuffer();
sb.append(k).append(LEFT_SQUARE_BRACKET).append(i).append(RIGHT_SQUARE_BRACKET);
out.putAll(deepMapToMap(val, sb.toString(), sep));
out.putAll(deepMapToMap(val, sb.toString(), sep, keepOrder));
i++;
}
out.put(k + ".size", list.size());

View File

@@ -42,14 +42,18 @@ import javax.xml.transform.Result;
import javax.xml.transform.dom.DOMResult;
import javax.xml.transform.stream.StreamResult;
import org.apache.cxf.Bus;
import org.apache.cxf.BusFactory;
import org.apache.cxf.common.jaxb.JAXBBeanInfo;
import org.apache.cxf.common.jaxb.JAXBContextProxy;
import org.apache.cxf.common.logging.LogUtils;
import org.apache.cxf.common.spi.ClassGeneratorClassLoader;
import org.apache.cxf.common.util.ASMHelper;
import org.apache.cxf.common.util.ASMHelper.ClassWriter;
import org.apache.cxf.common.util.ASMHelper.FieldVisitor;
import org.apache.cxf.common.util.ASMHelper.Label;
import org.apache.cxf.common.util.ASMHelper.MethodVisitor;
import org.apache.cxf.common.util.ASMHelperImpl;
import org.apache.cxf.common.util.CachedClass;
import org.apache.cxf.common.util.PackageUtils;
import org.apache.cxf.common.util.ReflectionInvokationHandler;
@@ -578,7 +582,7 @@ public final class JAXBUtils {
public static void setNamespaceWrapper(final Map<String, String> nspref, Marshaller marshaller) throws PropertyException {
Object mapper = null;
if (marshaller.getClass().getName().contains(".internal.")) {
mapper = createNamespaceWrapper(nspref);
mapper = createNamespaceWrapper(null, nspref);
if (mapper == null) {
LOG.log(Level.INFO, "Could not create namespace mapper for JDK internal" + " JAXB implementation.");
} else {
@@ -595,6 +599,31 @@ public final class JAXBUtils {
}
}
/*
* To avoid possible runtime collision.
*/
public static Object setNamespaceMapper(Bus bus, final Map<String, String> nspref,
Marshaller marshaller) throws PropertyException {
Object mapper = null;
if (marshaller.getClass().getName().contains(".internal.")) {
mapper = createNamespaceWrapper(bus, nspref);
if (mapper == null) {
LOG.log(Level.INFO, "Could not create namespace mapper for JDK internal" + " JAXB implementation.");
} else {
marshaller.setProperty("com.sun.xml.internal.bind.namespacePrefixMapper", mapper);
}
} else {
try {
Class<?> cls = Class.forName("org.apache.cxf.common.jaxb.NamespaceMapper");
mapper = cls.getConstructor(Map.class).newInstance(nspref);
} catch (Exception ex) {
LOG.log(Level.INFO, "Could not create NamespaceMapper", ex);
}
marshaller.setProperty("com.sun.xml.bind.namespacePrefixMapper", mapper);
}
return mapper;
}
public static BridgeWrapper createBridge(Set<Class<?>> ctxClasses, QName qname, Class<?> refcls, Annotation anns[])
throws JAXBException {
try {
@@ -1018,16 +1047,17 @@ public final class JAXBUtils {
return false;
}
private static synchronized Object createNamespaceWrapper(Map<String, String> map) {
ASMHelper helper = new ASMHelper();
private static synchronized Object createNamespaceWrapper(Bus bus, Map<String, String> map) {
ASMHelper helper = new ASMHelperImpl();
String className = "org.apache.cxf.jaxb.NamespaceMapperInternal";
Class<?> cls = helper.findClass(className, JAXBUtils.class);
NamespaceMapperClassGenerator nmcg = new NamespaceMapperClassGenerator(bus);
Class<?> cls = nmcg.findClass(className, JAXBUtils.class);
if (cls == null) {
ClassWriter cw = helper.createClassWriter();
if (cw == null) {
return null;
}
cls = createNamespaceWrapperInternal(helper, cw);
cls = createNamespaceWrapperInternal(helper, cw, nmcg);
}
try {
return cls.getConstructor(Map.class).newInstance(map);
@@ -1036,7 +1066,7 @@ public final class JAXBUtils {
}
}
private static Class<?> createNamespaceWrapperInternal(ASMHelper helper, ClassWriter cw) {
private static Class<?> createNamespaceWrapperInternal(ASMHelper helper, ClassWriter cw, NamespaceMapperClassGenerator nmcg) {
String className = "org.apache.cxf.jaxb.NamespaceMapperInternal";
FieldVisitor fv;
MethodVisitor mv;
@@ -1127,7 +1157,7 @@ public final class JAXBUtils {
}
}
return helper.loadClass(className, cls, bts);
return nmcg.loadClass(className, cls, bts);
}
public static JAXBBeanInfo getBeanInfo(JAXBContextProxy context, Class<?> cls) {
@@ -1138,4 +1168,20 @@ public final class JAXBUtils {
return ReflectionInvokationHandler.createProxyWrapper(o, JAXBBeanInfo.class);
}
private static class NamespaceMapperClassGenerator extends ClassGeneratorClassLoader {
private NamespaceMapperClassGenerator(Bus bus) {
super(bus == null ? BusFactory.getDefaultBus() : bus);
}
@Override
protected Class<?> findClass(String className, Class<?> cls) {
return super.findClass(className, cls);
}
@Override
protected Class<?> loadClass(String className, Class<?> cls, byte[] bytes) {
return super.loadClass(className, cls, bytes);
}
}
}

View File

@@ -3,13 +3,12 @@
*/
package org.talend.webservice.mapper;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.talend.webservice.exception.LocalizedException;
import javax.xml.namespace.QName;
import org.talend.webservice.exception.LocalizedException;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
/**
*
@@ -151,7 +150,7 @@ public class ComplexTypeMapper implements TypeMapper {
if (!clazz.getName().equals(beanName)) {
ComplexTypeMapper instanceComplexTypeMapper = findInstanceByClassName(beanName);
if (instanceComplexTypeMapper != null) {
Map<String, Object> values = new HashMap<String, Object>();
Map<String, Object> values = new LinkedHashMap<String, Object>();
values.put(ABSTRACT_TYPE_NAME, instanceComplexTypeMapper.typeName);
values.put(instanceComplexTypeMapper.typeName.getLocalPart(), instanceComplexTypeMapper.typeToValue(bean));
return values;
@@ -167,7 +166,7 @@ public class ComplexTypeMapper implements TypeMapper {
return null;
}
} else {
Map<String, Object> values = new HashMap<String, Object>(mappers.size());
Map<String, Object> values = new LinkedHashMap<String, Object>(mappers.size());
for (Map.Entry<String, PropertyMapper> entry : mappers.entrySet()) {
Object value = entry.getValue().getValueFrom(bean);
if (value != null) {
@@ -198,7 +197,7 @@ public class ComplexTypeMapper implements TypeMapper {
if (params == null) {
return null;
}
Map<String, Object> values = new HashMap<String, Object>(mappers.size());
Map<String, Object> values = new LinkedHashMap<String, Object>(mappers.size());
int i = 0;
for (Object param : params) {

View File

@@ -4,6 +4,7 @@
package org.talend.webservice.mapper;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
@@ -336,7 +337,8 @@ public class MapperFactory {
Class<?> clazz = classMapper.getClassForType(xmlSchemaComplexType.getQName(), orderedMap.keyList(), 1);
// 3.create propertyMapper (propertyName,class,schemaTypeMap,typeMapperQname)
Map<String, PropertyMapper> mappers = new HashMap<String, PropertyMapper>();
//need to use the order map as the order is important for response auto parser by index
Map<String, PropertyMapper> mappers = new LinkedHashMap<>();
for (String key : properties.keySet()) {
Object xmlSchemaObject = properties.get(key);
if (xmlSchemaObject == null) {

View File

@@ -5,6 +5,7 @@
package org.talend.webservice.mapper;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import javax.wsdl.Message;
@@ -152,7 +153,7 @@ public class MessageMapperImpl implements MessageMapper {
return wrappedValue;
} else {
List<Part> orderedParts = message.getOrderedParts(null);
Map<String, Object> values = new HashMap<String, Object>(params.length);
Map<String, Object> values = new LinkedHashMap<String, Object>(params.length);
int i = 0;
for (Object param : params) {
Part part = orderedParts.get(i);

View File

@@ -1,7 +0,0 @@
org.talend.ws.exception.IllegalPropertyAccessException=\u0391\u03B4\u03C5\u03BD\u03B1\u03BC\u03AF\u03B1 \u03C0\u03C1\u03CC\u03C3\u03B2\u03B1\u03C3\u03B7\u03C2 \u03C3\u03C4\u03B7\u03BD \u03B9\u03B4\u03B9\u03CC\u03C4\u03B7\u03C4\u03B1 {0} \u03C0\u03BF\u03C5 \u03B4\u03B5\u03BD \u03B5\u03AF\u03BD\u03B1\u03B9 \u03C0\u03C1\u03BF\u03C3\u03B2\u03AC\u03C3\u03B9\u03BC\u03B7 \u03B3\u03B9\u03B1 \u03C4\u03CD\u03C0\u03BF {1}
org.talend.ws.exception.NoSuchPropertyException=\u0397 \u03B9\u03B4\u03B9\u03CC\u03C4\u03B7\u03C4\u03B1 {0} \u03B4\u03B5\u03BD \u03C5\u03C0\u03AC\u03C1\u03C7\u03B5\u03B9 \u03B3\u03B9\u03B1 \u03C4\u03BF\u03BD \u03C4\u03CD\u03C0\u03BF {1}
org.talend.ws.exception.Instantiation=\u0391\u03B4\u03C5\u03BD\u03B1\u03BC\u03AF\u03B1 \u03BD\u03B1 \u03B4\u03BF\u03B8\u03B5\u03AF \u03C5\u03C0\u03CC\u03C3\u03C4\u03B1\u03C3\u03B7 \u03C3\u03B5 \u03BA\u03BB\u03AC\u03C3\u03B7 \u03C4\u03CD\u03C0\u03BF\u03C5 {0}
org.talend.ws.exception.illegalAccessValueOf=\u0391\u03B4\u03C5\u03BD\u03B1\u03BC\u03AF\u03B1 \u03BA\u03BB\u03AE\u03C3\u03B7\u03C2 \u03BC\u03B5\u03B8\u03CC\u03B4\u03BF\u03C5 valueOf \u03B3\u03B9\u03B1 \u03C4\u03CD\u03C0\u03BF enum {0}
org.talend.ws.exception.Unknown=\u039C\u03B9\u03B1 \u03AC\u03B3\u03BD\u03C9\u03C3\u03C4\u03B7 \u03B5\u03BE\u03B1\u03AF\u03C1\u03B5\u03C3\u03B7 \u03C0\u03C1\u03BF\u03AD\u03BA\u03C5\u03C8\u03B5
org.talend.ws.exception.InvalidEnumValueException=\u0397 \u03C4\u03B9\u03BC\u03AE {0} \u03B4\u03B5\u03BD \u03B5\u03AF\u03BD\u03B1\u03B9 \u03AD\u03B3\u03BA\u03C5\u03C1\u03B7 \u03B3\u03B9\u03B1 enum {1}
org.talend.ws.exception.InvalidParameterAnyType=\u03A0\u03C1\u03AD\u03C0\u03B5\u03B9 \u03BD\u03B1 \u03C0\u03C1\u03BF\u03C3\u03B4\u03B9\u03BF\u03C1\u03AF\u03C3\u03B5\u03C4\u03B5 \u03AD\u03BD\u03B1\u03BD \u03C7\u03AC\u03C1\u03C4\u03B7 \u03C3\u03B1\u03BD \u03B1\u03C5\u03C4\u03CC\u03BD \u03B3\u03B9\u03B1 anyTypes : {anyType: value, anyType_type: qname}

View File

@@ -1,8 +0,0 @@
org.talend.ws.exception.IllegalPropertyAccessException=Unable to access property {0} which is not accessible for type {1}
org.talend.ws.exception.NoSuchPropertyException=Property {0} does not exist for type {1}
org.talend.ws.exception.Instantiation=Unable to instantiate class of type {0}
org.talend.ws.exception.InvocationTargetPropertyAccessor=A property accessor has thrown an exception : property {0} of class {1}
org.talend.ws.exception.illegalAccessValueOf=Unable to call method valueOf for enum type {0}
org.talend.ws.exception.Unknown=An unknown exception has been thrown
org.talend.ws.exception.InvalidEnumValueException=Value {0} is not valid for enum {1}
org.talend.ws.exception.InvalidParameterAnyType=You must specify a map like this for anyTypes : {anyType: value, anyType_type: qname} pour les anyType

View File

@@ -1,6 +1,8 @@
org.talend.ws.exception.IllegalPropertyAccessException=Impossible d'acc\u00e9der \u00e0 la propri\u00e9t\u00e9 {0} qui est inaccessible pour le type {1}
org.talend.ws.exception.NoSuchPropertyException=La propri\u00e9t\u00e9 {0} n'existe pas pour le type {1}
org.talend.ws.exception.Instantiation=Impossible d'instancier la classe de type {0}
org.talend.ws.exception.illegalAccessValueOf=Impossible d'appeler une m\u00e9thode valueOf pour le type enum {0}
org.talend.ws.exception.Unknown=Une exception inconnue a \u00e9t\u00e9 rencontr\u00e9e
org.talend.ws.exception.IllegalPropertyAccessException=Impossible d'acc\u00E9der \u00E0 la propri\u00E9t\u00E9 {0} qui est inaccessible pour le type {1}
org.talend.ws.exception.NoSuchPropertyException=La propri\u00E9t\u00E9 {0} n'existe pas pour le type {1}
org.talend.ws.exception.Instantiation=Impossible d'instancier le type de classe {0}
org.talend.ws.exception.InvocationTargetPropertyAccessor=Un accesseur de propri\u00E9t\u00E9 a retourner une exception : propri\u00E9t\u00E9 {0} de classe {1}
org.talend.ws.exception.illegalAccessValueOf=Impossible d'appeler une m\u00E9thode valueOf pour le type enum {0}
org.talend.ws.exception.Unknown=Une exception inconnue a \u00E9t\u00E9 d\u00E9clench\u00E9e
org.talend.ws.exception.InvalidEnumValueException=La valeur {0} n'est pas valide pour enum {1}
org.talend.ws.exception.InvalidParameterAnyType=Vous devez sp\u00E9cifier une Map comme celle-ci pour anyTypes : {anyType: value, anyType_type: qname} pour les anyType

View File

@@ -1,8 +1,8 @@
org.talend.ws.exception.IllegalPropertyAccessException=\u30BF\u30A4\u30D7{1}\u306B\u30A2\u30AF\u30BB\u30B9\u3067\u304D\u306A\u3044\u30D7\u30ED\u30D1\u30C6\u30A3{0}\u306B\u30A2\u30AF\u30BB\u30B9\u3059\u308B\u3053\u3068\u306F\u3067\u304D\u307E\u305B\u3093
org.talend.ws.exception.IllegalPropertyAccessException={0} \u30D7\u30ED\u30D1\u30C6\u30A3\u306B\u30A2\u30AF\u30BB\u30B9\u3067\u304D\u307E\u305B\u3093\u3002\u3053\u308C\u306F {1} \u578B\u306E\u305F\u3081\u30A2\u30AF\u30BB\u30B9\u3067\u304D\u307E\u305B\u3093\u3002
org.talend.ws.exception.NoSuchPropertyException=\u30BF\u30A4\u30D7{1}\u306E\u30D7\u30ED\u30D1\u30C6\u30A3{0}\u306F\u5B58\u5728\u3057\u307E\u305B\u3093
org.talend.ws.exception.Instantiation=\u30BF\u30A4\u30D7{0}\u306E\u30AF\u30E9\u30B9\u3092\u30A4\u30F3\u30B9\u30BF\u30F3\u30B9\u5316\u3059\u308B\u3053\u3068\u306F\u3067\u304D\u307E\u305B\u3093
org.talend.ws.exception.InvocationTargetPropertyAccessor=\u30D7\u30ED\u30D1\u30C6\u30A3\u30A2\u30AF\u30BB\u30C3\u30B5\u306F\u4F8B\u5916\u3092\u767A\u751F\u3055\u305B\u307E\u3057\u305F: \u30AF\u30E9\u30B9{1}\u306E\u30D7\u30ED\u30D1\u30C6\u30A3{0}
org.talend.ws.exception.illegalAccessValueOf=enum\u578B{0}\u306E\u30E1\u30BD\u30C3\u30C9valueOf\u3092\u547C\u3073\u51FA\u3059\u3053\u3068\u304C\u3067\u304D\u307E\u305B\u3093
org.talend.ws.exception.Unknown=\u4E0D\u660E\u306A\u4F8B\u5916\u304C\u767A\u751F\u3057\u307E\u3057\u305F
org.talend.ws.exception.InvalidEnumValueException=\u5024{0}\u306F\u5217\u6319\u578B{1}\u3068\u3057\u3066\u6709\u52B9\u3067\u306F\u3042\u308A\u307E\u305B\u3093
org.talend.ws.exception.InvalidParameterAnyType=\u3053\u306E\u3088\u3046\u306AanyTypes\u306E\u30DE\u30C3\u30D7\u3092\u6307\u5B9A\u3059\u308B\u5FC5\u8981\u304C\u3042\u308A\u307E\u3059: {anyType: value, anyType_type: qname}
org.talend.ws.exception.Instantiation={0} \u578B\u306E\u30AF\u30E9\u30B9\u306E\u30A4\u30F3\u30B9\u30BF\u30F3\u30B9\u3092\u4F5C\u6210\u3067\u304D\u307E\u305B\u3093\u3002
org.talend.ws.exception.InvocationTargetPropertyAccessor=\u30D7\u30ED\u30D1\u30C6\u30A3\u30A2\u30AF\u30BB\u30B9\u306B\u3088\u308A\u3001\u4F8B\u5916\u304C\u30B9\u30ED\u30FC\u3055\u308C\u307E\u3057\u305F\uFF1A\u30AF\u30E9\u30B9 {1} \u306E\u30D7\u30ED\u30D1\u30C6\u30A3 {0}
org.talend.ws.exception.illegalAccessValueOf=\u5217\u6319\u578B {0} \u306EvalueOf\u30E1\u30BD\u30C3\u30C9\u3092\u547C\u3073\u51FA\u3059\u3053\u3068\u306F\u3067\u304D\u307E\u305B\u3093
org.talend.ws.exception.Unknown=\u4E0D\u660E\u306A\u4F8B\u5916\u304C\u30B9\u30ED\u30FC\u3055\u308C\u307E\u3057\u305F
org.talend.ws.exception.InvalidEnumValueException=\u5024 {0} \u306Fenum\u578B {1} \u3067\u306F\u3042\u308A\u307E\u305B\u3093\u3002
org.talend.ws.exception.InvalidParameterAnyType=\u30DE\u30C3\u30D7\u306F\u3069\u306E\u30BF\u30A4\u30D7\u306B\u3064\u3044\u3066\u3082\u4EE5\u4E0B\u306E\u3088\u3046\u306B\u6307\u5B9A\u3059\u308B\u5FC5\u8981\u304C\u3042\u308A\u307E\u3059: {anyType: value, anyType_type: qname}

View File

@@ -3,6 +3,6 @@ org.talend.ws.exception.NoSuchPropertyException=\u5C5E\u6027 {0} \u5BF9\u4E8E\u7
org.talend.ws.exception.Instantiation=\u65E0\u6CD5\u5B9E\u4F8B\u5316\u7C7B\u578B {0} \u7684\u7C7B
org.talend.ws.exception.InvocationTargetPropertyAccessor=\u5C5E\u6027\u8BBF\u95EE\u5668\u629B\u51FA\u4E86\u4E00\u4E2A\u5F02\u5E38\uFF1A\u7C7B {1} \u7684\u5C5E\u6027 {0}
org.talend.ws.exception.illegalAccessValueOf=\u65E0\u6CD5\u4E3A\u679A\u4E3E\u7C7B\u578B {0} \u8C03\u7528\u65B9\u6CD5 valueOf
org.talend.ws.exception.Unknown=\u629B\u51FA\u4E86\u4E00\u4E2A\u672A\u77E5\u7684\u5F02\u5E38
org.talend.ws.exception.Unknown=\u53D1\u751F\u4E00\u4E2A\u672A\u77E5\u5F02\u5E38
org.talend.ws.exception.InvalidEnumValueException=\u503C {0} \u5BF9\u4E8E\u679A\u4E3E {1} \u65E0\u6548
org.talend.ws.exception.InvalidParameterAnyType=\u60A8\u5FC5\u987B\u6309\u5982\u4E0B\u6240\u793A\u4E3A anyType \u6307\u5B9A\u6620\u5C04\uFF1A{anyType: value, anyType_type: qname}

View File

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

View File

@@ -189,7 +189,7 @@
<CODEGENERATION>
<IMPORTS>
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.14.jar" MVN="mvn:org.postgresql/postgresql/42.2.14" REQUIRED_IF="DB_VERSION =='V9_X'" />
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.25.jar" MVN="mvn:org.postgresql/postgresql/42.2.25" REQUIRED_IF="DB_VERSION =='V9_X'" />
<IMPORT NAME="Driver-Postgres" MODULE="postgresql-8.4-703.jdbc4.jar" MVN="mvn:postgresql/postgresql/8.4-703.jdbc4" REQUIRED_IF="DB_VERSION =='PRIOR_TO_V9'" />
</IMPORTS>
</CODEGENERATION>

View File

@@ -424,36 +424,57 @@
if(<%= mainInputTableName %> == null) {
<%= mainInputTableName %> = new <%= realMainConnection.getName() %>Struct();
}
<%
<%
} // T_TM_M_291
if(!hasPersistentLookup) {
for (int iInputTable = 1; iInputTable < sizeInputTables; iInputTable++) {
final ExternalMapperTable externalTable = inputTables.get(iInputTable);
final String tableName = externalTable.getName();
final IConnection connection = hNameToConnection.get(tableName);
if (connection == null) {
continue;
}
final EConnectionType connectionType = connection.getLineStyle();
if (connectionType == EConnectionType.FLOW_REF) {//lookup line
final List<ExternalMapperTableEntry> metadataTableEntries = externalTable.getMetadataTableEntries();
if (metadataTableEntries == null) {
continue;
}
if (!isVirtualIn) {
%>
<%=tableName %>Struct <%=tableName %> = null;
<%
}
}
}
}
if (!dieonerror) {
tryOffset = stringBuffer.length();
} // close dieonerror if check
%>
// ###############################
// # Input tables (lookups)
<%
<%
if (!dieonerror) {
tryOffset = stringBuffer.length();
ArrayList<ExternalMapperTable> inputTablesWithInnerJoin = new ArrayList<ExternalMapperTable>();
boolean hasValidLookupTables = false;
} // close dieonerror if check
int closeBracketCounter = 0;
%>
// ###############################
// # Input tables (lookups)
<%
ArrayList<ExternalMapperTable> inputTablesWithInnerJoin = new ArrayList<ExternalMapperTable>();
boolean hasValidLookupTables = false;
int closeBracketCounter = 0;
%>
boolean <%= rejectedInnerJoin %> = false;
boolean <%= mainRowRejected %> = false;
boolean <%= rejectedInnerJoin %> = false;
boolean <%= mainRowRejected %> = false;
<%
String previousLookupName = null;
String previousTableName = mainInputTableName;
int previousJoinedTablesPersistentSortedDelimited = 0;
int nextJoinedTableIndex = currentJoinedTableIndex;
@@ -467,7 +488,7 @@
List<String> declarationsStructForNextSortedWhile = new ArrayList<String>();
List<String> closeAllRowsBlockCount = new ArrayList<String>();
for (int iInputTable = 0; iInputTable < sizeInputTables; iInputTable++) { // T_TM_M_261
for (int iInputTable = 0; iInputTable < sizeInputTables; iInputTable++) { // T_TM_M_261
ExternalMapperTable externalTable = inputTables.get(iInputTable);
boolean isMultipleResultMode = false;
@@ -696,7 +717,7 @@
hasValidLookupTables = true;
String matchingMode = externalTable.getMatchingMode();
String matchingMode = externalTable.getMatchingMode();
if(matchingMode == null) {
if(aKeysValues.length > 0) {
matchingMode = "UNIQUE_MATCH";
@@ -999,7 +1020,9 @@
} // T 52
%>
<%= tableName %>Struct <%= tableName %> = null;
<%if(hasPersistentLookup) {%>
<%=tableName %>Struct <%=tableName %> = null;
<%}%>
<%
if(isMultipleResultMode) { // T 60
@@ -1369,6 +1392,7 @@
boolean atLeastOneInputTableWithInnerJoin = !inputTablesWithInnerJoin.isEmpty();
if (!dieonerror) {
//here mean disable TDI-45732 for some special case, is a workaround fix
if(gm.getBlocksCodeToClose()!=null && gm.getBlocksCodeToClose().size()>0){
%>
try {

View File

@@ -27544,7 +27544,7 @@
<IMPORT NAME="mail" MODULE="javax.mail-1.6.2.jar" MVN="mvn:com.sun.mail/javax.mail/1.6.2" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')"/>
<IMPORT NAME="neethi" MODULE="neethi-3.0.1.jar" MVN="mvn:org.talend.libraries/neethi-3.0.1/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/neethi-3.0.1.jar" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')"/>
<IMPORT NAME="WSDL4J-1_6_3" MODULE="wsdl4j-1.6.3.jar" MVN="mvn:wsdl4j/wsdl4j/1.6.3" BundleID="org.apache.servicemix.bundles.wsdl4j" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')"/>
<IMPORT NAME="xmlbeans" MODULE="xmlbeans-2.3.0.jar" MVN="mvn:org.talend.libraries/xmlbeans-2.3.0/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.xml/lib/xmlbeans-2.3.0.jar" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')"/>
<IMPORT NAME="xmlbeans" MODULE="xmlbeans-2.3.0.jar" MVN="mvn:org.talend.libraries/xmlbeans-2.3.0/6.0.0" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')"/>
<IMPORT NAME="XmlSchema" MODULE="xmlschema-core-2.0.1.jar" MVN="mvn:org.talend.libraries/xmlschema-core-2.0.1/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/xmlschema-core-2.0.1.jar" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')"/>
<IMPORT NAME="geronimo-stax" MODULE="geronimo-stax-api_1.0_spec-1.0.1.jar" MVN="mvn:org.talend.libraries/geronimo-stax-api_1.0_spec-1.0.1/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/geronimo-stax-api_1.0_spec-1.0.1.jar" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')"/>
<IMPORT NAME="wstx-asl" MODULE="wstx-asl-3.2.4.jar" MVN="mvn:org.talend.libraries/wstx-asl-3.2.4/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/wstx-asl-3.2.4.jar" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')"/>
@@ -27574,7 +27574,7 @@
<IMPORT NAME="neethi-3.0.3" MODULE="neethi-3.0.3.jar" MVN="mvn:org.apache.neethi/neethi/3.0.3" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="WSDL4J-1_6_3" MODULE="wsdl4j-1.6.3.jar" MVN="mvn:wsdl4j/wsdl4j/1.6.3" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="wstx-asl-3.2.9" MODULE="wstx-asl-3.2.9.jar" MVN="mvn:org.talend.libraries/wstx-asl-3.2.9/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/wstx-asl-3.2.9.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="xmlbeans-2.6.0" MODULE="xmlbeans-2.6.0.jar" MVN="mvn:org.talend.libraries/xmlbeans-2.6.0/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.xml/lib/xmlbeans-2.6.0.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="xmlbeans-2.6.0" MODULE="xmlbeans-2.6.0.jar" MVN="mvn:org.talend.libraries/xmlbeans-2.6.0/6.0.0" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="xmlschema-core-2.2.1" MODULE="xmlschema-core-2.2.1.jar" MVN="mvn:org.apache.ws.xmlschema/xmlschema-core/2.2.1" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')"/>
<IMPORT NAME="commons-httpclient-3.1" MODULE="commons-httpclient-3.1.jar" MVN="mvn:commons-httpclient/commons-httpclient/3.1" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')"/>
<IMPORT NAME="commons-fileupload-1.3.1" MODULE="commons-fileupload-1.3.1.jar" MVN="mvn:org.talend.libraries/commons-fileupload-1.3.1/6.0.0" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
@@ -27598,84 +27598,84 @@
MVN="mvn:org.ow2.asm/asm/9.1"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-core-3.3.10"
MODULE="cxf-core-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-core/3.3.10"
NAME="cxf-core-3.4.7"
MODULE="cxf-core-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-core/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-bindings-soap-3.3.10"
MODULE="cxf-rt-bindings-soap-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-bindings-soap/3.3.10"
NAME="cxf-rt-bindings-soap-3.4.7"
MODULE="cxf-rt-bindings-soap-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-bindings-soap/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-bindings-xml-3.3.10"
MODULE="cxf-rt-bindings-xml-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-bindings-xml/3.3.10"
NAME="cxf-rt-bindings-xml-3.4.7"
MODULE="cxf-rt-bindings-xml-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-bindings-xml/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-databinding-jaxb-3.3.10"
MODULE="cxf-rt-databinding-jaxb-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-databinding-jaxb/3.3.10"
NAME="cxf-rt-databinding-jaxb-3.4.7"
MODULE="cxf-rt-databinding-jaxb-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-databinding-jaxb/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-frontend-jaxws-3.3.10"
MODULE="cxf-rt-frontend-jaxws-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-frontend-jaxws/3.3.10"
NAME="cxf-rt-frontend-jaxws-3.4.7"
MODULE="cxf-rt-frontend-jaxws-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-frontend-jaxws/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-frontend-simple-3.3.10"
MODULE="cxf-rt-frontend-simple-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-frontend-simple/3.3.10"
NAME="cxf-rt-frontend-simple-3.4.7"
MODULE="cxf-rt-frontend-simple-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-frontend-simple/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-security-3.3.10"
MODULE="cxf-rt-security-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-security/3.3.10"
NAME="cxf-rt-security-3.4.7"
MODULE="cxf-rt-security-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-security/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-transports-http-3.3.10"
MODULE="cxf-rt-transports-http-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-transports-http/3.3.10"
NAME="cxf-rt-transports-http-3.4.7"
MODULE="cxf-rt-transports-http-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-transports-http/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-ws-addr-3.3.10"
MODULE="cxf-rt-ws-addr-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-addr/3.3.10"
NAME="cxf-rt-ws-addr-3.4.7"
MODULE="cxf-rt-ws-addr-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-addr/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-ws-mex-3.3.10"
MODULE="cxf-rt-ws-mex-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-mex/3.3.10"
NAME="cxf-rt-ws-mex-3.4.7"
MODULE="cxf-rt-ws-mex-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-mex/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-ws-policy-3.3.10"
MODULE="cxf-rt-ws-policy-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-policy/3.3.10"
NAME="cxf-rt-ws-policy-3.4.7"
MODULE="cxf-rt-ws-policy-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-policy/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-ws-rm-3.3.10"
MODULE="cxf-rt-ws-rm-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-rm/3.3.10"
NAME="cxf-rt-ws-rm-3.4.7"
MODULE="cxf-rt-ws-rm-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-rm/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-ws-security-3.3.10"
MODULE="cxf-rt-ws-security-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-security/3.3.10"
NAME="cxf-rt-ws-security-3.4.7"
MODULE="cxf-rt-ws-security-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-security/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-security-saml-3.3.10"
MODULE="cxf-rt-security-saml-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-security-saml/3.3.10"
NAME="cxf-rt-security-saml-3.4.7"
MODULE="cxf-rt-security-saml-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-security-saml/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-wsdl-3.3.10"
MODULE="cxf-rt-wsdl-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-wsdl/3.3.10"
NAME="cxf-rt-wsdl-3.4.7"
MODULE="cxf-rt-wsdl-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-wsdl/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-services-sts-core-3.3.10"
MODULE="cxf-services-sts-core-3.3.10.jar"
MVN="mvn:org.apache.cxf.services.sts/cxf-services-sts-core/3.3.10"
NAME="cxf-services-sts-core-3.4.7"
MODULE="cxf-services-sts-core-3.4.7.jar"
MVN="mvn:org.apache.cxf.services.sts/cxf-services-sts-core/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="ehcache-2.10.5"

View File

@@ -38303,7 +38303,7 @@
<IMPORT NAME="mail" MODULE="javax.mail-1.6.2.jar" MVN="mvn:com.sun.mail/javax.mail/1.6.2" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')"/>
<IMPORT NAME="neethi" MODULE="neethi-3.0.1.jar" MVN="mvn:org.talend.libraries/neethi-3.0.1/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/neethi-3.0.1.jar" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')"/>
<IMPORT NAME="WSDL4J-1_6_3" MODULE="wsdl4j-1.6.3.jar" MVN="mvn:wsdl4j/wsdl4j/1.6.3" BundleID="org.apache.servicemix.bundles.wsdl4j" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')"/>
<IMPORT NAME="xmlbeans" MODULE="xmlbeans-2.3.0.jar" MVN="mvn:org.talend.libraries/xmlbeans-2.3.0/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.xml/lib/xmlbeans-2.3.0.jar" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')"/>
<IMPORT NAME="xmlbeans" MODULE="xmlbeans-2.3.0.jar" MVN="mvn:org.talend.libraries/xmlbeans-2.3.0/6.0.0" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')"/>
<IMPORT NAME="XmlSchema" MODULE="xmlschema-core-2.0.1.jar" MVN="mvn:org.talend.libraries/xmlschema-core-2.0.1/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/xmlschema-core-2.0.1.jar" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')"/>
<IMPORT NAME="geronimo-stax" MODULE="geronimo-stax-api_1.0_spec-1.0.1.jar" MVN="mvn:org.talend.libraries/geronimo-stax-api_1.0_spec-1.0.1/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/geronimo-stax-api_1.0_spec-1.0.1.jar" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')"/>
<IMPORT NAME="wstx-asl" MODULE="wstx-asl-3.2.4.jar" MVN="mvn:org.talend.libraries/wstx-asl-3.2.4/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/wstx-asl-3.2.4.jar" REQUIRED_IF="((AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2011')) OR (API_VERSION=='API_2007')"/>
@@ -38333,7 +38333,7 @@
<IMPORT NAME="neethi-3.0.3" MODULE="neethi-3.0.3.jar" MVN="mvn:org.apache.neethi/neethi/3.0.3" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="WSDL4J-1_6_3" MODULE="wsdl4j-1.6.3.jar" MVN="mvn:wsdl4j/wsdl4j/1.6.3" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="wstx-asl-3.2.9" MODULE="wstx-asl-3.2.9.jar" MVN="mvn:org.talend.libraries/wstx-asl-3.2.9/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.axis2/lib/wstx-asl-3.2.9.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="xmlbeans-2.6.0" MODULE="xmlbeans-2.6.0.jar" MVN="mvn:org.talend.libraries/xmlbeans-2.6.0/6.0.0" UrlPath="platform:/plugin/org.talend.libraries.apache.xml/lib/xmlbeans-2.6.0.jar" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="xmlbeans-2.6.0" MODULE="xmlbeans-2.6.0.jar" MVN="mvn:org.talend.libraries/xmlbeans-2.6.0/6.0.0" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
<IMPORT NAME="xmlschema-core-2.2.1" MODULE="xmlschema-core-2.2.1.jar" MVN="mvn:org.apache.ws.xmlschema/xmlschema-core/2.2.1" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')"/>
<IMPORT NAME="commons-httpclient-3.1" MODULE="commons-httpclient-3.1.jar" MVN="mvn:commons-httpclient/commons-httpclient/3.1" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')"/>
<IMPORT NAME="commons-fileupload-1.3.1" MODULE="commons-fileupload-1.3.1.jar" MVN="mvn:org.talend.libraries/commons-fileupload-1.3.1/6.0.0" REQUIRED_IF="(AUTH_TYPE=='ONLINE') AND (API_VERSION=='API_2011')" />
@@ -38357,84 +38357,84 @@
MVN="mvn:org.ow2.asm/asm/9.1"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-core-3.3.10"
MODULE="cxf-core-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-core/3.3.10"
NAME="cxf-core-3.4.7"
MODULE="cxf-core-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-core/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-bindings-soap-3.3.10"
MODULE="cxf-rt-bindings-soap-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-bindings-soap/3.3.10"
NAME="cxf-rt-bindings-soap-3.4.7"
MODULE="cxf-rt-bindings-soap-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-bindings-soap/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-bindings-xml-3.3.10"
MODULE="cxf-rt-bindings-xml-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-bindings-xml/3.3.10"
NAME="cxf-rt-bindings-xml-3.4.7"
MODULE="cxf-rt-bindings-xml-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-bindings-xml/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-databinding-jaxb-3.3.10"
MODULE="cxf-rt-databinding-jaxb-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-databinding-jaxb/3.3.10"
NAME="cxf-rt-databinding-jaxb-3.4.7"
MODULE="cxf-rt-databinding-jaxb-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-databinding-jaxb/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-frontend-jaxws-3.3.10"
MODULE="cxf-rt-frontend-jaxws-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-frontend-jaxws/3.3.10"
NAME="cxf-rt-frontend-jaxws-3.4.7"
MODULE="cxf-rt-frontend-jaxws-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-frontend-jaxws/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-frontend-simple-3.3.10"
MODULE="cxf-rt-frontend-simple-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-frontend-simple/3.3.10"
NAME="cxf-rt-frontend-simple-3.4.7"
MODULE="cxf-rt-frontend-simple-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-frontend-simple/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-security-3.3.10"
MODULE="cxf-rt-security-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-security/3.3.10"
NAME="cxf-rt-security-3.4.7"
MODULE="cxf-rt-security-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-security/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-transports-http-3.3.10"
MODULE="cxf-rt-transports-http-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-transports-http/3.3.10"
NAME="cxf-rt-transports-http-3.4.7"
MODULE="cxf-rt-transports-http-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-transports-http/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-ws-addr-3.3.10"
MODULE="cxf-rt-ws-addr-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-addr/3.3.10"
NAME="cxf-rt-ws-addr-3.4.7"
MODULE="cxf-rt-ws-addr-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-addr/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-ws-mex-3.3.10"
MODULE="cxf-rt-ws-mex-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-mex/3.3.10"
NAME="cxf-rt-ws-mex-3.4.7"
MODULE="cxf-rt-ws-mex-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-mex/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-ws-policy-3.3.10"
MODULE="cxf-rt-ws-policy-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-policy/3.3.10"
NAME="cxf-rt-ws-policy-3.4.7"
MODULE="cxf-rt-ws-policy-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-policy/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-ws-rm-3.3.10"
MODULE="cxf-rt-ws-rm-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-rm/3.3.10"
NAME="cxf-rt-ws-rm-3.4.7"
MODULE="cxf-rt-ws-rm-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-rm/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-ws-security-3.3.10"
MODULE="cxf-rt-ws-security-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-security/3.3.10"
NAME="cxf-rt-ws-security-3.4.7"
MODULE="cxf-rt-ws-security-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-ws-security/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-security-saml-3.3.10"
MODULE="cxf-rt-security-saml-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-security-saml/3.3.10"
NAME="cxf-rt-security-saml-3.4.7"
MODULE="cxf-rt-security-saml-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-security-saml/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-rt-wsdl-3.3.10"
MODULE="cxf-rt-wsdl-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-wsdl/3.3.10"
NAME="cxf-rt-wsdl-3.4.7"
MODULE="cxf-rt-wsdl-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-wsdl/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="cxf-services-sts-core-3.3.10"
MODULE="cxf-services-sts-core-3.3.10.jar"
MVN="mvn:org.apache.cxf.services.sts/cxf-services-sts-core/3.3.10"
NAME="cxf-services-sts-core-3.4.7"
MODULE="cxf-services-sts-core-3.4.7.jar"
MVN="mvn:org.apache.cxf.services.sts/cxf-services-sts-core/3.4.7"
REQUIRED_IF="(AUTH_TYPE == 'ON_PREMISE') AND (MS_CRM_VERSION == 'CRM_2015')" />
<IMPORT
NAME="ehcache-2.10.5"

View File

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

View File

@@ -170,7 +170,7 @@
<CODEGENERATION>
<IMPORTS>
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.14.jar" MVN="mvn:org.postgresql/postgresql/42.2.14" REQUIRED_IF="DB_VERSION =='V9_X'" />
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.25.jar" MVN="mvn:org.postgresql/postgresql/42.2.25" REQUIRED_IF="DB_VERSION =='V9_X'" />
<IMPORT NAME="Driver-Postgres" MODULE="postgresql-8.4-703.jdbc4.jar" MVN="mvn:postgresql/postgresql/8.4-703.jdbc4" REQUIRED_IF="DB_VERSION =='PRIOR_TO_V9'" />
<IMPORT NAME="slf4j-api-1.7.25.jar" MODULE="slf4j-api-1.7.25.jar" MVN="mvn:org.slf4j/slf4j-api/1.7.25" REQUIRED_IF="USE_SHARED_CONNECTION =='true'" />
<IMPORT NAME="slf4j-log4j12-1.7.25.jar" MODULE="slf4j-log4j12-1.7.25.jar" MVN="mvn:org.slf4j/slf4j-log4j12/1.7.25" REQUIRED_IF="USE_SHARED_CONNECTION =='true'" />

View File

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

View File

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

View File

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

View File

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

View File

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

View File

@@ -228,7 +228,7 @@
<CODEGENERATION>
<IMPORTS>
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.14.jar" MVN="mvn:org.postgresql/postgresql/42.2.14" REQUIRED_IF="(DB_VERSION =='V9_X') AND (USE_EXISTING_CONNECTION == 'false') AND (DRIVER_IF_GREENPLUM == 'POSTGRESQL')" />
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.25.jar" MVN="mvn:org.postgresql/postgresql/42.2.25" REQUIRED_IF="(DB_VERSION =='V9_X') AND (USE_EXISTING_CONNECTION == 'false') AND (DRIVER_IF_GREENPLUM == 'POSTGRESQL')" />
<IMPORT NAME="Postgres_Driver"
MODULE="postgresql-8.4-703.jdbc4.jar" MVN="mvn:postgresql/postgresql/8.4-703.jdbc4" REQUIRED_IF="((DB_VERSION =='PRIOR_TO_V9') AND (USE_EXISTING_CONNECTION == 'false') AND (DRIVER_IF_GREENPLUM == 'POSTGRESQL'))" />
<IMPORT NAME="Greenplum-Driver" MODULE="greenplum-5.1.4.000275.jar" MVN="mvn:com.pivotal/greenplum/5.1.4.000275" REQUIRED_IF="(DRIVER_IF_GREENPLUM == 'GREENPLUM') AND (USE_EXISTING_CONNECTION == 'false')"/>

View File

@@ -202,7 +202,7 @@
<CODEGENERATION>
<IMPORTS>
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.14.jar" MVN="mvn:org.postgresql/postgresql/42.2.14" REQUIRED_IF="DB_VERSION =='V9_X'" />
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.25.jar" MVN="mvn:org.postgresql/postgresql/42.2.25" REQUIRED_IF="DB_VERSION =='V9_X'" />
<IMPORT NAME="Driver-Postgres" MODULE="postgresql-8.4-703.jdbc4.jar" MVN="mvn:postgresql/postgresql/8.4-703.jdbc4" REQUIRED_IF="DB_VERSION =='PRIOR_TO_V9'" />
<IMPORT NAME="slf4j-api-1.7.25.jar" MODULE="slf4j-api-1.7.25.jar" MVN="mvn:org.slf4j/slf4j-api/1.7.25" REQUIRED_IF="(USE_SHARED_CONNECTION == 'true' AND SPECIFY_DATASOURCE_ALIAS=='false')" />
<IMPORT NAME="slf4j-log4j12-1.7.25.jar" MODULE="slf4j-log4j12-1.7.25.jar" MVN="mvn:org.slf4j/slf4j-log4j12/1.7.25" REQUIRED_IF="(USE_SHARED_CONNECTION == 'true' AND SPECIFY_DATASOURCE_ALIAS=='false')" />

View File

@@ -280,7 +280,7 @@
<CODEGENERATION>
<IMPORTS>
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.14.jar" MVN="mvn:org.postgresql/postgresql/42.2.14" REQUIRED_IF="(DB_VERSION =='V9_X') AND (USE_EXISTING_CONNECTION == 'false')" />
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.25.jar" MVN="mvn:org.postgresql/postgresql/42.2.25" REQUIRED_IF="(DB_VERSION =='V9_X') AND (USE_EXISTING_CONNECTION == 'false')" />
<IMPORT NAME="Driver-Postgres" MODULE="postgresql-8.4-703.jdbc4.jar" MVN="mvn:postgresql/postgresql/8.4-703.jdbc4" REQUIRED_IF="(DB_VERSION =='PRIOR_TO_V9') AND (USE_EXISTING_CONNECTION == 'false')" />
<IMPORT NAME="Driver-Postgis" MODULE="postgis_1.4.0.jar" MVN="mvn:org.talend.libraries/postgis_1.4.0/6.0.0" REQUIRED="false" />
<IMPORT NAME="org.talend.sdi" MODULE="org.talend.sdi.jar" MVN="mvn:org.talend.libraries/org.talend.sdi/6.0.0" REQUIRED="false" />

View File

@@ -441,7 +441,7 @@
<CODEGENERATION>
<IMPORTS>
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.14.jar" MVN="mvn:org.postgresql/postgresql/42.2.14" REQUIRED_IF="(DB_VERSION =='V9_X') AND (USE_EXISTING_CONNECTION == 'false')" />
<IMPORT NAME="Driver-Postgres9" MODULE="postgresql-42.2.25.jar" MVN="mvn:org.postgresql/postgresql/42.2.25" REQUIRED_IF="(DB_VERSION =='V9_X') AND (USE_EXISTING_CONNECTION == 'false')" />
<IMPORT NAME="Driver-Postgres" MODULE="postgresql-8.4-703.jdbc4.jar" MVN="mvn:postgresql/postgresql/8.4-703.jdbc4" REQUIRED_IF="(DB_VERSION =='PRIOR_TO_V9') AND (USE_EXISTING_CONNECTION == 'false')" />
<IMPORT NAME="Driver-Postgis" MODULE="postgis_1.4.0.jar" MVN="mvn:org.talend.libraries/postgis_1.4.0/6.0.0" REQUIRED="false" />
<IMPORT NAME="org.talend.sdi" MODULE="org.talend.sdi.jar" MVN="mvn:org.talend.libraries/org.talend.sdi/6.0.0" REQUIRED="false" />

View File

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

View File

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

View File

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

View File

@@ -63,10 +63,6 @@ if("".equals(tempPath))tempPath="\"\"";
System.setProperty("javax.xml.accessExternalSchema", "all");
//shade the log level for DynamicClientFactory.class
java.util.logging.Logger LOG_<%=cid%> = org.apache.cxf.common.logging.LogUtils.getL7dLogger(org.apache.cxf.endpoint.dynamic.DynamicClientFactory.class);
LOG_<%=cid%>.setLevel(java.util.logging.Level.WARNING);
org.talend.webservice.helper.Utils util_<%=cid%> = new org.talend.webservice.helper.Utils();
org.talend.webservice.helper.conf.ServiceHelperConfiguration config_<%=cid%> = new org.talend.webservice.helper.conf.ServiceHelperConfiguration();

View File

@@ -208,15 +208,15 @@
<CODEGENERATION>
<IMPORTS>
<IMPORT
NAME="cxf-core-3.3.10"
MODULE="cxf-core-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-core/3.3.10"
NAME="cxf-core-3.4.7"
MODULE="cxf-core-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-core/3.4.7"
REQUIRED="true"
/>
<IMPORT
NAME="cxf-rt-frontend-simple-3.3.10"
MODULE="cxf-rt-frontend-simple-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-frontend-simple/3.3.10"
NAME="cxf-rt-frontend-simple-3.4.7"
MODULE="cxf-rt-frontend-simple-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-frontend-simple/3.4.7"
REQUIRED="true"
/>
<IMPORT
@@ -226,15 +226,15 @@
REQUIRED="true"
/>
<IMPORT
NAME="cxf-tools-common-3.3.10"
MODULE="cxf-tools-common-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-tools-common/3.3.10"
NAME="cxf-tools-common-3.4.7"
MODULE="cxf-tools-common-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-tools-common/3.4.7"
REQUIRED="true"
/>
<IMPORT
NAME="cxf-rt-wsdl-3.3.10"
MODULE="cxf-rt-wsdl-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-wsdl/3.3.10"
NAME="cxf-rt-wsdl-3.4.7"
MODULE="cxf-rt-wsdl-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-wsdl/3.4.7"
REQUIRED="true"
/>
<IMPORT
@@ -250,27 +250,27 @@
REQUIRED="true"
/>
<IMPORT
NAME="cxf-rt-bindings-soap-3.3.10"
MODULE="cxf-rt-bindings-soap-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-bindings-soap/3.3.10"
NAME="cxf-rt-bindings-soap-3.4.7"
MODULE="cxf-rt-bindings-soap-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-bindings-soap/3.4.7"
REQUIRED="true"
/>
<IMPORT
NAME="cxf-rt-databinding-jaxb-3.3.10"
MODULE="cxf-rt-databinding-jaxb-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-databinding-jaxb/3.3.10"
NAME="cxf-rt-databinding-jaxb-3.4.7"
MODULE="cxf-rt-databinding-jaxb-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-databinding-jaxb/3.4.7"
REQUIRED="true"
/>
<IMPORT
NAME="cxf-rt-transports-http-jetty-3.3.10"
MODULE="cxf-rt-transports-http-jetty-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-transports-http-jetty/3.3.10"
NAME="cxf-rt-transports-http-jetty-3.4.7"
MODULE="cxf-rt-transports-http-jetty-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-transports-http-jetty/3.4.7"
REQUIRED="true"
/>
<IMPORT
NAME="cxf-rt-transports-http-3.3.10"
MODULE="cxf-rt-transports-http-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-transports-http/3.3.10"
NAME="cxf-rt-transports-http-3.4.7"
MODULE="cxf-rt-transports-http-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-transports-http/3.4.7"
REQUIRED="true"
/>
@@ -327,8 +327,8 @@
/>
<IMPORT
NAME="talend-ws"
MODULE="talend-ws-1.0.5-20210629.jar"
MVN="mvn:org.talend.components/talend-ws/1.0.5-20210629"
MODULE="talend-ws-1.0.7-20220526.jar"
MVN="mvn:org.talend.components/talend-ws/1.0.7-20220526"
REQUIRED="true"
/>

View File

@@ -55,10 +55,6 @@ if(("false").equals(ElementParameterParser.getValue(node,"__ADVANCED_USE__"))) {
System.setProperty("javax.xml.accessExternalSchema", "all");
//shade the log level for DynamicClientFactory.class
java.util.logging.Logger LOG_<%=cid%> = org.apache.cxf.common.logging.LogUtils.getL7dLogger(org.apache.cxf.endpoint.dynamic.DynamicClientFactory.class);
LOG_<%=cid%>.setLevel(java.util.logging.Level.WARNING);
org.talend.webservice.helper.Utils util_<%=cid%> = new org.talend.webservice.helper.Utils();
org.talend.webservice.helper.conf.ServiceHelperConfiguration config_<%=cid%> = new org.talend.webservice.helper.conf.ServiceHelperConfiguration();

View File

@@ -254,15 +254,15 @@ for(int i = 0; i &lt; result.length; i++){
<!-- cxf api support -->
<IMPORT
NAME="cxf-core-3.3.10"
MODULE="cxf-core-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-core/3.3.10"
NAME="cxf-core-3.4.7"
MODULE="cxf-core-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-core/3.4.7"
REQUIRED_IF="(API=='CXF')"
/>
<IMPORT
NAME="cxf-rt-frontend-simple-3.3.10"
MODULE="cxf-rt-frontend-simple-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-frontend-simple/3.3.10"
NAME="cxf-rt-frontend-simple-3.4.7"
MODULE="cxf-rt-frontend-simple-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-frontend-simple/3.4.7"
REQUIRED_IF="(API=='CXF')"
/>
<IMPORT
@@ -272,15 +272,15 @@ for(int i = 0; i &lt; result.length; i++){
REQUIRED_IF="(API=='CXF')"
/>
<IMPORT
NAME="cxf-tools-common-3.3.10"
MODULE="cxf-tools-common-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-tools-common/3.3.10"
NAME="cxf-tools-common-3.4.7"
MODULE="cxf-tools-common-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-tools-common/3.4.7"
REQUIRED_IF="(API=='CXF')"
/>
<IMPORT
NAME="cxf-rt-wsdl-3.3.10"
MODULE="cxf-rt-wsdl-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-wsdl/3.3.10"
NAME="cxf-rt-wsdl-3.4.7"
MODULE="cxf-rt-wsdl-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-wsdl/3.4.7"
REQUIRED_IF="(API=='CXF')"
/>
<IMPORT
@@ -296,27 +296,27 @@ for(int i = 0; i &lt; result.length; i++){
REQUIRED_IF="(API=='CXF')"
/>
<IMPORT
NAME="cxf-rt-bindings-soap-3.3.10"
MODULE="cxf-rt-bindings-soap-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-bindings-soap/3.3.10"
NAME="cxf-rt-bindings-soap-3.4.7"
MODULE="cxf-rt-bindings-soap-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-bindings-soap/3.4.7"
REQUIRED_IF="(API=='CXF')"
/>
<IMPORT
NAME="cxf-rt-databinding-jaxb-3.3.10"
MODULE="cxf-rt-databinding-jaxb-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-databinding-jaxb/3.3.10"
NAME="cxf-rt-databinding-jaxb-3.4.7"
MODULE="cxf-rt-databinding-jaxb-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-databinding-jaxb/3.4.7"
REQUIRED_IF="(API=='CXF')"
/>
<IMPORT
NAME="cxf-rt-transports-http-jetty-3.3.10"
MODULE="cxf-rt-transports-http-jetty-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-transports-http-jetty/3.3.10"
NAME="cxf-rt-transports-http-jetty-3.4.7"
MODULE="cxf-rt-transports-http-jetty-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-transports-http-jetty/3.4.7"
REQUIRED_IF="(API=='CXF')"
/>
<IMPORT
NAME="cxf-rt-transports-http-3.3.10"
MODULE="cxf-rt-transports-http-3.3.10.jar"
MVN="mvn:org.apache.cxf/cxf-rt-transports-http/3.3.10"
NAME="cxf-rt-transports-http-3.4.7"
MODULE="cxf-rt-transports-http-3.4.7.jar"
MVN="mvn:org.apache.cxf/cxf-rt-transports-http/3.4.7"
REQUIRED_IF="(API=='CXF')"
/>
<IMPORT
@@ -359,8 +359,8 @@ for(int i = 0; i &lt; result.length; i++){
/>
<IMPORT
NAME="talend-ws"
MODULE="talend-ws-1.0.5-20210629.jar"
MVN="mvn:org.talend.components/talend-ws/1.0.5-20210629"
MODULE="talend-ws-1.0.7-20220526.jar"
MVN="mvn:org.talend.components/talend-ws/1.0.7-20220526"
REQUIRED_IF="(API=='CXF')"
/>
<IMPORT

View File

@@ -141,13 +141,13 @@ public class CLASS {
boolean end = false;
if(expression.indexOf("[")>-1) {
strBuilder.append(expression.substring(0, expression.indexOf("[")));
currentExpression = currentExpression.substring(currentExpression.indexOf("["), currentExpression.length());
if(expression.contains("[")) {
strBuilder.append(expression, 0, expression.indexOf("["));
currentExpression = currentExpression.substring(currentExpression.indexOf("["));
while(currentExpression.length()>0 && !end) {
expression = this.getXPathExpression(currentExpression);
currentExpression = currentExpression.substring(expression.length(), currentExpression.length());
currentExpression = currentExpression.substring(expression.length());
matcherFromDoc = expressionFromDoc.matcher(expression);
if(matcherFromDoc.matches()) {
tmpXpath = expression.substring(1, expression.length()-1);
@@ -167,9 +167,9 @@ public class CLASS {
} else {
strBuilder.append(expression);
}
if(currentExpression.indexOf("[")>-1) {
strBuilder.append(currentExpression.substring(0, currentExpression.indexOf("[")));
currentExpression = currentExpression.substring(currentExpression.indexOf("["), currentExpression.length());
if(currentExpression.contains("[")) {
strBuilder.append(currentExpression, 0, currentExpression.indexOf("["));
currentExpression = currentExpression.substring(currentExpression.indexOf("["));
} else {
strBuilder.append(currentExpression);
end=true;
@@ -191,13 +191,16 @@ public class CLASS {
count++;
}
if(']' == c) {
if(count==1) {
if(count--==1) {
break;
}
count--;
}
}
return currentExpression.substring(0,i+1);
if (count == 0) {
return currentExpression.substring(0, i + 1);
} else { //not a valid XPathExpression, returning as is
return currentExpression;
}
}
}

View File

@@ -33,21 +33,21 @@
<!-- hd insight common libraries -->
<libraryNeeded
context="plugin:org.talend.libraries.apache.cxf"
id="cxf-rt-bindings-xml-3.3.10.jar"
name="cxf-rt-bindings-xml-3.3.10.jar"
mvn_uri="mvn:org.apache.cxf/cxf-rt-bindings-xml/3.3.10">
id="cxf-rt-bindings-xml-3.4.7.jar"
name="cxf-rt-bindings-xml-3.4.7.jar"
mvn_uri="mvn:org.apache.cxf/cxf-rt-bindings-xml/3.4.7">
</libraryNeeded>
<libraryNeeded
context="plugin:org.talend.libraries.apache.cxf"
id="cxf-rt-frontend-jaxrs-3.3.10.jar"
name="cxf-rt-frontend-jaxrs-3.3.10.jar"
mvn_uri="mvn:org.apache.cxf/cxf-rt-frontend-jaxrs/3.3.10">
id="cxf-rt-frontend-jaxrs-3.4.7.jar"
name="cxf-rt-frontend-jaxrs-3.4.7.jar"
mvn_uri="mvn:org.apache.cxf/cxf-rt-frontend-jaxrs/3.4.7">
</libraryNeeded>
<libraryNeeded
context="plugin:org.talend.libraries.apache.cxf"
id="cxf-rt-transports-http-3.3.10.jar"
name="cxf-rt-transports-http-3.3.10.jar"
mvn_uri="mvn:org.apache.cxf/cxf-rt-transports-http/3.3.10">
id="cxf-rt-transports-http-3.4.7.jar"
name="cxf-rt-transports-http-3.4.7.jar"
mvn_uri="mvn:org.apache.cxf/cxf-rt-transports-http/3.4.7">
</libraryNeeded>
<libraryNeeded
context="plugin:org.talend.libraries.jackson"
@@ -178,9 +178,9 @@
id="HD_INSIGHT_COMMON_LIBRARIES_LATEST"
name="HD_INSIGHT_COMMON_LIBRARIES_LATEST">
<library id="talend-bigdata-launcher-1.1.0-20160405.jar" />
<library id="cxf-rt-bindings-xml-3.3.10.jar" />
<library id="cxf-rt-frontend-jaxrs-3.3.10.jar" />
<library id="cxf-rt-transports-http-3.3.10.jar" />
<library id="cxf-rt-bindings-xml-3.4.7.jar" />
<library id="cxf-rt-frontend-jaxrs-3.4.7.jar" />
<library id="cxf-rt-transports-http-3.4.7.jar" />
<library id="json_simple-1.1.jar" />
<library id="javax.ws.rs-api-2.0-m10.jar" />
<library id="wsdl4j-1.6.3.jar" />

View File

@@ -113,7 +113,7 @@
<artifactItem>
<groupId>org.talend.components</groupId>
<artifactId>talend-ws</artifactId>
<version>1.0.5-20210629</version>
<version>1.0.7-20220526</version>
<type>jar</type>
<overWrite>true</overWrite>
<outputDirectory>${webservicecore.dir}</outputDirectory>

View File

@@ -29,6 +29,7 @@ import org.eclipse.jdt.ui.JavadocContentAccess;
import org.eclipse.jface.action.IAction;
import org.eclipse.jface.preference.IPreferenceStore;
import org.eclipse.jface.viewers.ILabelProvider;
import org.eclipse.swt.widgets.Display;
import org.eclipse.ui.IEditorPart;
import org.eclipse.ui.IEditorReference;
import org.eclipse.ui.IViewPart;
@@ -38,6 +39,7 @@ import org.eclipse.ui.PlatformUI;
import org.eclipse.ui.part.MultiPageEditorPart;
import org.talend.commons.CommonsPlugin;
import org.talend.commons.exception.ExceptionHandler;
import org.talend.commons.ui.gmf.util.DisplayUtils;
import org.talend.core.CorePlugin;
import org.talend.core.model.components.ComponentCategory;
import org.talend.core.model.components.IComponent;
@@ -270,8 +272,16 @@ public class DesignerCoreService implements IDesignerCoreService {
*/
@Override
public IProcess getCurrentProcess() {
IEditorPart editor = PlatformUI.getWorkbench().getActiveWorkbenchWindow().getActivePage().getActiveEditor();
if (!(editor instanceof AbstractMultiPageTalendEditor)) {
IEditorPart editor;
if (Display.getCurrent() == null) {
List<IEditorPart> list = new ArrayList<>();
DisplayUtils.getDisplay().syncExec(
() -> list.add(PlatformUI.getWorkbench().getActiveWorkbenchWindow().getActivePage().getActiveEditor()));
editor = list.get(0);
} else {
editor = PlatformUI.getWorkbench().getActiveWorkbenchWindow().getActivePage().getActiveEditor();
}
if (editor == null || !(editor instanceof AbstractMultiPageTalendEditor)) {
return null;
}
IProcess process = ((AbstractMultiPageTalendEditor) editor).getProcess();

View File

@@ -510,7 +510,7 @@ public class ChangeValuesFromRepository extends ChangeMetadataCommand {
}
}
JobSettingVersionUtil.setDbVersion(elementParameter, dbVersion, false);
JobSettingVersionUtil.setDbVersion(elementParameter, dbType, dbVersion, false);
DesignerUtilities.setSchemaDB(elementParameter2, param.getValue());
} else if (param.getFieldType().equals(EParameterFieldType.CLOSED_LIST)
&& "FRAMEWORK_TYPE".equals(param.getRepositoryValue())) { //$NON-NLS-1$

View File

@@ -139,9 +139,9 @@ public class StatsAndLogsConstants {
"jtds-1.3.1-patch-20190523.jar", "mssql-jdbc.jar"};//$NON-NLS-1$ //$NON-NLS-2$
public static final String[] DB_VERSION_DISPLAY = new String[] {"Oracle 18 and above", "Oracle 12", "Oracle 11", "Oracle 10", "Oracle 9",
"Oracle 8", "MySQL 5", "MariaDB", "Open source JTDS", "Microsoft", "Access 2003", "Access 2007", "Prior to v9",
"v9 +", "Sybase 16 (SQL Anywhere)", "Sybase 16", "Sybase 12/15" };
public static final String[] DB_VERSION_DISPLAY = new String[] { "Oracle 18 and above", "Oracle 12", "Oracle 11", "Oracle 10",
"Oracle 9", "Oracle 8", "MySQL 8", "MySQL 5", "MariaDB", "Open source JTDS", "Microsoft", "Access 2003",
"Access 2007", "Prior to v9", "v9 +", "Sybase 16 (SQL Anywhere)", "Sybase 16", "Sybase 12/15" };
public static final String[] DB_VERSION_CODE = new String[] {"ORACLE_18", "ORACLE_12", "ORACLE_11", "ORACLE_10", "ORACLE_9", "ORACLE_8",
@@ -174,7 +174,7 @@ public class StatsAndLogsConstants {
public static final String[] PSQL_VERSION_CODE = new String[] { "V9_X","PRIOR_TO_V9" }; //$NON-NLS-1$ //$NON-NLS-2$
public static final String[] PSQL_VERSION_DRIVER = new String[] {
"postgresql-42.2.14.jar", "postgresql-8.4-703.jdbc4.jar" }; //$NON-NLS-1$ //$NON-NLS-2$
"postgresql-42.2.25.jar", "postgresql-8.4-703.jdbc4.jar" }; //$NON-NLS-1$ //$NON-NLS-2$
public static final String[][] DISPLAY_DBNAMES = new String[][] { PERL_DISPLAY_DBNAMES, JAVA_DISPLAY_DBNAMES };

View File

@@ -57,6 +57,7 @@ import org.talend.core.language.ICodeProblemsChecker;
import org.talend.core.model.components.ComponentCategory;
import org.talend.core.model.general.ModuleNeeded;
import org.talend.core.model.general.Project;
import org.talend.core.model.general.RetrieveResult;
import org.talend.core.model.general.TalendJobNature;
import org.talend.core.model.process.IContext;
import org.talend.core.model.process.IProcess;
@@ -397,17 +398,21 @@ public class DefaultRunProcessService implements IRunProcessService {
* org.talend.designer.runprocess.IRunProcessService#updateLibraries(org.talend.core.model.properties.RoutineItem)
*/
@Override
public void updateLibraries(Item routineItem) {
public boolean updateLibraries(Item routineItem) {
Set<ModuleNeeded> modulesForRoutine = ModulesNeededProvider.updateModulesNeededForRoutine(routineItem);
File libDir = getJavaProjectLibFolder().getLocation().toFile();
if (libDir == null) {
return;
return false;
}
ILibraryManagerService repositoryBundleService = CorePlugin.getDefault().getRepositoryBundleService();
repositoryBundleService.retrieve(ERepositoryObjectType.getItemType(routineItem), modulesForRoutine,
libDir.getAbsolutePath(), true);
RetrieveResult result = repositoryBundleService.retrieveModules(ERepositoryObjectType.getItemType(routineItem),
modulesForRoutine, libDir.getAbsolutePath(), true);
repositoryBundleService.installModules(modulesForRoutine, null);
CorePlugin.getDefault().getLibrariesService().checkLibraries();
boolean updated = !result.getResovledModules().isEmpty();
if (updated) {
CorePlugin.getDefault().getLibrariesService().checkLibraries();
}
return updated;
}
/*

View File

@@ -212,8 +212,8 @@ public class RunProcessService implements IRunProcessService {
* org.talend.designer.runprocess.IRunProcessService#updateLibraries(org.talend.core.model.properties.RoutineItem)
*/
@Override
public void updateLibraries(Item routineItem) {
delegateService.updateLibraries(routineItem);
public boolean updateLibraries(Item routineItem) {
return delegateService.updateLibraries(routineItem);
}
@Override

View File

@@ -174,6 +174,12 @@
id="talend-spark-assembly-1.3.1-hadoop2.5.1-mapr-1501.jar"
name="talend-spark-assembly-1.3.1-hadoop2.5.1-mapr-1501.jar" mvn_uri="mvn:org.talend.libraries/talend-spark-assembly-1.3.1-hadoop2.5.1-mapr-1501/6.0.0">
</libraryNeeded>
<libraryNeeded
context="plugin:org.talend.libraries.hadoop.mapr.5.0.0"
id="reload4j-1.2.19.jar"
name="reload4j-1.2.19.jar" mvn_uri="mvn:ch.qos.reload4j/reload4j/1.2.19/jar">
</libraryNeeded>
<libraryNeededGroup
description="The lastest HDFS libraries of MAPR50X"
id="HDFS-LIB-MAPR50X_LASTEST"
@@ -200,7 +206,7 @@
id="protobuf-java-2.5.0.jar">
</library>
<library
id="log4j-1.2.17.jar">
id="reload4j-1.2.19.jar">
</library>
<library
id="slf4j-api-1.7.5.jar">

View File

@@ -3710,6 +3710,15 @@
name="XSLTCheckCacheFileInMemoryTask"
version="7.3.1">
</projecttask>
<projecttask
beforeLogon="false"
breaks="7.3.0"
class="org.talend.repository.model.migration.RenameTimeoutParameterstRESTClient"
description="Rename timeout parameters for tRESTClient"
id="org.talend.repository.model.migration.RenameTimeoutParameterstRESTClient"
name="RenameTimeoutParameterstRESTClient"
version="7.3.1">
</projecttask>
</extension>
<extension

View File

@@ -24,6 +24,7 @@ woodstox-core-asl
# MSSQL
jtds
mssql-jdbc
# tdm-lib-di
tdm-lib-di

View File

@@ -0,0 +1,85 @@
// ============================================================================
//
// Copyright (C) 2006-2021 Talend Inc. - www.talend.com
//
// This source code is available under agreement available at
// %InstallDIR%\features\org.talend.rcp.branding.%PRODUCTNAME%\%PRODUCTNAME%license.txt
//
// You should have received a copy of the agreement
// along with this program; if not, write to Talend SA
// 9 rue Pages 92150 Suresnes, France
//
// ============================================================================
package org.talend.repository.model.migration;
import java.util.Calendar;
import java.util.Date;
import java.util.GregorianCalendar;
import org.eclipse.emf.common.util.EList;
import org.talend.commons.exception.ExceptionHandler;
import org.talend.commons.exception.PersistenceException;
import org.talend.core.model.migration.AbstractJobMigrationTask;
import org.talend.core.model.properties.Item;
import org.talend.core.repository.model.ProxyRepositoryFactory;
import org.talend.designer.core.model.utils.emf.talendfile.ElementParameterType;
import org.talend.designer.core.model.utils.emf.talendfile.NodeType;
import org.talend.designer.core.model.utils.emf.talendfile.ProcessType;
/**
* Rename timeout parameters for tRESTClient
*/
public class RenameTimeoutParameterstRESTClient extends AbstractJobMigrationTask {
@Override
public ExecutionResult execute(Item item) {
ProcessType processType = getProcessType(item);
if (processType == null) {
return ExecutionResult.NOTHING_TO_DO;
}
try {
renameConnections(item, processType);
return ExecutionResult.SUCCESS_WITH_ALERT;
} catch (Exception e) {
ExceptionHandler.process(e);
return ExecutionResult.FAILURE;
}
}
private void renameConnections(Item item, ProcessType processType) throws PersistenceException {
ProxyRepositoryFactory factory = ProxyRepositoryFactory.getInstance();
boolean modified = false;
EList nodes = processType.getNode();
for (Object n : nodes) {
NodeType type = (NodeType) n;
if (type.getComponentName().equals("tRESTClient")) {
EList elementParameterList = type.getElementParameter();
for (Object elem : elementParameterList) {
ElementParameterType elemType = (ElementParameterType) elem;
if (elemType.getName().equals("CONNECTION_TIMEOUT_DESC")) {
elemType.setValue("");
modified = true;
}
if (elemType.getName().equals("RECEIVE_TIMEOUT_DESC")) {
elemType.setValue("(See tRESTClient doc. to configure timeouts for Talend Runtime)");
modified = true;
}
}
}
}
if (modified) {
factory.save(item, true);
}
}
public Date getOrder() {
GregorianCalendar gc = new GregorianCalendar(2022, Calendar.APRIL, 21, 17, 0, 0);
return gc.getTime();
}
}

View File

@@ -13,6 +13,9 @@
package org.talend.repository.ui.actions.routines;
import org.eclipse.core.resources.IFile;
import org.eclipse.core.runtime.IProgressMonitor;
import org.eclipse.core.runtime.IStatus;
import org.eclipse.core.runtime.jobs.Job;
import org.eclipse.jface.viewers.IStructuredSelection;
import org.eclipse.jface.viewers.TreeViewer;
import org.eclipse.ui.IEditorPart;
@@ -26,11 +29,15 @@ import org.talend.core.context.Context;
import org.talend.core.context.RepositoryContext;
import org.talend.core.language.ECodeLanguage;
import org.talend.core.model.properties.RoutineItem;
import org.talend.core.model.repository.ERepositoryObjectType;
import org.talend.core.repository.model.ProxyRepositoryFactory;
import org.talend.core.repository.ui.editor.RepositoryEditorInput;
import org.talend.designer.codegen.ICodeGeneratorService;
import org.talend.designer.codegen.ITalendSynchronizer;
import org.talend.designer.maven.tools.AggregatorPomsHelper;
import org.talend.designer.maven.tools.CodeM2CacheManager;
import org.talend.repository.ProjectManager;
import org.talend.repository.RepositoryPlugin;
import org.talend.repository.i18n.Messages;
import org.talend.repository.model.RepositoryNode;
import org.talend.repository.ui.actions.AContextualAction;
@@ -138,4 +145,23 @@ public abstract class AbstractRoutineAction extends AContextualAction {
repositoryNode = (RepositoryNode) o;
}
void updateRoutineProject() {
Job job = new Job("Update Routine project") {
@Override
protected IStatus run(IProgressMonitor monitor) {
try {
new AggregatorPomsHelper().updateCodeProject(monitor, ERepositoryObjectType.ROUTINES, true, true, false);
return org.eclipse.core.runtime.Status.OK_STATUS;
} catch (Exception e) {
return new org.eclipse.core.runtime.Status(IStatus.ERROR, RepositoryPlugin.PLUGIN_ID, 1, e.getMessage(),
e);
}
}
};
job.setUser(false);
job.schedule();
}
}

View File

@@ -106,7 +106,9 @@ public class EditRoutineAction extends AbstractRoutineAction {
openRoutineEditor(routineItem, false);
refresh(repositoryNode);
// CorePlugin.getDefault().getLibrariesService().resetModulesNeeded();
CorePlugin.getDefault().getRunProcessService().updateLibraries(routineItem);
if (CorePlugin.getDefault().getRunProcessService().updateLibraries(routineItem)) {
updateRoutineProject();
}
} catch (PartInitException e) {
MessageBoxExceptionHandler.process(e);
} catch (SystemException e) {

View File

@@ -97,7 +97,9 @@ public class ReadRoutineAction extends AbstractRoutineAction {
routineItem = (RoutineItem) repositoryNode.getObject().getProperty().getItem();
try {
openRoutineEditor(routineItem, true);
CorePlugin.getDefault().getRunProcessService().updateLibraries(routineItem);
if (CorePlugin.getDefault().getRunProcessService().updateLibraries(routineItem)) {
updateRoutineProject();
}
} catch (PartInitException e) {
MessageBoxExceptionHandler.process(e);
} catch (SystemException e) {

View File

@@ -2708,7 +2708,7 @@ public class LoginComposite extends Composite {
@Override
public void linkActivated(HyperlinkEvent e) {
String url = "https://help.talend.com/pages/viewpage.action?pageId=14230347";
String url = "https://document-link.us.cloud.talend.com/ts_ig_install-external-modules?version=73&lang=en&env=prd";
TalendBrowserLaunchHelper.openURL(url);
}
});

View File

@@ -2712,7 +2712,7 @@ public class LoginProjectPage extends AbstractLoginActionPage {
@Override
public void linkActivated(HyperlinkEvent e) {
String url = "https://help.talend.com/pages/viewpage.action?pageId=14230347";
String url = "https://document-link.us.cloud.talend.com/ts_ig_install-external-modules?version=73&lang=en&env=prd";
TalendBrowserLaunchHelper.openURL(url);
}
});

View File

@@ -81,6 +81,7 @@ import org.talend.core.runtime.maven.MavenArtifact;
import org.talend.core.runtime.maven.MavenConstants;
import org.talend.core.runtime.process.ITalendProcessJavaProject;
import org.talend.core.runtime.process.LastGenerationInfo;
import org.talend.core.runtime.process.TalendProcessOptionConstants;
import org.talend.core.runtime.repository.build.BuildExportManager;
import org.talend.core.service.ITaCoKitDependencyService;
import org.talend.core.ui.branding.IBrandingService;
@@ -1242,6 +1243,13 @@ public class JobJavaScriptOSGIForESBManager extends JobJavaScriptsManager {
return analyzer;
}
private boolean usesMssql(ProcessItem processItem) {
IDesignerCoreService service = CorePlugin.getDefault().getDesignerCoreService();
return service.getProcessFromProcessItem(processItem, false)
.getNeededLibraries(TalendProcessOptionConstants.MODULES_DEFAULT).stream()
.anyMatch(lib -> lib.matches("mssql-jdbc.jar"));
}
protected void addOsgiDependencies(Analyzer analyzer, ExportFileResource libResource, ProcessItem processItem)
throws IOException {
analyzer.setProperty(Analyzer.EXPORT_SERVICE, "routines.system.api.TalendJob;name=" + processItem.getProperty().getLabel() + ";type=" + "job");
@@ -1305,7 +1313,10 @@ public class JobJavaScriptOSGIForESBManager extends JobJavaScriptsManager {
importPackages.add("org.talend.cloud"); //$NON-NLS-1$
}
if(usesMssql(processItem)) {
importPackages.add("com.microsoft.sqlserver.jdbc");
}
if (requireBundle != null && !requireBundle.isEmpty()) {
requireBundle += (", org.ops4j.pax.logging.pax-logging-api");
} else {