Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

CommandType #601

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

CommandType #601

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 10 additions & 8 deletions SqlKata.Execution/QueryFactory.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -607,13 +607,14 @@ public async Task ChunkAsync<T>(
}
}

public IEnumerable<T> Select<T>(string sql, object param = null, IDbTransaction transaction = null, int? timeout = null)
public IEnumerable<T> Select<T>(string sql, object param = null, IDbTransaction transaction = null, int? timeout = null, CommandType? commandType = null)
{
return this.Connection.Query<T>(
sql,
param,
transaction: transaction,
commandTimeout: timeout ?? this.QueryTimeout
commandTimeout: timeout ?? this.QueryTimeout,
commandType: commandType
);
}

Expand All @@ -629,29 +630,30 @@ public async Task<IEnumerable<T>> SelectAsync<T>(string sql, object param = null
return await this.Connection.QueryAsync<T>(commandDefinition);
}

public IEnumerable<dynamic> Select(string sql, object param = null, IDbTransaction transaction = null, int? timeout = null)
public IEnumerable<dynamic> Select(string sql, object param = null, IDbTransaction transaction = null, int? timeout = null, CommandType? commandType = null)
{
return this.Select<dynamic>(sql, param, transaction, timeout);
return this.Select<dynamic>(sql, param, transaction, timeout, commandType);
}

public async Task<IEnumerable<dynamic>> SelectAsync(string sql, object param = null, IDbTransaction transaction = null, int? timeout = null, CancellationToken cancellationToken = default)
{
return await this.SelectAsync<dynamic>(sql, param, transaction, timeout, cancellationToken);
}

public int Statement(string sql, object param = null, IDbTransaction transaction = null, int? timeout = null)
public int Statement(string sql, object param = null, IDbTransaction transaction = null, int? timeout = null, CommandType? commandType = null)
{
return this.Connection.Execute(sql, param, transaction: transaction, commandTimeout: timeout ?? this.QueryTimeout);
return this.Connection.Execute(sql, param, transaction: transaction, commandTimeout: timeout ?? this.QueryTimeout, commandType);
}

public async Task<int> StatementAsync(string sql, object param = null, IDbTransaction transaction = null, int? timeout = null, CancellationToken cancellationToken = default)
public async Task<int> StatementAsync(string sql, object param = null, IDbTransaction transaction = null, int? timeout = null, CancellationToken cancellationToken = default, CommandType? commandType = null)
{
var commandDefinition = new CommandDefinition(
commandText: sql,
parameters: param,
transaction: transaction,
commandTimeout: timeout ?? this.QueryTimeout,
cancellationToken: cancellationToken);
cancellationToken: cancellationToken,
commandType: commandType);
return await this.Connection.ExecuteAsync(commandDefinition);
}

Expand Down