我正在做一个项目，我必须通过循环更新 MySql 中的表，并更新 C# 中的每一行(逐行)。 注意:我只需要更新表中一列的值。

现在，我知道这个问题之前已经被问过(很多次)，但是在花了很多时间在互联网上搜索之后，我还没有找到解决我的问题的方法。

更多说明:

所以我已经知道完成这项工作所必需的一些事情:

• 我知道如何建立(有效的)SSH 连接。
• 我知道如何与我的数据库建立(有效的)MySql 连接。
• 我知道如何在 C# 中运行/执行 SELECT 和 UPDATE 查询/命令。

所以我唯一需要做的就是循环本身。

现在，在我的研究过程中，我遇到了一些建议使用 Reader 的答案。我不知道这是否是我需要的以及(如果是)如何正确使用它。

下面是我到目前为止的代码(用于建立连接和执行查询)。

我的代码:

class ReaderDemo1
{
    public static void Update()
    {
        Console.WriteLine("[Core] Opening Connection To Database...");
        Database.openStockConn(Settings.databaseName, Settings.databaseUsername, Settings.databasePassword, Settings.sshHost, Settings.sshUsername, Settings.sshPassword);

        if (Database.stockConn.State != ConnectionState.Open)
        {
            Database.openStockConn(Settings.databaseName, Settings.databaseUsername, Settings.databasePassword, Settings.sshHost, Settings.sshUsername, Settings.sshPassword);
        }
        Console.WriteLine("[Core] database connection is now open!\n");

        MySqlCommand cmd = new MySqlCommand("SELECT value FROM catalog_product_entity_decimal", Database.stockConn);
        try
        {
            Console.WriteLine("[Price] Updating Prices...");

            MySqlCommand command = new MySqlCommand("UPDATE catalog_product_entity_decimal SET value= 1112 WHERE value_id= 4063", Database.stockConn);
            command.ExecuteNonQuery();

            Console.WriteLine("[Price] Prices Have Been Updated!");                
        }
        catch
        {
            Console.WriteLine("Updating Failed!");
        }
        finally
        {
            if (Database.stockConn != null)
            {
                Database.stockConn.Close();
            }
        }
    } 
}

只是为了提供一些额外的背景:

• Database.cs 是我创建连接(SSH 和 MySql)的地方
• Settings.cs 是我拥有 SSH 和 MySql 连接的所有登录数据的地方。

如果你们想知道的话，我自己已经尝试了一些关于循环的事情，但是(正如我已经提到的)这些尝试没有成功。

我对 Reader 的尝试:

using (var reader = command.ExecuteReader())
{
     var indexOfValue = reader.GetOrdinal("value");

     while (reader.Read())
     {
          var price1 = reader.GetValue(indexOfValue);

           Console.WriteLine("Executing Update Command...");

           MySqlCommand cmd = new MySqlCommand("UPDATE catalog_product_entity_decimal SET value= 1222 WHERE entity_id= 759 AND entity_id= 839 AND entity_id= 881", con);
           cmd.ExecuteNonQuery();

           Console.WriteLine("Update Command Executed!"); 
    }
} 

如前所述，上面的代码没有按我希望的方式运行(可能是因为它现在实际上没有做任何事情)。只是想让你们知道，我没有陷入错误。我只是想知道如何做到这一点。

我希望你们中的某个人可以帮助我解决这个问题或为我指明正确的方向，如果您认为我的问题与另一个问题重复，请告诉我，我会调查的! :) 提前致谢。

亲切的问候，

李锦记

编辑:

如果你们想知道，this是我的 table 的样子。 该表包含大约 5600 行，因此这些只是最上面的行。

最佳答案

就像 Frederiks 的回答一样，您现在尝试做的事情是遍历一个表并一遍又一遍地执行相同的查询。

即使您设法让您的代码工作，它也会非常慢(因为您有大约 5600 行要更新)。

所以我的建议是您创建一个新表，其中包含新值(因此您希望在循环后拥有该值)。然后只需运行一个更新命令即可使用新表中的值更新旧表。

这个选项可能需要几秒钟，然后就会完成，所以速度要快得多! :)

您需要的查询应如下所示:

    UPDATE old_table
    INNER JOIN  new_table 
    USING (column) --> // if you want to update a specific column

编辑:

除/更新我的回答外，您还可以通过以下方式更准确地更新表格:

UPDATE old_table
   INNER JOIN new_table ON old_table.value_id = new_table.value_id  // Use this to set your columns with unique values's
   SET old_table.value = new_table.value // For the column with the value's you want to update

因此，在上面的代码中，您使用 new_table 中的值更新了 old_table。在此示例中，您仅更新一列(您想要的)的值。

您可以扩展查询以获得不同的结果。

关于C# - 如何循环遍历表以更新每一行 MySQL，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/50391695/