0

如果这是一个愚蠢的错误，我深表歉意——但我已经为此苦苦挣扎了几个星期，我不再继续了。

问题是 - 我从基于 DT 的 DS 到 SQL Db 的更新调用只是插入 nerw 记录，而不是更新修改过的记录。

我有一个数据源（httpWebRequested html 表），我定期调用它并用它更新属于 DataSet 的 DataTable。最初我将它全部解析为第二个 DataTable 并将其与我的 DataSet 表合并 - 但这不起作用，所以目前我只有一个 DataTable 并且要么将新行插入到表中，要么通过迭代源并添加一行来更新现有值一个数组的时间 - 检查当前行的存在，并更新或插入（[Session ID] 是一个 PK，Data[0] 是对应的唯一值）：-

                foreach (var row in rows.Skip(1))
            {
                //create new list collection
                var data = new List<string>();
                //interate through rows
                foreach (var column in row.Descendants("td"))
                {
                    //add data to list from Table
                    data.Add(column.InnerText);
                }
                    string strSelect = "[Session ID] = '"+ data[0] +"'";
                    DataRow[] myRow = dt.Select(strSelect);
                    if (myRow.Length == 1)
                    {
                        if (myRow[0][2].ToString() != data[2].ToString())
                        {
                            myRow[0][2] = data[2];
                        }
                        if (myRow[0][3].ToString() != data[3].ToString())
                        {
                            myRow[0][3] = data[3];
                        }
                        if (myRow[0][4].ToString() != data[4].ToString())
                        {
                            myRow[0][4] = data[4];
                        }
                        if (myRow[0][5].ToString() != data[5].ToString())
                        {
                            myRow[0][5] = data[5];
                        }
                        if (myRow[0][7].ToString() != data[7].ToString())
                        {
                            myRow[0][7] = data[7];
                        }
                    }
                    else
                    {
                        dt.Rows.Add(data.ToArray());
                    }

我在最后也加了一点，计算了添加和修改：-

            int modified= 0;
            int added = 0;
            foreach (DataRow dr in pca.chatDataSetG.Tables[0].Rows)
            {
                if (dr.RowState == DataRowState.Modified)
                {
                    modified++;
                }
                if (dr.RowState == DataRowState.Added)
                {
                    added++;
                }
            }

此时 - 计数很好 - 修改后拾取属性已更改和添加的行是正确的。

当我调用我的更新 Db 方法时 - 事情开始出错： -

    public static void updateSqlTable()
    {

        string connectionString = "Connection String here";
        string qry = @"select * from chatData";

        SqlConnection conn = new SqlConnection(connectionString);

        try
        {
            SqlDataAdapter da = new SqlDataAdapter(qry, conn);
            SqlCommandBuilder sb = new SqlCommandBuilder(da);
            log.Info("Building Queries...");
            da.UpdateCommand = sb.GetUpdateCommand();
            da.InsertCommand = sb.GetInsertCommand();
            da.DeleteCommand = sb.GetDeleteCommand();

            log.Info("Filling Data into Adapter...");
            int modified = 0;
            int added = 0;
            foreach (DataRow dr in pca.chatDataSetG.Tables[0].Rows)
            {
                if (dr.RowState == DataRowState.Modified)
                {
                    modified++;
                }
                if (dr.RowState == DataRowState.Added)
                {
                    added++;
                }
            }
            //This is where the modified count reverts
            da.Fill(pca.chatDataSetG, "Chat");
            modified = 0;
            added = 0;
            foreach (DataRow dr in pca.chatDataSetG.Tables[0].Rows)
            {
                if (dr.RowState == DataRowState.Modified)
                {
                    modified ++;
                }
                if (dr.RowState == DataRowState.Added)
                {
                    added++;
                }
            }
            conn.Open();
            log.Info("Calling Update to DB...");
            int rowseffected = da.Update(pca.chatDataSetG, "Chat");
            log.Info("Update Complete - " + rowseffected + " rows effected........");

        }
        catch (Exception ex)
        {
            log.Error("Error Updating Db with chat Data", ex);
        }
        finally
        {
            conn.Close();
        }

    }

计数正好在填充之前，但之后 - 添加的计数保持不变 - 好，但修改后的计数变为 0 - 坏:(。我尝试了所有形状来尝试看看这里发生了什么 - 但老实说 -我很难过。任何帮助都会非常非常非常感谢。数据库中的行没有反映新的值。

彼得

4

1 回答 1

0

您确实在这行代码中重新填充了 DataSet/Tables

//This is where the modified count reverts
da.Fill(pca.chatDataSetG, "Chat");

在 MSDN DataAdapter 填充中，我认为对所描述的行为有解释

您可以在同一个 DataTable 上多次使用 Fill 方法。如果 存在主键，则传入行将与已存在的匹配行合并。如果不存在主键，则将传入行附加到 DataTable。

IMO 修改的行已与数据库中的原始拥有合并，因此失去其 rowState，而插入的项目已按所述附加。

于 2012-09-03T11:35:45.700 回答