sfi.director.repository.JDBC Class Reference

Inheritance diagram for sfi.director.repository.JDBC:

Classes
class	CachedConnection
class	JDBCTableEnumeration
class	SelectEnumeration

Public Member Functions
	JDBC ()
	track number of maximum unsuccessful re-connection retries the LDAP is willing to do.
	JDBC (String url)
void	setCredentials (Credentials cred)
synchronized void	setURL (String url) throws DirectorException
Enumeration	search (String expr, final Options searchopt) throws DirectorException
DBAccessor	get (DN dn) throws DirectorException
void	remove (DBObject dbo) throws DirectorException
void	append (DBObject dbo) throws DirectorException
void	replace (DBObject dbo) throws DirectorException
void	truncate () throws DirectorException
Public Member Functions inherited from sfi.director.repository.DBConnection
String	getURL ()
void	setContext (RemoteJob context)
void	setOption (String option)
void	setOption (String option, String val)
void	setOption (Options opt)
void	setOption (SURL url)
String	getOption (String option)
void	setError (Exception e)
Exception	getError ()
DN	completeDN (DN dn)
Enumeration	search (String expr) throws DirectorException
abstract Enumeration	search (String expr, Options searchopt) throws DirectorException
void	modify (DBObject dbo, Vector attrs) throws DirectorException
void	close () throws DirectorException

Static Public Attributes
static final int	retryLoopDelay = 5000
static final int	retryMaxCount = 24
Static Public Attributes inherited from sfi.director.repository.DBConnection
static final String	SEARCH_BASEDN = "BaseDN"
	used in conjunction with the search() method to set the base DN of the subtree we are about to search (option)
static final String	SEARCH_NOSUB = "Sub"
static final String	SEARCH_WITHSTRUCT = "WithStruct"
static final String	SEARCH_SORT = "Sort"
static final String	SEARCH_SCHEMA = "Schema"

Protected Member Functions
CachedConnection	getCachedConnection () throws DirectorException
void	putCachedConnection (CachedConnection conn)
java.sql.Connection	getConnection () throws DirectorException
String	getPrimaryKey (java.sql.Connection conn, String tableName) throws Exception
String[]	parseDN (DN dn) throws DirectorException
String	encodeValue (String value)
String	sqlFilter (String attr, String value)
Hashtable	getColumns (java.sql.Connection conn, String table) throws DirectorException
Enumeration	enumerateTables (final String expr, final Options searchopt) throws DirectorException

Protected Attributes
boolean	wasConnectedBefore = false
Hashtable	columnCache = new Hashtable()
Vector	cachedConnections = new Vector()
Protected Attributes inherited from sfi.director.repository.DBConnection
String	url
RemoteJob	context
Options	options = new Options()
Exception	error = null

Static Protected Attributes
static int	reconnectRetries
static Hashtable	loadedDrivers = new Hashtable()

Additional Inherited Members
Static Public Member Functions inherited from sfi.director.repository.DBConnection
static Enumeration	unwrap (final Enumeration wrapped)
	Given an Enumeration of DBAccessor objects as returned by the search() method, returns an Enumeration of DBObject objects.
static String	escapeSearchval (String val)

Constructor & Destructor Documentation

sfi.director.repository.JDBC.JDBC

(

)

track number of maximum unsuccessful re-connection retries the LDAP is willing to do.

This is 'static' since we want to avoid the number of retries increase with the number of open connections.

sfi.director.repository.JDBC.JDBC

(

String

url

)

References sfi.director.repository.JDBC.setURL().

Member Function Documentation

void sfi.director.repository.JDBC.append ( DBObject  dbo ) throws DirectorException

virtual

  * 

Exceptions

DirectorException

Parameters

dbo

Implements sfi.director.repository.DBConnection.

References sfi.director.util.Tools.debug(), sfi.director.repository.JDBC.encodeValue(), sfi.director.repository.JDBC.getCachedConnection(), sfi.director.repository.JDBC.getColumns(), sfi.director.repository.JDBC.parseDN(), and sfi.director.repository.JDBC.putCachedConnection().

Referenced by sfi.director.repository.JDBC.replace().

String sfi.director.repository.JDBC.encodeValue ( String  value )

protected

Referenced by sfi.director.repository.JDBC.append(), sfi.director.repository.JDBC.replace(), and sfi.director.repository.JDBC.sqlFilter().

Enumeration sfi.director.repository.JDBC.enumerateTables ( final String  expr, final Options  searchopt  ) throws DirectorException

protected

References sfi.director.util.Tools.debug().

Referenced by sfi.director.repository.JDBC.get(), and sfi.director.repository.JDBC.search().

DBAccessor sfi.director.repository.JDBC.get

(

DN

dn

)

throws DirectorException

Reimplemented from sfi.director.repository.DBConnection.

References sfi.director.repository.JDBC.enumerateTables(), sfi.director.repository.JDBC.parseDN(), and sfi.director.repository.JDBC.sqlFilter().

CachedConnection sfi.director.repository.JDBC.getCachedConnection ( ) throws DirectorException

protected

References sfi.director.repository.JDBC.cachedConnections, and sfi.director.repository.JDBC.getConnection().

Referenced by sfi.director.repository.JDBC.append(), sfi.director.repository.JDBC.remove(), and sfi.director.repository.JDBC.replace().

Hashtable sfi.director.repository.JDBC.getColumns ( java.sql.Connection  conn, String  table  ) throws DirectorException

protected

References sfi.director.repository.JDBC.columnCache, and sfi.director.util.Tools.debug().

Referenced by sfi.director.repository.JDBC.append(), and sfi.director.repository.JDBC.replace().

java.sql.Connection sfi.director.repository.JDBC.getConnection ( ) throws DirectorException

protected

References sfi.director.util.Tools.debug(), sfi.director.util.Credentials.getPassword(), sfi.director.util.Credentials.getPrincipal(), sfi.director.util.Credentials.isCancelled(), sfi.director.repository.JDBC.reconnectRetries, sfi.director.repository.JDBC.retryLoopDelay, and sfi.director.repository.JDBC.wasConnectedBefore.

Referenced by sfi.director.repository.JDBC.getCachedConnection(), sfi.director.repository.JDBC.setURL(), and sfi.director.repository.JDBC.truncate().

String sfi.director.repository.JDBC.getPrimaryKey ( java.sql.Connection  conn, String  tableName  ) throws Exception

protected

String [] sfi.director.repository.JDBC.parseDN ( DN  dn ) throws DirectorException

protected

References sfi.director.util.Tools.split().

Referenced by sfi.director.repository.JDBC.append(), sfi.director.repository.JDBC.get(), sfi.director.repository.JDBC.remove(), sfi.director.repository.JDBC.replace(), and sfi.director.repository.JDBC.truncate().

void sfi.director.repository.JDBC.putCachedConnection ( CachedConnection  conn )

protected

References sfi.director.repository.JDBC.cachedConnections.

Referenced by sfi.director.repository.JDBC.append(), sfi.director.repository.JDBC.remove(), and sfi.director.repository.JDBC.replace().

void sfi.director.repository.JDBC.remove

(

DBObject

dbo

)

throws DirectorException

Reimplemented from sfi.director.repository.DBConnection.

References sfi.director.repository.JDBC.getCachedConnection(), sfi.director.repository.JDBC.parseDN(), sfi.director.repository.JDBC.putCachedConnection(), and sfi.director.repository.JDBC.sqlFilter().

void sfi.director.repository.JDBC.replace

(

DBObject

dbo

)

throws DirectorException

Reimplemented from sfi.director.repository.DBConnection.

References sfi.director.repository.JDBC.append(), sfi.director.util.Tools.debug(), sfi.director.repository.DBObject.diffAttributes(), sfi.director.repository.JDBC.encodeValue(), sfi.director.repository.JDBC.getCachedConnection(), sfi.director.repository.JDBC.getColumns(), sfi.director.repository.DBAccessor.getDBObject(), sfi.director.repository.JDBC.parseDN(), sfi.director.repository.JDBC.putCachedConnection(), and sfi.director.repository.JDBC.sqlFilter().

Enumeration sfi.director.repository.JDBC.search	(	String	expr,
		final Options	searchopt
	)		throws DirectorException

References sfi.director.repository.DN.append(), sfi.director.repository.DN.clone(), sfi.director.repository.JDBC.enumerateTables(), sfi.director.repository.DN.getRaw(), sfi.director.repository.DBConnection.SEARCH_BASEDN, and sfi.director.repository.DN.setRaw().

void sfi.director.repository.JDBC.setCredentials

(

Credentials

cred

)

Reimplemented from sfi.director.repository.DBConnection.

synchronized void sfi.director.repository.JDBC.setURL

(

String

url

)

throws DirectorException

Reimplemented from sfi.director.repository.DBConnection.

References sfi.director.util.Tools.debug(), sfi.director.repository.JDBC.getConnection(), sfi.director.util.Credentials.getCredentials(), sfi.director.util.SURL.getHost(), sfi.director.util.SURL.getProtocol(), sfi.director.repository.JDBC.loadedDrivers, sfi.director.util.Tools.log(), sfi.director.repository.JDBC.reconnectRetries, sfi.director.repository.JDBC.retryMaxCount, sfi.director.util.Logger.WARNING, and sfi.director.repository.JDBC.wasConnectedBefore.

Referenced by sfi.director.repository.JDBC.JDBC().

String sfi.director.repository.JDBC.sqlFilter ( String  attr, String  value  )

protected

References sfi.director.repository.JDBC.encodeValue().

Referenced by sfi.director.repository.JDBC.get(), sfi.director.repository.JDBC.remove(), and sfi.director.repository.JDBC.replace().

void sfi.director.repository.JDBC.truncate ( ) throws DirectorException

virtual

Implements sfi.director.repository.DBConnection.

References sfi.director.repository.JDBC.getConnection(), and sfi.director.repository.JDBC.parseDN().

Member Data Documentation

Vector sfi.director.repository.JDBC.cachedConnections = new Vector()

protected

Referenced by sfi.director.repository.JDBC.getCachedConnection(), and sfi.director.repository.JDBC.putCachedConnection().

Hashtable sfi.director.repository.JDBC.columnCache = new Hashtable()

protected

Referenced by sfi.director.repository.JDBC.getColumns().

Hashtable sfi.director.repository.JDBC.loadedDrivers = new Hashtable()

staticprotected

Referenced by sfi.director.repository.JDBC.setURL().

int sfi.director.repository.JDBC.reconnectRetries

staticprotected

Referenced by sfi.director.repository.JDBC.getConnection(), and sfi.director.repository.JDBC.setURL().

final int sfi.director.repository.JDBC.retryLoopDelay = 5000

static

Referenced by sfi.director.repository.JDBC.getConnection().

final int sfi.director.repository.JDBC.retryMaxCount = 24

static

Referenced by sfi.director.repository.JDBC.setURL().

boolean sfi.director.repository.JDBC.wasConnectedBefore = false

protected

Referenced by sfi.director.repository.JDBC.getConnection(), and sfi.director.repository.JDBC.setURL().

---

The documentation for this class was generated from the following file:

• director/src/sfi/director/repository/JDBC.java