github/Ombi
1
0
Fork 0
mirror of https://github.com/Ombi-app/Ombi.git synced 2025-08-19 04:49:33 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

Catch the missing table exception when they have a new DB

Browse source
This commit is contained in:
Jamie Rees 2016-03-18 21:59:34 +00:00
commit 3c6338cadc
1 changed files with 23 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

33
PlexRequests.Core/Setup.cs
View file

@ -24,6 +24,8 @@
// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
// ************************************************************************/ // ************************************************************************/
#endregion #endregion
using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq; using System.Linq;
@ -70,18 +72,29 @@ namespace PlexRequests.Core
private void MigrateDb() // TODO: Remove when no longer needed private void MigrateDb() // TODO: Remove when no longer needed
{ {
var repo = new GenericRepository<RequestedModel>(Db);
var records = repo.GetAll();
var requestedModels = records as RequestedModel[] ?? records.ToArray();
if(!requestedModels.Any())
{ return; }
var jsonRepo = new JsonRequestService(new RequestJsonRepository(Db, new MemoryCacheProvider()));
var result = new List<long>(); var result = new List<long>();
foreach (var r in requestedModels) RequestedModel[] requestedModels;
var repo = new GenericRepository<RequestedModel>(Db);
try
{ {
var id = jsonRepo.AddRequest(r); var records = repo.GetAll();
result.Add(id);
requestedModels = records as RequestedModel[] ?? records.ToArray();
if (!requestedModels.Any())
{ return; }
var jsonRepo = new JsonRequestService(new RequestJsonRepository(Db, new MemoryCacheProvider()));
foreach (var r in requestedModels)
{
var id = jsonRepo.AddRequest(r);
result.Add(id);
}
}
catch (SqliteException)
{
// There is no requested table so they do not have an old version of the DB
return;
} }
if (result.Any(x => x == -1)) if (result.Any(x => x == -1))