write_batch.h 2.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283
  1. // Copyright (c) 2011 The LevelDB Authors. All rights reserved.
  2. // Use of this source code is governed by a BSD-style license that can be
  3. // found in the LICENSE file. See the AUTHORS file for names of contributors.
  4. //
  5. // WriteBatch holds a collection of updates to apply atomically to a DB.
  6. //
  7. // The updates are applied in the order in which they are added
  8. // to the WriteBatch. For example, the value of "key" will be "v3"
  9. // after the following batch is written:
  10. //
  11. // batch.Put("key", "v1");
  12. // batch.Delete("key");
  13. // batch.Put("key", "v2");
  14. // batch.Put("key", "v3");
  15. //
  16. // Multiple threads can invoke const methods on a WriteBatch without
  17. // external synchronization, but if any of the threads may call a
  18. // non-const method, all threads accessing the same WriteBatch must use
  19. // external synchronization.
  20. #ifndef STORAGE_LEVELDB_INCLUDE_WRITE_BATCH_H_
  21. #define STORAGE_LEVELDB_INCLUDE_WRITE_BATCH_H_
  22. #include <string>
  23. #include "leveldb/export.h"
  24. #include "leveldb/status.h"
  25. namespace leveldb {
  26. class Slice;
  27. class LEVELDB_EXPORT WriteBatch {
  28. public:
  29. class LEVELDB_EXPORT Handler {
  30. public:
  31. virtual ~Handler();
  32. virtual void Put(const Slice& key, const Slice& value) = 0;
  33. virtual void Delete(const Slice& key) = 0;
  34. };
  35. WriteBatch();
  36. // Intentionally copyable.
  37. WriteBatch(const WriteBatch&) = default;
  38. WriteBatch& operator=(const WriteBatch&) = default;
  39. ~WriteBatch();
  40. // Store the mapping "key->value" in the database.
  41. void Put(const Slice& key, const Slice& value);
  42. // If the database contains a mapping for "key", erase it. Else do nothing.
  43. void Delete(const Slice& key);
  44. // Clear all updates buffered in this batch.
  45. void Clear();
  46. // The size of the database changes caused by this batch.
  47. //
  48. // This number is tied to implementation details, and may change across
  49. // releases. It is intended for LevelDB usage metrics.
  50. size_t ApproximateSize() const;
  51. // Copies the operations in "source" to this batch.
  52. //
  53. // This runs in O(source size) time. However, the constant factor is better
  54. // than calling Iterate() over the source batch with a Handler that replicates
  55. // the operations into this batch.
  56. void Append(const WriteBatch& source);
  57. // Support for iterating over the contents of a batch.
  58. Status Iterate(Handler* handler) const;
  59. private:
  60. friend class WriteBatchInternal;
  61. std::string rep_; // See comment in write_batch.cc for the format of rep_
  62. };
  63. } // namespace leveldb
  64. #endif // STORAGE_LEVELDB_INCLUDE_WRITE_BATCH_H_