thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-21 17:20:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix extract keys

Browse Source
This commit is contained in:
sundy-li 2020-10-16 09:02:16 +08:00
parent ad78e0b3f5
commit fced1a0e28
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/Storages/Rocksdb/StorageEmbeddedRocksdb.cpp
View File

@ -239,15 +239,13 @@ Pipe StorageEmbeddedRocksdb::read(
{
std::vector<rocksdb::Slice> slices_keys;
std::vector<String> values;
std::vector<WriteBufferFromOwnString> wbs(keys.size());
WriteBufferFromOwnString wb;
UInt64 offset = 0;
for (const auto & key : keys)
for (size_t i = 0; i < keys.size(); ++i)
{
sample_block.getByName(primary_key).type->serializeBinary(key, wb);
auto str_ref = wb.stringRef();
slices_keys.emplace_back(str_ref.data + offset, str_ref.size - offset);
offset = str_ref.size;
sample_block.getByName(primary_key).type->serializeBinary(keys[i], wbs[i]);
auto str_ref = wbs[i].stringRef();
slices_keys.emplace_back(str_ref.data, str_ref.size);
}
auto statuses = rocksdb_ptr->MultiGet(rocksdb::ReadOptions(), slices_keys, &values);