Package com.inductiveautomation.ignition.gateway.localdb

Class AbstractDBInterface

java.lang.Object

com.inductiveautomation.ignition.gateway.localdb.AbstractDBInterface

All Implemented Interfaces:

DBInterface

Direct Known Subclasses:

PersistenceSession.PersistenceSessionDBInterface

public abstract class AbstractDBInterface
extends Object
implements DBInterface

Created by colby.clegg on 11/17/2015.

Nested Class Summary

Nested classes/interfaces inherited from interface com.inductiveautomation.ignition.gateway.localdb.DBInterface

DBInterface.Transaction

Constructor Summary

Constructors

Constructor	Description
AbstractDBInterface()

Method Summary

Modifier and Type	Method	Description
abstract Connection	getConnection()
long	getSeq(String seqName)	Gets the next value in a sequence.
long	getSeq(String seqName, Connection connection)	Like the other getSeq, but operates against a particular local db connection, which may be necessary if the sequence generation is part of a transaction.
static List<List<Object>>	resultSetToListNatural(ResultSet rs)
List<List<Object>>	runPrepQuery(String stmt, Object... args)	Runs the given SELECT query as a prepared statement, after setting the arguments in the varargs list.
static List<List<Object>>	runPrepQuery(Connection con, String stmt, Object... args)
int	runPrepUpdate(String stmt, Serializable... args)	Runs the given UPDATE/INSERT/DELETE query as a prepared statement, after setting the arguments in the varargs list.
static int	runPrepUpdate(Connection con, String stmt, Serializable... args)
List<List<Object>>	runQuery(String query)	Runs the given SELECT query, and returns the results in a List of Lists of Objects.
static List<List<Object>>	runQuery(Connection con, String query)
Object	runScalarQuery(String query)	Runs the given query.
Object	runTransaction(DBInterface.Transaction tx)	Runs the given transaction with a new connection.
int	runUpdateQuery(String query)	Runs the given update query, and returns the number of rows affected.
static int	runUpdateQuery(Connection con, String query)
protected boolean	shouldCloseConnection()

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractDBInterface

public AbstractDBInterface()

Method Details

getConnection

public abstract Connection getConnection()
                                  throws SQLException

Specified by:

getConnection in interface DBInterface

Throws:

SQLException

shouldCloseConnection

protected boolean shouldCloseConnection()

resultSetToListNatural

public static List<List<Object>> resultSetToListNatural(ResultSet rs)
                                                 throws SQLException

Throws:

SQLException

getSeq

public long getSeq(String seqName)
            throws SQLException

Gets the next value in a sequence.

Specified by:

getSeq in interface DBInterface

Throws:

SQLException

getSeq

public long getSeq(String seqName,
 Connection connection)
            throws SQLException

Description copied from interface: DBInterface

Like the other getSeq, but operates against a particular local db connection, which may be necessary if the sequence generation is part of a transaction.

Specified by:

getSeq in interface DBInterface

Throws:

SQLException

runPrepQuery

public static List<List<Object>> runPrepQuery(Connection con,
 String stmt,
 Object... args)
                                       throws SQLException

Throws:

SQLException

runPrepQuery

public List<List<Object>> runPrepQuery(String stmt,
 Object... args)
                                throws SQLException

Description copied from interface: DBInterface

Runs the given SELECT query as a prepared statement, after setting the arguments in the varargs list. Returns the results in a List of Lists of Objects.

Specified by:

runPrepQuery in interface DBInterface

Throws:

SQLException

runPrepUpdate

public static int runPrepUpdate(Connection con,
 String stmt,
 Serializable... args)
                         throws SQLException

Throws:

SQLException

runPrepUpdate

public int runPrepUpdate(String stmt,
 Serializable... args)
                  throws SQLException

Description copied from interface: DBInterface

Runs the given UPDATE/INSERT/DELETE query as a prepared statement, after setting the arguments in the varargs list. Returns the number of rows affected.

Specified by:

runPrepUpdate in interface DBInterface

Throws:

SQLException

runQuery

public static List<List<Object>> runQuery(Connection con,
 String query)
                                   throws SQLException

Throws:

SQLException

runQuery

public List<List<Object>> runQuery(String query)
                            throws SQLException

Description copied from interface: DBInterface

Runs the given SELECT query, and returns the results in a List of Lists of Objects.

Specified by:

runQuery in interface DBInterface

Throws:

SQLException

runScalarQuery

public Object runScalarQuery(String query)
                      throws SQLException

Runs the given query. Returns null if no rows are returned, or the value at row 1 column 1 as a string if rows are returned.

Specified by:

runScalarQuery in interface DBInterface

Throws:

SQLException

runTransaction

public Object runTransaction(DBInterface.Transaction tx)
                      throws SQLException

Runs the given transaction with a new connection. Closes the connection if the transaction doesn't do it.

Specified by:

runTransaction in interface DBInterface

Throws:

SQLException

runUpdateQuery

public static int runUpdateQuery(Connection con,
 String query)
                          throws SQLException

Throws:

SQLException

runUpdateQuery

public int runUpdateQuery(String query)
                   throws SQLException

Runs the given update query, and returns the number of rows affected.

Specified by:

runUpdateQuery in interface DBInterface

Throws:

SQLException