1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
|
/*
* Copyright (c) 1998, 2018 Oracle and/or its affiliates. All rights reserved.
*
* This program and the accompanying materials are made available under the
* terms of the Eclipse Public License v. 2.0 which is available at
* http://www.eclipse.org/legal/epl-2.0,
* or the Eclipse Distribution License v. 1.0 which is available at
* http://www.eclipse.org/org/documents/edl-v10.php.
*
* SPDX-License-Identifier: EPL-2.0 OR BSD-3-Clause
*/
// Contributors:
// Oracle - initial API and implementation from Oracle TopLink
package org.eclipse.persistence.platform.database.oracle;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;
import javax.naming.Context;
import javax.naming.NamingException;
import oracle.jdbc.pool.OracleOCIConnectionPool;
import org.eclipse.persistence.exceptions.DatabaseException;
import org.eclipse.persistence.exceptions.ValidationException;
import org.eclipse.persistence.sessions.JNDIConnector;
import org.eclipse.persistence.sessions.Session;
public class OracleOCIProxyConnector extends JNDIConnector {
/**
* PUBLIC:
* Construct a Connector with no settings.
* The datasource name will still need to be set.
*/
public OracleOCIProxyConnector() {
super();
}
/**
* PUBLIC:
* Construct a Connector with the datasource name.
*/
public OracleOCIProxyConnector(Context context, String name) throws ValidationException {
super(context, name);
}
/**
* PUBLIC:
* Construct a Connector with the datasource name.
*/
public OracleOCIProxyConnector(String name) {
super(name);
}
/**
* PUBLIC:
* Construct a Connector with OracleOCIConnectionPool.
*/
public OracleOCIProxyConnector(OracleOCIConnectionPool oracleOCIConnectionPool) {
super(oracleOCIConnectionPool);
}
/**
* INTERNAL:
* In case "proxytype" property is specified connects using proxy connection,
* otherwise calls its superclass.
*/
public Connection connect(Properties properties, Session session) throws DatabaseException, ValidationException {
String proxytype = properties.getProperty(OracleOCIConnectionPool.PROXYTYPE);
if(proxytype == null || proxytype.length() == 0) {
return super.connect(properties, session);
} else {
try {
OracleOCIConnectionPool oracleOCIConnectionPool = (OracleOCIConnectionPool)getDataSource();
if (oracleOCIConnectionPool == null) {
try {
oracleOCIConnectionPool = (OracleOCIConnectionPool)getContext().lookup(getName());
this.setDataSource(oracleOCIConnectionPool);
} catch (NamingException exception) {
throw ValidationException.cannotAcquireDataSource(getName(), exception);
}
}
return oracleOCIConnectionPool.getProxyConnection(proxytype, properties);
} catch (SQLException exception) {
throw DatabaseException.sqlException(exception, true);
} catch (ClassCastException classCastException) {
throw ValidationException.oracleOCIProxyConnectorRequiresOracleOCIConnectionPool();
}
}
}
}
|
