refactor: rm boost split (#4047)

Author: dl239

src/apiserver/api_server_impl.cc

@@ -24,6 +24,7 @@
 #include "apiserver/interface_provider.h"
 
 #include "absl/cleanup/cleanup.h"
+#include "absl/strings/ascii.h"
 #include "brpc/server.h"
 #include "butil/time.h"
 
@@ -160,7 +161,7 @@ void APIServerImpl::RegisterQuery() {
             writer << resp.Set("Json parse failed, " + req.status().ToString());
             return;
         }
-        auto mode = boost::to_lower_copy(req.mode);
+        auto mode = absl::AsciiStrToLower(req.mode);
         auto it = mode_map.find(mode);
         if (it == mode_map.end()) {
             writer << resp.Set("Invalid mode " + mode);

src/base/ddl_parser.cc

@@ -24,6 +24,7 @@
 #include <vector>
 #include <set>
 
+#include "absl/strings/str_split.h"
 #include "codec/schema_codec.h"
 #include "google/protobuf/util/message_differencer.h"
 #include "node/node_manager.h"
@@ -644,8 +645,7 @@ std::tuple<std::string, std::string, std::string, common::ColumnKey> IndexMapBui
     auto ts_sep = index_str.find(TS_MARK);
     auto keys_str = index_str.substr(key_sep + 1, ts_sep - key_sep - 1);
     // split keys
-    std::vector<std::string> keys;
-    boost::split(keys, keys_str, boost::is_any_of(std::string(1, KEY_SEP)));
+    std::vector<std::string> keys = absl::StrSplit(keys_str, std::string(1, KEY_SEP));
     for (auto& key : keys) {
         DCHECK(!key.empty());
         column_key.add_col_name(key);

src/base/ddl_parser_test.cc

@@ -19,6 +19,8 @@
 #include <utility>
 
 #include "absl/cleanup/cleanup.h"
+#include "absl/strings/strip.h"
+#include "absl/strings/str_split.h"
 #include "codec/schema_codec.h"
 #include "glog/logging.h"
 #include "google/protobuf/util/message_differencer.h"
@@ -81,23 +83,20 @@ void StrToTTLType(const std::string& ttl_type, type::TTLType* type) {
 
 common::ColumnKey ParseIndex(const std::string& index_str) {
     common::ColumnKey key;
-    std::vector<std::string> vec;
-    boost::split(vec, index_str, boost::is_any_of(";"));
+    std::vector<std::string> vec = absl::StrSplit(index_str, ";");  
     if (vec.size() != 3) {
         LOG(WARNING) << "invalid index str " << index_str;
         return {};
     }
-    std::vector<std::string> keys;
-    boost::split(keys, vec[0], boost::is_any_of(","));
+    std::vector<std::string> keys = absl::StrSplit(vec[0], ",");
     for (auto& k : keys) {
         key.add_col_name(k);
     }
     if (!vec[1].empty()) {
         key.set_ts_name(vec[1]);
     }
     // parse ttl in vec[2]
-    std::vector<std::string> ttl_parts;
-    boost::split(ttl_parts, vec[2], boost::is_any_of(","));
+    std::vector<std::string> ttl_parts = absl::StrSplit(vec[2], ",");
     if (ttl_parts.size() != 3) {
         LOG(WARNING) << "invalid ttl str " << vec[2];
         return {};
@@ -184,8 +183,8 @@ class DDLParserTest : public ::testing::Test {
         // copy to trim
         auto name = col_name;
         auto type = col_type;
-        boost::trim(name);
-        boost::trim(type);
+        absl::StripAsciiWhitespace(&name);
+        absl::StripAsciiWhitespace(&type);
         auto col = table->add_columns();
         col->set_name(name);
         auto t = codec::DATA_TYPE_MAP.find(type);
@@ -214,13 +213,11 @@ class DDLParserTest : public ::testing::Test {
                              const std::string& col_sep, const std::string& name_type_sep) {
         auto table = db->add_tables();
         table->set_name(table_name);
-        std::vector<std::string> cols;
-        boost::split(cols, cols_def, boost::is_any_of(col_sep));
+        std::vector<std::string> cols = absl::StrSplit(cols_def, col_sep);
         for (auto col : cols) {
             // name: type
-            std::vector<std::string> vec;
-            boost::trim(col);
-            boost::split(vec, col, boost::is_any_of(name_type_sep));
+            absl::StripAsciiWhitespace(&col);
+            std::vector<std::string> vec = absl::StrSplit(col, name_type_sep);
             EXPECT_EQ(vec.size(), 2);
 
             auto name = vec[0];

src/cmd/openmldb.cc

@@ -24,6 +24,8 @@
 #include <memory>
 #include <random>
 
+#include "absl/strings/strip.h"
+#include "absl/strings/str_split.h"
 #include "base/file_util.h"
 #include "base/glog_wrapper.h"
 #include "base/hash.h"
@@ -38,7 +40,6 @@
 #endif
 #include "apiserver/api_server_impl.h"
 #include "auth/brpc_authenticator.h"
-#include "boost/algorithm/string.hpp"
 #include "boost/lexical_cast.hpp"
 #include "brpc/server.h"
 #include "client/ns_client.h"
@@ -371,8 +372,7 @@ int SplitPidGroup(const std::string& pid_group, std::set<uint32_t>& pid_set) {
         if (::openmldb::base::IsNumber(pid_group)) {
             pid_set.insert(boost::lexical_cast<uint32_t>(pid_group));
         } else if (pid_group.find('-') != std::string::npos) {
-            std::vector<std::string> vec;
-            boost::split(vec, pid_group, boost::is_any_of("-"));
+            std::vector<std::string> vec = absl::StrSplit(pid_group, "-");
             if (vec.size() != 2 || !::openmldb::base::IsNumber(vec[0]) || !::openmldb::base::IsNumber(vec[1])) {
                 return -1;
             }
@@ -383,8 +383,7 @@ int SplitPidGroup(const std::string& pid_group, std::set<uint32_t>& pid_set) {
                 start_index++;
             }
         } else if (pid_group.find(',') != std::string::npos) {
-            std::vector<std::string> vec;
-            boost::split(vec, pid_group, boost::is_any_of(","));
+            std::vector<std::string> vec = absl::StrSplit(pid_group, ",");
             for (const auto& pid_str : vec) {
                 if (!::openmldb::base::IsNumber(pid_str)) {
                     return -1;
@@ -3630,7 +3629,7 @@ void StartClient() {
             }
             if (line[0] != '\0' && line[0] != '/') {
                 buffer.assign(line);
-                boost::trim(buffer);
+                absl::StripAsciiWhitespace(&buffer);
                 if (!buffer.empty()) {
                     ::openmldb::base::linenoiseHistoryAdd(line);
                 }
@@ -3780,7 +3779,7 @@ void StartNsClient() {
 
             if (line[0] != '\0' && line[0] != '/') {
                 buffer.assign(line);
-                boost::trim(buffer);
+                absl::StripAsciiWhitespace(&buffer);
                 if (!buffer.empty()) {
                     ::openmldb::base::linenoiseHistoryAdd(line);
                 }
@@ -3909,8 +3908,7 @@ void StartAPIServer() {
 
     auto api_service = std::make_unique<::openmldb::apiserver::APIServerImpl>(real_endpoint);
     if (!FLAGS_nameserver.empty()) {
-        std::vector<std::string> vec;
-        boost::split(vec, FLAGS_nameserver, boost::is_any_of(":"));
+        std::vector<std::string> vec = absl::StrSplit(FLAGS_nameserver, ":");
         if (vec.size() != 2) {
             PDLOG(WARNING, "Invalid nameserver format");
             exit(1);

src/codec/row_codec.cc

@@ -21,7 +21,6 @@
 #include <vector>
 
 #include "base/glog_wrapper.h"
-#include "boost/algorithm/string.hpp"
 #include "boost/container/deque.hpp"
 #include "codec/schema_codec.h"
 #include "codec/row_codec.h"

src/codec/schema_codec.h

@@ -32,7 +32,6 @@
 #include "codec/fe_row_codec.h"
 #include "codec/field_codec.h"
 #include "proto/name_server.pb.h"
-#include <boost/algorithm/string.hpp>
 
 namespace openmldb {
 namespace codec {

src/nameserver/name_server_impl.cc

@@ -25,6 +25,7 @@
 
 #include "absl/strings/numbers.h"
 #include "absl/strings/str_cat.h"
+#include "absl/strings/str_join.h"
 #include "absl/strings/str_split.h"
 #include "absl/time/time.h"
 #include "nameserver/system_table.h"
@@ -41,7 +42,6 @@
 #include "base/proto_util.h"
 #include "base/status.h"
 #include "base/strings.h"
-#include "boost/algorithm/string.hpp"
 #include "boost/bind.hpp"
 #include "codec/row_codec.h"
 #include "gflags/gflags.h"
@@ -1456,7 +1456,7 @@ base::Status NameServerImpl::FlushPrivileges() {
     }
     if (failed_tablet_list.size() > 0) {
         return {ReturnCode::kFlushPrivilegesFailed,
-                "Failed to flush privileges to tablets: " + boost::algorithm::join(failed_tablet_list, ", ")};
+                "Failed to flush privileges to tablets: " + absl::StrJoin(failed_tablet_list, ", ")};
     }
     return {};
 }

src/zk/zk_client.cc

@@ -20,9 +20,9 @@
 #include <utility>
 
 #include "absl/cleanup/cleanup.h"
+#include "absl/strings/str_split.h"
 #include "base/glog_wrapper.h"
 #include "base/strings.h"
-#include "boost/algorithm/string.hpp"
 #include "boost/lexical_cast.hpp"
 #include "gflags/gflags.h"
 
@@ -617,8 +617,7 @@ bool ZkClient::MkdirNoLock(const std::string& path) {
     if (zk_ == NULL || !connected_) {
         return false;
     }
-    std::vector<std::string> parts;
-    boost::split(parts, path, boost::is_any_of("/"));
+    std::vector<std::string> parts = absl::StrSplit(path, "/");
     std::string full_path = "/";
     std::vector<std::string>::iterator it = parts.begin();
     int32_t index = 0;