Skip to content

Commit

Permalink
Consolidate async/sync query param tests
Browse files Browse the repository at this point in the history
  • Loading branch information
nr-ahemsath committed Nov 22, 2023
1 parent b415aba commit 6de37fd
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 433 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -160,17 +160,17 @@ public string MsSqlWithParameterizedQuery(bool paramsWithAtSign)
[LibraryMethod]
[Transaction]
[MethodImpl(MethodImplOptions.NoOptimization | MethodImplOptions.NoInlining)]
public async Task<string> MsSqlAsync_WithParameterizedQuery(string tableName, bool paramsWithAtSign)
public async Task<string> MsSqlAsync_WithParameterizedQuery(bool paramsWithAtSign)
{
var teamMembers = new List<string>();

using (var connection = new SqlConnection(MsSqlConfiguration.MsSqlConnectionString))
{
await connection.OpenAsync();

using (var command = new SqlCommand("SELECT * FROM NewRelic.dbo.TeamMembers WHERE FirstName = @FN", connection))
using (var command = new SqlCommand("SELECT * FROM NewRelic.dbo.TeamMembers WHERE LastName = @LN", connection))
{
command.Parameters.Add(new SqlParameter(paramsWithAtSign ? "@FN" : "FN", "O'Keefe"));
command.Parameters.Add(new SqlParameter(paramsWithAtSign ? "@LN" : "LN", "Lee"));
using (var reader = await command.ExecuteReaderAsync())
{
while (await reader.ReadAsync())
Expand All @@ -183,25 +183,6 @@ public async Task<string> MsSqlAsync_WithParameterizedQuery(string tableName, bo
}
}
}

var insertSql = string.Format(InsertPersonMsSql, tableName);
var countSql = string.Format(CountPersonMsSql, tableName);
var deleteSql = string.Format(DeletePersonMsSql, tableName);

using (var command = new SqlCommand(insertSql, connection))
{
var insertCount = await command.ExecuteNonQueryAsync();
}

using (var command = new SqlCommand(countSql, connection))
{
var teamMemberCount = await command.ExecuteScalarAsync();
}

using (var command = new SqlCommand(deleteSql, connection))
{
var deleteCount = await command.ExecuteNonQueryAsync();
}
}

return string.Join(",", teamMembers);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -163,17 +163,17 @@ public string MsSqlWithParameterizedQuery(bool paramsWithAtSign)
[LibraryMethod]
[Transaction]
[MethodImpl(MethodImplOptions.NoOptimization | MethodImplOptions.NoInlining)]
public async Task<string> MsSqlAsync_WithParameterizedQuery(string tableName, bool paramsWithAtSign)
public async Task<string> MsSqlAsync_WithParameterizedQuery(bool paramsWithAtSign)
{
var teamMembers = new List<string>();

using (var connection = new SqlConnection(MsSqlConfiguration.MsSqlConnectionString))
{
await connection.OpenAsync();

using (var command = new SqlCommand("SELECT * FROM NewRelic.dbo.TeamMembers WHERE FirstName = @FN", connection))
using (var command = new SqlCommand("SELECT * FROM NewRelic.dbo.TeamMembers WHERE LastName = @LN", connection))
{
command.Parameters.Add(new SqlParameter(paramsWithAtSign ? "@FN" : "FN", "O'Keefe"));
command.Parameters.Add(new SqlParameter(paramsWithAtSign ? "@LN" : "LN", "Lee"));
using (var reader = await command.ExecuteReaderAsync())
{
while (await reader.ReadAsync())
Expand All @@ -186,25 +186,6 @@ public async Task<string> MsSqlAsync_WithParameterizedQuery(string tableName, bo
}
}
}

var insertSql = string.Format(InsertPersonMsSql, tableName);
var countSql = string.Format(CountPersonMsSql, tableName);
var deleteSql = string.Format(DeletePersonMsSql, tableName);

using (var command = new SqlCommand(insertSql, connection))
{
var insertCount = await command.ExecuteNonQueryAsync();
}

using (var command = new SqlCommand(countSql, connection))
{
var teamMemberCount = await command.ExecuteScalarAsync();
}

using (var command = new SqlCommand(deleteSql, connection))
{
var deleteCount = await command.ExecuteNonQueryAsync();
}
}

return string.Join(",", teamMembers);
Expand Down
Loading

0 comments on commit 6de37fd

Please sign in to comment.