Skip to content

Commit

Permalink
Renamed cancellation token param.
Browse files Browse the repository at this point in the history
  • Loading branch information
Markeli committed Apr 14, 2023
1 parent 548babf commit 5c83049
Show file tree
Hide file tree
Showing 12 changed files with 28 additions and 22 deletions.
6 changes: 6 additions & 0 deletions src/Curiosity.Migrations/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,11 @@
# Changelog

## [4.1.3] - 2023-04-14

### Changed

- Renamed cancellation token param.

## [4.1.2] - 2023-04-12

### Fixed
Expand Down
2 changes: 1 addition & 1 deletion src/Curiosity.Migrations/Curiosity.Migrations.csproj
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
<PackageTags>migrations; migration; migrator; versioning; migration-tool; .net-core; .netstandard; database; siisltd; curiosity</PackageTags>
<Language>English</Language>

<PackageVersion>4.1.2</PackageVersion>
<PackageVersion>4.1.3</PackageVersion>
<AssemblyVersion>1.0.0</AssemblyVersion>
<FileVersion>1.0.0</FileVersion>

Expand Down
2 changes: 1 addition & 1 deletion src/Curiosity.Migrations/Migrations/CodeMigration.cs
Original file line number Diff line number Diff line change
Expand Up @@ -67,5 +67,5 @@ public abstract class CodeMigration : IMigration
}

/// <inheritdoc />
public abstract Task UpgradeAsync(DbTransaction? transaction = null, CancellationToken token = default);
public abstract Task UpgradeAsync(DbTransaction? transaction = null, CancellationToken cancellationToken = default);
}
4 changes: 2 additions & 2 deletions src/Curiosity.Migrations/Migrations/IMigration.cs
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ public interface IMigration
/// Upgrades database to the version specified in <see cref="Version"/>.
/// </summary>
/// <param name="transaction">Transaction in which operation must be executed. Optional. Use it when you need attach transaction to Entity Framework data context.</param>
/// <param name="token">Cancellation token.</param>
/// <param name="cancellationToken">Cancellation token.</param>
/// <returns>Task associated with upgrade.</returns>
Task UpgradeAsync(DbTransaction? transaction = null, CancellationToken token = default);
Task UpgradeAsync(DbTransaction? transaction = null, CancellationToken cancellationToken = default);
}
4 changes: 2 additions & 2 deletions src/Curiosity.Migrations/Migrations/ScriptMigration.cs
Original file line number Diff line number Diff line change
Expand Up @@ -62,9 +62,9 @@ public class ScriptMigration : IMigration
}

/// <inheritdoc />
public async Task UpgradeAsync(DbTransaction? transaction = null, CancellationToken token = default)
public async Task UpgradeAsync(DbTransaction? transaction = null, CancellationToken cancellationToken = default)
{
await RunBatchesAsync(UpScripts, token);
await RunBatchesAsync(UpScripts, cancellationToken);
}

/// <summary>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,8 @@ public class CodeMigration_2_0 : CodeMigration
public override string Comment => "Correct script via provider";

/// <inheritdoc />
public override async Task UpgradeAsync(DbTransaction? transaction = null, CancellationToken token = default)
public override async Task UpgradeAsync(DbTransaction? transaction = null, CancellationToken cancellationToken = default)
{
await MigrationConnection.ExecuteNonQuerySqlAsync("select 1;", null, token);
await MigrationConnection.ExecuteNonQuerySqlAsync("select 1;", null, cancellationToken);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ public class CodeMigration_3_0 : CodeMigration
public override string Comment { get; } = "Migration using multiple EF context with one connection";

/// <inheritdoc />
public override async Task UpgradeAsync(DbTransaction? transaction = null, CancellationToken token = default)
public override async Task UpgradeAsync(DbTransaction? transaction = null, CancellationToken cancellationToken = default)
{
var tempContextOptionsBuilder = new DbContextOptionsBuilder<TempContext>();
tempContextOptionsBuilder.UseNpgsql(MigrationConnection.Connection!);
Expand All @@ -27,8 +27,8 @@ public override async Task UpgradeAsync(DbTransaction? transaction = null, Cance
await using (var tempContext = new TempContext(tempContextOptionsBuilder.Options))
await using (var anotherContext = new AnotherTempContext(anotherTempContextOptionsBuilder.Options))
{
await tempContext.Database.UseTransactionAsync(transaction, token);
await anotherContext.Database.UseTransactionAsync(transaction, token);
await tempContext.Database.UseTransactionAsync(transaction, cancellationToken);
await anotherContext.Database.UseTransactionAsync(transaction, cancellationToken);

var request1 = new BackgroundProcessorRequestEntity
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ public CodeMigration_5_0()
IsTransactionRequired = false;
}

public override async Task UpgradeAsync(DbTransaction? transaction = null, CancellationToken token = default)
public override async Task UpgradeAsync(DbTransaction? transaction = null, CancellationToken cancellationToken = default)
{
var tempContextOptionsBuilder = new DbContextOptionsBuilder<TempContext>();
tempContextOptionsBuilder.UseNpgsql(MigrationConnection.Connection!);
Expand Down Expand Up @@ -58,8 +58,8 @@ await using (var anotherContext = new AnotherTempContext(anotherTempContextOptio
tempContext.Requests.Add(request1);
anotherContext.Requests.Add(request2);

await tempContext.SaveChangesAsync(token);
await anotherContext.SaveChangesAsync(token);
await tempContext.SaveChangesAsync(cancellationToken);
await anotherContext.SaveChangesAsync(cancellationToken);
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,12 +22,12 @@ public FourthMigrationWithDependency(DependencyService dependencyService)


/// <inheritdoc />
public override Task UpgradeAsync(DbTransaction transaction, CancellationToken token = default)
public override Task UpgradeAsync(DbTransaction transaction, CancellationToken cancellationToken = default)
{
return MigrationConnection.ExecuteNonQuerySqlAsync(
ScriptConstants.UpScript,
null,
token);
cancellationToken);
}

/// <inheritdoc />
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,12 +12,12 @@ public class InitialMigration : CodeMigration, IDowngradeMigration
public override string Comment => "comment";

/// <inheritdoc />
public override Task UpgradeAsync(DbTransaction transaction, CancellationToken token = default)
public override Task UpgradeAsync(DbTransaction transaction, CancellationToken cancellationToken = default)
{
return MigrationConnection.ExecuteNonQuerySqlAsync(
ScriptConstants.UpScript,
null,
token);
cancellationToken);
}

/// <inheritdoc />
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,12 +12,12 @@ public class SecondMigration : CodeMigration, ISpecificCodeMigrations, IDowngrad
public override string Comment => "comment";

/// <inheritdoc />
public override Task UpgradeAsync(DbTransaction transaction = null, CancellationToken token = default)
public override Task UpgradeAsync(DbTransaction transaction = null, CancellationToken cancellationToken = default)
{
return MigrationConnection.ExecuteNonQuerySqlAsync(
ScriptConstants.UpScript,
null,
token);
cancellationToken);
}

/// <inheritdoc />
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,12 +13,12 @@ public class ThirdMigration : CodeMigration, ISpecificCodeMigrations, IDowngrade
public override string Comment => "comment";

/// <inheritdoc />
public override Task UpgradeAsync(DbTransaction transaction = null, CancellationToken token = default)
public override Task UpgradeAsync(DbTransaction transaction = null, CancellationToken cancellationToken = default)
{
return MigrationConnection.ExecuteNonQuerySqlAsync(
ScriptConstants.UpScript,
null,
token);
cancellationToken);
}

/// <inheritdoc />
Expand Down

0 comments on commit 5c83049

Please sign in to comment.