10225501448 李度 10225101546 陈胤遒 10215501422 高宇菲
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

84 lines
2.5 KiB

  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. #include <cstdint>
  26. namespace leveldb {
  27. class Slice;
  28. class LEVELDB_EXPORT WriteBatch {
  29. public:
  30. class LEVELDB_EXPORT Handler {
  31. public:
  32. virtual ~Handler();
  33. virtual void Put(const Slice& key, const Slice& value, uint64_t deadTime = 0) = 0;
  34. virtual void Delete(const Slice& key) = 0;
  35. };
  36. WriteBatch();
  37. // Intentionally copyable.
  38. WriteBatch(const WriteBatch&) = default;
  39. WriteBatch& operator=(const WriteBatch&) = default;
  40. ~WriteBatch();
  41. // Store the mapping "key->value" in the database.
  42. void Put(const Slice& key, const Slice& value, uint64_t ttl = 0);
  43. // If the database contains a mapping for "key", erase it. Else do nothing.
  44. void Delete(const Slice& key);
  45. // Clear all updates buffered in this batch.
  46. void Clear();
  47. // The size of the database changes caused by this batch.
  48. //
  49. // This number is tied to implementation details, and may change across
  50. // releases. It is intended for LevelDB usage metrics.
  51. size_t ApproximateSize() const;
  52. // Copies the operations in "source" to this batch.
  53. //
  54. // This runs in O(source size) time. However, the constant factor is better
  55. // than calling Iterate() over the source batch with a Handler that replicates
  56. // the operations into this batch.
  57. void Append(const WriteBatch& source);
  58. // Support for iterating over the contents of a batch.
  59. Status Iterate(Handler* handler) const;
  60. private:
  61. friend class WriteBatchInternal;
  62. std::string rep_; // See comment in write_batch.cc for the format of rep_
  63. };
  64. } // namespace leveldb
  65. #endif // STORAGE_LEVELDB_INCLUDE_WRITE_BATCH_H_