disable zone commands

src/graph/validator/AdminValidator.cpp

@@ -21,8 +21,9 @@ Status CreateSpaceValidator::validateImpl() {
  auto status = Status::OK();
  spaceDesc_.space_name_ref() = std::move(*(sentence->spaceName()));
  if (sentence->zoneNames()) {
- spaceDesc_.zone_names_ref() = sentence->zoneNames()->zoneNames();
+ return Status::SemanticError("Create space with zone is unsupported");
  }
+
  StatusOr<std::string> retStatusOr;
  std::string result;
  auto *charsetInfo = qctx_->getCharsetInfo();
@@ -323,10 +324,6 @@ Status ShowListenerValidator::toPlan() {
 }
 
 Status AddHostsValidator::validateImpl() {
- return Status::OK();
-}
-
-Status AddHostsValidator::toPlan() {
  auto sentence = static_cast<AddHostsSentence *>(sentence_);
  auto hosts = sentence->hosts()->hosts();
  if (hosts.empty()) {
@@ -337,18 +334,19 @@ Status AddHostsValidator::toPlan() {
  if (it != hosts.end()) {
  return Status::SemanticError("Host have duplicated");
  }
+ return Status::OK();
+}
 
+Status AddHostsValidator::toPlan() {
+ auto sentence = static_cast<AddHostsSentence *>(sentence_);
+ auto hosts = sentence->hosts()->hosts();
  auto *addHost = AddHosts::make(qctx_, nullptr, hosts);
  root_ = addHost;
  tail_ = root_;
  return Status::OK();
 }
 
 Status DropHostsValidator::validateImpl() {
- return Status::OK();
-}
-
-Status DropHostsValidator::toPlan() {
  auto sentence = static_cast<DropHostsSentence *>(sentence_);
  auto hosts = sentence->hosts()->hosts();
  if (hosts.empty()) {
@@ -359,7 +357,12 @@ Status DropHostsValidator::toPlan() {
  if (it != hosts.end()) {
  return Status::SemanticError("Host have duplicated");
  }
+ return Status::OK();
+}
 
+Status DropHostsValidator::toPlan() {
+ auto sentence = static_cast<DropHostsSentence *>(sentence_);
+ auto hosts = sentence->hosts()->hosts();
  auto *dropHost = DropHosts::make(qctx_, nullptr, hosts);
  root_ = dropHost;
  tail_ = root_;

src/graph/validator/MaintainValidator.cpp

@@ -496,7 +496,7 @@ Status ShowEdgeIndexStatusValidator::toPlan() {
 }
 
 Status MergeZoneValidator::validateImpl() {
- return Status::OK();
+ return Status::SemanticError("Merge zone is unsupported");
 }
 
 Status MergeZoneValidator::toPlan() {
@@ -509,7 +509,7 @@ Status MergeZoneValidator::toPlan() {
 }
 
 Status RenameZoneValidator::validateImpl() {
- return Status::OK();
+ return Status::SemanticError("Rename zone is unsupported");
 }
 
 Status RenameZoneValidator::toPlan() {
@@ -534,7 +534,7 @@ Status DropZoneValidator::toPlan() {
 }
 
 Status DivideZoneValidator::validateImpl() {
- return Status::OK();
+ return Status::SemanticError("Divide zone is unsupported");
 }
 
 Status DivideZoneValidator::toPlan() {
@@ -558,11 +558,11 @@ Status DescribeZoneValidator::toPlan() {
  return Status::OK();
 }
 
-Status ListZonesValidator::validateImpl() {
- return Status::OK();
+Status ShowZonesValidator::validateImpl() {
+ return Status::SemanticError("Show zones is unsupported");
 }
 
-Status ListZonesValidator::toPlan() {
+Status ShowZonesValidator::toPlan() {
  auto *doNode = ListZones::make(qctx_, nullptr);
  root_ = doNode;
  tail_ = root_;

src/graph/validator/MaintainValidator.h

@@ -382,9 +382,9 @@ class DescribeZoneValidator final : public Validator {
  Status toPlan() override;
 };
 
-class ListZonesValidator final : public Validator {
+class ShowZonesValidator final : public Validator {
  public:
- ListZonesValidator(Sentence* sentence, QueryContext* context) : Validator(sentence, context) {
+ ShowZonesValidator(Sentence* sentence, QueryContext* context) : Validator(sentence, context) {
  setNoSpaceRequired();
  }
 

src/graph/validator/Validator.cpp

@@ -217,7 +217,7 @@ std::unique_ptr<Validator> Validator::makeValidator(Sentence* sentence, QueryCon
  case Sentence::Kind::kDescribeZone:
  return std::make_unique<DescribeZoneValidator>(sentence, context);
  case Sentence::Kind::kListZones:
- return std::make_unique<ListZonesValidator>(sentence, context);
+ return std::make_unique<ShowZonesValidator>(sentence, context);
  case Sentence::Kind::kAddHostsIntoZone:
  return std::make_unique<AddHostsIntoZoneValidator>(sentence, context);
  case Sentence::Kind::kAddListener:

src/parser/AdminSentences.cpp

@@ -57,14 +57,6 @@ std::string ShowCollationSentence::toString() const {
  return std::string("SHOW COLLATION");
 }
 
-std::string ShowGroupsSentence::toString() const {
- return std::string("SHOW GROUPS");
-}
-
-std::string ShowZonesSentence::toString() const {
- return std::string("SHOW ZONES");
-}
-
 std::string SpaceOptItem::toString() const {
  switch (optType_) {
  case OptionType::PARTITION_NUM:

src/parser/AdminSentences.h

@@ -154,22 +154,6 @@ class ShowCollationSentence final : public Sentence {
  std::string toString() const override;
 };
 
-class ShowGroupsSentence final : public Sentence {
- public:
- ShowGroupsSentence() {
- kind_ = Kind::kShowGroups;
- }
- std::string toString() const override;
-};
-
-class ShowZonesSentence final : public Sentence {
- public:
- ShowZonesSentence() {
- kind_ = Kind::kShowZones;
- }
- std::string toString() const override;
-};
-
 class SpaceOptItem final {
  public:
  using Value = boost::variant<int64_t, std::string, meta::cpp2::ColumnTypeDef>;

src/parser/MaintainSentences.cpp

@@ -461,7 +461,7 @@ std::string DescribeZoneSentence::toString() const {
  return folly::stringPrintf("DESCRIBE ZONE \"%s\"", zoneName_.get()->c_str());
 }
 
-std::string ListZonesSentence::toString() const {
+std::string ShowZonesSentence::toString() const {
  return folly::stringPrintf("SHOW ZONES");
 }
 

src/parser/MaintainSentences.h

@@ -1079,9 +1079,9 @@ class DescribeZoneSentence : public Sentence {
  std::unique_ptr<std::string> zoneName_;
 };
 
-class ListZonesSentence : public Sentence {
+class ShowZonesSentence : public Sentence {
  public:
- ListZonesSentence() {
+ ShowZonesSentence() {
  kind_ = Kind::kListZones;
  }
 

src/parser/parser.yy

@@ -3421,7 +3421,7 @@ show_sentence
  $$ = new ShowCollationSentence();
  }
  | KW_SHOW KW_ZONES {
- $$ = new ListZonesSentence();
+ $$ = new ShowZonesSentence();
  }
  | KW_SHOW KW_STATS {
  $$ = new ShowStatsSentence();

tests/admin/test_space.py

@@ -21,10 +21,10 @@ def test_space(self):
  self.check_resp_succeeded(resp)
 
  # check result
- resp = self.client.execute('DESC SPACE space_with_default_options')
- expect_result = [['space_with_default_options', 100, 1, 'utf8', 'utf8_bin',
- 'FIXED_STRING(8)', False, 'default_zone', T_EMPTY]]
- self.check_result(resp, expect_result, {0})
+ # resp = self.client.execute('DESC SPACE space_with_default_options')
+ # expect_result = [['space_with_default_options', 100, 1, 'utf8', 'utf8_bin',
+ # 'FIXED_STRING(8)', False, 'default_zone', T_EMPTY]]
+ # self.check_result(resp, expect_result, {0})
 
  # drop space
  resp = self.client.execute('DROP SPACE space_with_default_options')
@@ -42,26 +42,26 @@ def test_space(self):
  # desc space
  resp = self.client.execute('DESC SPACE default_space')
  self.check_resp_succeeded(resp)
- expect_result = [['default_space', 9, 1, 'utf8', 'utf8_bin', 'FIXED_STRING(8)',
- False, 'default_zone', T_EMPTY]]
- self.check_result(resp, expect_result, {0})
+ # expect_result = [['default_space', 9, 1, 'utf8', 'utf8_bin', 'FIXED_STRING(8)',
+ # False, 'default_zone', T_EMPTY]]
+ # self.check_result(resp, expect_result, {0})
 
  # show create space
  # TODO(shylock) need meta cache to permission checking
  time.sleep(self.delay)
  resp = self.client.execute('SHOW CREATE SPACE default_space')
  self.check_resp_succeeded(resp)
 
- create_space_str_result = 'CREATE SPACE `default_space` (partition_num = 9, '\
- 'replica_factor = 1, '\
- 'charset = utf8, '\
- 'collate = utf8_bin, '\
- 'vid_type = FIXED_STRING(8), '\
- 'atomic_edge = false) '\
- 'ON default_zone'
+ # create_space_str_result = 'CREATE SPACE `default_space` (partition_num = 9, '\
+ #  'replica_factor = 1, '\
+ #  'charset = utf8, '\
+ #  'collate = utf8_bin, '\
+ #  'vid_type = FIXED_STRING(8), '\
+ #  'atomic_edge = false) '\
+ #  'ON default_zone'
 
- expect_result = [['default_space', create_space_str_result]]
- self.check_result(resp, expect_result)
+ # expect_result = [['default_space', create_space_str_result]]
+ # self.check_result(resp, expect_result)
 
  # check result from show create
  resp = self.client.execute('DROP SPACE default_space')
@@ -92,8 +92,8 @@ def test_charset_collate(self):
 
  resp = self.client.execute('DESC SPACE space_charset_collate')
  self.check_resp_succeeded(resp)
- expect_result = [['space_charset_collate', 9, 1, 'utf8', 'utf8_bin', 'FIXED_STRING(8)', False, 'default_zone', T_EMPTY]]
- self.check_result(resp, expect_result, {0})
+ # expect_result = [['space_charset_collate', 9, 1, 'utf8', 'utf8_bin', 'FIXED_STRING(8)', False, 'default_zone', T_EMPTY]]
+ # self.check_result(resp, expect_result, {0})
 
  # drop space
  resp = self.client.execute('DROP SPACE space_charset_collate')
@@ -105,8 +105,8 @@ def test_charset_collate(self):
 
  resp = self.client.execute('DESC SPACE space_charset')
  self.check_resp_succeeded(resp)
- expect_result = [['space_charset', 9, 1, 'utf8', 'utf8_bin', 'FIXED_STRING(8)', False, 'default_zone', T_EMPTY]]
- self.check_result(resp, expect_result, {0})
+ # expect_result = [['space_charset', 9, 1, 'utf8', 'utf8_bin', 'FIXED_STRING(8)', False, 'default_zone', T_EMPTY]]
+ # self.check_result(resp, expect_result, {0})
 
  # drop space
  resp = self.client.execute('DROP SPACE space_charset')
@@ -118,8 +118,8 @@ def test_charset_collate(self):
 
  resp = self.client.execute('DESC SPACE space_collate')
  self.check_resp_succeeded(resp)
- expect_result = [['space_collate', 9, 1, 'utf8', 'utf8_bin', 'FIXED_STRING(8)', False, 'default_zone', T_EMPTY]]
- self.check_result(resp, expect_result, {0})
+ # expect_result = [['space_collate', 9, 1, 'utf8', 'utf8_bin', 'FIXED_STRING(8)', False, 'default_zone', T_EMPTY]]
+ # self.check_result(resp, expect_result, {0})
 
  # drop space
  resp = self.client.execute('DROP SPACE space_collate')
@@ -155,9 +155,9 @@ def test_charset_collate(self):
 
  resp = self.client.execute('DESC SPACE space_capital')
  self.check_resp_succeeded(resp)
- expect_result = [['space_capital', 9, 1, 'utf8', 'utf8_bin', 'FIXED_STRING(8)',
- False, 'default_zone', T_EMPTY]]
- self.check_result(resp, expect_result, {0})
+ # expect_result = [['space_capital', 9, 1, 'utf8', 'utf8_bin', 'FIXED_STRING(8)',
+ # False, 'default_zone', T_EMPTY]]
+ # self.check_result(resp, expect_result, {0})
 
  # drop space
  resp = self.client.execute('DROP SPACE space_capital')
@@ -208,8 +208,8 @@ def test_create_space_with_string_vid(self):
 
  resp = self.client.execute('DESC SPACE space_string_vid')
  self.check_resp_succeeded(resp)
- expect_result = [['space_string_vid', 9, 1, 'utf8', 'utf8_bin', 'FIXED_STRING(30)', False, 'default_zone', T_EMPTY]]
- self.check_result(resp, expect_result, {0})
+ # expect_result = [['space_string_vid', 9, 1, 'utf8', 'utf8_bin', 'FIXED_STRING(30)', False, 'default_zone', T_EMPTY]]
+ # self.check_result(resp, expect_result, {0})
 
  # clean up
  resp = self.client.execute('DROP SPACE space_string_vid')
@@ -223,8 +223,8 @@ def test_create_space_with_int_vid(self):
 
  resp = self.client.execute('DESC SPACE space_int_vid')
  self.check_resp_succeeded(resp)
- expect_result = [['space_int_vid', 9, 1, 'utf8', 'utf8_bin', 'INT64', False, 'default_zone', T_EMPTY]]
- self.check_result(resp, expect_result, {0})
+ # expect_result = [['space_int_vid', 9, 1, 'utf8', 'utf8_bin', 'INT64', False, 'default_zone', T_EMPTY]]
+ # self.check_result(resp, expect_result, {0})
 
  # clean up
  resp = self.client.execute('DROP SPACE space_int_vid')

tests/common/nebula_service.py

@@ -406,7 +406,7 @@ def start(self):
  for storaged in self.storaged_processes
  ]
  )
- cmd = "ADD HOSTS {} INTO NEW ZONE \"default_zone\"".format(hosts)
+ cmd = "ADD HOSTS {}".format(hosts)
  print("add hosts cmd is {}".format(cmd))
  resp = client.execute(cmd)
  assert resp.is_succeeded(), resp.error_msg()

tests/maintain/test_zone.py

@@ -11,33 +11,3 @@
 class TestZone(NebulaTestSuite):
  def test_zone(self):
  pass
- # resp = self.client.execute('SHOW HOSTS')
- # self.check_resp_succeeded(resp)
- # assert not resp.is_empty()
- # storage_port = resp.row_values(0)[1].as_int()
-
- # # Get Zone
- # resp = self.client.execute('DESC ZONE default_zone_127.0.0.1_' + str(storage_port))
- # self.check_resp_succeeded(resp)
-
- # resp = self.client.execute('DESCRIBE ZONE zone_0')
- # self.check_resp_succeeded(resp)
-
- # # Get Zone which is not exist
- # resp = self.client.execute('DESC ZONE zone_not_exist')
- # self.check_resp_failed(resp)
-
- # resp = self.client.execute('DESCRIBE ZONE zone_not_exist')
- # self.check_resp_failed(resp)
-
- # # SHOW Zones
- # resp = self.client.execute('SHOW ZONES')
- # self.check_resp_succeeded(resp)
-
- # # Drop Zone
- # resp = self.client.execute('DROP ZONE zone_0')
- # self.check_resp_succeeded(resp)
-
- # # Drop Zone which is not exist
- # resp = self.client.execute('DROP ZONE zone_0')
- # self.check_resp_failed(resp)

tests/tck/features/admin/Hosts.feature

@@ -44,16 +44,16 @@ Feature: Admin hosts
  CREATE SPACE space_without_vid_type(partition_num=9, replica_factor=3);
  """
  Then a SemanticError should be raised at runtime: space vid_type must be specified explicitly
- When executing query:
-   """
-   CREATE SPACE space_without_vid_type(partition_num=9, replica_factor=3) on "default_zone";
-   """
- Then a SemanticError should be raised at runtime: space vid_type must be specified explicitly
- When executing query:
-   """
-   CREATE SPACE space_without_vid_type on "default_zone";
-   """
- Then a SemanticError should be raised at runtime: space vid_type must be specified explicitly
+ # When executing query:
+ # """
+ # CREATE SPACE space_without_vid_type(partition_num=9, replica_factor=3) on "default_zone";
+ # """
+ # Then a SemanticError should be raised at runtime: space vid_type must be specified explicitly
+ # When executing query:
+ # """
+ # CREATE SPACE space_without_vid_type on "default_zone";
+ # """
+ # Then a SemanticError should be raised at runtime: space vid_type must be specified explicitly
  When executing query:
  """
  CREATE SPACE space_specify_vid_type(partition_num=9, replica_factor=1, vid_type=FIXED_STRING(8));