/*
|
* CDDL HEADER START
|
*
|
* The contents of this file are subject to the terms of the Common Development and
|
* Distribution License (the License). You may not use this file except in compliance with the
|
* License.
|
*
|
* You can obtain a copy of the License at legal/CDDLv1.0.txt. See the License for the
|
* specific language governing permission and limitations under the License.
|
*
|
* When distributing Covered Software, include this CDDL Header Notice in each file and include
|
* the License file at legal/CDDLv1.0.txt. If applicable, add the following below the CDDL
|
* Header, with the fields enclosed by brackets [] replaced by your own identifying
|
* information: "Portions Copyright [year] [name of copyright owner]".
|
*
|
* CDDL HEADER END
|
*
|
* Copyright 2013 ForgeRock AS.
|
* Portions Copyright 2013 IS4U.
|
*/
|
|
package org.forgerock.opendj.virtual;
|
|
import org.forgerock.opendj.ldap.Connection;
|
import org.forgerock.opendj.ldap.ConnectionFactory;
|
import org.forgerock.opendj.ldap.ErrorResultException;
|
import org.forgerock.opendj.ldap.FutureResult;
|
import org.forgerock.opendj.ldap.ResultHandler;
|
|
/**
|
* A factory class which can be used to obtain connections to an SQL Database
|
* Server.
|
*/
|
public final class JDBCConnectionFactory implements ConnectionFactory
|
{
|
private String ConnectionUrl = "";
|
private final String Host;
|
private final int Port;
|
private final String DbName;
|
private JDBCConnection jdbc;
|
|
/**
|
* Creates a new JDBC connection factory which can be used to create JDBC
|
* connections to the Database Server at the provided host and port
|
* address.
|
*
|
* @param host
|
* The host name.
|
* @param port
|
* The port number.
|
* @param dbName
|
* The name of the SQL database.
|
* @throws NullPointerException
|
* If {@code dbName} was {@code null}.
|
*/
|
public JDBCConnectionFactory(final String host, final int port, final String dbName)
|
{
|
this.Host = host;
|
this.Port = port;
|
this.DbName = dbName;
|
|
//For connection to h2 database, use this.ConnectionUrl="jdbc:h2"
|
this.ConnectionUrl="jdbc:mysql://"
|
.concat(Host+":")
|
.concat(Port+"/")
|
.concat(DbName);
|
}
|
|
/**
|
* Returns a connection to the Directory Server associated with this
|
* connection factory. The connection returned by this method can be used
|
* immediately.
|
* <p>
|
* If the calling thread is interrupted while waiting for the connection
|
* attempt to complete then the calling thread unblock and throw a
|
* {@link CancelledResultException} whose cause is the underlying
|
* {@link InterruptedException}.
|
*
|
* @return A connection to the Database Server associated with this
|
* connection factory.
|
* @throws ErrorResultException
|
* If the connection request failed for some reason.
|
*/
|
@Override
|
public Connection getConnection() throws ErrorResultException
|
{
|
if (jdbc == null){
|
this.jdbc = new JDBCConnection(ConnectionUrl);
|
}
|
return jdbc;
|
}
|
|
/**
|
* Returns the SQL database host name that was provided to this
|
* connection factory.
|
*
|
* @return The SQL database host name that this connection factory uses.
|
*/
|
public String getHostName()
|
{
|
return Host;
|
}
|
|
/**
|
* Returns the SQL database port number that was provided to this
|
* connection factory.
|
*
|
* @return The SQL database name that this connection factory uses.
|
*/
|
public int getPort()
|
{
|
return Port;
|
}
|
|
/**
|
* Returns the SQL database name that was provided to this
|
* connection factory.
|
*
|
* @return The SQL database name that this connection factory uses.
|
*/
|
public String getDatabaseName()
|
{
|
return DbName;
|
}
|
|
@Override
|
public FutureResult<Connection> getConnectionAsync(
|
ResultHandler<? super Connection> handler)
|
{
|
return null;
|
}
|
}
|
|
|
|
