107 lines
3.5 KiB
C++
107 lines
3.5 KiB
C++
/**
|
|
* Copyright (c) 2021 OceanBase
|
|
* OceanBase CE is licensed under Mulan PubL v2.
|
|
* You can use this software according to the terms and conditions of the Mulan PubL v2.
|
|
* You may obtain a copy of Mulan PubL v2 at:
|
|
* http://license.coscl.org.cn/MulanPubL-2.0
|
|
* THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND,
|
|
* EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT,
|
|
* MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE.
|
|
* See the Mulan PubL v2 for more details.
|
|
*/
|
|
|
|
#include "src/share/backup/ob_log_restore_struct.h"
|
|
#include <gtest/gtest.h>
|
|
|
|
namespace oceanbase
|
|
{
|
|
using namespace common;
|
|
using namespace palf;
|
|
|
|
namespace unittest
|
|
{
|
|
|
|
TEST(TestRestoreSource, test_net_standby_restore_source)
|
|
{
|
|
ObSqlString source_str;
|
|
char original_str[1000] = "ip_list=127.0.0.1:1001;127.0.0.1:1002,USER=restore_user@primary_tenant,PASSWORD=38344B42344C61477232324839306F3093231FF975D957829E4813195215E5B0,TENANT_ID=9223372036854775807,CLUSTER_ID=4294967295,COMPATIBILITY_MODE=MYSQL,IS_ENCRYPTED=false";
|
|
char passwd_str[OB_MAX_PASSWORD_LENGTH + 1] = { 0 };
|
|
source_str.assign(original_str);
|
|
|
|
ObSqlString user_and_tenant;
|
|
ObSqlString ip_list;
|
|
ObSqlString user_str;
|
|
ObSqlString tenant_id_str;
|
|
ObSqlString cluster_id_str;
|
|
ObSqlString mode_str;
|
|
|
|
share::ObRestoreSourceServiceAttr attr, tmp_attr;
|
|
(void)attr.parse_service_attr_from_str(source_str);
|
|
|
|
EXPECT_TRUE(attr.is_valid());
|
|
ASSERT_EQ(OB_SUCCESS, tmp_attr.assign(attr));
|
|
EXPECT_TRUE(tmp_attr.is_valid());
|
|
|
|
// check attr.user_
|
|
EXPECT_EQ(attr.user_.tenant_id_, 9223372036854775807);
|
|
EXPECT_EQ(attr.user_.cluster_id_, 4294967295);
|
|
EXPECT_EQ(0, STRCMP(attr.user_.user_name_, "restore_user"));
|
|
EXPECT_EQ(0, STRCMP(attr.user_.tenant_name_, "primary_tenant"));
|
|
EXPECT_EQ(attr.user_.mode_, ObCompatibilityMode::MYSQL_MODE);
|
|
EXPECT_TRUE(attr.user_ == tmp_attr.user_);
|
|
|
|
|
|
// check attr
|
|
common::ObAddr addr1(common::ObAddr::VER::IPV4, "127.0.0.1", 1001);
|
|
EXPECT_TRUE(attr.addr_.at(0) == addr1);
|
|
common::ObAddr addr2(common::ObAddr::VER::IPV4, "127.0.0.1", 1002);
|
|
EXPECT_TRUE(attr.addr_.at(1) == addr2);
|
|
|
|
(void)attr.get_ip_list_str_(ip_list);
|
|
EXPECT_EQ(0, STRCMP(ip_list.ptr(),"127.0.0.1:1001;127.0.0.1:1002"));
|
|
|
|
(void)attr.get_user_str_(user_and_tenant);
|
|
EXPECT_EQ(0, STRCMP(user_and_tenant.ptr(), "restore_user@primary_tenant"));
|
|
|
|
(void)attr.get_tenant_id_str_(tenant_id_str);
|
|
EXPECT_EQ(0, STRCMP(tenant_id_str.ptr(), "9223372036854775807"));
|
|
|
|
(void)attr.get_cluster_id_str_(cluster_id_str);
|
|
EXPECT_EQ(0, STRCMP(cluster_id_str.ptr(), "4294967295"));
|
|
|
|
(void)attr.get_compatibility_mode_str_(mode_str);
|
|
EXPECT_EQ(0, STRCMP(mode_str.ptr(), "MYSQL"));
|
|
|
|
|
|
EXPECT_TRUE(attr.service_user_is_valid());
|
|
EXPECT_TRUE(attr.service_host_is_valid());
|
|
EXPECT_TRUE(attr.is_valid());
|
|
EXPECT_TRUE(attr.compare_addr_(tmp_attr.addr_));
|
|
EXPECT_TRUE(attr == tmp_attr);
|
|
|
|
// check invalid attr
|
|
share::ObRestoreSourceServiceAttr attr1, attr2, attr3;
|
|
(void)attr1.assign(attr);
|
|
attr1.set_service_cluster_id("-1");
|
|
EXPECT_FALSE(attr1.is_valid());
|
|
|
|
(void)attr2.assign(attr);
|
|
attr2.set_service_tenant_id("0");
|
|
EXPECT_FALSE(attr2.is_valid());
|
|
|
|
(void)attr3.assign(attr);
|
|
attr3.addr_.destroy();
|
|
EXPECT_FALSE(attr3.is_valid());
|
|
}
|
|
|
|
} // end of unittest
|
|
} // end of oceanbase
|
|
|
|
int main(int argc, char **argv)
|
|
{
|
|
OB_LOGGER.set_file_name("test_net_standby_restore_source.log", true);
|
|
OB_LOGGER.set_log_level("INFO");
|
|
::testing::InitGoogleTest(&argc, argv);
|
|
return RUN_ALL_TESTS();
|
|
}
|