1 instantiation of SqlConnection
Microsoft.CodeAnalysis.Workspaces (1)
Storage\SQLite\v2\Interop\SqlConnection.cs (1)
111
var connection = new
SqlConnection
(handle, queryToStatement);
42 references to SqlConnection
Microsoft.CodeAnalysis.Workspaces (42)
Storage\SQLite\v2\Interop\SqlConnection.cs (4)
25
/// cref="SQLitePersistentStorage.GetPooledConnection(out
SqlConnection
)"/>). Connections can be used by different
79
public static
SqlConnection
Create(IPersistentStorageFaultInjector? faultInjector, string databasePath)
111
var
connection = new SqlConnection(handle, queryToStatement);
361
Func<
SqlConnection
, SafeSqliteBlobHandle, Optional<T>> readBlob)
Storage\SQLite\v2\Interop\SqlStatement.cs (2)
27
/// by <see cref="
SqlConnection
.Close_OnlyForUseBySQLiteConnectionPool"/>.</para>
29
internal readonly struct SqlStatement(
SqlConnection
connection, SafeSqliteStatementHandle statement)
Storage\SQLite\v2\SQLitePersistentStorage.Accessor.cs (12)
96
protected abstract TDatabaseKey? TryGetDatabaseKey(
SqlConnection
connection, TKey key, bool allowWrite);
108
public void CreateTable(
SqlConnection
connection, Database database)
159
Func<TData,
SqlConnection
, Database, long, Optional<T>> readColumn,
172
using var _ = this.Storage.GetPooledConnection(out
var
connection);
204
Optional<T> ReadColumnHelper(
SqlConnection
connection, Database database, TDatabaseKey databaseKey, int dataNameID)
231
using var _ = this.Storage.GetPooledConnection(out
var
connection);
263
SqlConnection
connection, Database database, long rowId, Checksum? checksum)
296
SqlConnection
connection, Database database, long rowId)
312
private bool ChecksumsMatch_MustRunInTransaction(
SqlConnection
connection, Database database, long rowId, Checksum checksum)
327
private bool TryGetActualRowIdFromDatabase(
SqlConnection
connection, Database database, TDatabaseKey databaseKey, int dataNameId, out long rowId)
357
SqlConnection
connection,
384
public void FlushInMemoryDataToDisk_MustRunInTransaction(
SqlConnection
connection)
Storage\SQLite\v2\SQLitePersistentStorage.cs (3)
40
private readonly Stack<
SqlConnection
> _connectionsPool = new();
187
using var _ = GetPooledConnection(checkScheduler: false, out
var
connection);
233
void EnsureTables(
SqlConnection
connection, Database database)
Storage\SQLite\v2\SQLitePersistentStorage_DocumentIds.cs (1)
25
private DocumentPrimaryKey? TryGetDocumentPrimaryKey(
SqlConnection
connection, DocumentKey documentKey, bool allowWrite)
Storage\SQLite\v2\SQLitePersistentStorage_DocumentSerialization.cs (1)
39
protected override DocumentPrimaryKey? TryGetDatabaseKey(
SqlConnection
connection, DocumentKey key, bool allowWrite)
Storage\SQLite\v2\SQLitePersistentStorage_FlushWrites.cs (1)
42
using var _ = this.GetPooledConnection(out
var
connection);
Storage\SQLite\v2\SQLitePersistentStorage_ProjectIds.cs (1)
25
private ProjectPrimaryKey? TryGetProjectPrimaryKey(
SqlConnection
connection, ProjectKey projectKey, bool allowWrite)
Storage\SQLite\v2\SQLitePersistentStorage_ProjectSerialization.cs (1)
37
protected override ProjectPrimaryKey? TryGetDatabaseKey(
SqlConnection
connection, ProjectKey projectKey, bool allowWrite)
Storage\SQLite\v2\SQLitePersistentStorage_SolutionSerialization.cs (1)
38
protected override SolutionPrimaryKey? TryGetDatabaseKey(
SqlConnection
connection, SolutionKey key, bool allowWrite)
Storage\SQLite\v2\SQLitePersistentStorage_StringIds.cs (5)
18
private int? TryGetStringId(
SqlConnection
connection, string? value, bool allowWrite)
45
private int? TryGetStringIdFromDatabase(
SqlConnection
connection, string value, bool allowWrite)
107
private int InsertStringIntoDatabase_MustRunInTransaction(
SqlConnection
connection, string value)
138
SqlConnection
connection, string value, bool canReturnNull)
173
private void LoadExistingStringIds(
SqlConnection
connection)
Storage\SQLite\v2\SQLitePersistentStorage+PooledConnection.cs (10)
14
private readonly struct PooledConnection(SQLitePersistentStorage storage,
SqlConnection
sqlConnection) : IDisposable
16
public readonly
SqlConnection
Connection = sqlConnection;
23
/// Gets a <see cref="
SqlConnection
"/> from the connection pool, or creates one if none are available.
30
private PooledConnection GetPooledConnection(out
SqlConnection
connection)
34
/// <inheritdoc cref="GetPooledConnection(out
SqlConnection
)"/>
38
private PooledConnection GetPooledConnection(bool checkScheduler, out
SqlConnection
connection)
52
private
SqlConnection
GetConnection()
57
if (_connectionsPool.TryPop(out
var
connection))
62
return
SqlConnection
.Create(_faultInjector, this.DatabaseFile);
65
private void ReleaseConnection(
SqlConnection
connection)