2011-05-24 01:29:14 +02:00
|
|
|
|
using System;
|
2011-06-17 05:36:52 +02:00
|
|
|
|
using System.Data;
|
2011-06-18 04:51:53 +02:00
|
|
|
|
using System.Data.Common;
|
2011-06-23 08:56:17 +02:00
|
|
|
|
using System.Data.SqlServerCe;
|
2011-05-24 01:29:14 +02:00
|
|
|
|
using System.IO;
|
2011-06-14 03:35:44 +02:00
|
|
|
|
using MvcMiniProfiler.Data;
|
2011-06-15 04:31:41 +02:00
|
|
|
|
using PetaPoco;
|
2011-05-24 01:29:14 +02:00
|
|
|
|
|
|
|
|
|
namespace NzbDrone.Core.Datastore
|
|
|
|
|
{
|
|
|
|
|
public static class Connection
|
|
|
|
|
{
|
|
|
|
|
private static readonly DirectoryInfo AppDataPath = new DirectoryInfo(Path.Combine(CentralDispatch.AppPath, "App_Data"));
|
|
|
|
|
|
|
|
|
|
static Connection()
|
|
|
|
|
{
|
|
|
|
|
if (!AppDataPath.Exists) AppDataPath.Create();
|
2011-06-18 04:51:53 +02:00
|
|
|
|
Database.Mapper = new CustomeMapper();
|
2011-05-24 01:29:14 +02:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
2011-06-04 20:19:22 +02:00
|
|
|
|
public static string GetConnectionString(string path)
|
2011-05-24 01:29:14 +02:00
|
|
|
|
{
|
2011-06-23 08:56:17 +02:00
|
|
|
|
//return String.Format("Data Source={0};Version=3;Cache Size=30000;Pooling=true;Default Timeout=2", path);
|
|
|
|
|
return String.Format("Data Source={0}", path);
|
2011-05-24 01:29:14 +02:00
|
|
|
|
}
|
|
|
|
|
|
2011-06-04 20:19:22 +02:00
|
|
|
|
public static String MainConnectionString
|
2011-05-24 01:29:14 +02:00
|
|
|
|
{
|
|
|
|
|
get
|
|
|
|
|
{
|
2011-06-23 08:56:17 +02:00
|
|
|
|
return GetConnectionString(Path.Combine(AppDataPath.FullName, "nzbdrone.sdf"));
|
2011-05-24 01:29:14 +02:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2011-06-04 20:19:22 +02:00
|
|
|
|
public static String LogConnectionString
|
2011-05-24 01:29:14 +02:00
|
|
|
|
{
|
|
|
|
|
get
|
|
|
|
|
{
|
2011-06-23 08:56:17 +02:00
|
|
|
|
return GetConnectionString(Path.Combine(AppDataPath.FullName, "log.sdf"));
|
2011-05-24 01:29:14 +02:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2011-06-18 04:51:53 +02:00
|
|
|
|
|
|
|
|
|
public static IDatabase GetPetaPocoDb(string connectionString, Boolean profiled = true)
|
2011-06-15 04:31:41 +02:00
|
|
|
|
{
|
2011-06-17 08:58:50 +02:00
|
|
|
|
MigrationsHelper.Run(connectionString, true);
|
2011-06-23 08:56:17 +02:00
|
|
|
|
var sqliteConnection = new SqlCeConnection(connectionString);
|
2011-06-22 07:43:45 +02:00
|
|
|
|
DbConnection connection = sqliteConnection;
|
2011-06-23 08:56:17 +02:00
|
|
|
|
|
2011-06-18 04:51:53 +02:00
|
|
|
|
if (profiled)
|
|
|
|
|
{
|
2011-06-22 07:43:45 +02:00
|
|
|
|
connection = ProfiledDbConnection.Get(sqliteConnection);
|
2011-06-18 04:51:53 +02:00
|
|
|
|
}
|
2011-06-17 08:58:50 +02:00
|
|
|
|
|
2011-06-18 04:51:53 +02:00
|
|
|
|
var db = new Database(connection);
|
2011-06-18 22:30:30 +02:00
|
|
|
|
db.ForceDateTimesToUtc = false;
|
2011-06-17 05:36:52 +02:00
|
|
|
|
|
2011-06-18 04:51:53 +02:00
|
|
|
|
if (connection.State != ConnectionState.Open)
|
|
|
|
|
connection.Open();
|
2011-06-15 04:31:41 +02:00
|
|
|
|
|
|
|
|
|
return db;
|
|
|
|
|
}
|
|
|
|
|
|
2011-05-24 01:29:14 +02:00
|
|
|
|
}
|
|
|
|
|
}
|