From f9aa02ec1a4c24e80a206857d4f68198bb027bb4 Mon Sep 17 00:00:00 2001
From: crupest <crupest@outlook.com>
Date: Mon, 11 Nov 2024 01:12:29 +0800
Subject: HALF WORK: 2024.12.19

Re-organize file structure.
---
 .../CrupestApi.Commons/Crud/DbConnectionFactory.cs | 75 ++++++++++++++++++++++
 1 file changed, 75 insertions(+)
 create mode 100644 dropped/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/DbConnectionFactory.cs

(limited to 'dropped/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/DbConnectionFactory.cs')

diff --git a/dropped/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/DbConnectionFactory.cs b/dropped/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/DbConnectionFactory.cs
new file mode 100644
index 0000000..701622c
--- /dev/null
+++ b/dropped/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/DbConnectionFactory.cs
@@ -0,0 +1,75 @@
+using System.Data;
+using Microsoft.Data.Sqlite;
+using Microsoft.Extensions.Options;
+
+namespace CrupestApi.Commons.Crud;
+
+public interface IDbConnectionFactory
+{
+    IDbConnection Get(string? name = null);
+    bool ShouldDisposeConnection { get; }
+}
+
+public class SqliteConnectionFactory : IDbConnectionFactory
+{
+    private readonly IOptionsMonitor<CrupestApiConfig> _apiConfigMonitor;
+
+    public SqliteConnectionFactory(IOptionsMonitor<CrupestApiConfig> apiConfigMonitor)
+    {
+        _apiConfigMonitor = apiConfigMonitor;
+    }
+
+    public IDbConnection Get(string? name = null)
+    {
+        var connectionString = new SqliteConnectionStringBuilder()
+        {
+            DataSource = Path.Combine(_apiConfigMonitor.CurrentValue.DataDir, $"{name ?? "crupest-api"}.db"),
+            Mode = SqliteOpenMode.ReadWriteCreate
+        }.ToString();
+
+        var connection = new SqliteConnection(connectionString);
+        connection.Open();
+        return connection;
+    }
+
+    public bool ShouldDisposeConnection => true;
+}
+
+public class SqliteMemoryConnectionFactory : IDbConnectionFactory, IDisposable
+{
+    private readonly Dictionary<string, IDbConnection> _connections = new();
+
+    public IDbConnection Get(string? name = null)
+    {
+        name = name ?? "crupest-api";
+
+        if (_connections.TryGetValue(name, out var connection))
+        {
+            return connection;
+        }
+        else
+        {
+            var connectionString = new SqliteConnectionStringBuilder()
+            {
+                DataSource = ":memory:",
+                Mode = SqliteOpenMode.ReadWriteCreate
+            }.ToString();
+
+            connection = new SqliteConnection(connectionString);
+            _connections.Add(name, connection);
+            connection.Open();
+            return connection;
+        }
+    }
+
+    public bool ShouldDisposeConnection => false;
+
+
+    public void Dispose()
+    {
+        foreach (var connection in _connections.Values)
+        {
+            connection.Dispose();
+        }
+    }
+}
-- 
cgit v1.2.3