PluralKit/PluralKit.Core/Database/Wrappers/IPKConnection.cs

using System.Data;

using Npgsql;

namespace PluralKit.Core;

public interface IPKConnection: IDbConnection, IAsyncDisposable
{
    public Guid ConnectionId { get; }

    public Task OpenAsync(CancellationToken cancellationToken = default);
    public Task CloseAsync();

    public Task ChangeDatabaseAsync(string databaseName, CancellationToken ct = default);

    public ValueTask<IPKTransaction> BeginTransactionAsync(CancellationToken ct = default) =>
        BeginTransactionAsync(IsolationLevel.Unspecified, ct);

    public ValueTask<IPKTransaction> BeginTransactionAsync(IsolationLevel level, CancellationToken ct = default);

    public NpgsqlBinaryImporter BeginBinaryImport(string copyFromCommand);
    public NpgsqlBinaryExporter BeginBinaryExport(string copyToCommand);

    [Obsolete] new void Open();
    [Obsolete] new void Close();

    [Obsolete] new IDbTransaction BeginTransaction();
    [Obsolete] new IDbTransaction BeginTransaction(IsolationLevel il);
}