org.openanzo.server.repository.rdb.sql
Class LastTransactionTime

java.lang.Object
  org.openanzo.server.repository.rdb.sql.LastTransactionTime

public class LastTransactionTime
extends java.lang.Object

LastTransactionTime provides wrappers around SQL queries and transforms ResultSets into java objects

Author:

Generated Source from org.openanzo.jdbc.utils.opgen.jet

Nested Class Summary

static class	LastTransactionTime.BatchInsertFirstTransactionTime Batch operation for adding parameters to the InsertFirstTransactionTime prepared statement
static class	LastTransactionTime.BatchInsertLastTransactionTime Batch operation for adding parameters to the InsertLastTransactionTime prepared statement
static class	LastTransactionTime.BatchInsertTransactionTimes Batch operation for adding parameters to the InsertTransactionTimes prepared statement
static interface	LastTransactionTime.GetLastTransactionResult Interface for holding the results of the getLastTransaction prepared statement.
static class	LastTransactionTime.GetLastTransactionResultImpl Default implementation of GetLastTransactionResult
static interface	LastTransactionTime.InsertFirstTransactionTimeParams Interface for managing the parameters to the insertFirstTransactionTime prepared statement.
static class	LastTransactionTime.InsertFirstTransactionTimeParamsImpl Default implementation of InsertFirstTransactionTimeParams
static interface	LastTransactionTime.InsertLastTransactionTimeParams Interface for managing the parameters to the insertLastTransactionTime prepared statement.
static class	LastTransactionTime.InsertLastTransactionTimeParamsImpl Default implementation of InsertLastTransactionTimeParams
static interface	LastTransactionTime.PrefetchPredicateUrisResult Interface for holding the results of the prefetchPredicateUris prepared statement.
static class	LastTransactionTime.PrefetchPredicateUrisResultImpl Default implementation of PrefetchPredicateUrisResult

Field Summary

static java.lang.String	getLastTransaction Constant "getLastTransaction" used to reference prepared statement LastTransaction.getLastTransaction SELECT COMMITED,LASTID FROM LASTTRANSACTIONTIME WHERE ID=0
static java.lang.String	getLastTransactionTime Constant "getLastTransactionTime" used to reference prepared statement LastTransaction.getLastTransactionTime SELECT MAX(COMMITED) FROM TRANSACTIONTIMES
static java.lang.String	getTransactionId Constant "getTransactionId" used to reference prepared statement LastTransaction.getTransactionId SELECT LASTID FROM TRANSACTIONTIMES WHERE COMMITED=?
static java.lang.String	insertFirstTransactionTime Constant "insertFirstTransactionTime" used to reference prepared statement LastTransaction.insertFirstTransactionTime INSERT INTO LASTTRANSACTIONTIME (ID,COMMITED,LASTID)VALUES(0,?,?)
static java.lang.String	insertLastTransactionTime Constant "insertLastTransactionTime" used to reference prepared statement LastTransaction.insertLastTransactionTime UPDATE LASTTRANSACTIONTIME SET COMMITED=?,LASTID=? WHERE ID=0
static java.lang.String	insertTransactionTimes Constant "insertTransactionTimes" used to reference prepared statement LastTransaction.insertTransactionTimes INSERT INTO TRANSACTIONTIMES (COMMITED,LASTID) SELECT COMMITED,LASTID FROM LASTTRANSACTIONTIME WHERE ID=0
static java.lang.String	prefetchPredicateUris Constant "prefetchPredicateUris" used to reference prepared statement LastTransaction.prefetchPredicateUris SELECT B.ID,B.VALUE FROM (SELECT COUNT(*) AS CNT,PROP FROM STATEMENTS WHERE HEND IS NULL GROUP BY PROP HAVING COUNT(*) > 1000) A JOIN (SELECT ID,VALUE FROM ${a}_U) B ON A.PROP=B.ID
static java.lang.String	selectCurrentTimestamp Constant "selectCurrentTimestamp" used to reference prepared statement LastTransaction.selectCurrentTimestamp NULL

Constructor Summary

LastTransactionTime()

Method Summary

static LastTransactionTime.GetLastTransactionResult	getLastTransaction(PreparedStatementCache sqlCache) Runs the getLastTransaction prepared statement.
static LastTransactionTime.GetLastTransactionResult	getLastTransaction(PreparedStatementCache sqlCache, LastTransactionTime.GetLastTransactionResult result) Runs the getLastTransaction prepared statement.
static java.lang.Long	getLastTransactionTime(PreparedStatementCache sqlCache) Runs the getLastTransactionTime prepared statement.
static java.lang.Long	getTransactionId(PreparedStatementCache sqlCache, java.lang.Long transactiontime) Runs the getTransactionId prepared statement.
static void	insertFirstTransactionTime(PreparedStatementCache sqlCache, LastTransactionTime.InsertFirstTransactionTimeParams params) Runs the insertFirstTransactionTime prepared statement.
static void	insertFirstTransactionTime(PreparedStatementCache sqlCache, java.lang.Long commited, long id) Runs the insertFirstTransactionTime prepared statement.
static void	insertLastTransactionTime(PreparedStatementCache sqlCache, LastTransactionTime.InsertLastTransactionTimeParams params) Runs the insertLastTransactionTime prepared statement.
static void	insertLastTransactionTime(PreparedStatementCache sqlCache, java.lang.Long commited, long id) Runs the insertLastTransactionTime prepared statement.
static void	insertTransactionTimes(PreparedStatementCache sqlCache) Runs the insertTransactionTimes prepared statement.
static ClosableIterator<LastTransactionTime.PrefetchPredicateUrisResult>	prefetchPredicateUris(PreparedStatementCache sqlCache, java.lang.String tableNamePrefix) Runs the prefetchPredicateUris prepared statement with the default transformer.
static ClosableIterator<LastTransactionTime.PrefetchPredicateUrisResult>	prefetchPredicateUris(PreparedStatementCache sqlCache, java.lang.String tableNamePrefix, Transformer<LastTransactionTime.PrefetchPredicateUrisResult> transform) Runs the prefetchPredicateUris prepared statement.
static void	prepareGetLastTransaction(java.sql.PreparedStatement ps) Sets the input parameters for the getLastTransaction prepared statement.
static void	prepareGetLastTransactionTime(java.sql.PreparedStatement ps) Sets the input parameters for the getLastTransactionTime prepared statement.
static void	prepareGetTransactionId(java.sql.PreparedStatement ps, java.lang.Long transactiontime) Sets the input parameters for the getTransactionId prepared statement.
static void	prepareInsertFirstTransactionTime(java.sql.PreparedStatement ps, java.lang.Long commited, long id) Sets the input parameters for the insertFirstTransactionTime prepared statement.
static void	prepareInsertLastTransactionTime(java.sql.PreparedStatement ps, java.lang.Long commited, long id) Sets the input parameters for the insertLastTransactionTime prepared statement.
static void	prepareInsertTransactionTimes(java.sql.PreparedStatement ps) Sets the input parameters for the insertTransactionTimes prepared statement.
static void	preparePrefetchPredicateUris(java.sql.PreparedStatement ps) Sets the input parameters for the prefetchPredicateUris prepared statement.
static void	prepareSelectCurrentTimestamp(java.sql.PreparedStatement ps) Sets the input parameters for the selectCurrentTimestamp prepared statement.
static java.sql.Timestamp	selectCurrentTimestamp(PreparedStatementCache sqlCache) Runs the selectCurrentTimestamp prepared statement.

Methods inherited from class java.lang.Object

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

Field Detail

getLastTransactionTime

public static final java.lang.String getLastTransactionTime

Constant "getLastTransactionTime" used to reference prepared statement LastTransaction.getLastTransactionTime SELECT MAX(COMMITED) FROM TRANSACTIONTIMES

See Also:

Constant Field Values

getLastTransaction

public static final java.lang.String getLastTransaction

Constant "getLastTransaction" used to reference prepared statement LastTransaction.getLastTransaction SELECT COMMITED,LASTID FROM LASTTRANSACTIONTIME WHERE ID=0

See Also:

Constant Field Values

getTransactionId

public static final java.lang.String getTransactionId

Constant "getTransactionId" used to reference prepared statement LastTransaction.getTransactionId SELECT LASTID FROM TRANSACTIONTIMES WHERE COMMITED=?

See Also:

Constant Field Values

insertLastTransactionTime

public static final java.lang.String insertLastTransactionTime

Constant "insertLastTransactionTime" used to reference prepared statement LastTransaction.insertLastTransactionTime UPDATE LASTTRANSACTIONTIME SET COMMITED=?,LASTID=? WHERE ID=0

See Also:

Constant Field Values

insertTransactionTimes

public static final java.lang.String insertTransactionTimes

Constant "insertTransactionTimes" used to reference prepared statement LastTransaction.insertTransactionTimes INSERT INTO TRANSACTIONTIMES (COMMITED,LASTID) SELECT COMMITED,LASTID FROM LASTTRANSACTIONTIME WHERE ID=0

See Also:

Constant Field Values

insertFirstTransactionTime

public static final java.lang.String insertFirstTransactionTime

Constant "insertFirstTransactionTime" used to reference prepared statement LastTransaction.insertFirstTransactionTime INSERT INTO LASTTRANSACTIONTIME (ID,COMMITED,LASTID)VALUES(0,?,?)

See Also:

Constant Field Values

prefetchPredicateUris

public static final java.lang.String prefetchPredicateUris

Constant "prefetchPredicateUris" used to reference prepared statement LastTransaction.prefetchPredicateUris SELECT B.ID,B.VALUE FROM (SELECT COUNT(*) AS CNT,PROP FROM STATEMENTS WHERE HEND IS NULL GROUP BY PROP HAVING COUNT(*) > 1000) A JOIN (SELECT ID,VALUE FROM ${a}_U) B ON A.PROP=B.ID

See Also:

Constant Field Values

selectCurrentTimestamp

public static final java.lang.String selectCurrentTimestamp

Constant "selectCurrentTimestamp" used to reference prepared statement LastTransaction.selectCurrentTimestamp NULL

See Also:

Constant Field Values

Constructor Detail

LastTransactionTime

public LastTransactionTime()

Method Detail

getLastTransactionTime

public static java.lang.Long getLastTransactionTime(PreparedStatementCache sqlCache)
                                             throws AnzoException,
                                                    java.sql.SQLException

Runs the getLastTransactionTime prepared statement. SELECT MAX(COMMITED) FROM TRANSACTIONTIMES

Parameters:

sqlCache - factory and cache of PreparedStatments

Returns:

Long

Throws:

AnzoException

java.sql.SQLException

prepareGetLastTransactionTime

public static void prepareGetLastTransactionTime(java.sql.PreparedStatement ps)
                                          throws java.sql.SQLException

Sets the input parameters for the getLastTransactionTime prepared statement.

Parameters:

ps - PreparedStatement to whose parameters are set

Throws:

java.sql.SQLException

getLastTransaction

public static LastTransactionTime.GetLastTransactionResult getLastTransaction(PreparedStatementCache sqlCache)
                                                                       throws AnzoException,
                                                                              java.sql.SQLException

Runs the getLastTransaction prepared statement. SELECT COMMITED,LASTID FROM LASTTRANSACTIONTIME WHERE ID=0

Parameters:

sqlCache - factory and cache of PreparedStatments

Returns:

GetLastTransactionResult containing the results of the SQL operation

Throws:

AnzoException

java.sql.SQLException

getLastTransaction

public static LastTransactionTime.GetLastTransactionResult getLastTransaction(PreparedStatementCache sqlCache,
                                                                              LastTransactionTime.GetLastTransactionResult result)
                                                                       throws AnzoException,
                                                                              java.sql.SQLException

Runs the getLastTransaction prepared statement. SELECT COMMITED,LASTID FROM LASTTRANSACTIONTIME WHERE ID=0

Parameters:

sqlCache - factory and cache of PreparedStatments

result - GetLastTransactionResult result object

Returns:

GetLastTransactionResult

Throws:

AnzoException

java.sql.SQLException

prepareGetLastTransaction

public static void prepareGetLastTransaction(java.sql.PreparedStatement ps)
                                      throws java.sql.SQLException

Sets the input parameters for the getLastTransaction prepared statement.

Parameters:

ps - PreparedStatement to whose parameters are set

Throws:

java.sql.SQLException

getTransactionId

public static java.lang.Long getTransactionId(PreparedStatementCache sqlCache,
                                              java.lang.Long transactiontime)
                                       throws AnzoException,
                                              java.sql.SQLException

Runs the getTransactionId prepared statement. SELECT LASTID FROM TRANSACTIONTIMES WHERE COMMITED=?

Parameters:

sqlCache - factory and cache of PreparedStatments

transactiontime - template parameter

Returns:

Long

Throws:

AnzoException

java.sql.SQLException

prepareGetTransactionId

public static void prepareGetTransactionId(java.sql.PreparedStatement ps,
                                           java.lang.Long transactiontime)
                                    throws java.sql.SQLException

Sets the input parameters for the getTransactionId prepared statement.

Parameters:

ps - PreparedStatement to whose parameters are set

transactiontime - template parameter

Throws:

java.sql.SQLException

insertLastTransactionTime

public static void insertLastTransactionTime(PreparedStatementCache sqlCache,
                                             LastTransactionTime.InsertLastTransactionTimeParams params)
                                      throws AnzoException,
                                             java.sql.SQLException

Runs the insertLastTransactionTime prepared statement. UPDATE LASTTRANSACTIONTIME SET COMMITED=?,LASTID=? WHERE ID=0

Parameters:

sqlCache - factory and cache of PreparedStatments

params - InsertLastTransactionTimeParams input Interface

Throws:

AnzoException

java.sql.SQLException

insertLastTransactionTime

public static void insertLastTransactionTime(PreparedStatementCache sqlCache,
                                             java.lang.Long commited,
                                             long id)
                                      throws AnzoException,
                                             java.sql.SQLException

Runs the insertLastTransactionTime prepared statement. UPDATE LASTTRANSACTIONTIME SET COMMITED=?,LASTID=? WHERE ID=0

Parameters:

sqlCache - factory and cache of PreparedStatments

commited - template parameter

id - template parameter

Throws:

AnzoException

java.sql.SQLException

prepareInsertLastTransactionTime

public static void prepareInsertLastTransactionTime(java.sql.PreparedStatement ps,
                                                    java.lang.Long commited,
                                                    long id)
                                             throws java.sql.SQLException

Sets the input parameters for the insertLastTransactionTime prepared statement.

Parameters:

ps - PreparedStatement to whose parameters are set

commited - template parameter

id - template parameter

Throws:

java.sql.SQLException

insertTransactionTimes

public static void insertTransactionTimes(PreparedStatementCache sqlCache)
                                   throws AnzoException,
                                          java.sql.SQLException

Runs the insertTransactionTimes prepared statement. INSERT INTO TRANSACTIONTIMES (COMMITED,LASTID) SELECT COMMITED,LASTID FROM LASTTRANSACTIONTIME WHERE ID=0

Parameters:

sqlCache - factory and cache of PreparedStatments

Throws:

AnzoException

java.sql.SQLException

prepareInsertTransactionTimes

public static void prepareInsertTransactionTimes(java.sql.PreparedStatement ps)
                                          throws java.sql.SQLException

Sets the input parameters for the insertTransactionTimes prepared statement.

Parameters:

ps - PreparedStatement to whose parameters are set

Throws:

java.sql.SQLException

insertFirstTransactionTime

public static void insertFirstTransactionTime(PreparedStatementCache sqlCache,
                                              LastTransactionTime.InsertFirstTransactionTimeParams params)
                                       throws AnzoException,
                                              java.sql.SQLException

Runs the insertFirstTransactionTime prepared statement. INSERT INTO LASTTRANSACTIONTIME (ID,COMMITED,LASTID)VALUES(0,?,?)

Parameters:

sqlCache - factory and cache of PreparedStatments

params - InsertFirstTransactionTimeParams input Interface

Throws:

AnzoException

java.sql.SQLException

insertFirstTransactionTime

public static void insertFirstTransactionTime(PreparedStatementCache sqlCache,
                                              java.lang.Long commited,
                                              long id)
                                       throws AnzoException,
                                              java.sql.SQLException

Runs the insertFirstTransactionTime prepared statement. INSERT INTO LASTTRANSACTIONTIME (ID,COMMITED,LASTID)VALUES(0,?,?)

Parameters:

sqlCache - factory and cache of PreparedStatments

commited - template parameter

id - template parameter

Throws:

AnzoException

java.sql.SQLException

prepareInsertFirstTransactionTime

public static void prepareInsertFirstTransactionTime(java.sql.PreparedStatement ps,
                                                     java.lang.Long commited,
                                                     long id)
                                              throws java.sql.SQLException

Sets the input parameters for the insertFirstTransactionTime prepared statement.

Parameters:

ps - PreparedStatement to whose parameters are set

commited - template parameter

id - template parameter

Throws:

java.sql.SQLException

prefetchPredicateUris

public static ClosableIterator<LastTransactionTime.PrefetchPredicateUrisResult> prefetchPredicateUris(PreparedStatementCache sqlCache,
                                                                                                      java.lang.String tableNamePrefix)
                                                                                               throws AnzoException,
                                                                                                      java.sql.SQLException

Runs the prefetchPredicateUris prepared statement with the default transformer. SELECT B.ID,B.VALUE FROM (SELECT COUNT(*) AS CNT,PROP FROM STATEMENTS WHERE HEND IS NULL GROUP BY PROP HAVING COUNT(*) > 1000) A JOIN (SELECT ID,VALUE FROM ${a}_U) B ON A.PROP=B.ID

Parameters:

sqlCache - factory and cache of PreparedStatments

tableNamePrefix - template parameter

Returns:

org.openanzo.jdbc.utils.ClosableIterator

Throws:

AnzoException

java.sql.SQLException

prefetchPredicateUris

public static ClosableIterator<LastTransactionTime.PrefetchPredicateUrisResult> prefetchPredicateUris(PreparedStatementCache sqlCache,
                                                                                                      java.lang.String tableNamePrefix,
                                                                                                      Transformer<LastTransactionTime.PrefetchPredicateUrisResult> transform)
                                                                                               throws AnzoException,
                                                                                                      java.sql.SQLException

Runs the prefetchPredicateUris prepared statement. SELECT B.ID,B.VALUE FROM (SELECT COUNT(*) AS CNT,PROP FROM STATEMENTS WHERE HEND IS NULL GROUP BY PROP HAVING COUNT(*) > 1000) A JOIN (SELECT ID,VALUE FROM ${a}_U) B ON A.PROP=B.ID

Parameters:

sqlCache - factory and cache of PreparedStatments

tableNamePrefix - template parameter

transform - org.openanzo.jdbc.utils.Transformer used to transform results into java objects

Returns:

org.openanzo.jdbc.utils.ClosableIterator

Throws:

AnzoException

java.sql.SQLException

preparePrefetchPredicateUris

public static void preparePrefetchPredicateUris(java.sql.PreparedStatement ps)
                                         throws java.sql.SQLException

Sets the input parameters for the prefetchPredicateUris prepared statement.

Parameters:

ps - PreparedStatement to whose parameters are set

Throws:

java.sql.SQLException

selectCurrentTimestamp

public static java.sql.Timestamp selectCurrentTimestamp(PreparedStatementCache sqlCache)
                                                 throws AnzoException,
                                                        java.sql.SQLException

Runs the selectCurrentTimestamp prepared statement. NULL

Parameters:

sqlCache - factory and cache of PreparedStatments

Returns:

java.sql.Timestamp

Throws:

AnzoException

java.sql.SQLException

prepareSelectCurrentTimestamp

public static void prepareSelectCurrentTimestamp(java.sql.PreparedStatement ps)
                                          throws java.sql.SQLException

Sets the input parameters for the selectCurrentTimestamp prepared statement.

Parameters:

ps - PreparedStatement to whose parameters are set

Throws:

java.sql.SQLException