39 lines
1.2 KiB
C#
39 lines
1.2 KiB
C#
|
using System;
|
||
|
|
using System.Collections.Concurrent;
|
||
|
|
using LiteDB;
|
||
|
|
using PCL.Core.App.IoC;
|
||
|
|
|
||
|
|
namespace PCL.Core.App.Database;
|
||
|
|
|
||
|
|
[LifecycleService(LifecycleState.Loading)]
|
||
|
|
public class DatabaseService() : GeneralService("database", "数据库管理")
|
||
|
|
{
|
||
|
|
private static readonly ConcurrentDictionary<string, LiteDatabase> _Instances = new();
|
||
|
|
|
||
|
|
/// <inheritdoc />
|
||
|
|
public override void Stop()
|
||
|
|
{
|
||
|
|
foreach (var instance in _Instances.Values)
|
||
|
|
{
|
||
|
|
instance.Dispose();
|
||
|
|
}
|
||
|
|
|
||
|
|
_Instances.Clear();
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary>
|
||
|
|
/// Get the database connenction from specified connection path.<br/>
|
||
|
|
/// If not exists, a new connection will be created and cached.
|
||
|
|
/// </summary>
|
||
|
|
/// <returns>Getted connenction instance.</returns>
|
||
|
|
/// <exception cref="ArgumentException">Throw if connection path is invalid.</exception>
|
||
|
|
public static LiteDatabase GetConnection(string connectionPath)
|
||
|
|
{
|
||
|
|
if (string.IsNullOrWhiteSpace(connectionPath))
|
||
|
|
{
|
||
|
|
throw new ArgumentException("Connection string canot be null or whitespace.", nameof(connectionPath));
|
||
|
|
}
|
||
|
|
|
||
|
|
return _Instances.GetOrAdd(connectionPath, cp => new LiteDatabase(cp));
|
||
|
|
}
|
||
|
|
}
|