private static async Task BinaryImportAsync<T>(DbContext dbContext,
                                               List<T> data,
                                               string tableName) where T : class
{
    var connection = dbContext.Database.GetDbConnection() as NpgsqlConnection;
    if (connection == null)
        throw new InvalidOperationException("Connection must be an NpgsqlConnection");

    if (connection.State != System.Data.ConnectionState.Open)
        await connection.OpenAsync();

    var entityType = dbContext.Model.FindEntityType(typeof(T));

    var columns = entityType.GetProperties()
        .OrderBy(p => p.GetColumnName())
        .ToList();

    var columnNames = columns.Select(p => $"\"{p.GetColumnName()}\"").ToList();
    string columnsQuery = string.Join(", ", columnNames);

    await using (var writer = await connection.BeginBinaryImportAsync($"COPY {tableName} " +
                                 $"({columnsQuery}) FROM STDIN (FORMAT BINARY)"))
    {
        if (writer == null)
            throw new InvalidOperationException("Connection must be an NpgsqlConnection");

        foreach (var item in data)
        {
            await writer.StartRowAsync();
            foreach (var prop in columns)
            {
                var value = prop.PropertyInfo.GetValue(item);

                // Handle nulls
                if (value == null)
                {
                    await writer.WriteNullAsync();
                }
                else
                {
                    // Handle enums (write as string or integer)
                    if (prop.PropertyInfo.PropertyType.IsEnum)
                        value = (int)value;

                    await writer.WriteAsync(value);
                }
            }
        }

        await writer.CompleteAsync();
    }
}