ldb support new WAL records

This commit is contained in:
Reid Horuff 2016-04-28 18:23:29 -07:00
parent a92049e3e7
commit 1d2e4ef747

View File

@ -1505,19 +1505,53 @@ class InMemoryHandler : public WriteBatch::Handler {
} }
} }
virtual void Put(const Slice& key, const Slice& value) override { virtual Status PutCF(uint32_t cf, const Slice& key,
row_ << "PUT : "; const Slice& value) override {
row_ << "PUT(" << cf << ") : ";
commonPutMerge(key, value); commonPutMerge(key, value);
return Status::OK();
} }
virtual void Merge(const Slice& key, const Slice& value) override { virtual Status MergeCF(uint32_t cf, const Slice& key,
row_ << "MERGE : "; const Slice& value) override {
row_ << "MERGE(" << cf << ") : ";
commonPutMerge(key, value); commonPutMerge(key, value);
return Status::OK();
} }
virtual void Delete(const Slice& key) override { virtual Status DeleteCF(uint32_t cf, const Slice& key) override {
row_ <<",DELETE : "; row_ << "DELETE(" << cf << ") : ";
row_ << LDBCommand::StringToHex(key.ToString()) << " "; row_ << LDBCommand::StringToHex(key.ToString()) << " ";
return Status::OK();
}
virtual Status SingleDeleteCF(uint32_t cf, const Slice& key) override {
row_ << "SINGLE_DELETE(" << cf << ") : ";
row_ << LDBCommand::StringToHex(key.ToString()) << " ";
return Status::OK();
}
virtual Status MarkBeginPrepare() {
row_ << "BEGIN_PREARE ";
return Status::OK();
}
virtual Status MarkEndPrepare(const Slice& xid) {
row_ << "END_PREPARE(";
row_ << LDBCommand::StringToHex(xid.ToString()) << ") ";
return Status::OK();
}
virtual Status MarkRollback(const Slice& xid) {
row_ << "ROLLBACK(";
row_ << LDBCommand::StringToHex(xid.ToString()) << ") ";
return Status::OK();
}
virtual Status MarkCommit(const Slice& xid) {
row_ << "COMMIT(";
row_ << LDBCommand::StringToHex(xid.ToString()) << ") ";
return Status::OK();
} }
virtual ~InMemoryHandler() {} virtual ~InMemoryHandler() {}