5

NHibernateを使用してドメインを永続化するアプリケーションにMicrosoftSyncFrameworkを実装しようとしています。

私たちが遭遇した問題の1つは、同期フレームワークが初期データベース構造を変更した後（シャドウテーブルとトリガーを追加した後）、データベースにオブジェクトを挿入しようとしたときにtoomanyrowsaffectedexceptionをスローすることでNHibernateが動揺しているように見えることです。

各更新ステートメントの周りにSETNOCOUNTONとOFFを追加するソリューションがあるこの記事を見つけましたが、テーブル構造はnhibernateによって自動的に生成され、同期トリガーは同期フレームワークによって自動的に生成されるため、すべてのトリガーを手動で調整することは実際にはオプションではありません。

http://www.codewrecks.com/blog/index.php/2009/03/25/nhibernate-and-toomanyrowsaffectedexception/

この質問で説明されているように、SQL Server 2008のプロパティNOCOUNTをオンに設定してみました：NOCOUNTを設定するのに最適な場所はどこですか？ ただし、これによりStaleStateExceptionが発生しました（-1行が影響を受け、1行が予想されます）。

トリガーにこれらのNOCOUNTステートメントを自動的に設定するように同期フレームワークを構成する方法があるかどうか知っていますか？または、NHibernateに変更された行の数を増やす/減らすように指示する方法はありますか？あるいは、これらのNOCOUNTステートメントを同期フレームワークのトリガーに追加する自動化されたスクリプトを持っている人もいるかもしれません。

事前にThx！

4

1 に答える 1

6

NOCOUNTの方法が進むべき道だと思います。これを行うには、同期フレームワークで使用されるすべてのテーブルにNOCOUNTを設定します。以下のコードを参照してください。もう1つの方法は、NHibernateにパッチを適用し、updatecountを無視することです（https://nhibernate.jira.com/browse/NH-1353）。

KR、

ポール

    class SqlSyncTriggerHelper
{
    private const string triggerSql = @"select sys.triggers.name from sys.triggers, sys.objects
        where sys.objects.name='{0}' and sys.objects.type = 'U' and sys.triggers.parent_id = sys.objects.object_id";

    private DbSyncScopeDescription syncScopeDescription;

    public SqlSyncTriggerHelper(DbSyncScopeDescription syncScopeDescription)
    {
        this.syncScopeDescription = syncScopeDescription;
    }

    public void Apply(SqlConnection conn)
    {
        SqlTransaction transaction = null;
        try
        {
            if (conn.State == System.Data.ConnectionState.Closed)
            {
                conn.Open();
            }
            transaction = conn.BeginTransaction();
            foreach (var table in syncScopeDescription.Tables)
            {
                foreach (string trigger in GetTriggers(table.UnquotedLocalName, conn, transaction))
                {
                    AlterTrigger(trigger, conn, transaction);
                }
            }
            transaction.Commit();
        }
        catch
        {
            if (transaction != null)
            {
                transaction.Rollback();
            }
            throw;
        }
        finally
        {
            if (transaction != null)
            {
                transaction.Dispose();
            }
            conn.Close();
        }
    }

    private void AlterTrigger(string trigger, SqlConnection conn, SqlTransaction transaction)
    {
        SqlCommand newCmd = new SqlCommand(string.Format("exec sp_helptext '{0}'", trigger), conn, transaction);
        var triggerStringBuilder = new StringBuilder();
        using (var reader = newCmd.ExecuteReader())
        {
            while (reader.Read())
            {
                triggerStringBuilder.Append(reader.GetValue(0) as string);
            }
        }
        var triggerString = triggerStringBuilder.ToString();
        triggerString = triggerString.Replace("CREATE TRIGGER", "ALTER TRIGGER").Replace(" AS\n", " AS\nSET NOCOUNT ON\n") + "\nSET NOCOUNT OFF";
        var alterTriggerCommand = new SqlCommand(triggerString, conn, transaction);
        alterTriggerCommand.ExecuteNonQuery();
    }

    private IEnumerable<string> GetTriggers(string tableName, SqlConnection conn, SqlTransaction transaction)
    {
        var resultList = new List<string>();
        var command = new SqlCommand(string.Format(triggerSql, tableName), conn, transaction);
        using (var reader = command.ExecuteReader())
        {
            while (reader.Read())
            {
                resultList.Add(reader.GetString(0));
            }
        }
        return resultList;
    }
}
于 2010-03-10T15:00:48.207 に答える