mirror of
https://gitee.com/milvus-io/milvus.git
synced 2025-12-08 10:08:42 +08:00
128 lines
4.0 KiB
C++
128 lines
4.0 KiB
C++
////////////////////////////////////////////////////////////////////////////////
|
|
// Copyright 上海赜睿信息科技有限公司(Zilliz) - All Rights Reserved
|
|
// Unauthorized copying of this file, via any medium is strictly prohibited.
|
|
// Proprietary and confidential.
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
#include <gtest/gtest.h>
|
|
#include <thread>
|
|
#include <easylogging++.h>
|
|
|
|
#include "utils.h"
|
|
#include "db/DBMetaImpl.h"
|
|
#include "db/Factories.h"
|
|
|
|
using namespace zilliz::vecwise::engine;
|
|
|
|
TEST_F(MetaTest, GROUP_TEST) {
|
|
auto group_id = "meta_test_group";
|
|
|
|
meta::GroupSchema group;
|
|
group.group_id = group_id;
|
|
auto status = impl_->add_group(group);
|
|
ASSERT_TRUE(status.ok());
|
|
|
|
auto gid = group.id;
|
|
group.id = -1;
|
|
status = impl_->get_group(group);
|
|
ASSERT_TRUE(status.ok());
|
|
ASSERT_EQ(group.id, gid);
|
|
ASSERT_EQ(group.group_id, group_id);
|
|
|
|
group.group_id = "not_found";
|
|
status = impl_->get_group(group);
|
|
ASSERT_TRUE(!status.ok());
|
|
|
|
group.group_id = group_id;
|
|
status = impl_->add_group(group);
|
|
ASSERT_TRUE(!status.ok());
|
|
}
|
|
|
|
TEST_F(MetaTest, GROUP_FILE_TEST) {
|
|
auto group_id = "meta_test_group";
|
|
|
|
meta::GroupSchema group;
|
|
group.group_id = group_id;
|
|
auto status = impl_->add_group(group);
|
|
|
|
meta::GroupFileSchema group_file;
|
|
group_file.group_id = group.group_id;
|
|
status = impl_->add_group_file(group_file);
|
|
ASSERT_TRUE(status.ok());
|
|
ASSERT_EQ(group_file.file_type, meta::GroupFileSchema::NEW);
|
|
|
|
auto file_id = group_file.file_id;
|
|
|
|
auto new_file_type = meta::GroupFileSchema::INDEX;
|
|
group_file.file_type = new_file_type;
|
|
|
|
status = impl_->update_group_file(group_file);
|
|
ASSERT_TRUE(status.ok());
|
|
ASSERT_EQ(group_file.file_type, new_file_type);
|
|
|
|
/* group_file.file_type = meta::GroupFileSchema::NEW; */
|
|
/* status = impl_->get_group_file(group_file.group_id, group_file.file_id, group_file); */
|
|
/* ASSERT_TRUE(status.ok()); */
|
|
/* ASSERT_EQ(group_file.file_type, new_file_type); */
|
|
}
|
|
|
|
TEST_F(MetaTest, GROUP_FILES_TEST) {
|
|
auto group_id = "meta_test_group";
|
|
|
|
meta::GroupSchema group;
|
|
group.group_id = group_id;
|
|
auto status = impl_->add_group(group);
|
|
|
|
int new_files_cnt = 4;
|
|
int raw_files_cnt = 5;
|
|
int to_index_files_cnt = 6;
|
|
int index_files_cnt = 7;
|
|
|
|
meta::GroupFileSchema group_file;
|
|
group_file.group_id = group.group_id;
|
|
|
|
for (auto i=0; i<new_files_cnt; ++i) {
|
|
status = impl_->add_group_file(group_file);
|
|
group_file.file_type = meta::GroupFileSchema::NEW;
|
|
status = impl_->update_group_file(group_file);
|
|
}
|
|
|
|
for (auto i=0; i<raw_files_cnt; ++i) {
|
|
status = impl_->add_group_file(group_file);
|
|
group_file.file_type = meta::GroupFileSchema::RAW;
|
|
status = impl_->update_group_file(group_file);
|
|
}
|
|
|
|
for (auto i=0; i<to_index_files_cnt; ++i) {
|
|
status = impl_->add_group_file(group_file);
|
|
group_file.file_type = meta::GroupFileSchema::TO_INDEX;
|
|
status = impl_->update_group_file(group_file);
|
|
}
|
|
|
|
for (auto i=0; i<index_files_cnt; ++i) {
|
|
status = impl_->add_group_file(group_file);
|
|
group_file.file_type = meta::GroupFileSchema::INDEX;
|
|
status = impl_->update_group_file(group_file);
|
|
}
|
|
|
|
meta::GroupFilesSchema files;
|
|
|
|
status = impl_->files_to_index(files);
|
|
ASSERT_TRUE(status.ok());
|
|
ASSERT_EQ(files.size(), to_index_files_cnt);
|
|
|
|
meta::DatePartionedGroupFilesSchema dated_files;
|
|
status = impl_->files_to_merge(group.group_id, dated_files);
|
|
ASSERT_TRUE(status.ok());
|
|
ASSERT_EQ(dated_files[group_file.date].size(), raw_files_cnt);
|
|
|
|
status = impl_->files_to_index(files);
|
|
ASSERT_TRUE(status.ok());
|
|
ASSERT_EQ(files.size(), to_index_files_cnt);
|
|
|
|
meta::DatesT dates = {group_file.date};
|
|
status = impl_->files_to_search(group_id, dates, dated_files);
|
|
ASSERT_TRUE(status.ok());
|
|
ASSERT_EQ(dated_files[group_file.date].size(),
|
|
to_index_files_cnt+raw_files_cnt+index_files_cnt);
|
|
}
|