org.opensubsystems.core.persist.db
Class DatabaseCreateMultipleDataObjectsOperation

java.lang.Object
  org.opensubsystems.core.persist.db.DatabaseOperation
      org.opensubsystems.core.persist.db.DatabaseUpdateOperation
          org.opensubsystems.core.persist.db.DatabaseCreateMultipleDataObjectsOperation

All Implemented Interfaces:

DatabaseOperations

public class DatabaseCreateMultipleDataObjectsOperation
extends DatabaseUpdateOperation

Adapter to simplify writing of batched database inserts, which takes care of requesting and returning connections, transaction management and exception handling. To use this adapter you just need to create an instance of this class and call executeUpdate method. Example of method in factory which creates collection of data using batch insert public int create( final Collection colDataObject ) throws OSSException { DatabaseBatchCreateOperation dbop = new DatabaseBatchCreateOperation( this, m_schema.getInsertMyData(), m_schema, dataType, colDataObject); dbop.executeUpdate(); return ((Integer)dbop.getReturnData()).intValue(); }

Version:

$Id: DatabaseCreateMultipleDataObjectsOperation.java,v 1.10 2007/01/28 06:54:42 bastafidli Exp $

Author:

Miro Halas

Code reviewer:

Miro Halas

Code reviewed:

1.7 2006/07/26 23:44:20 jlegeny

Field Summary

Fields inherited from class org.opensubsystems.core.persist.db.DatabaseOperation

m_data, m_dbschema, m_factory, m_iDataType, m_returnData, m_strQuery

Fields inherited from interface org.opensubsystems.core.persist.db.DatabaseOperations

DBOP_DELETE, DBOP_INSERT, DBOP_SELECT, DBOP_UPDATE

Constructor Summary

DatabaseCreateMultipleDataObjectsOperation(DatabaseFactoryImpl factory, java.lang.String query, ModifiableDatabaseSchema schema, java.util.Collection colDataObject, boolean bFetchGeneratedValues)
Constructor

Method Summary

protected void

performOperation(DatabaseFactoryImpl dbfactory, java.sql.Connection cntConnection, java.sql.PreparedStatement pstmQuery) Define content of this method to perform the database operation using the provided connection and optional prepared statement.

Methods inherited from class org.opensubsystems.core.persist.db.DatabaseUpdateOperation

executeUpdate, handleKnownError, handleSQLException, handleUnknownError, prepareData, setValuesForInsert, setValuesForUpdate

Methods inherited from class org.opensubsystems.core.persist.db.DatabaseOperation

getReturnData, setReturnData

Methods inherited from class java.lang.Object

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

Constructor Detail

DatabaseCreateMultipleDataObjectsOperation

public DatabaseCreateMultipleDataObjectsOperation(DatabaseFactoryImpl factory,
                                                  java.lang.String query,
                                                  ModifiableDatabaseSchema schema,
                                                  java.util.Collection colDataObject,
                                                  boolean bFetchGeneratedValues)

Constructor

Parameters:

factory - - factory which is executing this operation

query - - query to insert data

schema - - schema to set the data to the statement

colDataObject - - collection of data objects that will be created

bFetchGeneratedValues - - flag signaling if there have to be returned generated values true = there will be returned generated values false = will be returned number of inserted records

Method Detail

performOperation

protected void performOperation(DatabaseFactoryImpl dbfactory,
                                java.sql.Connection cntConnection,
                                java.sql.PreparedStatement pstmQuery)
                         throws OSSException,
                                java.sql.SQLException

Define content of this method to perform the database operation using the provided connection and optional prepared statement.

Overrides:

performOperation in class DatabaseUpdateOperation

Parameters:

dbfactory - - database factory used for this operation

cntConnection - - ready to use connection to perform the database operation. No need to return this connection.

pstmQuery - - prepared statement for query passed in as a parameter to the constructor. No need to close this statement. If no query was passed into constructor, this will be null.

Throws:

OSSException - - an error has occured

java.sql.SQLException - - an error has occured