0

ストアドプロシージャを呼び出すためのXMLRPCメカニズムを使用して呼び出しを受け入れるサードパーティアプリケーションがあります。

このメカニズムを使用して、更新/削除/挿入の束を含む複数のテーブルを含むZIP圧縮データセットを送信します。一方、CLR sprocはデータを解凍し、データセットを取得します。

次に、次のコードが実行されます。

    using (var conn = new SqlConnection("context connection=true"))
    {
        if (conn.State == ConnectionState.Closed)
           conn.Open();

        try
        {
            foreach (DataTable table in ds.Tables)
            {
                string columnList = "";
                for (int i = 0; i < table.Columns.Count; i++)
                {
                    if (i == 0)
                        columnList = table.Columns[0].ColumnName;
                    else
                        columnList += "," + table.Columns[i].ColumnName;
                }

                var da = new SqlDataAdapter("SELECT " + columnList + " FROM " + table.TableName, conn);

                var builder = new SqlCommandBuilder(da);
                builder.ConflictOption = ConflictOption.OverwriteChanges;

                da.RowUpdating += onUpdatingRow;
                da.Update(ds, table.TableName);

            }
        }

        catch (....)
        {
           .....
        }
    }

RowUpdatingイベントのイベントハンドラーは次のとおりです。

public static void onUpdatingRow(object sender, SqlRowUpdatingEventArgs e)
{
    if ((e.StatementType == StatementType.Update) && (e.Command == null))
    {
        e.Command = CreateUpdateCommand(e.Row, sender as SqlDataAdapter);
        e.Status = UpdateStatus.Continue;
    }
}

およびCreateUpdateCommandメソッド：

private static SqlCommand CreateUpdateCommand(DataRow row, SqlDataAdapter da)
{
    string whereClause = "";
    string setClause = "";

    SqlConnection conn = da.SelectCommand.Connection;
    for (int i = 0; i < row.Table.Columns.Count; i++)
    {
        char quoted;

        if ((row.Table.Columns[i].DataType == Type.GetType("System.String")) ||
            (row.Table.Columns[i].DataType == Type.GetType("System.DateTime")))
            quoted = '\'';
        else
            quoted = ' ';

        string val = row[i].ToString();
        if (row.Table.Columns[i].DataType == Type.GetType("System.Boolean"))
            val = (bool)row[i] ? "1" : "0";

        bool isPrimaryKey = false;

        for (int j = 0; j < row.Table.PrimaryKey.Length; j++)
        {
            if (row.Table.PrimaryKey[j].ColumnName == row.Table.Columns[i].ColumnName)
            {
                if (whereClause != "")
                    whereClause += " AND ";
                if (row[i] == DBNull.Value)
                    whereClause += row.Table.Columns[i].ColumnName + "=NULL";
                else
                    whereClause += row.Table.Columns[i].ColumnName + "=" + quoted +
                                   val + quoted;
                isPrimaryKey = true;
                break;
            }
        }

        /* Only values for column that is not a primary key can be modified  */
        if (!isPrimaryKey)
        {
            if (setClause != "")
                setClause += ", ";

            if (row[i] == DBNull.Value)
                setClause += row.Table.Columns[i].ColumnName + "=NULL";
            else
                setClause += row.Table.Columns[i].ColumnName + "=" + quoted +
                             val + quoted;

        }
    }

    return new SqlCommand("UPDATE " + row.Table.TableName + " SET " + setClause + " WHERE " + whereClause, conn);
}

ただし、レコードが多い場合、これは非常に遅くなります。

これを最適化する方法、または複数のテーブルで大量の更新/削除を送信するまったく異なる方法はありますか？これにはTSQLを使用したいのですが、データセットを通常のsprocに送信する方法がわかりません。

その他の注意事項：

  • SQLServerデータベースに直接アクセスすることはできません。
  • 圧縮せずに試しましたが、遅くなりました。
4

1 に答える 1

0

SQL Server 2008 を使用している場合は、MERGE を調べる必要があります。

MERGEの詳細はこちら

于 2009-12-21T18:37:42.653 に答える