Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.hibernate.jdbc
Class AbstractBatcher

java.lang.Object
  extended by org.hibernate.jdbc.AbstractBatcher
All Implemented Interfaces:
Batcher
Direct Known Subclasses:
BatchingBatcher, NonBatchingBatcher
public abstract class AbstractBatcher
extends java.lang.Object
implements Batcher

Manages prepared statements and batching.

Author:
Gavin King

Field Summary
protected static org.slf4j.Logger log
           
 
Constructor Summary
AbstractBatcher(ConnectionManager connectionManager, Interceptor interceptor)
           
 
Method Summary
 void abortBatch(java.sql.SQLException sqle)
          Must be called when an exception occurs
 void cancelLastQuery()
          Cancel the current query statement
 void closeConnection(java.sql.Connection conn)
          Dispose of the JDBC connection
 void closeQueryStatement(java.sql.PreparedStatement ps, java.sql.ResultSet rs)
          Close a prepared statement opened with prepareQueryStatement()
 void closeStatement(java.sql.PreparedStatement ps)
          Close a prepared or callable statement opened using prepareStatement() or prepareCallableStatement()
 void closeStatements()
          Actually releases the batcher, allowing it to cleanup internally held resources.
protected abstract  void doExecuteBatch(java.sql.PreparedStatement ps)
           
 void executeBatch()
          Execute the batch
protected  SessionFactoryImplementor getFactory()
           
 java.sql.ResultSet getResultSet(java.sql.CallableStatement ps, Dialect dialect)
          Execute the statement and return the result set from a callable statement
 java.sql.ResultSet getResultSet(java.sql.PreparedStatement ps)
          Execute the statement and return the result set
protected  java.sql.PreparedStatement getStatement()
           
 boolean hasOpenResources()
           
 java.sql.Connection openConnection()
          Obtain a JDBC connection
 java.lang.String openResourceStatsAsString()
           
 java.sql.CallableStatement prepareBatchCallableStatement(java.lang.String sql)
          Get a batchable callable statement to use for inserting / deleting / updating (might be called many times before a single call to executeBatch()).
 java.sql.PreparedStatement prepareBatchStatement(java.lang.String sql)
          Get a batchable prepared statement to use for inserting / deleting / updating (might be called many times before a single call to executeBatch()).
 java.sql.CallableStatement prepareCallableQueryStatement(java.lang.String sql, boolean scrollable, ScrollMode scrollMode)
          Get a prepared statement for use in loading / querying.
 java.sql.CallableStatement prepareCallableStatement(java.lang.String sql)
          Get a non-batchable callable statement to use for inserting / deleting / updating.
 java.sql.PreparedStatement prepareQueryStatement(java.lang.String sql, boolean scrollable, ScrollMode scrollMode)
          Get a prepared statement for use in loading / querying.
 java.sql.PreparedStatement prepareSelectStatement(java.lang.String sql)
          Get a non-batchable prepared statement to use for selecting.
 java.sql.PreparedStatement prepareStatement(java.lang.String sql)
          Get a non-batchable prepared statement to use for inserting / deleting / updating.
 java.sql.PreparedStatement prepareStatement(java.lang.String sql, boolean getGeneratedKeys)
          Get a non-batchable prepared statement to use for inserting / deleting / updating, using JDBC3 getGeneratedKeys (Connection.prepareStatement(String, int)).
 java.sql.PreparedStatement prepareStatement(java.lang.String sql, java.lang.String[] columnNames)
          Get a non-batchable prepared statement to use for inserting / deleting / updating.
 void setTransactionTimeout(int seconds)
          Set the transaction timeout to seconds later than the current system time.
 void unsetTransactionTimeout()
          Unset the transaction timeout, called after the end of a transaction.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.hibernate.jdbc.Batcher
addToBatch
 

Field Detail

log

protected static final org.slf4j.Logger log
Constructor Detail

AbstractBatcher

public AbstractBatcher(ConnectionManager connectionManager,
                       Interceptor interceptor)
Method Detail

setTransactionTimeout

public void setTransactionTimeout(int seconds)
Description copied from interface: Batcher
Set the transaction timeout to seconds later than the current system time.

Specified by:
setTransactionTimeout in interface Batcher

unsetTransactionTimeout

public void unsetTransactionTimeout()
Description copied from interface: Batcher
Unset the transaction timeout, called after the end of a transaction.

Specified by:
unsetTransactionTimeout in interface Batcher

getStatement

protected java.sql.PreparedStatement getStatement()

prepareCallableStatement

public java.sql.CallableStatement prepareCallableStatement(java.lang.String sql)
                                                    throws java.sql.SQLException,
                                                           HibernateException
Description copied from interface: Batcher
Get a non-batchable callable statement to use for inserting / deleting / updating.

Must be explicitly released by Batcher.closeStatement(java.sql.PreparedStatement) after use.

Specified by:
prepareCallableStatement in interface Batcher
Throws:
java.sql.SQLException
HibernateException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql)
                                            throws java.sql.SQLException,
                                                   HibernateException
Description copied from interface: Batcher
Get a non-batchable prepared statement to use for inserting / deleting / updating.

Must be explicitly released by Batcher.closeStatement(java.sql.PreparedStatement) after use.

Specified by:
prepareStatement in interface Batcher
Throws:
java.sql.SQLException
HibernateException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                   boolean getGeneratedKeys)
                                            throws java.sql.SQLException,
                                                   HibernateException
Description copied from interface: Batcher
Get a non-batchable prepared statement to use for inserting / deleting / updating, using JDBC3 getGeneratedKeys (Connection.prepareStatement(String, int)).

Must be explicitly released by Batcher.closeStatement(java.sql.PreparedStatement) after use.

Specified by:
prepareStatement in interface Batcher
Throws:
java.sql.SQLException
HibernateException

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql,
                                                   java.lang.String[] columnNames)
                                            throws java.sql.SQLException,
                                                   HibernateException
Description copied from interface: Batcher
Get a non-batchable prepared statement to use for inserting / deleting / updating. using JDBC3 getGeneratedKeys (Connection.prepareStatement(String, String[])).

Must be explicitly released by Batcher.closeStatement(java.sql.PreparedStatement) after use.

Specified by:
prepareStatement in interface Batcher
Throws:
java.sql.SQLException
HibernateException

prepareSelectStatement

public java.sql.PreparedStatement prepareSelectStatement(java.lang.String sql)
                                                  throws java.sql.SQLException,
                                                         HibernateException
Description copied from interface: Batcher
Get a non-batchable prepared statement to use for selecting. Does not result in execution of the current batch.

Specified by:
prepareSelectStatement in interface Batcher
Throws:
java.sql.SQLException
HibernateException

prepareQueryStatement

public java.sql.PreparedStatement prepareQueryStatement(java.lang.String sql,
                                                        boolean scrollable,
                                                        ScrollMode scrollMode)
                                                 throws java.sql.SQLException,
                                                        HibernateException
Description copied from interface: Batcher
Get a prepared statement for use in loading / querying. If not explicitly released by closeQueryStatement(), it will be released when the session is closed or disconnected.

Specified by:
prepareQueryStatement in interface Batcher
Throws:
java.sql.SQLException
HibernateException

prepareCallableQueryStatement

public java.sql.CallableStatement prepareCallableQueryStatement(java.lang.String sql,
                                                                boolean scrollable,
                                                                ScrollMode scrollMode)
                                                         throws java.sql.SQLException,
                                                                HibernateException
Description copied from interface: Batcher
Get a prepared statement for use in loading / querying. If not explicitly released by closeQueryStatement(), it will be released when the session is closed or disconnected.

Specified by:
prepareCallableQueryStatement in interface Batcher
Throws:
java.sql.SQLException
HibernateException

abortBatch

public void abortBatch(java.sql.SQLException sqle)
Description copied from interface: Batcher
Must be called when an exception occurs

Specified by:
abortBatch in interface Batcher
Parameters:
sqle - the (not null) exception that is the reason for aborting

getResultSet

public java.sql.ResultSet getResultSet(java.sql.PreparedStatement ps)
                                throws java.sql.SQLException
Description copied from interface: Batcher
Execute the statement and return the result set

Specified by:
getResultSet in interface Batcher
Throws:
java.sql.SQLException

getResultSet

public java.sql.ResultSet getResultSet(java.sql.CallableStatement ps,
                                       Dialect dialect)
                                throws java.sql.SQLException
Description copied from interface: Batcher
Execute the statement and return the result set from a callable statement

Specified by:
getResultSet in interface Batcher
Throws:
java.sql.SQLException

closeQueryStatement

public void closeQueryStatement(java.sql.PreparedStatement ps,
                                java.sql.ResultSet rs)
                         throws java.sql.SQLException
Description copied from interface: Batcher
Close a prepared statement opened with prepareQueryStatement()

Specified by:
closeQueryStatement in interface Batcher
Throws:
java.sql.SQLException

prepareBatchStatement

public java.sql.PreparedStatement prepareBatchStatement(java.lang.String sql)
                                                 throws java.sql.SQLException,
                                                        HibernateException
Description copied from interface: Batcher
Get a batchable prepared statement to use for inserting / deleting / updating (might be called many times before a single call to executeBatch()). After setting parameters, call addToBatch - do not execute the statement explicitly.

Specified by:
prepareBatchStatement in interface Batcher
Throws:
java.sql.SQLException
HibernateException
See Also:
Batcher.addToBatch(org.hibernate.jdbc.Expectation)

prepareBatchCallableStatement

public java.sql.CallableStatement prepareBatchCallableStatement(java.lang.String sql)
                                                         throws java.sql.SQLException,
                                                                HibernateException
Description copied from interface: Batcher
Get a batchable callable statement to use for inserting / deleting / updating (might be called many times before a single call to executeBatch()). After setting parameters, call addToBatch - do not execute the statement explicitly.

Specified by:
prepareBatchCallableStatement in interface Batcher
Throws:
java.sql.SQLException
HibernateException
See Also:
Batcher.addToBatch(org.hibernate.jdbc.Expectation)

executeBatch

public void executeBatch()
                  throws HibernateException
Description copied from interface: Batcher
Execute the batch

Specified by:
executeBatch in interface Batcher
Throws:
HibernateException

closeStatement

public void closeStatement(java.sql.PreparedStatement ps)
                    throws java.sql.SQLException
Description copied from interface: Batcher
Close a prepared or callable statement opened using prepareStatement() or prepareCallableStatement()

Specified by:
closeStatement in interface Batcher
Throws:
java.sql.SQLException

closeStatements

public void closeStatements()
Actually releases the batcher, allowing it to cleanup internally held resources.

Specified by:
closeStatements in interface Batcher

doExecuteBatch

protected abstract void doExecuteBatch(java.sql.PreparedStatement ps)
                                throws java.sql.SQLException,
                                       HibernateException
Throws:
java.sql.SQLException
HibernateException

getFactory

protected SessionFactoryImplementor getFactory()

openConnection

public java.sql.Connection openConnection()
                                   throws HibernateException
Description copied from interface: Batcher
Obtain a JDBC connection

Specified by:
openConnection in interface Batcher
Throws:
HibernateException

closeConnection

public void closeConnection(java.sql.Connection conn)
                     throws HibernateException
Description copied from interface: Batcher
Dispose of the JDBC connection

Specified by:
closeConnection in interface Batcher
Throws:
HibernateException

cancelLastQuery

public void cancelLastQuery()
                     throws HibernateException
Description copied from interface: Batcher
Cancel the current query statement

Specified by:
cancelLastQuery in interface Batcher
Throws:
HibernateException

hasOpenResources

public boolean hasOpenResources()
Specified by:
hasOpenResources in interface Batcher

openResourceStatsAsString

public java.lang.String openResourceStatsAsString()
Specified by:
openResourceStatsAsString in interface Batcher
Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD
Copyright © 2008 Hibernate.org. All Rights Reserved.