16

IDbConnectionのインスタンスがあります。これは、任意の接続、Sql、OleDbなどです。汎用ラッパーを作成して、ラッパーに接続を送信し、簡単に操作できる優れたメソッドのセットを取得できるようにします。Queryメソッドがあり、DataTableを返すようにしたいので、次のことができます。

IDataAdapter adapter = new OleDbDataAdapter();
adapter.SelectCommand = myCommand;
DataSet ds = new DataSet();
adapter.Fill(ds);

問題は、OleDbAdapterを使用する必要があり、SQLでは機能しないことです。「ドライバー固有の」コードを記述したくありません。インスタンス化されたIDbConnectionオブジェクトからIDataAdapterインスタンスを取得する方法はありますか？コマンドを作成できることはわかっています

IDbCommand command = _connection.CreateCommand();

IDataAdapterで同じことを行う簡単な方法があるはずだと考えるのは論理的です。

編集：

using (var reader = command.ExecuteReader())
{
    var dataTable = new DataTable();
    dataTable.Load(reader);
}

正確には私が求めたものではありませんが、素晴らしい解決策です。

4

2 に答える 2

7

リフレクションを使用してアダプターを取得する方法の大まかな例を次に示します。

IDataAdapter GetAdapter(IDbConnection connection) {
    var assembly = connection.GetType().Assembly;
    var @namespace = connection.GetType().Namespace;    

    // Assumes the factory is in the same namespace
    var factoryType = assembly.GetTypes()
                        .Where (x => x.Namespace == @namespace)
                        .Where (x => x.IsSubclassOf(typeof(DbProviderFactory)))
                        .Single();

    // SqlClientFactory and OleDbFactory both have an Instance field.
    var instanceFieldInfo = factoryType.GetField("Instance", BindingFlags.Static | BindingFlags.Public);
    var factory = (DbProviderFactory) instanceFieldInfo.GetValue(null);

    return factory.CreateDataAdapter();
}
于 2012-05-23T17:06:04.633 に答える
4

私も同じ問題を抱えていました。これが私がそれを解決した方法です

private DataSet executeDataQuery(string query, string connection, string provider, out Exception ex) {
        DataSet ds = new DataSet();
        ex = null;
        DbProviderFactory dbFactory = DbProviderFactories.GetFactory(provider);
        IDbConnection dbConnection = dbFactory.CreateConnection();
        dbConnection.ConnectionString = connection;
        using (dbConnection) {
            try {
                IDbDataAdapter dbAdapter = dbFactory.CreateDataAdapter();
                IDbCommand dbCommand = dbConnection.CreateCommand();
                dbCommand.CommandText = query;
                dbCommand.CommandType = CommandType.Text;
                dbAdapter.SelectCommand = dbCommand;
                dbAdapter.Fill(ds);
            }
            catch (Exception exc) {
                ex = exc;
            }
            finally {
                if (dbConnection.State == ConnectionState.Open) {
                    dbConnection.Close();
                }
            }
        }
        return ds;
    }
于 2014-12-13T17:39:34.917 に答える