1

我在 C# 中创建了一个程序来将 MySql 数据库结构和过程复制到新创建的数据库中。然后将新数据上传到它。无法上传包含“@”符号的程序的问题，例如：

SET @SEARCH := CONCAT( _SEARCH , '%');

我用来检索程序的代码是：

cmd = new MySqlCommand("SELECT CONCAT( 'CREATE PROCEDURE ', ISR.ROUTINE_NAME, '(', CASE WHEN ISP.PARAMETER_NAME IS NOT NULL THEN GROUP_CONCAT(CONCAT(ISP.PARAMETER_MODE, ' ', ISP.PARAMETER_NAME, ' ', ISP.DTD_IDENTIFIER)) ELSE '' END, ')\n', ISR.ROUTINE_DEFINITION) AS Create_Procedure FROM INFORMATION_SCHEMA.ROUTINES ISR LEFT JOIN INFORMATION_SCHEMA.PARAMETERS ISP ON ISR.ROUTINE_SCHEMA = ISP.SPECIFIC_SCHEMA AND ISR.ROUTINE_NAME = ISP.SPECIFIC_NAME AND ISR.ROUTINE_TYPE = ISP.ROUTINE_TYPE WHERE ROUTINE_SCHEMA = '" + Program.RemoteSource + "' GROUP BY ISR.ROUTINE_NAME;", remote);
using (MySqlDataReader dataReader = cmd.ExecuteReader())
    {
      while (dataReader.Read())
           {
             createProcedures.Add(dataReader.GetString(0));
           }
    };

以下将新的创建过程语句上传到新数据库：

counter = 0;
foreach (string procedure in createProcedures)
   {
     try
        {
            cmd = new MySqlCommand(@procedure, remote);
            cmd.ExecuteNonQuery();
            counter++;
            Console.Write("\rProcedures Created: " + counter + " of " + createProcedures.Count);
         }
     catch (MySqlException ex)
         {
             Console.WriteLine("Error: {0}", ex.ToString());
         }
    }

和错误：

Error: MySql.Data.MySqlClient.MySqlException (0x800040005): 
Fatal error encountered during command execution.  ---> 
MySql.Data.MySqlClient.MySqlException (0x800040005): 
   Parameter '@SEARCH' must be defined.

我将如何让 MySql.Data 忽略 @ 符号？

4

2 回答 2

1

;Allow User Variables=True我通过添加到连接字符串找到了答案。

是否可以在 .NET MySqlCommand 中使用 MySql 用户定义变量？

于 2014-04-03T20:24:56.483 回答
0

如何使用参数，如下所示：

cmd = new MySqlCommand("SELECT CONCAT( 'CREATE PROCEDURE ', ISR.ROUTINE_NAME, '(', CASE WHEN ISP.PARAMETER_NAME IS NOT NULL THEN GROUP_CONCAT(CONCAT(ISP.PARAMETER_MODE, ' ',ISP.PARAMETER_NAME, ' ', ISP.DTD_IDENTIFIER)) ELSE '' END, ')\n', ISR.ROUTINE_DEFINITION) AS Create_Procedure FROM INFORMATION_SCHEMA.ROUTINES ISR LEFT JOIN INFORMATION_SCHEMA.PARAMETERS ISP ON ISR.ROUTINE_SCHEMA = ISP.SPECIFIC_SCHEMA AND ISR.ROUTINE_NAME = ISP.SPECIFIC_NAME AND ISR.ROUTINE_TYPE = ISP.ROUTINE_TYPE WHERE ROUTINE_SCHEMA = @routine_schema GROUP BY ISR.ROUTINE_NAME;", remote);
cmd.Parameters.AddWithValue("@routine_schema", Program.RemoteSource);
    using (MySqlDataReader dataReader = cmd.ExecuteReader())
        {
          while (dataReader.Read())
               {
                 createProcedures.Add(dataReader.GetString(0));
               }
        };
于 2014-04-03T19:09:00.117 回答