时间戳

首页 > 解决方案 > 存储过程适用于 Mysql 工作台，但不适用于 C# 代码

c# - 存储过程适用于 Mysql 工作台，但不适用于 C# 代码

问题描述

我有一个存储过程，我想删除它然后想重新创建它。它在 Mysql 工作台上工作，但在 c# 代码中不工作。

我正在使用 MySql Workbench 6.3 CE

这是存储过程的试运行：

 DROP PROCEDURE IF EXISTS AccountGetAccountOpeningClosingStock;
 DELIMITER $$
 CREATE DEFINER=`root`@`%` PROCEDURE 
 `AccountGetAccountOpeningClosingStock`(IN _endDate datetime)
  BEGIN
  Select * From openingclosingstock Where CreateDate <= _endDate order by 
  CreateDate asc;
  END$$
  DELIMITER ;

这是来自 C# 代码的调用：

string myConnectionString = FetchDbConnectionString(environment, item);
MySqlConnection mySqlConnection = new MySqlConnection(myConnectionString);

MySqlCommand mySqlCommand = new MySqlCommand(storedProcedureSqlQuery, mySqlConnection);

await mySqlConnection.OpenAsync();

var reader = await mySqlCommand.ExecuteReaderAsync();

while (await reader.ReadAsync())
{
     // do something
}

reader.Close();
await mySqlConnection.CloseAsync();

来自 C# 代码的错误：

您的 SQL 语法有错误；检查与您的 MySQL 服务器版本相对应的手册，以在第 1 行的 'DELIMITER $$ CREATE DEFINER= root@ %PROCEDURE `AccountGetAccountOpeningClosi'附近使用正确的语法

我为示例创建了一个应用程序： 演示存储过程

标签： c#mysql

解决方案

看起来您正试图让 proc 同时重新创建和运行。这应该可以为您提供您正在寻找的数据，否则请调用 SQL 中的过程来获取数据。如果您尝试重新创建（测试它是否存在），请在需要数据之前在程序的单独部分中进行。

string myConnectionString = FetchDbConnectionString(environment, item);
MySqlConnection mySqlConnection = new MySqlConnection(myConnectionString);
string SQLC= "Select * From openingclosingstock Where CreateDate <= _endDate 
order by CreateDate asc;"
MySqlCommand mySqlCommand = new 
MySqlCommand(SQLC, mySqlConnection);
await mySqlConnection.OpenAsync();
var reader = await mySqlCommand.ExecuteReaderAsync();
while (await reader.ReadAsync())
{
    //do something
}
reader.Close();
await mySqlConnection.CloseAsync();

还是您在这里创建生产者以便稍后调用它？

删除开头的 DELIMITER $$ 和最后一个 END 后的 $$

DELIMITER 是一个 MySQL 客户端命令，使您能够在定义存储例程时临时更改其语句终止符。

如果您从不使用分号作为语句终止符的编程接口中定义存储例程，则存储例程定义中的分号不会出现任何特殊问题。

不知道那个代码能不能用。也许试试这个：

using (MySqlConnection conn = new MySqlConnection(connectionString))
{ 
conn.Open();

    using (MySqlTransaction trans = conn.BeginTransaction())
    {
        using (MySqlCommand command = conn.CreateCommand())
        {
            command.CommandText = query;

            command.ExecuteNonQuery();
        }

         trans.Commit();
    }
}

和 SQL：

DROP PROCEDURE IF EXISTS AccountGetAccountOpeningClosingStock;
 CREATE PROCEDURE AccountGetAccountOpeningClosingStock(IN endDate datetime) 

 BEGIN 
 Select * From openingclosingstock
 Where CreateDate <= endDate order by CreateDate; 

 END;

推荐阅读