com.databasesandlife.util.jdbc

Class ReadOnlyReconnectingDbConnection

java.lang.Object

com.databasesandlife.util.jdbc.ReadOnlyReconnectingDbConnection

All Implemented Interfaces:

DbQueryable

public class ReadOnlyReconnectingDbConnection
extends Object
implements DbQueryable

Read-only access to a database, which re-connects to the database if the connection is lost.

Is thread-safe, you can use this from multiple threads

It is assumed that the results of one query are read before the next one begins. Starting a new query can close the old database connection when reconnecting, meaning reads from previous queries might not work.

Author:

This source is copyright Adrian Smith and licensed under the LGPL 3.

See Also:

DbTransaction, Project on GitHub

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	ReadOnlyReconnectingDbConnection.ReconnectingDbQueryResultSet

Field Summary

Fields

Modifier and Type	Field and Description
protected DbTransaction.DbTransactionFactory	fac
protected ThreadLocal<DbTransaction>	tx

Constructor Summary

Constructors

Constructor and Description
ReadOnlyReconnectingDbConnection(DbTransaction.DbTransactionFactory fac)

Method Summary

Modifier and Type	Method and Description
DbTransaction.DbQueryResultSet	query(CharSequence sql, List<?> args)
DbTransaction.DbQueryResultSet	query(String sql, Object... args)

Methods inherited from class java.lang.Object

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

Field Detail

fac

protected DbTransaction.DbTransactionFactory fac

tx

protected ThreadLocal<DbTransaction> tx

Constructor Detail

ReadOnlyReconnectingDbConnection

public ReadOnlyReconnectingDbConnection(DbTransaction.DbTransactionFactory fac)

Method Detail

query

public DbTransaction.DbQueryResultSet query(String sql,
                                            Object... args)

Specified by:

query in interface DbQueryable

query

public DbTransaction.DbQueryResultSet query(CharSequence sql,
                                            List<?> args)

Specified by:

query in interface DbQueryable