fix(db): fix size api for db meta

Former-commit-id: b58a3f27ee9b574af78894eb6fb5120904430c66
This commit is contained in:
Xu Peng 2019-05-26 11:13:34 +08:00
parent c90aee8972
commit dfb0952880

View File

@ -489,13 +489,19 @@ Status DBMetaImpl::archive_files() {
}
Status DBMetaImpl::size(long& result) {
result = 0;
try {
auto sum_c = ConnectorPtr->sum(
&GroupFileSchema::rows,
auto selected = ConnectorPtr->select(columns(sum(&GroupFileSchema::rows)),
where(
c(&GroupFileSchema::file_type) != (int)GroupFileSchema::TO_DELETE
));
result = *sum_c*sizeof(float);
for (auto& sub_query : selected) {
if(!std::get<0>(sub_query)) {
continue;
}
result += (long)(*std::get<0>(sub_query))*sizeof(float);
}
} catch (std::exception & e) {
LOG(DEBUG) << e.what();
throw e;