public class DbQueryProvider : QueryProvider {

    DbConnection connection;



    public DbQueryProvider(DbConnection connection) {

        this.connection = connection;

    }



    public override string GetQueryText(Expression expression) {

        return this.Translate(expression);

    }



    public override object Execute(Expression expression) {

        DbCommand cmd = this.connection.CreateCommand();

        cmd.CommandText = this.Translate(expression);

        DbDataReader reader = cmd.ExecuteReader();

        Type elementType = TypeSystem.GetElementType(expression.Type);

        return Activator.CreateInstance(

            typeof(ObjectReader<>).MakeGenericType(elementType),

            BindingFlags.Instance | BindingFlags.NonPublic, null,

            new object[] { reader },

            null);

    }



    private string Translate(Expression expression) {

        return new QueryTranslator().Translate(expression);

    }

}