taylor 2003/08/22 17:07:06
Modified: plugin/src/java/org/apache/jetspeed/persistence
PersistencePlugin.java
plugin/src/java/org/apache/jetspeed/persistence/impl
AbstractOJBPersistencePlugin.java
Log:
added invalidateObject method to persistence plugin
this can be useful for making sure that you get an object from the persistence store
and not the cache
Revision Changes Path
1.2 +9 -1
jakarta-jetspeed-2/plugin/src/java/org/apache/jetspeed/persistence/PersistencePlugin.java
Index: PersistencePlugin.java
===================================================================
RCS file:
/home/cvs/jakarta-jetspeed-2/plugin/src/java/org/apache/jetspeed/persistence/PersistencePlugin.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- PersistencePlugin.java 13 Aug 2003 21:21:28 -0000 1.1
+++ PersistencePlugin.java 23 Aug 2003 00:07:06 -0000 1.2
@@ -213,4 +213,12 @@
void releaseSqlConnection(Connection sqlConnection);
+
+ /**
+ * Invalidates the object in the object cache, effectively forcing the object
+ * to be refreshed from the database.
+ *
+ * @param object The object to be invalidated from the cache
+ */
+ void invalidateObject(Object object);
}
1.3 +8 -1
jakarta-jetspeed-2/plugin/src/java/org/apache/jetspeed/persistence/impl/AbstractOJBPersistencePlugin.java
Index: AbstractOJBPersistencePlugin.java
===================================================================
RCS file:
/home/cvs/jakarta-jetspeed-2/plugin/src/java/org/apache/jetspeed/persistence/impl/AbstractOJBPersistencePlugin.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- AbstractOJBPersistencePlugin.java 14 Aug 2003 16:00:17 -0000 1.2
+++ AbstractOJBPersistencePlugin.java 23 Aug 2003 00:07:06 -0000 1.3
@@ -323,7 +323,7 @@
connectionToPBMap = new HashMap();
String correctPath =
configuration.getPathResolver().getRealPath(configuration.getProperty("OJB.path") +
File.separator);
-
+System.out.println("correctPath = " + correctPath);
File ojbPropsLocation = new File(correctPath);
URL ojbUrl = null;
if (ojbPropsLocation.exists())
@@ -543,5 +543,12 @@
{
return getCollectionByQuery(clazz, new Criteria());
}
+
+ public void invalidateObject(Object object)
+ {
+ PersistenceBroker broker = getBroker();
+ broker.removeFromCache(object);
+ }
+
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
