DBReplicator

Open Source Database Replication

• Home
• Documentation
• Downloads
• Supported Databases
• Community
• Site Help
• Contact
• Resources

Home

JavaDoc

• Developer Documentation
• Resource

org.dbreplicator.replication
Class ConnectionPool

java.lang.Object
  org.dbreplicator.replication.ConnectionPool

All Implemented Interfaces:

java.io.Serializable

public class ConnectionPool
extends java.lang.Object
implements java.io.Serializable

This class holds the mappings of all the connections in a perticular replication server. Every replication server has one copy of this class, that helps replication server to get different connections for different publications or subscriptions or default connection. This class stores this connection information in to a Map (connectionMap).

See Also:

Serialized Form

Constructor Summary

ConnectionPool()

ConnectionPool(javax.sql.DataSource dataSource)

ConnectionPool(javax.sql.DataSource dataSource, java.lang.String username, java.lang.String password)

ConnectionPool(java.lang.String url0, java.lang.String driver0, java.lang.String user0, java.lang.String password0)

Method Summary

static void	closeStatementAndResultSet(java.sql.Statement stmt, java.sql.ResultSet rs)
java.sql.Connection	getConnection(java.lang.String pubsubName)
java.sql.Connection	getDefaultConnection()
java.sql.Connection	getFreshConnection(java.lang.String pubsubName)
java.lang.String	getLocalAddress()
int	getLocalPortNo()
java.lang.String	getUserName()
void	removeSubPubFromMap(java.lang.String subPubName)
void	returnConnection(java.sql.Connection connection)
void	setLocalAddress(java.lang.String localAddress0)
void	setLocalPortNo(int localPort0)
java.net.ServerSocket	startServerSocket()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConnectionPool

public ConnectionPool()

ConnectionPool

public ConnectionPool(java.lang.String url0,
                      java.lang.String driver0,
                      java.lang.String user0,
                      java.lang.String password0)

ConnectionPool

public ConnectionPool(javax.sql.DataSource dataSource)

ConnectionPool

public ConnectionPool(javax.sql.DataSource dataSource,
                      java.lang.String username,
                      java.lang.String password)

Method Detail

getConnection

public java.sql.Connection getConnection(java.lang.String pubsubName)
                                  throws RepException

Throws:

RepException

getFreshConnection

public java.sql.Connection getFreshConnection(java.lang.String pubsubName)
                                       throws RepException

Throws:

RepException

setLocalAddress

public void setLocalAddress(java.lang.String localAddress0)

getLocalAddress

public java.lang.String getLocalAddress()

setLocalPortNo

public void setLocalPortNo(int localPort0)

getLocalPortNo

public int getLocalPortNo()

startServerSocket

public java.net.ServerSocket startServerSocket()
                                        throws RepException

Throws:

RepException

getUserName

public java.lang.String getUserName()

getDefaultConnection

public java.sql.Connection getDefaultConnection()
                                         throws RepException

Throws:

RepException

returnConnection

public void returnConnection(java.sql.Connection connection)
                      throws RepException

Throws:

RepException

removeSubPubFromMap

public void removeSubPubFromMap(java.lang.String subPubName)

closeStatementAndResultSet

public static void closeStatementAndResultSet(java.sql.Statement stmt,
                                              java.sql.ResultSet rs)