7

ミニプロファイラーと統合したいWebフォームアプリに既存のdb接続機能があります。アプリにミニ プロファイラーをインストールして実行していますが、データベース部分を正しく接続できないようです。以下は、データベースに接続するコードの一部です。

public override IEnumerable<IDataRecord> Execute()
{
    using( SqlConnection conn = new SqlConnection( ConnectionString ) ) {
        using( SqlCommand command = new SqlCommand( CommandText, conn ) ) {
            command.CommandType = SQLCommandType;
            foreach( SqlParameter p in ParamsToAdd ) {
                command.Parameters.Add( p );
            }
            conn.Open();
            SqlDataReader rdr;
            try {
                rdr = command.ExecuteReader();
            } catch( Exception ex ) {
                //log error
            }
            using( rdr ) {
                while( rdr.Read() ) {
                    yield return (IDataRecord)rdr;
                }
            }
        }
    }
}

次のように ExecuteReader() の周りに簡単にステップを配置できます。

using( MiniProfiler.Current.Step( command.CommandText ) ) {
    rdr = command.ExecuteReader();
}

しかし、これによりミニプロファイラーはトレースと同じくらい便利になり、サイトに表示されるクエリ機能を取得したいと考えています. ヘルプはありますか？

4

2 に答える 2

10

ProfiledDbConnectionクラスに基づいて、このコードで試すことができます

var connection = MiniProfiler.Data.ProfiledDbConnection.Get(new SqlConnection(str));
var cmd = connection.CreateCommand();
var param = connection.CreateParameter();

リンク: https://github.com/ServiceStack/ServiceStack/tree/master/src/ServiceStack/MiniProfiler/Data

于 2012-09-19T18:36:06.333 に答える
1

@aghilasの回答は他のライブラリを使用していましたが、以前はわからなかったという私の間違いを指摘するのに十分でした。

結局、SqlConnection の使用から DbConnection の使用に変更する必要があり、SQLCommand => DbCommand と SQLDataReader => DbDataReader についても同じことが必要になりました。これにより、ProfiledDbConnection が適切に接続できるようになりました。

...
using StackExchange.Profiling;
using StackExchange.Profiling.Data;
...
using( DbConnection conn = new ProfiledDbConnection( new SqlConnection( ConnectionString ), MiniProfiler.Current ) ) {
        using( DbCommand command = conn.CreateCommand() ) {
            command.CommandText = CommandText;
            command.Connection = conn;
            command.CommandType = SQLCommandType;
            foreach( SqlParameter p in ParamsToAdd ) {
                command.Parameters.Add( p );
            }
            conn.Open();
            DbDataReader rdr;
            try {
                rdr = command.ExecuteReader();
            } catch( Exception ex ) {
                //log error
            }
            using( rdr ) {
                while( rdr.Read() ) {
                    yield return (IDataRecord)rdr;
                }
            }
        }
    }
于 2012-09-19T19:39:30.267 に答える