migrate database providers to core framework

Oqtane.Server/Databases/MySQL/MySQLDatabase.cs

@@ -0,0 +1,114 @@
+using System.Data;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata;
+using Microsoft.EntityFrameworkCore.Migrations.Operations;
+using Microsoft.EntityFrameworkCore.Migrations.Operations.Builders;
+using MySql.Data.MySqlClient;
+using Oqtane.Databases;
+
+namespace Oqtane.Database.MySQL
+{
+    public class MySQLDatabase : DatabaseBase
+    {
+        private static string _friendlyName => "MySQL";
+
+        private static string _name => "MySQL";
+
+        static MySQLDatabase()
+        {
+            Initialize(typeof(MySQLDatabase));
+        }
+
+        public MySQLDatabase() :base(_name, _friendlyName) { }
+
+        public override string Provider => "Pomelo.EntityFrameworkCore.MySql";
+
+        public override OperationBuilder<AddColumnOperation> AddAutoIncrementColumn(ColumnsBuilder table, string name)
+        {
+            return table.Column<int>(name: name, nullable: false).Annotation("MySql:ValueGenerationStrategy", MySqlValueGenerationStrategy.IdentityColumn);
+        }
+
+        public override string ConcatenateSql(params string[] values)
+        {
+            var returnValue = "CONCAT(";
+            for (var i = 0; i < values.Length; i++)
+            {
+                if (i > 0)
+                {
+                    returnValue += ",";
+                }
+                returnValue += values[i];
+            }
+
+            returnValue += ")";
+
+            return returnValue;
+        }
+
+        public override int ExecuteNonQuery(string connectionString, string query)
+        {
+            var conn = new MySqlConnection(connectionString);
+            var cmd = conn.CreateCommand();
+            using (conn)
+            {
+                PrepareCommand(conn, cmd, query);
+                var val = -1;
+                try
+                {
+                    val = cmd.ExecuteNonQuery();
+                }
+                catch
+                {
+                    // an error occurred executing the query
+                }
+                return val;
+            }
+
+        }
+
+        public override IDataReader ExecuteReader(string connectionString, string query)
+        {
+            var conn = new MySqlConnection(connectionString);
+            var cmd = conn.CreateCommand();
+            PrepareCommand(conn, cmd, query);
+            var dr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
+            return dr;
+        }
+
+        public override string DelimitName(string name)
+        {
+            return $"`{name}`";
+        }
+
+        public override string RewriteValue(object value)
+        {
+            var type = value.GetType().Name;
+            if (type == "DateTime")
+            {
+                return $"'{value}'";
+            }
+            if (type == "Boolean")
+            {
+                return (bool)value ? "1" : "0"; // MySQL uses 1/0 for boolean values
+            }
+            return value.ToString();
+        }
+
+        public override DbContextOptionsBuilder UseDatabase(DbContextOptionsBuilder optionsBuilder, string connectionString)
+        {
+            return optionsBuilder.UseMySql(connectionString, ServerVersion.AutoDetect(connectionString));
+        }
+
+        private void PrepareCommand(MySqlConnection conn, MySqlCommand cmd, string query)
+        {
+            if (conn.State != ConnectionState.Open)
+            {
+                conn.Open();
+            }
+
+            cmd.Connection = conn;
+            cmd.CommandText = query;
+            cmd.CommandType = CommandType.Text;
+        }
+    }
+}