using System;
using System.Threading.Tasks;

namespace pgTest;

public class Program {
	private const string ConnStr = "Server=pg;Port=5432;Database=temp;User id=admin;Password=admin";
	private static readonly Npgsql.NpgsqlDataSource ds = new Npgsql.NpgsqlDataSourceBuilder(ConnStr).Build();

	public static async Task Main() {
		try {
			Console.WriteLine($"Started");
			using var conn = await ds.OpenConnectionAsync();
			Console.WriteLine($"Connected");
			using var tx = await conn.BeginTransactionAsync();

			using var cmd = conn.CreateCommand();
			cmd.CommandTimeout = 1;
			cmd.Transaction = tx;
			cmd.CommandText = """select v.i, jsonb_build_object(), current_timestamp + make_interval(0, 0, 0, 0, 0, 0, v.i), null::jsonb, '{"value": 42}'::jsonb from generate_series(1, 1000) as v(i)""";
			var rdr = await cmd.ExecuteReaderAsync(System.Data.CommandBehavior.SingleResult | System.Data.CommandBehavior.SequentialAccess);
			while (await rdr.ReadAsync()) {
				var v1 = rdr[0];
				var v2 = rdr[1];
				//_ = rdr[2]; // uncomment line for successful execution
				var v3 = rdr[3];
				var v4 = rdr[4];
			}
			await rdr.DisposeAsync();
			await cmd.DisposeAsync();

			await tx.CommitAsync();
			await conn.DisposeAsync();
		}
		catch (Exception e) {
			Console.WriteLine(e);
		}
	}
}