使用LINQ和mysqlconnection时遇到致命错误

本文关键字：遇到 致命错误 mysqlconnection LINQ 使用 | 更新日期: 2023-09-27 18:01:29

我对c#很陌生，所以请任何帮助将是伟大的。我做了一个简单的控制台代码更新到mysql数据库，放心我的数据库完成设置，App.config完成。现在的问题是，当我运行测试代码时，出现了这个错误。"执行命令时遇到致命错误"

下面是我的代码:

类库:

public class DBEntity
{
        private MySqlConnection DBConnection { get;  set; }
        public string INSERT = "insert";
        public string SELECT = "select";
        public string UPDATE = "update";
        public void Get_Connection(string ConnectionString)
        {
            DBConnection = new MySqlConnection(ConnectionString);
        }
        public void Close_Connection()
        {
            DBConnection.Close();
        }
        public void Query(string operation, string query, params object[] values)
        {
            try
            {
                DBConnection.Open();
                switch (operation)
                {
                    case "update":
                        try
                        {
                            using (MySqlCommand cmd = new MySqlCommand(query, DBConnection))
                            {
                                IEnumerable<string> tokens = query.Split(new char[] { ' ', '''', ';', ',' }).Where(str => str.Contains('@'));
                                var zipTwoTokens = tokens.Zip(values, (token, vals) => cmd.Parameters.AddWithValue(token, vals)).ToList();
                                cmd.ExecuteNonQuery();
                                DBConnection.Close();
                            }
                        }
                        catch (MySqlException e)
                        {
                            DBConnection.Close();
                            Console.WriteLine(e.Message);
                        }
                        break;
                    default:
                        break;
                }
            }
            catch (MySqlException)
            {
            }
       }
}

Main类

class Program
{
    static void Main(string[] args)
    {
        DBEntity database = new DBEntity();
        database.Get_Connection(ConfigurationManager.ConnectionStrings["MySQLConnection"].ConnectionString);
        database.Query(database.UPDATE, "UPDATE RoyDB.Products SET Products.Name = @productName WHERE Products.ProductID = @product;", "Kayak", 1);
        Console.Read();
    }
}

现在，问题是当我运行测试我的代码时，这个错误发生了。"执行命令时遇到致命错误"

有人能帮我吗?我似乎不明白错误的原因。

任何帮助将是伟大的!谢谢!

使用LINQ和mysqlconnection时遇到致命错误

拆分查询以确定参数的方式不太正确。在这种情况下，它包括分号，所以你得到的参数叫做@productName和@product;。在分割字符串中添加分号，如下所示:

IEnumerable<string> tokens = 
    query.Split(new char[] { ' ', '''', ';'}).Where(str => str.Contains('@'));

另外，你需要强制Zip方法被调用，因为Linq使用延迟执行。为此，在zip末尾添加ToList:

var zipTwoTokens = 
    parameterToken.Zip(values, (prmtoken, vals) => 
        cmd.Parameters.AddWithValue(prmtoken, vals)).ToList();
相关文章：