MySQLRemoteExecutor();

~MySQLRemoteExecutor() override;

void add_backend(const BackendConfig& config);

ResultSet execute(const char* backend_name, sql_parser::StringRef sql) override;

DmlResult execute_dml(const char* backend_name, sql_parser::StringRef sql) override;

bool allows_unpinned_distributed_2pc() const override { return true; }

void disconnect_all();

struct Connection {

BackendConfig config;

MYSQL* conn = nullptr;

bool connected = false;

};

std::unordered_map<std::string, Connection> backends_;

Connection& get_or_connect(const std::string& name);

ResultSet mysql_result_to_resultset(MYSQL_RES* res);

Value mysql_field_to_value(ResultSet& rs, const char* data,

unsigned long length,

enum_field_types type, bool is_null);