haeaeae/duplicati
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Updated methods to use the instance ReusableTransacition instead of starting a new one

Browse Source
This commit is contained in:
Carl Johnsen
2025-05-23 08:26:06 +02:00
parent abc7c79841
commit d27dec0a2f
1 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Duplicati/Library/Main/Database/LocalDatabase.cs
+4 -8
View File
@@ -2352,9 +2352,7 @@ namespace Duplicati.Library.Main.Database
public async Task PurgeLogData(DateTime threshold)
{
using var transaction = m_connection.BeginTransaction();
using var cmd = m_connection.CreateCommand();
cmd.Transaction = transaction;
using var cmd = m_connection.CreateCommand(m_rtr);
var t = Library.Utility.Utility.NormalizeDateTimeToEpochSeconds(threshold);
await cmd.SetCommandAndParameters(@"
@@ -2371,19 +2369,17 @@ namespace Duplicati.Library.Main.Database
.SetParameterValue("@Timestamp", t)
.ExecuteNonQueryAsync();
await transaction.CommitAsync();
await m_rtr.CommitAsync();
}
public async Task PurgeDeletedVolumes(DateTime threshold)
{
using var transaction = m_connection.BeginTransaction();
await m_removedeletedremotevolumeCommand
.SetTransaction(transaction)
.SetTransaction(m_rtr)
.SetParameterValue("@Now", Library.Utility.Utility.NormalizeDateTimeToEpochSeconds(threshold))
.ExecuteNonQueryAsync();
await transaction.CommitAsync();
await m_rtr.CommitAsync();
}
public virtual void Dispose()