using System.Data;
using Npgsql;
using NpgsqlTypes;

namespace ConsoleApp1;

static public class Test
{
    public class NpgsqlGuidInt64Type
    {
        [PgName("guid")]
        public Guid Id;
        [PgName("int64")]
        public Int64 Int64;
    }
    
    public static void DoTest()
    {
        AppContext.SetSwitch("Npgsql.EnableLegacyTimestampBehavior", true);
        AppContext.SetSwitch("Npgsql.EnableStoredProcedureCompatMode", true);
         
        NpgsqlConnection.GlobalTypeMapper.MapComposite<NpgsqlGuidInt64Type>("public.test.mytype");
         
        var connectionStringBuilder = new NpgsqlConnectionStringBuilder()
        {
            Host = "localhost",
            Database = "mydatabase",
            Username = "postgres",
            Password = "postgres",
            IncludeErrorDetail = true
        };
         
        using var connection = new NpgsqlConnection(connectionStringBuilder.ToString());
        connection.Open();

        try
        {
            Console.WriteLine("Testing call with composite type: public.test.mytype");
            DoTestInternal(connection);
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
        }

        try
        {
            Console.WriteLine("Testing call with array of composite types: public.test.mytype[]");
            DoTestArray(connection);
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
        }
        
        
    }

    private static void DoTestInternal(NpgsqlConnection connection)
    {
        using var command = connection.CreateCommand();
        command.CommandType = CommandType.StoredProcedure;
        command.CommandText = "testproc";
         
        var parameter = new NpgsqlGuidInt64Type()
        {
            Id = Guid.NewGuid(),
            Int64 = Int64.MaxValue
        };
        
        var npgsqlParameter = new NpgsqlParameter
        {
            ParameterName = "id",
            Value = parameter,
            DataTypeName = $"public.test.mytype"
        };
         
        command.Parameters.Add(npgsqlParameter);
         
        using var reader = command.ExecuteReader();
        while(reader.Read())
            Console.WriteLine(reader["guid"]);
    }

    private static void DoTestArray(NpgsqlConnection connection)
    {
        using var command = connection.CreateCommand();
        command.CommandType = CommandType.StoredProcedure;
        command.CommandText = "testprocarr";
         
        var parameters = new List<NpgsqlGuidInt64Type>();
        parameters.Add(new NpgsqlGuidInt64Type()
        {
            Id = Guid.NewGuid(),
            Int64 = Int64.MaxValue
        });
         
        parameters.Add(new NpgsqlGuidInt64Type()
        {
            Id = Guid.NewGuid(),
            Int64 = Int64.MinValue
        });
         
        var parameter = new NpgsqlParameter<IList<NpgsqlGuidInt64Type>>
        {
            ParameterName = "ids",
            Value = parameters,
            DataTypeName = $"public.test.mytype[]"
        };
         
        command.Parameters.Add(parameter);
         
        using var reader = command.ExecuteReader();
        while(reader.Read())
            Console.WriteLine(reader["guid"]);
    }
}