iframe-proxy | Sunbelt Computer Software

History

113 lines (101 loc) · 3.62 KB

Raw

100

101

102

103

104

105

106

107

108

109

110

111

112

113

using BenchmarkDotNet.Attributes;

using Npgsql;

namespace BenchmarkTests;

public class NpgsqlCachedCommand : NpgsqlCommand

{

private static readonly NpgsqlCachedCommand _instanceCache = new();

#pragma warning disable CS8603 // Possible null reference return.

private NpgsqlCommand CachedCommandClone() => MemberwiseClone() as NpgsqlCommand;

#pragma warning restore CS8603 // Possible null reference return.

public static NpgsqlCommand Create(NpgsqlConnection connection)

{

var result = _instanceCache.CachedCommandClone();

result.Connection = connection;

return result;

}

public class NpgsqlCachedParameter : NpgsqlParameter

{

private static readonly NpgsqlCachedParameter _textParam = new()

{

NpgsqlDbType = NpgsqlTypes.NpgsqlDbType.Text,

Value = DBNull.Value,

};

#pragma warning disable CS8603 // Possible null reference return.

public NpgsqlParameter CachedParameterMemberwiseClone() => MemberwiseClone() as NpgsqlParameter;

#pragma warning restore CS8603 // Possible null reference return.

public static NpgsqlParameter CreateTextParam(string? value)

{

var result = _textParam.CachedParameterMemberwiseClone();

if (value is not null)

{

result.Value = value;

}

return result;

}

[MemoryDiagnoser]

public class CacheCommandTests

{

private const string _connectionStr = "Host=127.0.0.1;Port=5432;Database=postgres;Username=postgres;Password=postgres";

[Benchmark(Baseline = true)]

public async Task NormalCommand()

{

using var connection = new NpgsqlConnection(_connectionStr);

connection.Open();

using var cmd = connection.CreateCommand();

cmd.CommandText = "select $1,$2,$3";

cmd.Parameters.Add(new NpgsqlParameter

{

NpgsqlDbType = NpgsqlTypes.NpgsqlDbType.Text,

Value = "test1"

});

cmd.Parameters.Add(new NpgsqlParameter

{

NpgsqlDbType = NpgsqlTypes.NpgsqlDbType.Text,

Value = "test2"

});

cmd.Parameters.Add(new NpgsqlParameter

{

NpgsqlDbType = NpgsqlTypes.NpgsqlDbType.Text,

Value = "test3"

});

await using var reader = await cmd.ExecuteReaderAsync();

}

[Benchmark]

public async Task CachedCommand()

{

using var connection = new NpgsqlConnection(_connectionStr);

connection.Open();

using var cmd = NpgsqlCachedCommand.Create(connection);

cmd.CommandText = "select $1,$2,$3";

cmd.Parameters.Add(new NpgsqlParameter

{

NpgsqlDbType = NpgsqlTypes.NpgsqlDbType.Text,

Value = "test1"

});

cmd.Parameters.Add(new NpgsqlParameter

{

NpgsqlDbType = NpgsqlTypes.NpgsqlDbType.Text,

Value = "test2"

});

cmd.Parameters.Add(new NpgsqlParameter

{

NpgsqlDbType = NpgsqlTypes.NpgsqlDbType.Text,

Value = "test3"

});

await using var reader = await cmd.ExecuteReaderAsync();

}

[Benchmark]

public async Task CachedCommandAndParemeters()

{

using var connection = new NpgsqlConnection(_connectionStr);

connection.Open();

using var cmd = NpgsqlCachedCommand.Create(connection);

cmd.CommandText = "select $1,$2,$3";

cmd.Parameters.Add(NpgsqlCachedParameter.CreateTextParam("test1"));

cmd.Parameters.Add(NpgsqlCachedParameter.CreateTextParam("test2"));

cmd.Parameters.Add(NpgsqlCachedParameter.CreateTextParam("test3"));

await using var reader = await cmd.ExecuteReaderAsync();

}

Sunbelt Computer Software

PL/B Language Development and Support

Navigation Menu

Uh oh!

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

Uh oh!

FilesExpand file tree

CacheCommandTests.cs

Latest commit

History

CacheCommandTests.cs

File metadata and controls