Skip to content

Commit 303e0b7

Browse files
Implement comments
1 parent a29f9ee commit 303e0b7

7 files changed

Lines changed: 4 additions & 9 deletions

File tree

src/PhenX.EntityFrameworkCore.BulkInsert.MySql/MySqlBulkInsertProvider.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ CancellationToken ctk
5858

5959
var bulkCopy = new MySqlBulkCopy(connection, mySqlTransaction);
6060
bulkCopy.DestinationTableName = tableName;
61-
bulkCopy.BulkCopyTimeout = 60;
61+
bulkCopy.BulkCopyTimeout = options.GetCopyTimeoutInSeconds();
6262

6363
var sourceOrdinal = 0;
6464
foreach (var prop in properties)

src/PhenX.EntityFrameworkCore.BulkInsert.MySql/MySqlDbContextOptionsExtensions.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
namespace PhenX.EntityFrameworkCore.BulkInsert.MySql;
55

66
/// <summary>
7-
/// DbContext options extension for SQL Server.
7+
/// DbContext options extension for MySql.
88
/// </summary>
99
public static class MySqlDbContextOptionsExtensions
1010
{

src/PhenX.EntityFrameworkCore.BulkInsert.SqlServer/SqlServerBulkInsertProvider.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ public SqlServerBulkInsertProvider(ILogger<SqlServerBulkInsertProvider>? logger
2222

2323
//language=sql
2424
/// <inheritdoc />
25-
protected override string AddTableCopyBulkInsertId => $"ALTER TABLE {{0}} ADD {BulkInsertId} INT;";
25+
protected override string AddTableCopyBulkInsertId => $"ALTER TABLE {{0}} ADD {BulkInsertId} INT IDENTITY PRIMARY KEY;";
2626

2727
/// <inheritdoc />
2828
protected override string GetTempTableName(string tableName) => $"#_temp_bulk_insert_{tableName}";

tests/PhenX.EntityFrameworkCore.BulkInsert.Tests/DbContainer/TestDbContainer.cs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,6 @@ protected TestDbContainer()
1919
DbContainer = GetDbContainer();
2020
}
2121

22-
protected string GetRandomContainerName() => "phenx-bulk-insert-test-" + Guid.NewGuid();
23-
2422
protected abstract IDatabaseContainer? GetDbContainer();
2523

2624
protected virtual string GetConnectionString()

tests/PhenX.EntityFrameworkCore.BulkInsert.Tests/DbContainer/TestDbContainerMySql.cs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,8 @@ public class TestDbContainerMySql<TDbContext> : TestDbContainer<TDbContext>
1515
protected override IDatabaseContainer? GetDbContainer()
1616
{
1717
return new MySqlBuilder()
18-
.WithReuse(true)
1918
.WithCommand("--log-bin-trust-function-creators=1", "--local-infile=1", "--innodb-print-all-deadlocks=ON")
20-
.WithName(GetRandomContainerName())
19+
.WithReuse(true)
2120
.Build();
2221
}
2322

tests/PhenX.EntityFrameworkCore.BulkInsert.Tests/DbContainer/TestDbContainerPostgreSql.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@ public class TestDbContainerPostgreSql<TDbContext> : TestDbContainer<TDbContext>
1919
.WithDatabase("testdb")
2020
.WithUsername("testuser")
2121
.WithPassword("testpassword")
22-
.WithName(GetRandomContainerName())
2322
.Build();
2423
}
2524

tests/PhenX.EntityFrameworkCore.BulkInsert.Tests/DbContainer/TestDbContainerSqlServer.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@ public class TestDbContainerSqlServer<TDbContext> : TestDbContainer<TDbContext>
1616
{
1717
return new MsSqlBuilder()
1818
.WithReuse(true)
19-
.WithName(GetRandomContainerName())
2019
.Build();
2120
}
2221

0 commit comments

Comments
 (0)