Class MySqlBulkCopy

Namespace

LinqToDB.Internal.DataProvider.MySql

Assembly

linq2db.dll

public class MySqlBulkCopy : BasicBulkCopy

Inheritance

object

BasicBulkCopy

MySqlBulkCopy

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

MySqlBulkCopy(MySqlDataProvider)

public MySqlBulkCopy(MySqlDataProvider provider)

Parameters

provider MySqlDataProvider

Properties

MaxParameters

Settings based on https://www.jooq.org/doc/3.12/manual/sql-building/dsl-context/custom-settings/settings-inline-threshold/ MySQL supports more but realistically this might be too much already for practical cases.

protected override int MaxParameters { get; }

Property Value

int

MaxSqlLength

MySQL can support much larger sizes, based on https://dev.mysql.com/doc/refman/8.0/en/server-system-variables.html#sysvar_max_allowed_packet But we keep a smaller number here to avoid choking the network.

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