using DotNet.Testcontainers.Builders;

using Npgsql;

using System;

using System.Collections.Generic;

using System.Numerics;

using System.Threading.Tasks;

using Testcontainers.PostgreSql;

namespace NpgsqlBenchmark

{

internal class Program

{

static async Task Main(string[] args)

{

var items = new List<BigNumberModel>()

{

new BigNumberModel

{

BigInteger = new System.Numerics.BigInteger(792281625)

},

new BigNumberModel

{

BigInteger = new System.Numerics.BigInteger(992281642)

}

};

await using var postgre =

new PostgreSqlBuilder()

.WithImage("postgres:16.0")

.WithPassword("dhgvbh73j")

.WithPortBinding(5432, true)

.WithAutoRemove(true)

.WithWaitStrategy(Wait.ForUnixContainer().UntilExternalTcpPortIsAvailable(5432))

.Build();

await postgre.StartAsync();

await postgre.WaitContainerStateRunningAsync(TimeSpan.FromMinutes(1));

await postgre.WaitResponseAsync(TimeSpan.FromMinutes(1));

await using (var masterConnection = new NpgsqlConnection(postgre.GetConnectionString()))

{

await masterConnection.OpenAsync();

await using var command = masterConnection.CreateCommand();

command.CommandText = $@"

SELECT

datname

FROM

pg_database

WHERE

datname='gedaqtests'

;

";

var dbName = (string)await command.ExecuteScalarAsync();

if (dbName == null)

{

await using var createCmd = masterConnection.CreateCommand();

createCmd.CommandText = $@"

CREATE DATABASE gedaqtests TEMPLATE template0 CONNECTION LIMIT = -1;

;

";

createCmd.ExecuteNonQuery();

}

}

var builder = new NpgsqlConnectionStringBuilder(postgre.GetConnectionString());

builder.Database = "gedaqtests";

var dataSourceBuilder = new NpgsqlDataSourceBuilder(builder.ConnectionString);

await using var npgsqlDataSource = dataSourceBuilder.Build();

{

await using var connection = await npgsqlDataSource.OpenConnectionAsync();

await using var cmd = connection.CreateCommand();

cmd.CommandText = @"

CREATE TABLE public.bigintegernumeric

(

value numeric NOT NULL

);

";

await cmd.ExecuteNonQueryAsync();

}

await ImportAsync(npgsqlDataSource, items);

var exportedItems = await ExportAsync(npgsqlDataSource);

}

private static async Task ImportAsync(NpgsqlDataSource npgsqlDataSource, IEnumerable<BigNumberModel> collection)

{

await using var connection = await npgsqlDataSource.OpenConnectionAsync();

NpgsqlBinaryImporter import = null;

try

{

import = connection.BeginBinaryImport(@"

COPY public.bigintegernumeric

(

value

)

FROM STDIN (FORMAT BINARY)

");

foreach (var item in collection)

{

import.StartRow();

import.Write(item.BigInteger, NpgsqlTypes.NpgsqlDbType.Numeric);

}

import.Complete();

import.Dispose();

import = null;

}

finally

{

if (import != null)

{

try

{

import.Close();

}

catch { /* ignore */ }

import.Dispose();

}

}

}

private static async Task<List<BigNumberModel>> ExportAsync(NpgsqlDataSource npgsqlDataSource)

{

await using var connection = await npgsqlDataSource.OpenConnectionAsync();

NpgsqlBinaryExporter export = null;

try

{

export = await connection.BeginBinaryExportAsync(@"

COPY public.bigintegernumeric

(

value

) TO STDOUT (FORMAT BINARY)

");

var list = new List<BigNumberModel>();

while (await export.StartRowAsync() != -1)

{

var item = new BigNumberModel();

item.BigInteger = await export.ReadAsync<System.Numerics.BigInteger>(NpgsqlTypes.NpgsqlDbType.Numeric);

list.Add(item);

}

await export.DisposeAsync();

export = null;

return list;

}

finally

{

if (export != null)

{

try

{

await export.CancelAsync();

}

catch { /* ignore */ }

await export.DisposeAsync();

}

}

}

}

public class BigNumberModel

{

public BigInteger BigInteger { get; set; }

}

}