| 748 | } |
| 749 | |
| 750 | bool BerkeleyBatch::ReadKey(CDataStream&& key, CDataStream& value) |
| 751 | { |
| 752 | if (!pdb) |
| 753 | return false; |
| 754 | |
| 755 | SafeDbt datKey(key.data(), key.size()); |
| 756 | |
| 757 | SafeDbt datValue; |
| 758 | int ret = pdb->get(activeTxn, datKey, datValue, 0); |
| 759 | if (ret == 0 && datValue.get_data() != nullptr) { |
| 760 | value.write({BytePtr(datValue.get_data()), datValue.get_size()}); |
| 761 | return true; |
| 762 | } |
| 763 | return false; |
| 764 | } |
| 765 | |
| 766 | bool BerkeleyBatch::WriteKey(CDataStream&& key, CDataStream&& value, bool overwrite) |
| 767 | { |