修复 SQL Server 到 MySQL 迁移期间 SSIS 中的“未为参数提供数据”问题

解决方案 1：将 SSIS 与 ADO.NET 目标和参数映射结合使用

将 SSIS 与 ADO.NET 目标结合使用来管理 SQL Server 到 MySQL 的数据迁移并处理参数映射问题。

-- Enable the NO_ENGINE_SUBSTITUTION and ANSI_QUOTES mode on MySQL to simplify compatibility -- Run as a preliminary Execute SQL Task in SSISSET sql_mode = 'NO_ENGINE_SUBSTITUTION,ANSI_QUOTES';
-- Create a MySQL table for the destinationCREATE TABLE test (nu INT);
-- Ensure that the table is empty before data insertionTRUNCATE TABLE test;
-- Configure SSIS Data Flow Task in SQL Server Data Tools (SSDT)
-- 1. Use an OLE DB Source to select data from SQL Server
-- 2. Map the "nu" column to MySQL’s "nu" column in the ADO.NET Destination Editor
-- 3. Use "Use a Table or View" mode in the ADO.NET Destination to auto-generate insert commands
-- 4. Verify that each parameter aligns with destination columns by checking the Preview feature
-- Example SQL Command on OLE DB Source (SSIS)
SELECT nu FROM dbo.test;

解决方案 2：ADO.NET 和 MySQL 连接器（C# 脚本）

使用 C# 脚本实现数据迁移，以实现从 SQL Server 到 MySQL 的更定制的数据传输。

// C# Script: Migrate data from SQL Server to MySQL with parameterized commands
using System.Data.SqlClient;
using MySql.Data.MySqlClient;
public void MigrateData()
{
    string sqlConnectionString = "Data Source=your_sql_server;Initial Catalog=your_db;User ID=user;Password=password";
    string mysqlConnectionString = "Server=your_mysql_server;Database=your_db;User ID=user;Password=password";
    using (SqlConnection sqlConn = new SqlConnection(sqlConnectionString))
    using (MySqlConnection mysqlConn = new MySqlConnection(mysqlConnectionString))
    {
        sqlConn.Open();
        mysqlConn.Open();
        string query = "SELECT nu FROM dbo.test";
        using (SqlCommand sqlCommand = new SqlCommand(query, sqlConn))
        using (MySqlCommand mysqlCommand = new MySqlCommand("INSERT INTO test (nu) VALUES (@nu)", mysqlConn))
        {
            mysqlCommand.Parameters.Add(new MySqlParameter("@nu", MySqlDbType.Int32));
            using (SqlDataReader reader = sqlCommand.ExecuteReader())
            {
                while (reader.Read())
                {
                    mysqlCommand.Parameters["@nu"].Value = reader.GetInt32(0);
                    mysqlCommand.ExecuteNonQuery();
                }
            }
        }
    }
}

解决方案 3：SSIS 迁移验证的单元测试

C# 单元测试脚本，用于验证从 SQL Server 迁移到 MySQL 时的数据一致性。

// Unit Test using NUnit to verify data migration accuracy
using NUnit.Framework;
using System.Data.SqlClient;
using MySql.Data.MySqlClient;
[TestFixture]
public class MigrationTests
{
    [Test]
    public void VerifyDataTransfer()
    {
        string sqlConnString = "Data Source=your_sql_server;Initial Catalog=your_db;User ID=user;Password=password";
        string mysqlConnString = "Server=your_mysql_server;Database=your_db;User ID=user;Password=password";
        using (SqlConnection sqlConn = new SqlConnection(sqlConnString))
        using (MySqlConnection mysqlConn = new MySqlConnection(mysqlConnString))
        {
            sqlConn.Open();
            mysqlConn.Open();
            // Query source and destination for comparison
            using (SqlCommand sqlCmd = new SqlCommand("SELECT COUNT(*) FROM dbo.test", sqlConn))
            using (MySqlCommand mysqlCmd = new MySqlCommand("SELECT COUNT(*) FROM test", mysqlConn))
            {
                int sqlCount = (int)sqlCmd.ExecuteScalar();
                int mysqlCount = Convert.ToInt32(mysqlCmd.ExecuteScalar());
                Assert.AreEqual(sqlCount, mysqlCount, "Record count mismatch between SQL Server and MySQL");
            }
        }
    }
}

有关解决 SSIS 迁移中的参数错误的常见问题

1. 是什么导致 SSIS 中出现“未提供参数数据”错误？
2. 此错误通常是由于迁移中参数未对齐或未初始化的值造成的，尤其是在迁移过程中 ADO.NET Destination MySQL 的组件。
3. 如何 SET sql_mode 迁移过程中的命令帮助？
4. 通过设置 sql_mode 改为“NO_ENGINE_SUBSTITUTION, ANSI_QUOTES”，允许 MySQL 灵活地解释引号，减少语法错误并提高与 SSIS 的兼容性。
5. 的作用是什么 MySqlDbType.Int32 在 C# 迁移脚本中？
6. 此命令可确保从 SQL Server 传输的整数值在 MySQL 中正确映射，从而防止插入期间发生数据类型冲突。
7. 如何验证所有数据行是否已正确迁移？
8. 使用单元测试 Assert.AreEqual 帮助检查源行计数和目标行计数是否匹配，确保迁移过程中的数据完整性。
9. 能否在 SSIS 中使用 C# 脚本代替 ADO.NET 目标？
10. 是的，自定义 C# 脚本 SqlDataReader 和 MySqlCommand 提供更多控制，允许您手动处理参数并避免常见的 SSIS 错误。
11. 是 ExecuteReader 每个 C# 迁移脚本都必需吗？
12. 不一定，但是 ExecuteReader 当您需要逐行处理来控制数据流并处理特定的转换逻辑时非常有用。
13. 为什么 SSIS 难以应对 MySQL 的参数处理？
14. 由于 SQL Server 和 MySQL 数据处理的差异，SSIS 的 ADO.NET 目标组件可能会误解 MySQL 中的参数，因此需要手动映射。
15. 如何处理 SSIS 迁移中的引用错误？
16. 环境 sql_mode 通过执行 SQL 任务转换为 ANSI_QUOTES 有助于 MySQL 将引号处理为标识符，从而减少 SSIS 解析错误。
17. 每次迁移之前都需要截断表吗？
18. 是的，使用 TRUNCATE TABLE 清除现有数据，防止重复并确保准确的迁移结果。
19. 将 NUnit 与 SSIS 迁移结合使用有什么好处？
20. NUnit 测试提供自动验证，帮助您在投入生产之前确认行数和数据准确性符合预期。

有效解决迁移错误

将数据从 SQL Server 迁移到 MySQL 时，解决 SSIS 中的参数错误可能具有挑战性。通过了解 ADO.NET 目标的配置要求并实施 SQL 模式调整，您可以缓解常见的兼容性问题。这些步骤在处理 SSIS 本身不符合 MySQL 要求的参数化查询时特别有用。 🚀

在迁移过程中应用单元测试来验证行计数也是有益的，可以确保源数据库和目标数据库之间的数据准确性。借助这些解决方案，数据库专业人员可以更有效地应对 SSIS 迁移挑战，节省时间并避免与跨平台数据传输相关的常见陷阱。