Interface IRedbConnection

Assembly: redb.Core.dll

Database connection abstraction for REDB.
Replaces DbContext with pure ADO.NET approach.
All methods automatically use CurrentTransaction if active.

public interface IRedbConnection : IAsyncDisposable, IDisposable

Properties

Connection string used for this connection.

string ConnectionString { get; }

Currently active transaction (null if no transaction).

IRedbTransaction? CurrentTransaction { get; }

Begin new transaction.

Task<IRedbTransaction> BeginTransactionAsync()

Execute SQL command (INSERT, UPDATE, DELETE) and return affected rows count.

Task<int> ExecuteAsync(string sql, params object[] parameters)

Execute multiple operations atomically (all-or-nothing).

Task ExecuteAtomicAsync(Func<Task> operations)

Execute multiple operations atomically and return result.

Task<T> ExecuteAtomicAsync<T>(Func<Task<T>> operations)

Execute raw SQL function returning JSON.

Task<string?> ExecuteJsonAsync(string sql, params object[] parameters)

Execute raw SQL function returning multiple JSON rows.

Task<List<string>> ExecuteJsonListAsync(string sql, params object[] parameters)

Execute SQL query and return scalar value.

Task<T?> ExecuteScalarAsync<T>(string sql, params object[] parameters)

Get underlying DbConnection for advanced operations (e.g., COPY protocol).

Task<DbConnection> GetUnderlyingConnectionAsync()

Execute SQL query and return list of mapped objects.

Task<List<T>> QueryAsync<T>(string sql, params object[] parameters) where T : new()

Execute SQL query and return first result or null.

Task<T?> QueryFirstOrDefaultAsync<T>(string sql, params object[] parameters) where T : class, new()

Execute SQL query and return list of scalar values (first column only).

Task<List<T>> QueryScalarListAsync<T>(string sql, params object[] parameters)