Class PostgreSQLBulkCopy

Namespace

LinqToDB.Internal.DataProvider.PostgreSQL

Assembly

linq2db.dll

public class PostgreSQLBulkCopy : BasicBulkCopy

Inheritance

object

BasicBulkCopy

PostgreSQLBulkCopy

Inherited Members

BasicBulkCopy.CastLiteral(ColumnDescriptor)

BasicBulkCopy.BulkCopy<T>(BulkCopyType, ITable<T>, DataOptions, IEnumerable<T>)

BasicBulkCopy.BulkCopyAsync<T>(BulkCopyType, ITable<T>, DataOptions, IEnumerable<T>, CancellationToken)

BasicBulkCopy.BulkCopyAsync<T>(BulkCopyType, ITable<T>, DataOptions, IAsyncEnumerable<T>, CancellationToken)

BasicBulkCopy.RowByRowCopy<T>(ITable<T>, DataOptions, IEnumerable<T>)

BasicBulkCopy.RowByRowCopyAsync<T>(ITable<T>, DataOptions, IEnumerable<T>, CancellationToken)

BasicBulkCopy.RowByRowCopyAsync<T>(ITable<T>, DataOptions, IAsyncEnumerable<T>, CancellationToken)

BasicBulkCopy.GetTableName<T>(ISqlBuilder, BulkCopyOptions, ITable<T>, bool)

BasicBulkCopy.TraceAction(DataConnection, Func<string>, Func<int>)

BasicBulkCopy.TraceActionAsync(DataConnection, Func<string>, Func<Task<int>>)

BasicBulkCopy.MultipleRowsCopyHelper(MultipleRowsHelper, IEnumerable, string, Action<MultipleRowsHelper>, Action<MultipleRowsHelper, object, string>, Action<MultipleRowsHelper>, int, int)

BasicBulkCopy.MultipleRowsCopyHelperAsync(MultipleRowsHelper, IEnumerable, string, Action<MultipleRowsHelper>, Action<MultipleRowsHelper, object, string>, Action<MultipleRowsHelper>, CancellationToken, int, int)

BasicBulkCopy.MultipleRowsCopyHelperAsync<T>(MultipleRowsHelper, IAsyncEnumerable<T>, string, Action<MultipleRowsHelper>, Action<MultipleRowsHelper, object, string>, Action<MultipleRowsHelper>, CancellationToken, int, int)

BasicBulkCopy.MultipleRowsCopy1<T>(ITable<T>, DataOptions, IEnumerable<T>)

BasicBulkCopy.MultipleRowsCopy1(MultipleRowsHelper, IEnumerable)

BasicBulkCopy.MultipleRowsCopy1Async<T>(ITable<T>, DataOptions, IEnumerable<T>, CancellationToken)

BasicBulkCopy.MultipleRowsCopy1Async(MultipleRowsHelper, IEnumerable, CancellationToken)

BasicBulkCopy.MultipleRowsCopy1Async<T>(ITable<T>, DataOptions, IAsyncEnumerable<T>, CancellationToken)

BasicBulkCopy.MultipleRowsCopy1Async<T>(MultipleRowsHelper, IAsyncEnumerable<T>, CancellationToken)

BasicBulkCopy.MultipleRowsCopy2<T>(ITable<T>, DataOptions, IEnumerable<T>, string)

BasicBulkCopy.MultipleRowsCopy2(MultipleRowsHelper, IEnumerable, string)

BasicBulkCopy.MultipleRowsCopy2Async<T>(ITable<T>, DataOptions, IEnumerable<T>, string, CancellationToken)

BasicBulkCopy.MultipleRowsCopy2Async(MultipleRowsHelper, IEnumerable, string, CancellationToken)

BasicBulkCopy.MultipleRowsCopy2Async<T>(ITable<T>, DataOptions, IAsyncEnumerable<T>, string, CancellationToken)

BasicBulkCopy.MultipleRowsCopy2Async<T>(MultipleRowsHelper, IAsyncEnumerable<T>, string, CancellationToken)

BasicBulkCopy.MultipleRowsCopy3(MultipleRowsHelper, IEnumerable, string)

BasicBulkCopy.MultipleRowsCopy3Async(MultipleRowsHelper, IEnumerable, string, CancellationToken)

BasicBulkCopy.MultipleRowsCopy3Async<T>(MultipleRowsHelper, IAsyncEnumerable<T>, string, CancellationToken)

BasicBulkCopy.MaxMultipleRows

BasicBulkCopy.CastFirstRowLiteralOnUnionAll

BasicBulkCopy.CastFirstRowParametersOnUnionAll

BasicBulkCopy.CastAllRowsParametersOnUnionAll

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

Sql.IsDistinctFrom<T>(T, T)

Sql.IsDistinctFrom<T>(T, T)

Sql.IsDistinctFrom<T>(T, T)

Sql.IsDistinctFrom<T>(T, T)

Sql.IsDistinctFrom<T>(T, T)

Sql.IsNotDistinctFrom<T>(T, T)

Sql.IsNotDistinctFrom<T>(T, T)

Sql.IsNotDistinctFrom<T>(T, T)

Sql.IsNotDistinctFrom<T>(T, T)

Sql.IsNotDistinctFrom<T>(T, T)

SqlExtensions.In<T>(T, T, T)

SqlExtensions.In<T>(T, T, T)

SqlExtensions.In<T>(T, T, T)

SqlExtensions.In<T>(T, T, T)

SqlExtensions.In<T>(T, T, T)

SqlExtensions.In<T>(T, T, T, T)

SqlExtensions.In<T>(T, T, T, T)

SqlExtensions.In<T>(T, T, T, T)

SqlExtensions.In<T>(T, T, T, T)

SqlExtensions.In<T>(T, T, T, T)

SqlExtensions.In<T>(T, params T[])

SqlExtensions.In<T>(T, params T[])

SqlExtensions.In<T>(T, params T[])

SqlExtensions.In<T>(T, params T[])

SqlExtensions.In<T>(T, params T[])

SqlExtensions.In<T>(T, IEnumerable<T>)

SqlExtensions.In<T>(T, IEnumerable<T>)

SqlExtensions.In<T>(T, IEnumerable<T>)

SqlExtensions.In<T>(T, IEnumerable<T>)

SqlExtensions.In<T>(T, IEnumerable<T>)

SqlExtensions.In<T>(T, IQueryable<T>)

SqlExtensions.In<T>(T, IQueryable<T>)

SqlExtensions.In<T>(T, IQueryable<T>)

SqlExtensions.In<T>(T, IQueryable<T>)

SqlExtensions.In<T>(T, IQueryable<T>)

SqlExtensions.NotIn<T>(T, T, T)

SqlExtensions.NotIn<T>(T, T, T)

SqlExtensions.NotIn<T>(T, T, T)

SqlExtensions.NotIn<T>(T, T, T)

SqlExtensions.NotIn<T>(T, T, T)

SqlExtensions.NotIn<T>(T, T, T, T)

SqlExtensions.NotIn<T>(T, T, T, T)

SqlExtensions.NotIn<T>(T, T, T, T)

SqlExtensions.NotIn<T>(T, T, T, T)

SqlExtensions.NotIn<T>(T, T, T, T)

SqlExtensions.NotIn<T>(T, params T[])

SqlExtensions.NotIn<T>(T, params T[])

SqlExtensions.NotIn<T>(T, params T[])

SqlExtensions.NotIn<T>(T, params T[])

SqlExtensions.NotIn<T>(T, params T[])

SqlExtensions.NotIn<T>(T, IEnumerable<T>)

SqlExtensions.NotIn<T>(T, IEnumerable<T>)

SqlExtensions.NotIn<T>(T, IEnumerable<T>)

SqlExtensions.NotIn<T>(T, IEnumerable<T>)

SqlExtensions.NotIn<T>(T, IEnumerable<T>)

SqlExtensions.NotIn<T>(T, IQueryable<T>)

SqlExtensions.NotIn<T>(T, IQueryable<T>)

SqlExtensions.NotIn<T>(T, IQueryable<T>)

SqlExtensions.NotIn<T>(T, IQueryable<T>)

SqlExtensions.NotIn<T>(T, IQueryable<T>)

Utils.IsNullValue(object?)

Utils.IsNullValue(object?)

Utils.IsNullValue(object?)

Utils.IsNullValue(object?)

Utils.IsNullValue(object?)

Constructors

PostgreSQLBulkCopy(PostgreSQLDataProvider)

public PostgreSQLBulkCopy(PostgreSQLDataProvider dataProvider)

Parameters

dataProvider PostgreSQLDataProvider

Properties

MaxParameters

protected override int MaxParameters { get; }

Property Value

int

Remarks

Settings based on https://www.jooq.org/doc/3.12/manual/sql-building/dsl-context/custom-settings/settings-inline-threshold/ We subtract 1 based on possibility of provider using parameter for command.

MaxSqlLength

Setting based on https://stackoverflow.com/a/4937695/2937845 Max is actually 2GiB, but we keep a lower number here to avoid the cost of huge statements.

protected override int MaxSqlLength { get; }

Property Value

int

Methods

MultipleRowsCopyAsync<T>(ITable<T>, DataOptions, IAsyncEnumerable<T>, CancellationToken)

protected override Task<BulkCopyRowsCopied> MultipleRowsCopyAsync<T>(ITable<T> table, DataOptions options, IAsyncEnumerable<T> source, CancellationToken cancellationToken) where T : notnull

Parameters

table ITable<T>

options DataOptions

source IAsyncEnumerable<T>

cancellationToken CancellationToken

Returns

Task<BulkCopyRowsCopied>

Type Parameters

T

MultipleRowsCopyAsync<T>(ITable<T>, DataOptions, IEnumerable<T>, CancellationToken)

protected override Task<BulkCopyRowsCopied> MultipleRowsCopyAsync<T>(ITable<T> table, DataOptions options, IEnumerable<T> source, CancellationToken cancellationToken) where T : notnull

Parameters

table ITable<T>

options DataOptions

source IEnumerable<T>

cancellationToken CancellationToken

Returns

Task<BulkCopyRowsCopied>

Type Parameters

T

MultipleRowsCopy<T>(ITable<T>, DataOptions, IEnumerable<T>)

protected override BulkCopyRowsCopied MultipleRowsCopy<T>(ITable<T> table, DataOptions options, IEnumerable<T> source) where T : notnull

Parameters

table ITable<T>

options DataOptions

source IEnumerable<T>

Returns

BulkCopyRowsCopied

Type Parameters

T

ProviderSpecificCopyAsync<T>(ITable<T>, DataOptions, IAsyncEnumerable<T>, CancellationToken)

protected override Task<BulkCopyRowsCopied> ProviderSpecificCopyAsync<T>(ITable<T> table, DataOptions options, IAsyncEnumerable<T> source, CancellationToken cancellationToken) where T : notnull

Parameters

table ITable<T>

options DataOptions

source IAsyncEnumerable<T>

cancellationToken CancellationToken

Returns

Task<BulkCopyRowsCopied>

Type Parameters

T

ProviderSpecificCopyAsync<T>(ITable<T>, DataOptions, IEnumerable<T>, CancellationToken)

protected override Task<BulkCopyRowsCopied> ProviderSpecificCopyAsync<T>(ITable<T> table, DataOptions options, IEnumerable<T> source, CancellationToken cancellationToken) where T : notnull

Parameters

table ITable<T>

options DataOptions

source IEnumerable<T>

cancellationToken CancellationToken

Returns

Task<BulkCopyRowsCopied>

Type Parameters

T

ProviderSpecificCopy<T>(ITable<T>, DataOptions, IEnumerable<T>)

protected override BulkCopyRowsCopied ProviderSpecificCopy<T>(ITable<T> table, DataOptions options, IEnumerable<T> source) where T : notnull

Parameters

table ITable<T>

options DataOptions

source IEnumerable<T>

Returns

BulkCopyRowsCopied

Type Parameters

T