@Test public void delete() { }
public void delete(String key) throws KitDBException { checkTxRange(); try (CloseLock ignored = checkClose()) { LockEntity lockEntity = lock(key); try { byte[] key_b = getKey(key); MetaV metaV = getMeta(key_b); if (metaV == null) { checkTxCommit(); return; } start(); deleteDB(key_b, SstColumnFamily.META); delete(key_b, metaV); commit(); } finally { unlock(lockEntity); release(); } checkTxCommit(); } catch (KitDBException e) { checkTxRollBack(); throw e; } }
RList extends RCollection { public void delete(String key) throws KitDBException { checkTxRange(); try (CloseLock ignored = checkClose()) { LockEntity lockEntity = lock(key); try { byte[] key_b = getKey(key); MetaV metaV = getMeta(key_b); if (metaV == null) { checkTxCommit(); return; } start(); deleteDB(key_b, SstColumnFamily.META); delete(key_b, metaV); commit(); } finally { unlock(lockEntity); release(); } checkTxCommit(); } catch (KitDBException e) { checkTxRollBack(); throw e; } } }
RList extends RCollection { public void delete(String key) throws KitDBException { checkTxRange(); try (CloseLock ignored = checkClose()) { LockEntity lockEntity = lock(key); try { byte[] key_b = getKey(key); MetaV metaV = getMeta(key_b); if (metaV == null) { checkTxCommit(); return; } start(); deleteDB(key_b, SstColumnFamily.META); delete(key_b, metaV); commit(); } finally { unlock(lockEntity); release(); } checkTxCommit(); } catch (KitDBException e) { checkTxRollBack(); throw e; } } protected  RList(DB db); }
RList extends RCollection { public void delete(String key) throws KitDBException { checkTxRange(); try (CloseLock ignored = checkClose()) { LockEntity lockEntity = lock(key); try { byte[] key_b = getKey(key); MetaV metaV = getMeta(key_b); if (metaV == null) { checkTxCommit(); return; } start(); deleteDB(key_b, SstColumnFamily.META); delete(key_b, metaV); commit(); } finally { unlock(lockEntity); release(); } checkTxCommit(); } catch (KitDBException e) { checkTxRollBack(); throw e; } } protected  RList(DB db); void add(String key, byte[] v); void addAll(String key, List<byte[]> vs); void addAllMayTTL(String key, List<byte[]> vs, int ttl); void set(String key, long i, byte[] v); byte[] get(String key, long i); List<byte[]> get(String key, List<Long> is); Long left(String key); Long right(String key); int size(String key); void deleteFast(String key); void delete(String key); boolean isExist(String key); List<byte[]> range(String key, long start, long end); @Override @SuppressWarnings("unchecked") RIterator<RList> iterator(String key); Entry getEntry(RocksIterator iterator); List<byte[]> blpop(String key, int num); List<byte[]> brpop(String key, int num); @Override KeyIterator getKeyIterator(); void ttl(String key, int ttl); void delTtl(String key); int getTtl(String key); void addMayTTL(String key, byte[] v, int ttl); }
RList extends RCollection { public void delete(String key) throws KitDBException { checkTxRange(); try (CloseLock ignored = checkClose()) { LockEntity lockEntity = lock(key); try { byte[] key_b = getKey(key); MetaV metaV = getMeta(key_b); if (metaV == null) { checkTxCommit(); return; } start(); deleteDB(key_b, SstColumnFamily.META); delete(key_b, metaV); commit(); } finally { unlock(lockEntity); release(); } checkTxCommit(); } catch (KitDBException e) { checkTxRollBack(); throw e; } } protected  RList(DB db); void add(String key, byte[] v); void addAll(String key, List<byte[]> vs); void addAllMayTTL(String key, List<byte[]> vs, int ttl); void set(String key, long i, byte[] v); byte[] get(String key, long i); List<byte[]> get(String key, List<Long> is); Long left(String key); Long right(String key); int size(String key); void deleteFast(String key); void delete(String key); boolean isExist(String key); List<byte[]> range(String key, long start, long end); @Override @SuppressWarnings("unchecked") RIterator<RList> iterator(String key); Entry getEntry(RocksIterator iterator); List<byte[]> blpop(String key, int num); List<byte[]> brpop(String key, int num); @Override KeyIterator getKeyIterator(); void ttl(String key, int ttl); void delTtl(String key); int getTtl(String key); void addMayTTL(String key, byte[] v, int ttl); final static String HEAD; final static byte[] HEAD_VALUE_B; final static byte[] HEAD_B; }