com.goldencode.p2j.persist.orm

Class JdbcDataSource

java.lang.Object

com.goldencode.p2j.persist.orm.JdbcDataSource

class JdbcDataSource
extends java.lang.Object

A JDBC data source which wraps a C3P0 pooled data source. Access to pooled data sources is via static methods, and is organized by database.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	JdbcDataSource.DatabaseKey Class that handles a database key for the sources map.

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	batch Flag indicating whether data source supports batch operations
private javax.sql.DataSource	dataSource Delegate data source
(package private) static CentralLogger	log Logger
private static java.util.Map<JdbcDataSource.DatabaseKey,JdbcDataSource>	sources Concurrent map of instances, keyed by database keys.

Constructor Summary

Constructors

Modifier	Constructor and Description
private	JdbcDataSource(javax.sql.DataSource dataSource) Private constructor; all access is via static methods.

Method Summary

Modifier and Type	Method and Description
(package private) static java.sql.Connection	getConnection(Database database, DatabaseConfig cfg, java.lang.String tenantId) Get a JDBC connection from the pool, creating it if necessary.
private static JdbcDataSource	getDataSource(Database database, DatabaseConfig cfg, java.lang.String tenantId) Get the JDBC data source for the given database.
(package private) static boolean	supportsBatch(Database database) Indicate whether the data source represented by the given database object supports batch operations.

Methods inherited from class java.lang.Object

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

Field Detail

log

static final CentralLogger log

Logger

sources

private static java.util.Map<JdbcDataSource.DatabaseKey,JdbcDataSource> sources

Concurrent map of instances, keyed by database keys.

dataSource

private final javax.sql.DataSource dataSource

Delegate data source

batch

private final boolean batch

Flag indicating whether data source supports batch operations

Constructor Detail

JdbcDataSource

private JdbcDataSource(javax.sql.DataSource dataSource)
                throws PersistenceException

Private constructor; all access is via static methods. Reads configuration data from the application directory and constructs the data source accordingly.

Parameters:

dataSource - The data source. Note that only the database name is used directly to configure the data source; all other information is read from the directory or is derived, based on the database type.

Throws:

PersistenceException - if there is an error configuring or obtaining the data source.

Method Detail

getConnection

static java.sql.Connection getConnection(Database database,
                                         DatabaseConfig cfg,
                                         java.lang.String tenantId)
                                  throws PersistenceException

Get a JDBC connection from the pool, creating it if necessary.

Parameters:

database - Database with which the connection must be established.

cfg - The configuration of the given database.

tenantId - The id of the tenant.

Returns:

JDBC connection.

Throws:

PersistenceException - if there is an error configuring or obtaining the data source or connection.

supportsBatch

static boolean supportsBatch(Database database)
                      throws PersistenceException

Indicate whether the data source represented by the given database object supports batch operations.

Parameters:

database - Database for which batch support information is needed.

Returns:

true if batch operations are supported, else false.

Throws:

PersistenceException - if database metadata needs to be queried and there is an error doing so.

getDataSource

private static JdbcDataSource getDataSource(Database database,
                                            DatabaseConfig cfg,
                                            java.lang.String tenantId)
                                     throws PersistenceException

Get the JDBC data source for the given database.

Parameters:

database - Database object which identifies the data source.

cfg - The configuration of the given database.

tenantId - The id of the tenant.

Returns:

Data source object.

Throws:

PersistenceException - if there is an error configuring or obtaining the data source.