dev-npgsql/npgsql: Npgsql is the .NET data provider for PostgreSQL.

test/Npgsql.Benchmarks/ReadArray.cs
88 строк3 KB
Shay Rojansky
Apply file-scoped namespaces for 6.0 (#4298)
28 янв 2022, 15:13
28 янв 2022, 15:132e0ad2d
using BenchmarkDotNet.Attributes;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Runtime.CompilerServices;

namespace Npgsql.Benchmarks;

public class ReadArrays
{
    [Params(true, false)]
    public bool AllNulls;

    [Params(1, 10, 1000, 100000)]
    public int NumElements;

    NpgsqlConnection _intConn = default!;
    NpgsqlCommand _intCmd = default!;
    NpgsqlDataReader _intReader = default!;

    NpgsqlConnection _nullableIntConn = default!;
    NpgsqlCommand _nullableIntCmd = default!;
    NpgsqlDataReader _nullableIntReader = default!;

    NpgsqlConnection _stringConn = default!;
    NpgsqlCommand _stringCmd = default!;
    NpgsqlDataReader _stringReader = default!;

    [GlobalSetup]
    public void Setup()
    {
        var intArray = new int[NumElements];
        for (var i = 0; i < NumElements; i++)
            intArray[i] = 666;
        _intConn = BenchmarkEnvironment.OpenConnection();
        _intCmd = new NpgsqlCommand("SELECT @p1", _intConn);
        _intCmd.Parameters.AddWithValue("p1", intArray);
        _intReader = _intCmd.ExecuteReader();
        _intReader.Read();

        var nullableIntArray = new int?[NumElements];
        for (var i = 0; i < NumElements; i++)
            nullableIntArray[i] = AllNulls ? (int?)null : 666;
        _nullableIntConn = BenchmarkEnvironment.OpenConnection();
        _nullableIntCmd = new NpgsqlCommand("SELECT @p1", _nullableIntConn);
        _nullableIntCmd.Parameters.AddWithValue("p1", nullableIntArray);
        _nullableIntReader = _nullableIntCmd.ExecuteReader();
        _nullableIntReader.Read();

        var stringArray = new string?[NumElements];
        for (var i = 0; i < NumElements; i++)
            stringArray[i] = AllNulls ? null : "666";
        _stringConn = BenchmarkEnvironment.OpenConnection();
        _stringCmd = new NpgsqlCommand("SELECT @p1", _stringConn);
        _stringCmd.Parameters.AddWithValue("p1", stringArray);
        _stringReader = _stringCmd.ExecuteReader();
        _stringReader.Read();
    }

    protected void Cleanup()
    {
        _intReader.Dispose();
        _nullableIntReader.Dispose();
        _stringReader.Dispose();

        _intCmd.Dispose();
        _nullableIntCmd.Dispose();
        _stringCmd.Dispose();

        _intConn.Dispose();
        _nullableIntConn.Dispose();
        _stringConn.Dispose();
    }

    [Benchmark]
    public int ReadIntArray()
        => _intReader.GetFieldValue<int[]>(0).Length;

    [Benchmark]
    public int ReadNullableIntArray()
        => _nullableIntReader.GetFieldValue<int?[]>(0).Length;

    [Benchmark]
    public int ReadStringArray()
        => _stringReader.GetFieldValue<string[]>(0).Length;
}