Interface IDataContext

Namespace

NextORM.Core

Assembly

nextorm.core.dll

Composite facade over the individual context roles, kept as the convenient entry point for consumers. The roles are separate interfaces so that providers and collaborators can depend on the smallest surface they actually need:

• IQueryExecutor — terminal operators;
• IQueryMaterializer — planning + row reading;
• IQueryCache — plan cache;
• IContextEnvironment — loggers, mapping mode, property bag;
• IRawCommandExecutor — raw parameterised commands.

Connection management is deliberately not part of this composite (see IConnectionManager): the in-memory provider must not be forced to implement a no-op connection lifecycle.

public interface IDataContext : IQueryExecutor, IQueryMaterializer, IQueryPlanner, IRowReaderFactory, IQueryCache, IContextEnvironment, IRawCommandExecutor, IAsyncDisposable, IDisposable

Inherited Members

IQueryExecutor.ToListAsync<TResult>(IPreparedQueryCommand<TResult>, object[], CancellationToken)

IQueryExecutor.ToList<TResult>(IPreparedQueryCommand<TResult>, ReadOnlySpan<object>)

IQueryExecutor.ExecuteScalar<TResult>(IPreparedQueryCommand<TResult>, object[], bool, CancellationToken)

IQueryExecutor.ExecuteScalar<TResult>(IPreparedQueryCommand<TResult>, ReadOnlySpan<object>, bool)

IQueryExecutor.First<TResult>(IPreparedQueryCommand<TResult>, ReadOnlySpan<object>)

IQueryExecutor.FirstAsync<TResult>(IPreparedQueryCommand<TResult>, object[], CancellationToken)

IQueryExecutor.FirstOrDefault<TResult>(IPreparedQueryCommand<TResult>, ReadOnlySpan<object>)

IQueryExecutor.FirstOrDefaultAsync<TResult>(IPreparedQueryCommand<TResult>, object[], CancellationToken)

IQueryExecutor.Single<TResult>(IPreparedQueryCommand<TResult>, ReadOnlySpan<object>)

IQueryExecutor.SingleAsync<TResult>(IPreparedQueryCommand<TResult>, object[], CancellationToken)

IQueryExecutor.SingleOrDefault<TResult>(IPreparedQueryCommand<TResult>, ReadOnlySpan<object>)

IQueryExecutor.SingleOrDefaultAsync<TResult>(IPreparedQueryCommand<TResult>, object[], CancellationToken)

IQueryPlanner.GetPreparedQueryCommand<TResult>(QueryCommand<TResult>, bool, bool, CancellationToken)

IQueryPlanner.ResetPreparation(QueryCommand)

IQueryPlanner.GetFrom(Type, QueryCommand)

IRowReaderFactory.CreateAsyncEnumerator<TResult>(IPreparedQueryCommand<TResult>, object[], CancellationToken)

IRowReaderFactory.CreateEnumerator<TResult>(IPreparedQueryCommand<TResult>, object[])

IRowReaderFactory.GetAsyncEnumerable<TResult>(IPreparedQueryCommand<TResult>, CancellationToken, params object[])

IRowReaderFactory.GetAsyncEnumerable<TResult>(IPreparedQueryCommand<TResult>, params object[])

IRowReaderFactory.GetEnumerable<TResult>(IPreparedQueryCommand<TResult>, params object[])

IRowReaderFactory.CreateEnumeratorAsync<TResult>(IPreparedQueryCommand<TResult>, object[], CancellationToken)

IQueryCache.AnyCommand

IQueryCache.PurgeQueryCache()

IContextEnvironment.Logger

IContextEnvironment.CommandLogger

IContextEnvironment.QueryFilterLogger

IContextEnvironment.NeedMapping

IContextEnvironment.Properties

IContextEnvironment.QuoteIdentifiers

IContextEnvironment.NamingConvention

IContextEnvironment.KeywordCase

IContextEnvironment.MultilineBatchSql

IContextEnvironment.CommandTimeout

IContextEnvironment.EagerLoadMode

IRawCommandExecutor.ExecuteRaw(string, params IReadOnlyList<ProcedureParameter>)

IRawCommandExecutor.ExecuteRawAsync(string, IReadOnlyList<ProcedureParameter>, CancellationToken)

IRawCommandExecutor.ExecuteRawAsync(string, params IReadOnlyList<ProcedureParameter>)

IRawCommandExecutor.ExecuteProcedure(string, params IReadOnlyList<ProcedureParameter>)

IRawCommandExecutor.ExecuteProcedureAsync(string, IReadOnlyList<ProcedureParameter>, CancellationToken)

IRawCommandExecutor.ExecuteProcedureAsync(string, params IReadOnlyList<ProcedureParameter>)

IAsyncDisposable.DisposeAsync()

IDisposable.Dispose()

Extension Methods

BatchExtensions.CreateBatchBuilder(IDataContext)

DataContextExtensions.Any(IDataContext, IPreparedQueryCommand<bool>, params ReadOnlySpan<object?>)

DataContextExtensions.AnyAsync(IDataContext, IPreparedQueryCommand<bool>, params object[]?)

DataContextExtensions.AnyAsync(IDataContext, IPreparedQueryCommand<bool>, object[]?, CancellationToken)

DataContextExtensions.AnyAsync(IDataContext, IPreparedQueryCommand<bool>, CancellationToken)

DataContextExtensions.CreateBulkInsertBuilder<TEntity>(IDataContext, BulkInsertOptions, Action<EntityMetadataBuilder<TEntity>>?)

DataContextExtensions.CreateBulkInsertBuilder<TEntity>(IDataContext, Action<EntityMetadataBuilder<TEntity>>?)

DataContextExtensions.CreateBulkInsertBuilder<TEntity>(IDataContext, Func<BulkInsertOptionsBuilder, BulkInsertOptionsBuilder>, Action<EntityMetadataBuilder<TEntity>>?)

DataContextExtensions.CreateCommand<T>(IDataContext, QueryDefinition)

DataContextExtensions.CreateDeleteBuilder<TEntity>(IDataContext, Action<EntityMetadataBuilder<TEntity>>?)

DataContextExtensions.CreateInsertBuilder<TEntity>(IDataContext, Action<EntityMetadataBuilder<TEntity>>?)

DataContextExtensions.CreateMergeBuilder<TEntity>(IDataContext, Action<EntityMetadataBuilder<TEntity>>?)

DataContextExtensions.CreateQueryBuilder(IDataContext, string)

DataContextExtensions.CreateQueryBuilder(IDataContext, string, Action<FromOptions>)

DataContextExtensions.CreateQueryBuilderFromSql(IDataContext, string, object?)

DataContextExtensions.CreateQueryBuilder<TResult>(IDataContext, EntityBuilder<TResult>)

DataContextExtensions.CreateQueryBuilder<TResult>(IDataContext, EntityBuilder<TResult>, Action<FromOptions>)

DataContextExtensions.CreateQueryBuilder<TResult>(IDataContext, QueryCommand<TResult>)

DataContextExtensions.CreateQueryBuilder<TResult>(IDataContext, QueryCommand<TResult>, Action<FromOptions>)

DataContextExtensions.CreateQueryBuilder<TResult>(IDataContext, TempTableSource<TResult>)

DataContextExtensions.CreateQueryBuilder<T>(IDataContext, Action<EntityMetadataBuilder<T>>?)

DataContextExtensions.CreateQueryBuilder<T>(IDataContext, Action<FromOptions>, Action<EntityMetadataBuilder<T>>?)

DataContextExtensions.CreateSqliteFts5CommandBuilder(IDataContext, string)

DataContextExtensions.CreateTruncateBuilder<TEntity>(IDataContext, Action<EntityMetadataBuilder<TEntity>>?)

DataContextExtensions.CreateUpdateBuilder<TEntity>(IDataContext, Action<EntityMetadataBuilder<TEntity>>?)

DataContextExtensions.DeleteAsync<TEntity>(IDataContext, TEntity, CancellationToken)

DataContextExtensions.Delete<TEntity>(IDataContext, TEntity)

DataContextExtensions.ExecuteProcedureAsync(IDataContext, string, CancellationToken)

DataContextExtensions.ExecuteRawAsync(IDataContext, string, CancellationToken)

DataContextExtensions.FirstAsync<TResult>(IDataContext, IPreparedQueryCommand<TResult>, params object[]?)

DataContextExtensions.FirstOrDefaultAsync<TResult>(IDataContext, IPreparedQueryCommand<TResult>, params object[]?)

DataContextExtensions.From(IDataContext, string)

DataContextExtensions.From(IDataContext, string, Action<FromOptions>)

DataContextExtensions.FromSql(IDataContext, string, object?)

DataContextExtensions.From<TResult>(IDataContext, CteReference<TResult>)

DataContextExtensions.From<TResult>(IDataContext, Cte<TResult>)

DataContextExtensions.From<TResult>(IDataContext, EntityBuilder<TResult>)

DataContextExtensions.From<TResult>(IDataContext, EntityBuilder<TResult>, Action<FromOptions>)

DataContextExtensions.From<TResult>(IDataContext, QueryCommand<TResult>)

DataContextExtensions.From<TResult>(IDataContext, QueryCommand<TResult>, Action<FromOptions>)

DataContextExtensions.From<TResult>(IDataContext, TempTableSource<TResult>)

DataContextExtensions.From<T>(IDataContext, Action<EntityMetadataBuilder<T>>?)

DataContextExtensions.From<T>(IDataContext, Action<FromOptions>, Action<EntityMetadataBuilder<T>>?)

DataContextExtensions.From<T>(IDataContext, Expression<Func<EntityBuilder<T>>>)

DataContextExtensions.From<T>(IDataContext, Expression<Func<EntityBuilder<T>>>, Action<FromOptions>)

DataContextExtensions.SingleAsync<TResult>(IDataContext, IPreparedQueryCommand<TResult>, params object[]?)

DataContextExtensions.SingleOrDefaultAsync<TResult>(IDataContext, IPreparedQueryCommand<TResult>, params object[]?)

DataContextExtensions.ToListAsync<TResult>(IDataContext, IPreparedQueryCommand<TResult>, params object[]?)

DataContextExtensions.ToList<TResult>(IDataContext, IPreparedQueryCommand<TResult>)

DataContextExtensions.UpdateAsync<TEntity>(IDataContext, TEntity, CancellationToken)

DataContextExtensions.Update<TEntity>(IDataContext, TEntity)

DataContextExtensions.With(IDataContext, string, QueryCommand)

DataContextExtensions.WithRecursive(IDataContext, string, QueryCommand, int?)

DataContextExtensions.With<TProjection, TResult>(IDataContext, string, DeleteJoinReturningBuilder<TProjection, TResult>)

DataContextExtensions.With<TEntity, TResult>(IDataContext, string, DeleteReturningBuilder<TEntity, TResult>)

DataContextExtensions.With<TEntity, TResult>(IDataContext, string, InsertReturningBuilder<TEntity, TResult>)

DataContextExtensions.With<TProjection, TResult>(IDataContext, string, UpdateJoinReturningBuilder<TProjection, TResult>)

DataContextExtensions.With<TEntity, TResult>(IDataContext, string, UpdateReturningBuilder<TEntity, TResult>)

EntityBuilderExtensions.AsEntityBuilder<T>(object?)

Methods

GetPreparedQueryCommand<TResult>(QueryCommand<TResult>, bool, bool, PreparedCommandCache, CancellationToken)

Prepares queryCommand with an explicit command-reuse policy, optionally creating the row enumerator and storing the plan in the cache.

IPreparedQueryCommand<TResult> GetPreparedQueryCommand<TResult>(QueryCommand<TResult> queryCommand, bool createEnumerator, bool storeInCache, PreparedCommandCache cache, CancellationToken cancellationToken)

Parameters

queryCommand QueryCommand<TResult>

The command to prepare.

createEnumerator bool

When true, creates the row enumerator as part of preparation.

storeInCache bool

When true, the resulting plan may be stored in the plan cache.

cache PreparedCommandCache

The policy that selects connection-scoped command reuse or a command per execution.

cancellationToken CancellationToken

Token used to cancel preparation.

Returns

IPreparedQueryCommand<TResult>

The prepared command, ready to execute.

Type Parameters

TResult

The projected result type.

Remarks

The default implementation supports only Connection and forwards to the policy-less overload. A context that does not implement the policy fails closed for any other value instead of silently substituting the connection policy.

Exceptions

NotSupportedException

The context implementation does not implement the requested cache policy.