ceph/src/rocksdb/java/src/main/java/org/rocksdb/AbstractWriteBatch.java

   1 // Copyright (c) 2011-present, Facebook, Inc.  All rights reserved.
   2 // This source code is licensed under the BSD-style license found in the
   3 // LICENSE file in the root directory of this source tree. An additional grant
   4 // of patent rights can be found in the PATENTS file in the same directory.
   5
   6 package org.rocksdb;
   7
   8 public abstract class AbstractWriteBatch extends RocksObject
   9     implements WriteBatchInterface {
  10
  11   protected AbstractWriteBatch(final long nativeHandle) {
  12     super(nativeHandle);
  13   }
  14
  15   @Override
  16   public int count() {
  17     return count0(nativeHandle_);
  18   }
  19
  20   @Override
  21   public void put(byte[] key, byte[] value) {
  22     put(nativeHandle_, key, key.length, value, value.length);
  23   }
  24
  25   @Override
  26   public void put(ColumnFamilyHandle columnFamilyHandle, byte[] key,
  27       byte[] value) {
  28     put(nativeHandle_, key, key.length, value, value.length,
  29         columnFamilyHandle.nativeHandle_);
  30   }
  31
  32   @Override
  33   public void merge(byte[] key, byte[] value) {
  34     merge(nativeHandle_, key, key.length, value, value.length);
  35   }
  36
  37   @Override
  38   public void merge(ColumnFamilyHandle columnFamilyHandle, byte[] key,
  39       byte[] value) {
  40     merge(nativeHandle_, key, key.length, value, value.length,
  41         columnFamilyHandle.nativeHandle_);
  42   }
  43
  44   @Override
  45   public void remove(byte[] key) {
  46     remove(nativeHandle_, key, key.length);
  47   }
  48
  49   @Override
  50   public void remove(ColumnFamilyHandle columnFamilyHandle, byte[] key) {
  51     remove(nativeHandle_, key, key.length, columnFamilyHandle.nativeHandle_);
  52   }
  53
  54   @Override
  55   public void deleteRange(byte[] beginKey, byte[] endKey) {
  56     deleteRange(nativeHandle_, beginKey, beginKey.length, endKey, endKey.length);
  57   }
  58
  59   @Override
  60   public void deleteRange(ColumnFamilyHandle columnFamilyHandle, byte[] beginKey, byte[] endKey) {
  61     deleteRange(nativeHandle_, beginKey, beginKey.length, endKey, endKey.length,
  62         columnFamilyHandle.nativeHandle_);
  63   }
  64
  65   @Override
  66   public void putLogData(byte[] blob) {
  67     putLogData(nativeHandle_, blob, blob.length);
  68   }
  69
  70   @Override
  71   public void clear() {
  72     clear0(nativeHandle_);
  73   }
  74
  75   @Override
  76   public void setSavePoint() {
  77     setSavePoint0(nativeHandle_);
  78   }
  79
  80   @Override
  81   public void rollbackToSavePoint() throws RocksDBException {
  82     rollbackToSavePoint0(nativeHandle_);
  83   }
  84
  85   abstract int count0(final long handle);
  86
  87   abstract void put(final long handle, final byte[] key, final int keyLen,
  88       final byte[] value, final int valueLen);
  89
  90   abstract void put(final long handle, final byte[] key, final int keyLen,
  91       final byte[] value, final int valueLen, final long cfHandle);
  92
  93   abstract void merge(final long handle, final byte[] key, final int keyLen,
  94       final byte[] value, final int valueLen);
  95
  96   abstract void merge(final long handle, final byte[] key, final int keyLen,
  97       final byte[] value, final int valueLen, final long cfHandle);
  98
  99   abstract void remove(final long handle, final byte[] key,
 100       final int keyLen);
 101
 102   abstract void remove(final long handle, final byte[] key,
 103       final int keyLen, final long cfHandle);
 104
 105   abstract void deleteRange(final long handle, final byte[] beginKey, final int beginKeyLen,
 106       final byte[] endKey, final int endKeyLen);
 107
 108   abstract void deleteRange(final long handle, final byte[] beginKey, final int beginKeyLen,
 109       final byte[] endKey, final int endKeyLen, final long cfHandle);
 110
 111   abstract void putLogData(final long handle, final byte[] blob,
 112       final int blobLen);
 113
 114   abstract void clear0(final long handle);
 115
 116   abstract void setSavePoint0(final long handle);
 117
 118   abstract void rollbackToSavePoint0(final long handle);
 119 }