From: Gautam J. <ga...@us...> - 2004-08-28 06:19:36
|
Update of /cvsroot/jaffa/JaffaCore/source/java/org/jaffa/persistence/engines In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv10945/source/java/org/jaffa/persistence/engines Modified Files: IPersistenceEngine.java Log Message: Added the flush() method to the UOW for flushing the add/update/delete queues of the persistence engine Index: IPersistenceEngine.java =================================================================== RCS file: /cvsroot/jaffa/JaffaCore/source/java/org/jaffa/persistence/engines/IPersistenceEngine.java,v retrieving revision 1.3 retrieving revision 1.4 diff -C2 -d -r1.3 -r1.4 *** IPersistenceEngine.java 14 May 2004 22:30:32 -0000 1.3 --- IPersistenceEngine.java 28 Aug 2004 06:19:11 -0000 1.4 *************** *** 58,62 **** */ public interface IPersistenceEngine { ! /** Generates an appropriate instance for the input persistentClass. * If the persistentClass is a 'Class', then it should implement the 'IPersistent' interface. The persistence engine will simply instantiate the class. --- 58,62 ---- */ public interface IPersistenceEngine { ! /** Generates an appropriate instance for the input persistentClass. * If the persistentClass is a 'Class', then it should implement the 'IPersistent' interface. The persistence engine will simply instantiate the class. *************** *** 66,101 **** */ public IPersistent newPersistentInstance(Class persistentClass); ! ! /** This is a helper method to determine the actual class which was used to create an IPersistent instance. * It is quite possible that the input object is a dynamic proxy. - * @param object The object which implements the IPersistent instance. * @return The class which was used for instantiating the instance. */ public Class getActualPersistentClass(Object persistentObject); ! /** * Adds an object to the persistent store. ! * The persistence engine may choose to add the object(s) only on a <code>commit</code>. * @param object The object to persist. * @throws AddFailedException if any error occurs during the process. */ public void add(IPersistent object) throws AddFailedException; ! /** * Updates an object from the persistent store. ! * The persistence engine may choose to update the object(s) only on a <code>commit</code>. * @param object The object to update. * @throws UpdateFailedException if any error occurs during the process. */ public void update(IPersistent object) throws UpdateFailedException; ! /** * Deletes an object from the persistent store. ! * The persistence engine may choose to delete the object(s) only on a <code>commit</code>. * @param object The object to delete from persistent storage. * @throws DeleteFailedException if any error occurs during the process. */ public void delete(IPersistent object) throws DeleteFailedException; ! /** * Queries the underlying persistent store based on the search profile passed in the Criteria object. --- 66,102 ---- */ public IPersistent newPersistentInstance(Class persistentClass); ! ! /** ! * This is a helper method to determine the actual class which was used to create an IPersistent instance. * It is quite possible that the input object is a dynamic proxy. * @return The class which was used for instantiating the instance. + * @param persistentObject An IPersistence instance. */ public Class getActualPersistentClass(Object persistentObject); ! /** * Adds an object to the persistent store. ! * The persistence engine may choose to add the object(s) only on a <code>commit</code or on a <code>flush</code> * @param object The object to persist. * @throws AddFailedException if any error occurs during the process. */ public void add(IPersistent object) throws AddFailedException; ! /** * Updates an object from the persistent store. ! * The persistence engine may choose to update the object(s) only on a <code>commit</code> or on a <code>flush</code>. * @param object The object to update. * @throws UpdateFailedException if any error occurs during the process. */ public void update(IPersistent object) throws UpdateFailedException; ! /** * Deletes an object from the persistent store. ! * The persistence engine may choose to delete the object(s) only on a <code>commit</code> or on a <code>flush</code>. * @param object The object to delete from persistent storage. * @throws DeleteFailedException if any error occurs during the process. */ public void delete(IPersistent object) throws DeleteFailedException; ! /** * Queries the underlying persistent store based on the search profile passed in the Criteria object. *************** *** 106,110 **** */ public Collection query(Criteria criteria) throws QueryFailedException, PostLoadFailedException; ! /** * Objects that have been added, objects that have been deleted, --- 107,118 ---- */ public Collection query(Criteria criteria) throws QueryFailedException, PostLoadFailedException; ! ! /** ! * Flushes the add/update/delete queues of the persistence engine. ! * This will have no effect if the persistence engine does not queue the add, update or the delete operations. ! * @throws UOWException if any error occurs. ! */ ! public void flush() throws UOWException; ! /** * Objects that have been added, objects that have been deleted, *************** *** 117,121 **** */ public void commit() throws AddFailedException, UpdateFailedException, DeleteFailedException, CommitFailedException; ! /** * Rollbacks all the additions, deletions, updations. --- 125,129 ---- */ public void commit() throws AddFailedException, UpdateFailedException, DeleteFailedException, CommitFailedException; ! /** * Rollbacks all the additions, deletions, updations. *************** *** 123,130 **** */ public void rollback() throws RollbackFailedException; ! /** Frees up the connection to the database. */ public void close(); ! /** * This will acquire a lock on the database row corrsponding to the input persistent object. --- 131,138 ---- */ public void rollback() throws RollbackFailedException; ! /** Frees up the connection to the database. */ public void close(); ! /** * This will acquire a lock on the database row corrsponding to the input persistent object. |