Changes of DB implementation

Docs/SweetLib.Storage

@@ -4,18 +4,6 @@
         <name>SweetLib.Storage</name>
     </assembly>
     <members>
-        <member name="T:SweetLib.Storage.Database.IConnectionProvider`1">
-            <summary>
-                Provider for database connection.
-            </summary>
-            <typeparam name="T">Specific type of the database connection. Must inherit <see cref="T:System.Data.Common.DbConnection" />.</typeparam>
-        </member>
-        <member name="M:SweetLib.Storage.Database.IConnectionProvider`1.GetConnection">
-            <summary>
-                Gets an instance of a database connection.
-            </summary>
-            <returns></returns>
-        </member>
         <member name="T:SweetLib.Storage.Database.IDatabaseObject`1">
             <summary>
                 Object to store in database.
@@ -48,6 +36,17 @@
             </summary>
             <returns></returns>
         </member>
+        <member name="T:SweetLib.Storage.IConnectionProvider`1">
+            <summary>
+                Provider for database connection.
+            </summary>
+        </member>
+        <member name="M:SweetLib.Storage.IConnectionProvider`1.GetConnection">
+            <summary>
+                Gets an instance of a database connection.
+            </summary>
+            <returns></returns>
+        </member>
         <member name="T:SweetLib.Storage.IIdentified`1">
             <summary>
                 Interface for identified objects.

SweetLib.Storage.MySql/CustomMySqlObject.cs

@@ -2,7 +2,6 @@
 using System.Data.Common;
 using System.Linq;
 using System.Threading.Tasks;
-using MySql.Data.MySqlClient;
 using SweetLib.Storage.Database;
 using SweetLib.Storage.MySql.Helper;
 
@@ -10,7 +9,7 @@ namespace SweetLib.Storage.MySql;
 
 public abstract class CustomMySqlObject<T> : IDatabaseObject<T>
 {
-    protected CustomMySqlObject(IConnectionProvider<MySqlConnection> connectionProvider,
+    protected CustomMySqlObject(IDatabaseConnectionProvider connectionProvider,
         IIdGenerator<T> idGenerator)
     {
         ConnectionProvider = connectionProvider;
@@ -18,7 +17,7 @@ public abstract class CustomMySqlObject<T> : IDatabaseObject<T>
         Id = UnidentifiedId();
     }
 
-    protected IConnectionProvider<MySqlConnection> ConnectionProvider { get; }
+    protected IDatabaseConnectionProvider ConnectionProvider { get; }
     protected IIdGenerator<T> IdGenerator { get; }
 
     public T Id { get; set; }
@@ -50,7 +49,7 @@ public abstract class CustomMySqlObject<T> : IDatabaseObject<T>
         }
         finally
         {
-            await connection.CloseAsync();
+            connection.Close();
         }
     }
 
@@ -59,7 +58,7 @@ public abstract class CustomMySqlObject<T> : IDatabaseObject<T>
         return Id.Equals(UnidentifiedId());
     }
 
-    public IEnumerable<string> AssignFieldNames()
+    public virtual IEnumerable<string> AssignFieldNames()
     {
         var result = new List<string>();
         result.Add(IdFieldName());
@@ -67,15 +66,16 @@ public abstract class CustomMySqlObject<T> : IDatabaseObject<T>
         return result;
     }
 
-    public async Task AssignToAsync(DbParameterCollection parameters)
+    public virtual async Task AssignToAsync(DbParameterCollection parameters)
     {
         if (IsNew()) Id = await IdGenerator.GenerateNewIdAsync();
 
         parameters.AddMySqlParameterWithValue("@Id", Id);
     }
 
-    public async Task AssignFromAsync(DbDataReader reader)
+    public virtual async Task AssignFromAsync(DbDataReader reader)
     {
+        await reader.ReadAsync();
         Id = (T)reader["Id"];
     }
 
@@ -89,7 +89,7 @@ public abstract class CustomMySqlObject<T> : IDatabaseObject<T>
         {
             var command = connection.CreateCommand();
             command.CommandText = $"SELECT * FROM {TableName()} WHERE Id=@id";
-            command.Parameters.AddWithValue("@id", identifier);
+            command.Parameters.AddMySqlParameterWithValue("@id", identifier);
 
             var reader = await command.ExecuteReaderAsync();
             if (!reader.HasRows)
@@ -100,7 +100,7 @@ public abstract class CustomMySqlObject<T> : IDatabaseObject<T>
         }
         finally
         {
-            await connection.CloseAsync();
+            connection.Close();
         }
     }
 

SweetLib.Storage.MySql/Helper/DbParameterExtensions.cs

@@ -1,17 +1,16 @@
 using System.Data.Common;
 using MySql.Data.MySqlClient;
 
-namespace SweetLib.Storage.MySql.Helper
+namespace SweetLib.Storage.MySql.Helper;
-{
-    public static class MySqlDbParameterExtensions
-    {
-        public static MySqlParameter AddMySqlParameterWithValue(this DbParameterCollection parameterCollection,
-            string name, object value)
-        {
-            var param = new MySqlParameter(name, value);
-            parameterCollection.Add(param);
 
-            return param;
+public static class MySqlDbParameterExtensions
-        }
+{
+    public static MySqlParameter AddMySqlParameterWithValue(this DbParameterCollection parameterCollection,
+        string name, object value)
+    {
+        var param = new MySqlParameter(name, value);
+        parameterCollection.Add(param);
+
+        return param;
     }
 }

SweetLib.Storage/Database/IDatabaseConnectionProvider.cs

@@ -0,0 +1,8 @@
+using System.Data.Common;
+
+namespace SweetLib.Storage.Database
+{
+    public interface IDatabaseConnectionProvider : IConnectionProvider<DbConnection>
+    {
+    }
+}

SweetLib.Storage/IConnectionProvider.cs

@@ -1,12 +1,11 @@
-using System.Data.Common;
+using System.Data;
 
-namespace SweetLib.Storage.Database
+namespace SweetLib.Storage
 {
     /// <summary>
     ///     Provider for database connection.
     /// </summary>
-    /// <typeparam name="T">Specific type of the database connection. Must inherit <see cref="DbConnection" />.</typeparam>
+    public interface IConnectionProvider<out T> where T : IDbConnection
-    public interface IConnectionProvider<T> where T : DbConnection
     {
         /// <summary>
         ///     Gets an instance of a database connection.