milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

feat(db): fix insert bug 

Former-commit-id: be162dd2b77e8ea1b47253f5f404a8874b46bddd
pull/191/head
Xu Peng 2019-04-18 18:41:06 +08:00
parent 98270ac004
commit a1ebba77e6
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
cpp/src/db/DBMetaImpl.cpp
View File

@ -156,13 +156,16 @@ Status DBMetaImpl::add_group_file(GroupFileSchema& group_file) {
group_file.file_id = ss.str();
group_file.dimension = group_info.dimension;
GetGroupFilePath(group_file);
try {
auto commited = ConnectorPtr->transaction([&] () mutable {
auto id = ConnectorPtr->insert(group_file);
std::cout << __func__ << " id=" << id << std::endl;
group_info.id = id;
} catch(std::system_error& e) {
return Status::GroupError("Add GroupFile Group "
+ group_info.group_id + " File " + group_file.file_id + " Error");
std::cout << __func__ << " id=" << id << std::endl;
return true;
});
if (!commited) {
return Status::DBTransactionError("Add file Error");
}
auto partition_path = GetGroupDatePartitionPath(group_file.group_id, group_file.date);