Skip to content

Commit 7c18383

Browse files
authored
Merge pull request #554 from ipax77/dev
increase csv import timeout
2 parents 76d8f9c + 28f9820 commit 7c18383

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

src/dsstats.ratings/RatingsSaveService.Csv2Sql.cs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ private async Task Csv2Mysql(string fileName,
2626
await connection.OpenAsync();
2727

2828
var command = connection.CreateCommand();
29-
command.CommandTimeout = 420;
29+
command.CommandTimeout = 840;
3030

3131
command.CommandText = @$"
3232
DROP TABLE IF EXISTS {tempTable};
@@ -66,7 +66,7 @@ private async Task ContinueCsv2Mysql(string fileName,
6666
await connection.OpenAsync();
6767

6868
var command = connection.CreateCommand();
69-
command.CommandTimeout = 360;
69+
command.CommandTimeout = 840;
7070

7171
command.CommandText = @$"
7272
SET FOREIGN_KEY_CHECKS = 0;
@@ -93,7 +93,7 @@ private async Task FixDsstatsForeignKey(string connectionString)
9393
await connection.OpenAsync();
9494

9595
var command = connection.CreateCommand();
96-
command.CommandTimeout = 420;
96+
command.CommandTimeout = 840;
9797

9898
command.CommandText = @$"ALTER TABLE {nameof(ReplayContext.PlayerRatingChanges)} DROP FOREIGN KEY FK_PlayerRatingChanges_PlayerRatings_PlayerRatingId;
9999
ALTER TABLE {nameof(ReplayContext.PlayerRatingChanges)} ADD CONSTRAINT FK_PlayerRatingChanges_PlayerRatings_PlayerRatingId
@@ -115,7 +115,7 @@ private async Task FixArcadeForeignKey(string connectionString)
115115
await connection.OpenAsync();
116116

117117
var command = connection.CreateCommand();
118-
command.CommandTimeout = 360;
118+
command.CommandTimeout = 840;
119119

120120
command.CommandText = @$"ALTER TABLE {nameof(ReplayContext.ArcadePlayerRatingChanges)} DROP FOREIGN KEY `FK_ArcadePlayerRatingChanges_ArcadePlayerRatings_ArcadePlayerRa~`;
121121
ALTER TABLE {nameof(ReplayContext.ArcadePlayerRatingChanges)} ADD CONSTRAINT `FK_ArcadePlayerRatingChanges_ArcadePlayerRatings_ArcadePlayerRa~`
@@ -137,7 +137,7 @@ private async Task DropDsstatsIndexes(string connectionString)
137137
await connection.OpenAsync();
138138

139139
var command = connection.CreateCommand();
140-
command.CommandTimeout = 420;
140+
command.CommandTimeout = 840;
141141

142142
command.CommandText = @$"ALTER TABLE {nameof(ReplayContext.RepPlayerRatings)} DROP INDEX `IX_RepPlayerRatings_ReplayPlayerId`;
143143
ALTER TABLE {nameof(ReplayContext.RepPlayerRatings)} DROP INDEX `IX_RepPlayerRatings_ReplayRatingInfoId`;
@@ -159,7 +159,7 @@ private async Task ReCreateDsstatsIndexes(string connectionString)
159159
await connection.OpenAsync();
160160

161161
var command = connection.CreateCommand();
162-
command.CommandTimeout = 420;
162+
command.CommandTimeout = 840;
163163

164164
command.CommandText = @$"CREATE UNIQUE INDEX `IX_RepPlayerRatings_ReplayPlayerId` ON {nameof(ReplayContext.RepPlayerRatings)} ({nameof(RepPlayerRating.ReplayPlayerId)});
165165
CREATE INDEX `IX_RepPlayerRatings_ReplayRatingInfoId` ON {nameof(ReplayContext.RepPlayerRatings)} ({nameof(RepPlayerRating.ReplayRatingInfoId)});";

0 commit comments

Comments
 (0)