从数据集更新数据库

本文关键字：数据库 更新 数据集 | 更新日期: 2023-09-27 18:30:03

我的目标是为每个SKU更新QTY。我正在使用SqlDataAdapter来实现这一点。程序运行良好。只是没有结果。

问：为什么没有结果？我的数据库保持不变。

下方的代码

public static void updateInventoryfromAMZ(DataTable datatable)
{
        int index = 0;
        string connString = System.Configuration.ConfigurationManager.ConnectionStrings["MyConnectionString"].ToString();
        DataSet amzInventoryDataSet = new DataSet("AMZINVDATASET");
        amzInventoryDataSet.Tables.Add(datatable);
        // FOR EACH ROW - PERFORM AN UPDATE //
        using (SqlConnection connection = new SqlConnection(connString))
        {
            SqlDataAdapter adapter = new SqlDataAdapter();
            foreach (DataRow row in amzInventoryDataSet.Tables[index].Rows)
            {
                string sku = datatable.Rows[index]["seller-sku"].ToString();
                string qty = datatable.Rows[index]["quantity"].ToString();
                // Create the UpdateCommand.
                SqlCommand command = new SqlCommand(
                     "UPDATE Inventory SET qty = @qty" +
                     "WHERE sku = @sku", connection);
                // Add the parameters for the UpdateCommand.
                command.Parameters.Add("@qty", SqlDbType.Int, qty.Length, qty);
                command.Parameters.Add("@sku", SqlDbType.VarChar, sku.Length, sku);
                adapter.UpdateCommand = command;
                adapter.Update(amzInventoryDataSet.Tables[index]);     
                index++;
            }
        }
    }

从数据集更新数据库

连接两个sql字符串时，最好在第一个字符串的末尾或第二个字符串的开头添加空格。正如Gordon Linoff指出的那样，您的sql语句是不正确的。此外，设置参数和值需要根据参数的类型进行更改。

尝试下面的代码，我已经使用SqlCommand和ExecuteNonQuery方法来更新每行数据

using (SqlConnection connection = new SqlConnection(connString))
using (SqlCommand cmd = new SqlCommand("UPDATE Inventory SET qty = @qty WHERE sku = @sku", connection))
{
    connection.Open();
    var paramqty=  cmd.Parameters.Add("@qty", SqlDbType.Int);
    var parasku = cmd.Parameters.Add("@sku", SqlDbType.VarChar);
    foreach (DataRow row in amzInventoryDataSet.Tables[0].Rows)
    {
        parasku.Value = row["seller-sku"].ToString();
        paramqty.Value = int.Parse(row["quantity"].ToString());
        cmd.ExecuteNonQuery();
    }
}

我认为你的问题是以下几行：

 "UPDATE Inventory SET qty = @qty" +
 "WHERE sku = @sku", connection);

他们将产生一个字符串，如：

 "UPDATE Inventory SET qty = @qtyWHERE sku = @sku", connection);

并且没有定义变量@qtyWHERE。

试试这个：

 "UPDATE Inventory SET qty = @qty WHERE sku = @sku", connection);
相关文章：