Struct MySqlExecutor 

pub struct MySqlExecutor { /* private fields */ }

MySQL容器异步差异SQL执行器 专为Duck Client自动升级部署设计

Implementations

impl MySqlExecutor

pub fn new(config: MySqlConfig) -> Self

创建新的执行器

pub async fn test_connection(&self) -> Result<(), Error>

测试连接是否可用

pub async fn execute_single(&self, sql: &str) -> Result<u64, Error>

执行单个SQL语句

pub async fn execute_diff_sql( &self, sql_content: &str, ) -> Result<Vec<String>, Error>

执行差异SQL内容（多语句支持） 自动处理注释和空行，支持事务回滚

pub async fn execute_diff_sql_with_retry( &self, sql_content: &str, max_retries: u8, ) -> Result<Vec<String>, Error>

带重试机制的SQL执行

pub async fn get_table_info(&self, table_name: &str) -> Result<(), Error>

获取数据库表结构信息

pub async fn fetch_live_schema( &self, ) -> Result<HashMap<String, TableDefinition>, Error>

抓取在线数据库架构：通过 SHOW CREATE TABLE 获取真实DDL，再用 sqlparser 解析为内部类型

pub async fn fetch_live_schema_with_sql( &self, ) -> Result<(HashMap<String, TableDefinition>, String), Error>

抓取在线数据库架构并返回原始 SQL 返回：(解析后的表定义, 原始 CREATE TABLE SQL)

pub async fn verify_execution( &self, _expected_changes: &str, ) -> Result<bool, Error>

验证执行结果

pub async fn health_check(&self) -> HealthStatus

检查数据库连接健康