GridView批量更新Oracle数据库异常及高效更新方案咨询

问题根源分析 #

你遇到的更新异常，本质是两个常见错误：

1. 更新条件不唯一：如果更新SQL的WHERE子句只使用TDR_CODE过滤，当数据库中存在多条同TDR_CODE的记录时，每次循环都会把所有匹配TDR_CODE的行更新为当前循环的行数据，最后一次循环就会覆盖所有同TDR_CODE的记录为最后一行的值。
2. 参数绑定逻辑错误：如果循环中没有重新初始化参数对象，或者参数值没有正确更新，会导致所有SQL执行都使用最后一次循环的参数值，最终只有最后一行更新生效。

修复基础更新逻辑 #

首先修正更新语句，必须加入唯一主键（比如TDR_ID）作为WHERE条件的一部分，确保只更新当前行对应的数据库记录。同时使用GridView.DataKeys存储主键，避免在页面暴露敏感数据：

string updateSql = "UPDATE TDR_TABLE SET COL1 = :col1, COL2 = :col2 WHERE TDR_CODE = :tdrCode AND TDR_ID = :tdrId";

foreach (GridViewRow row in GridView1.Rows)
{
    if (row.RowType != DataControlRowType.DataRow) continue;

    // 从DataKeys获取唯一主键
    int tdrId = Convert.ToInt32(GridView1.DataKeys[row.RowIndex].Value);
    string tdrCode = ((Label)row.FindControl("lblTdrCode")).Text;
    string col1 = ((TextBox)row.FindControl("txtCol1")).Text;
    string col2 = ((TextBox)row.FindControl("txtCol2")).Text;

    using (OracleCommand cmd = new OracleCommand(updateSql, conn))
    {
        // 绑定参数，确保每次循环都使用当前行的数值
        cmd.Parameters.Add(":col1", OracleDbType.Varchar2).Value = col1;
        cmd.Parameters.Add(":col2", OracleDbType.Varchar2).Value = col2;
        cmd.Parameters.Add(":tdrCode", OracleDbType.Varchar2).Value = tdrCode;
        cmd.Parameters.Add(":tdrId", OracleDbType.Int32).Value = tdrId;
        
        cmd.ExecuteNonQuery();
    }
}

高效批量更新方案 #

逐行更新在数据量大时效率极低，推荐以下两种批量方案：

方案1：Oracle数组绑定+FORALL语句 #

利用Oracle的FORALL批量处理语法，将所有行的参数打包成数组，一次性发送到数据库执行，减少网络往返次数：

// 收集所有行的参数数据
List<int> tdrIds = new List<int>();
List<string> tdrCodes = new List<string>();
List<string> col1List = new List<string>();
List<string> col2List = new List<string>();

foreach (GridViewRow row in GridView1.Rows)
{
    if (row.RowType != DataControlRowType.DataRow) continue;

    tdrIds.Add(Convert.ToInt32(GridView1.DataKeys[row.RowIndex].Value));
    tdrCodes.Add(((Label)row.FindControl("lblTdrCode")).Text);
    col1List.Add(((TextBox)row.FindControl("txtCol1")).Text);
    col2List.Add(((TextBox)row.FindControl("txtCol2")).Text);
}

// 批量更新SQL
string batchUpdateSql = @"
    FORALL i IN 1..:count
        UPDATE TDR_TABLE 
        SET COL1 = :col1(i), COL2 = :col2(i)
        WHERE TDR_CODE = :tdrCode(i) AND TDR_ID = :tdrId(i)";

using (OracleCommand cmd = new OracleCommand(batchUpdateSql, conn))
{
    cmd.Parameters.Add(":count", OracleDbType.Int32).Value = tdrIds.Count;
    // 绑定数组参数
    cmd.Parameters.Add(":col1", OracleDbType.Varchar2, col1List.ToArray(), ParameterDirection.Input);
    cmd.Parameters.Add(":col2", OracleDbType.Varchar2, col2List.ToArray(), ParameterDirection.Input);
    cmd.Parameters.Add(":tdrCode", OracleDbType.Varchar2, tdrCodes.ToArray(), ParameterDirection.Input);
    cmd.Parameters.Add(":tdrId", OracleDbType.Int32, tdrIds.ToArray(), ParameterDirection.Input);
    
    cmd.ExecuteNonQuery();
}

方案2：临时表+MERGE语句（同时支持插入和更新） #

如果需要同时处理新增和更新的行，推荐使用全局临时表配合MERGE语句，这是Oracle中最高效的批量同步方案：

1. 先创建全局临时表（只需执行一次）：

CREATE GLOBAL TEMPORARY TABLE TMP_TDR_DATA (
    TDR_ID NUMBER,
    TDR_CODE VARCHAR2(50),
    COL1 VARCHAR2(100),
    COL2 VARCHAR2(100)
) ON COMMIT PRESERVE ROWS;

2. C#代码实现批量同步：

// 1. 将GridView数据转换为DataTable
DataTable dt = new DataTable();
dt.Columns.Add("TDR_ID", typeof(int));
dt.Columns.Add("TDR_CODE", typeof(string));
dt.Columns.Add("COL1", typeof(string));
dt.Columns.Add("COL2", typeof(string));

foreach (GridViewRow row in GridView1.Rows)
{
    if (row.RowType != DataControlRowType.DataRow) continue;

    DataRow dr = dt.NewRow();
    dr["TDR_ID"] = Convert.ToInt32(GridView1.DataKeys[row.RowIndex].Value);
    dr["TDR_CODE"] = ((Label)row.FindControl("lblTdrCode")).Text;
    dr["COL1"] = ((TextBox)row.FindControl("txtCol1")).Text;
    dr["COL2"] = ((TextBox)row.FindControl("txtCol2")).Text;
    dt.Rows.Add(dr);
}

// 2. 使用OracleBulkCopy批量插入临时表
using (OracleBulkCopy bulkCopy = new OracleBulkCopy(conn))
{
    bulkCopy.DestinationTableName = "TMP_TDR_DATA";
    bulkCopy.WriteToServer(dt);
}

// 3. 执行MERGE语句，匹配则更新，不匹配则插入
string mergeSql = @"
    MERGE INTO TDR_TABLE t
    USING TMP_TDR_DATA tmp
    ON (t.TDR_ID = tmp.TDR_ID)
    WHEN MATCHED THEN
        UPDATE SET t.COL1 = tmp.COL1, t.COL2 = tmp.COL2
    WHEN NOT MATCHED THEN
        INSERT (TDR_ID, TDR_CODE, COL1, COL2)
        VALUES (tmp.TDR_ID, tmp.TDR_CODE, tmp.COL1, tmp.COL2)";

using (OracleCommand cmd = new OracleCommand(mergeSql, conn))
{
    cmd.ExecuteNonQuery();
}

// 清空临时表（可选，全局临时表会自动在会话结束时清空）
using (OracleCommand cmd = new OracleCommand("TRUNCATE TABLE TMP_TDR_DATA", conn))
{
    cmd.ExecuteNonQuery();
}

关于临时方案的说明 #

你当前采用的"删除再插入"方式虽然能解决问题，但存在隐患：会丢失原记录的非修改字段数据（如创建时间、操作日志），如果表存在外键关联，还可能触发外键约束错误，不建议长期使用。

内容的提问来源于stack exchange，提问作者Syaza Suhaini