diff options
| author | Brian S. O'Neill <bronee@gmail.com> | 2006-10-17 23:32:59 +0000 |
|---|---|---|
| committer | Brian S. O'Neill <bronee@gmail.com> | 2006-10-17 23:32:59 +0000 |
| commit | 30cc7f1c3943be87573849864f1f0637fd5cc3c6 (patch) | |
| tree | af8c1e479d97bed96eb28e6fc55358f48c71fa74 /src/main/java/com/amazon/carbonado/spi/LobEngine.java | |
| parent | 987e5b79304062308a5d304a57dabcce97654867 (diff) | |
Prevent accidental replication of internal storables.
Diffstat (limited to 'src/main/java/com/amazon/carbonado/spi/LobEngine.java')
| -rw-r--r-- | src/main/java/com/amazon/carbonado/spi/LobEngine.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/main/java/com/amazon/carbonado/spi/LobEngine.java b/src/main/java/com/amazon/carbonado/spi/LobEngine.java index 167c5b1..e91bf59 100644 --- a/src/main/java/com/amazon/carbonado/spi/LobEngine.java +++ b/src/main/java/com/amazon/carbonado/spi/LobEngine.java @@ -149,7 +149,7 @@ public class LobEngine { lob.setLocator(locator);
if (lob.tryDelete()) {
try {
- lob.getBlocks().deleteAll();
+ mLobBlockStorage.query("locator = ?").with(lob.getLocator()).deleteAll();
} catch (FetchException e) {
throw e.toPersistException();
}
@@ -579,7 +579,8 @@ public class LobEngine { // Free unused blocks.
long newBlockCount = lob.getBlockCount();
if (newBlockCount < oldBlockCount) {
- lob.getBlocks().and("blockNumber >= ?")
+ mLobBlockStorage.query("locator = ? & blockNumber >= ?")
+ .with(lob.getLocator())
// Subtract 0x80000000 such that block zero is
// physically stored with the smallest integer.
.with(((int) newBlockCount) - 0x80000000)
|