Class PostgreSQLDatabase

Namespace

The.PostgreSQL

Assembly

Instagile.PostgreSQL.dll

PostgreSQL database implementation using Npgsql.

public class PostgreSQLDatabase : PooledDatabase, IDatabase

Inheritance

object

PooledDatabase

PostgreSQLDatabase

Implements

IDatabase

Inherited Members

PooledDatabase.Server

PooledDatabase.Name

PooledDatabase.Execute(string, TimeSpan?, params DbParameter[])

PooledDatabase.ExecuteAsync(string, TimeSpan?, CancellationToken, params DbParameter[])

PooledDatabase.BulkExecute(string, TimeSpan?, IReadOnlyList<DbParameter[]>)

PooledDatabase.BulkExecuteAsync(string, TimeSpan?, CancellationToken, IReadOnlyList<DbParameter[]>)

PooledDatabase.Query<TResult>(string, TimeSpan?, CommandBehavior, Func<DbDataReader, TResult>, params DbParameter[])

PooledDatabase.QueryAsync<TResult>(string, TimeSpan?, CancellationToken, CommandBehavior, Func<DbDataReader, TResult>, params DbParameter[])

PooledDatabase.Stream<TResult>(string, TimeSpan?, Func<IDataRecord, TResult>, params DbParameter[])

PooledDatabase.Stream(string, TimeSpan?, Func<DbDataReader, Stream>, params DbParameter[])

PooledDatabase.StreamAsync(string, TimeSpan?, CancellationToken, Func<DbDataReader, Stream>, params DbParameter[])

PooledDatabase.Batch(IEnumerable<BatchQuery>, TimeSpan?)

PooledDatabase.BatchAsync(IEnumerable<BatchQuery>, TimeSpan?, CancellationToken)

PooledDatabase.GetTransaction()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

DatabaseExtensions.BufferAsync<TResult>(IDatabase, string, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.BufferAsync<TResult>(IDatabase, string, TimeSpan?, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.BufferAsync<TResult>(IDatabase, string, TimeSpan?, CancellationToken, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.BufferAsync<TResult>(IDatabase, string, CancellationToken, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.Buffer<TResult>(IDatabase, string, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.Buffer<TResult>(IDatabase, string, TimeSpan?, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.Execute(IDatabase, string, params DbParameter[])

DatabaseExtensions.ExecuteAsync(IDatabase, string, params DbParameter[])

DatabaseExtensions.ExecuteAsync(IDatabase, string, CancellationToken, params DbParameter[])

DatabaseExtensions.QueryAsync<TResult>(IDatabase, string, CommandBehavior, Func<DbDataReader, TResult>, params DbParameter[])

DatabaseExtensions.QueryAsync<TResult>(IDatabase, string, Func<DbDataReader, TResult>, params DbParameter[])

DatabaseExtensions.QueryAsync<TResult>(IDatabase, string, CancellationToken, CommandBehavior, Func<DbDataReader, TResult>, params DbParameter[])

DatabaseExtensions.QueryAsync<TResult>(IDatabase, string, CancellationToken, Func<DbDataReader, TResult>, params DbParameter[])

DatabaseExtensions.Query<TResult>(IDatabase, string, Func<DbDataReader, TResult>, params DbParameter[])

DatabaseExtensions.ReadAsync<TResult>(IDatabase, string, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.ReadAsync<TResult>(IDatabase, string, TimeSpan?, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.ReadAsync<TResult>(IDatabase, string, TimeSpan?, CancellationToken, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.ReadAsync<TResult>(IDatabase, string, CancellationToken, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.Read<TResult>(IDatabase, string, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.Read<TResult>(IDatabase, string, TimeSpan?, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.Stream<TResult>(IDatabase, string, Func<IDataRecord, TResult>, params DbParameter[])

Constructors

PostgreSQLDatabase(string, TimeSpan?)

PostgreSQL database implementation using Npgsql.

public PostgreSQLDatabase(string connectionString, TimeSpan? timeout = null)

Parameters

connectionString string

Npgsql connection string (e.g., "Host=localhost;Database=mydb;Username=user;Password=pass")

timeout TimeSpan?

Optional command timeout. Default: 30 seconds.

Methods

ChangeDatabase(string)

Changes the target database for this connection.

public void ChangeDatabase(string databaseName)

Parameters

databaseName string

Name of the database to connect to.

CreateConnection()

protected override DbConnection CreateConnection()

Returns

DbConnection

CreateTransaction()

public NpgsqlTransaction CreateTransaction()

Returns

NpgsqlTransaction