Skip to content

Commit a89ff0f

Browse files
add new method 'GetUnbuffered<T>'
1 parent 90a8f92 commit a89ff0f

File tree

1 file changed

+17
-0
lines changed

1 file changed

+17
-0
lines changed

SqlKata.Execution/QueryFactory.cs

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,23 @@ public Query FromQuery(Query query)
7272
return xQuery;
7373
}
7474

75+
public IEnumerable<T> GetUnbuffered<T>( Query query, IDbTransaction transaction = null, int? timeout = null )
76+
{
77+
var compiled = CompileAndLog( query );
78+
79+
var result = this.Connection.Query<T>(
80+
compiled.Sql,
81+
compiled.NamedBindings,
82+
transaction: transaction,
83+
buffered: false,
84+
commandTimeout: timeout ?? this.QueryTimeout
85+
);
86+
87+
result = handleIncludes<T>( query, result );
88+
89+
return result;
90+
}
91+
7592
public IEnumerable<T> Get<T>(Query query, IDbTransaction transaction = null, int? timeout = null)
7693
{
7794
var compiled = CompileAndLog(query);

0 commit comments

Comments
 (0)