/
envoy.istio
/
oblogproxy
Обзор
Документация
Войти
/
envoy.istio
/
oblogproxy
Код
Запросы
0
Пакеты
0
Релизы
0
CI/CD
Аналитика
Безопасность
dev
third-party/etransfer-cpp/src/sink/drop_table_object_builder.cpp
46 строк
2 KB
wangxiantong.wxt
support ddl convert
17 янв 2024, 09:54
17 янв 2024, 09:54
818805e
Код
Авторство
О чём код?
/** * Copyright (c) 2024 OceanBase * OceanBase Migration Service LogProxy 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 "sink/drop_table_object_builder.h" #include "object/drop_table_object.h" #include "sink/sql_builder_util.h" namespace etransfer { namespace sink { DropTableObjectBuilder &DropTableObjectBuilder::Instance() { static DropTableObjectBuilder the_drop_table_object_builder; return the_drop_table_object_builder; } Strings DropTableObjectBuilder::RealBuildSql( ObjectPtr db_object, ObjectPtr parent_object, std::shared_ptr<BuildContext> sql_builder_context) { std::shared_ptr<object::DropTableObject> drop_table_object = std::dynamic_pointer_cast<object::DropTableObject>(db_object); Strings res; std::string line; line.append("DROP TABLE "); auto tables = drop_table_object->GetTablesToDrop(); for (int i = 0; i < tables.size(); i++) { if (i > 0) { line.append(","); } line.append(SqlBuilderUtil::BuildRealTableName( tables[i].first, tables[i].second, sql_builder_context, true)); } res.push_back(line); return res; } } // namespace sink } // namespace etransfer