Struct SchemaSync 

pub struct SchemaSync { /* private fields */ }

Schema Sync 协调器

Implementations

impl SchemaSync

pub fn new(entity_tables: Vec<TableDef>) -> Self

创建 SchemaSync（按方言选择 DDL 生成器）

pub fn with_generator( entity_tables: Vec<TableDef>, ddl_generator: Box<dyn DdlGenerator>, ) -> Self

创建 SchemaSync（指定 DDL 生成器）

pub fn with_rename_threshold(self, max_distance: usize, max_ratio: f64) -> Self

配置重命名检测阈值（v2.2.0 B-2）

pub async fn sync_dry_run( &self, conn: &mut dyn Connection, ) -> Result<Vec<String>, DbError>

干运行：计算 DDL 但不执行

1. introspect → 读取 DB 现有表结构
2. diff → 计算变更
3. 检查破坏性变更 → 若有则返回 Err(DestructiveChangeDetected)
4. generate → 生成 DDL

pub async fn sync( &self, conn: &mut dyn Connection, ) -> Result<SyncResult, DbError>

执行同步：事务内执行 DDL

1. sync_dry_run → 获取 DDL
2. begin_transaction
3. 逐条执行 DDL
4. commit / rollback

pub fn diff_against(&self, db_tables: &[TableDef]) -> SchemaDiff

仅计算 diff（不连接 DB）

pub async fn destructive_sync( &self, conn: &mut dyn Connection, confirm: Confirm, hooks: Option<&dyn DataMigrationHook>, ) -> Result<DestructiveSyncResult, DbError>

执行破坏性同步（v2.2.0 B-2）

显式执行破坏性 DDL（DROP COLUMN / RENAME COLUMN），需 Confirm::Yes 确认。 事务内原子执行，每条破坏性 DDL 前调用对应钩子。

参数

• conn：数据库连接
• confirm：显式确认（必须 Confirm::Yes 才执行）
• hooks：可选数据迁移钩子

异常处理

• confirm == Confirm::No → 返回 Err 要求显式确认
• 钩子失败 → ROLLBACK 返回 Err
• DDL 执行失败 → ROLLBACK 返回 Err