test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-03 12:29:36 +08:00
Code Issues Actions 13 Packages Projects Releases Wiki Activity

feat(db): impl get_group

Browse Source 
Former-commit-id: 5519dfb718d786120322faacd32ef364bcf8b82a
This commit is contained in:
Xu Peng 2019-04-18 09:54:50 +08:00 committed by xj.lin
parent 0e6881d94c
commit 1b4ccfdba4
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -71,8 +71,23 @@ Status DBMetaImpl::add_group(GroupSchema& group_info) {
return Status::OK();
}
Status DBMetaImpl::get_group(GroupSchema& group_info_) {
Status DBMetaImpl::get_group(GroupSchema& group_info) {
auto groups = ConnectorPtr->select(columns(&GroupSchema::id,
&GroupSchema::group_id,
&GroupSchema::files_cnt,
&GroupSchema::dimension),
where(c(&GroupSchema::group_id) == group_info.group_id));
assert(groups.size() <= 1);
if (groups.size() == 1) {
group_info.id = std::get<0>(groups[0]);
group_info.files_cnt = std::get<2>(groups[0]);
group_info.dimension = std::get<3>(groups[0]);
} else {
return Status::NotFound("Group " + group_info.group_id + " not found");
}
std::cout << __func__ << ": gid=" << group_info.group_id
<< " dimension=" << group_info.dimension << std::endl;
return Status::OK();
}