如何使用SSIS在Vertica目标库执行带绑定变量的DELETE命令

方案1：使用ODBC Command组件直接替代OLE DB Command #

这是改动最小的方案，不需要调整原有同步逻辑：

• 先下载安装Vertica官方ODBC驱动，在SSIS运行服务器上配置好系统DSN，测试连接正常
• 删除原有OLE DB Command组件，替换为ODBC Command组件
• 组件的连接管理器选择新建的Vertica ODBC连接，SQL命令仍使用你之前的写法delete from targetTB where ID=?
• 在参数映射页面，把输入流里的ID列映射到参数0即可，配置逻辑和OLE DB Command基本一致

注意：Vertica ODBC驱动的参数占位符默认用?，按顺序匹配即可，不需要指定参数名，只要映射顺序和SQL语句中?的顺序一致就不会报错。

方案2：批量删除（适合大数量变更场景，性能更高） #

如果你的CDC变更数据量较大，逐行执行删除性能太低，可以用批量处理方案，完全避开结果集转参数的问题：

• 首先在数据流中拆分CDC变更流，把需要删除的ID（包括删除操作的ID、更新操作的前镜像ID）单独输出到Vertica的会话级临时表temp_delete_ids，表结构仅保留ID字段即可
• 数据流执行完成后，添加一个Execute SQL Task，连接到Vertica，直接执行批量删除SQL：

delete from targetTB where ID in (select ID from temp_delete_ids)

该方案不需要做任何结果集到参数的映射，执行效率比逐行删除高5-10倍。

方案3：脚本组件自定义执行删除（灵活度最高） #

如果上面两个方案存在兼容问题，可以用脚本组件自定义控制执行逻辑：

• 先安装Vertica官方.NET驱动（Vertica.Data.dll），在SSIS脚本项目的引用中添加该dll
• 数据流中添加「转换」类型的脚本组件，输入列勾选ID列和CDC操作类型列（通常为__$operation，1=删除、3=更新前镜像）
• 编辑脚本，核心逻辑示例如下：

using Vertica.Data.VerticaClient;

private VerticaConnection verticaConn;
public override void PreExecute()
{
    base.PreExecute();
    // 连接字符串建议存储在SSIS变量中方便修改，此处为示例直接写死
    string connStr = "Server=Vertica服务器地址;Port=5433;Database=数据库名;User=用户名;Password=密码;";
    verticaConn = new VerticaConnection(connStr);
    verticaConn.Open();
}

public override void Input0_ProcessInputRow(Input0Buffer Row)
{
    // 遇到删除或者更新前镜像的行，执行目标表删除
    if (Row.__operation == 1 || Row.__operation == 3)
    {
        using (var cmd = new VerticaCommand("delete from targetTB where ID = @id", verticaConn))
        {
            cmd.Parameters.AddWithValue("@id", Row.ID);
            cmd.ExecuteNonQuery();
        }
    }
}

public override void PostExecute()
{
    base.PostExecute();
    if (verticaConn != null && verticaConn.State == System.Data.ConnectionState.Open)
    {
        verticaConn.Close();
        verticaConn.Dispose();
    }
}

内容的提问来源于stack exchange，提问作者alice