aboutsummaryrefslogtreecommitdiff
path: root/Emby.Server.Implementations/Sync/SyncRepository.cs
diff options
context:
space:
mode:
authorLuke <luke.pulverenti@gmail.com>2016-11-29 14:47:45 -0500
committerGitHub <noreply@github.com>2016-11-29 14:47:45 -0500
commit8c2095b24ee3228c0e112ebc3cfcb73e146d2a78 (patch)
tree6a83c8132f9eac18c0a0bc2461e191c5c725c3c1 /Emby.Server.Implementations/Sync/SyncRepository.cs
parent1d09262963fb1d09f3a04843922a6a7a2f4364b3 (diff)
parent456d5e5b760abe46c8dedf08b2465d2bd3ced4af (diff)
Merge pull request #2317 from MediaBrowser/dev
Dev
Diffstat (limited to 'Emby.Server.Implementations/Sync/SyncRepository.cs')
-rw-r--r--Emby.Server.Implementations/Sync/SyncRepository.cs15
1 files changed, 5 insertions, 10 deletions
diff --git a/Emby.Server.Implementations/Sync/SyncRepository.cs b/Emby.Server.Implementations/Sync/SyncRepository.cs
index b2d9fbcc9..037507872 100644
--- a/Emby.Server.Implementations/Sync/SyncRepository.cs
+++ b/Emby.Server.Implementations/Sync/SyncRepository.cs
@@ -43,12 +43,7 @@ namespace Emby.Server.Implementations.Sync
{
using (var connection = CreateConnection())
{
- connection.ExecuteAll(string.Join(";", new[]
- {
- "PRAGMA page_size=4096",
- "pragma default_temp_store = memory",
- "pragma temp_store = memory"
- }));
+ RunDefaultInitialization(connection);
string[] queries = {
@@ -79,7 +74,7 @@ namespace Emby.Server.Implementations.Sync
existingColumnNames = GetColumnNames(db, "SyncJobItems");
AddColumn(db, "SyncJobItems", "ItemDateModifiedTicks", "BIGINT", existingColumnNames);
- });
+ }, TransactionMode);
}
}
@@ -268,7 +263,7 @@ namespace Emby.Server.Implementations.Sync
connection.RunInTransaction(conn =>
{
conn.Execute(commandText, paramList.ToArray());
- });
+ }, TransactionMode);
}
}
}
@@ -290,7 +285,7 @@ namespace Emby.Server.Implementations.Sync
{
conn.Execute("delete from SyncJobs where Id=?", id.ToGuidParamValue());
conn.Execute("delete from SyncJobItems where JobId=?", id);
- });
+ }, TransactionMode);
}
}
}
@@ -743,7 +738,7 @@ namespace Emby.Server.Implementations.Sync
connection.RunInTransaction(conn =>
{
conn.Execute(commandText, paramList.ToArray());
- });
+ }, TransactionMode);
}
}
}