Class SQLiteWriter

Namespace

The.SQLite.Persistence

Assembly

Instagile.SQLite.dll

public sealed class SQLiteWriter : WriterBase, IVisitor, IDisposable

Inheritance

object

WriterBase

SQLiteWriter

Implements

IVisitor

IDisposable

Inherited Members

WriterBase.Visit(AssertEntityVersion)

WriterBase.Visit(DeleteEntity)

WriterBase.Visit(DeleteRelationship)

WriterBase.Visit(InsertRelationship)

WriterBase.ExecuteAsync()

WriterBase.Dispose()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

SQLiteWriter(IDatabase, Dictionary<string, EntityTable>, Dictionary<string, AutonumColumn>, Random, TimeSpan, int, bool, Identity, CancellationToken)

public SQLiteWriter(IDatabase db, Dictionary<string, EntityTable> persisters, Dictionary<string, AutonumColumn> autonums, Random rng, TimeSpan versionConflictLeeway, int maximumBatchedQueryCount, bool disableParameterisedQueries, Identity queryWriteIdentity, CancellationToken cancellationToken)

Parameters

db IDatabase

persisters Dictionary<string, EntityTable>

autonums Dictionary<string, AutonumColumn>

rng Random

versionConflictLeeway TimeSpan

maximumBatchedQueryCount int

disableParameterisedQueries bool

queryWriteIdentity Identity

cancellationToken CancellationToken

Properties

MaxParamsPerStatement

RDBMS-specific max placeholder count.

protected override int MaxParamsPerStatement { get; }

Property Value

int

Methods

CreateDML(IReadOnlyDictionary<string, EntityTable>, QueryConfig)

protected override IDMLDialect CreateDML(IReadOnlyDictionary<string, EntityTable> tables, QueryConfig config)

Parameters

tables IReadOnlyDictionary<string, EntityTable>

config QueryConfig

Returns

IDMLDialect

CreateParameter(int, Guid)

protected override DbParameter CreateParameter(int number, Guid value)

Parameters

number int

value Guid

Returns

DbParameter

CreateParameter(int, int, object)

protected override DbParameter CreateParameter(int number, int dbType, object value)

Parameters

number int

dbType int

value object

Returns

DbParameter

CreateParameter(int, string)

protected override DbParameter CreateParameter(int number, string value)

Parameters

number int

value string

Returns

DbParameter

CreateParameter(int, ulong)

protected override DbParameter CreateParameter(int number, ulong value)

Parameters

number int

value ulong

Returns

DbParameter

DeferInsertRelationships(string, string, IReadOnlyList<InsertRelationship>, CancellationToken)

public void DeferInsertRelationships(string typeName, string relationshipName, IReadOnlyList<InsertRelationship> rels, CancellationToken cancellationToken)

Parameters

typeName string

relationshipName string

rels IReadOnlyList<InsertRelationship>

cancellationToken CancellationToken

ExecuteAsync(List<List<BatchedCommand>>)

protected override Task ExecuteAsync(List<List<BatchedCommand>> _Batches)

Parameters

_Batches List<List<BatchedCommand>>

Returns

Task

GetParameterValue(AttributeColumn, object?)

protected override object GetParameterValue(AttributeColumn c, object? raw)

Parameters

c AttributeColumn

raw object

Returns

object

InsertEntitiesAsync(string, IReadOnlyList<ColumnsByIndex>, CancellationToken)

public Task InsertEntitiesAsync(string typeName, IReadOnlyList<ColumnsByIndex> fusedOperations, CancellationToken cancellationToken)

Parameters

typeName string

fusedOperations IReadOnlyList<ColumnsByIndex>

cancellationToken CancellationToken

Returns

Task

ReadDateTime(IDataRecord, int)

protected override DateTime ReadDateTime(IDataRecord row, int index)

Parameters

row IDataRecord

index int

Returns

DateTime

Visit(InsertEntity)

public override void Visit(InsertEntity operation)

Parameters

operation InsertEntity

Visit(UpdateEntity)

public override void Visit(UpdateEntity operation)

Parameters

operation UpdateEntity