Set the transaction lock mode

trajano · Jun 20, 2011 · 7ef94a2 · 7ef94a2
1 parent f491027
commit 7ef94a2
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/src/main/java/net/trajano/berkeleydbhttpcachestorage/internal/BerkeleyDBCacheDatabase.java b/src/main/java/net/trajano/berkeleydbhttpcachestorage/internal/BerkeleyDBCacheDatabase.java
@@ -14,6 +14,7 @@
 import com.sleepycat.je.Database;
 import com.sleepycat.je.DatabaseEntry;
 import com.sleepycat.je.DatabaseException;
+import com.sleepycat.je.LockMode;
 import com.sleepycat.je.OperationStatus;
 import com.sleepycat.je.Transaction;
 
@@ -66,7 +67,7 @@ public HttpCacheEntry getEntry(final Transaction txn, final String key)
 		try {
 			final DatabaseEntry data = new DatabaseEntry();
 			final OperationStatus status = database.get(txn, new DatabaseEntry(
-					key.getBytes()), data, null);
+					key.getBytes()), data, LockMode.READ_COMMITTED);
 			if (status == OperationStatus.NOTFOUND) {
 				return null;
 			} else if (status == OperationStatus.SUCCESS) {
@@ -159,7 +160,7 @@ public void updateEntry(final Transaction txn, final String key,
 			// Made not final as this will get replaced.
 			HttpCacheEntry entry;
 			final OperationStatus status = database.get(txn, new DatabaseEntry(
-					key.getBytes()), data, null);
+					key.getBytes()), data, LockMode.READ_COMMITTED);
 			if (status == OperationStatus.NOTFOUND) {
 				entry = null;
 			} else if (status == OperationStatus.SUCCESS) {

diff --git a/src/main/java/net/trajano/berkeleydbhttpcachestorage/internal/package-info.java b/src/main/java/net/trajano/berkeleydbhttpcachestorage/internal/package-info.java
@@ -1,5 +1,6 @@
 /**
- * Internal classes used by BerkleyDbHttpCacheStorage.
+ * Internal classes used by BerkleyDbHttpCacheStorage.  Clients should not use
+ * any of the classes in this package directly.
  */
 package net.trajano.berkeleydbhttpcachestorage.internal;