nopCommerce如何支持MySQL

using MySql.Data.MySqlClient;
using System;
using System.Collections.Generic;
using System.Data.Common;
using System.Data.Entity.Infrastructure;
using System.Linq;
using System.Text;

namespace Easy.Data
{
    public class MySqlConnectionFactory : IDbConnectionFactory
    {
        private readonly string _baseConnectionString;
        private Func<string, DbProviderFactory> _providerFactoryCreator;

        public MySqlConnectionFactory()
        {
        }

        public MySqlConnectionFactory(string baseConnectionString)
        {
            this._baseConnectionString = baseConnectionString;
        }

        public DbConnection CreateConnection(string nameOrConnectionString)
        {
            string connectionString = nameOrConnectionString;

            bool treatAsConnectionString = nameOrConnectionString.IndexOf(‘=‘) >= 0;

            if (!treatAsConnectionString)
            {
                MySqlConnectionStringBuilder builder = new MySqlConnectionStringBuilder(this.BaseConnectionString);
                builder.Server = nameOrConnectionString;
                connectionString = builder.ConnectionString;
            }
            DbConnection connection = null;
            try
            {
                connection = this.ProviderFactory("MySql.Data.MySqlClient").CreateConnection();
                connection.ConnectionString = connectionString;
            }
            catch
            {
                connection = new MySqlConnection(connectionString);
            }
            return connection;
        }

        public string BaseConnectionString
        {
            get
            {
                return this._baseConnectionString;
            }
        }

        internal Func<string, DbProviderFactory> ProviderFactory
        {
            get
            {
                Func<string, DbProviderFactory> func1 = this._providerFactoryCreator;
                return delegate(string name)
                {
                    return DbProviderFactories.GetFactory(name);
                };
            }
            set
            {
                this._providerFactoryCreator = value;
            }
        }
    }
}

using Easy.Data.Initializers;
using MySql.Data.MySqlClient;
using System;
using System.Collections.Generic;
using System.Data.Common;
using System.Data.Entity;
using System.Data.Entity.Infrastructure;
using System.IO;
using System.Linq;
using System.Text;
using System.Web.Hosting;

namespace Easy.Data
{
    public class MySqlDataProvider : BaseEfDataProvider
    {
        /// <summary>
        /// Get connection factory
        /// </summary>
        /// <returns>Connection factory</returns>
        public override IDbConnectionFactory GetConnectionFactory()
        {
            return new MySqlConnectionFactory();
        }

        /// <summary>
        /// Set database initializer
        /// </summary>
        public override void SetDatabaseInitializer()
        {
            //pass some table names to ensure that we have nopCommerce 2.X installed
            var tablesToValidate = new[] { "Customer", "Discount", "Order", "Product", "ShoppingCartItem" };

            //custom commands (stored proedures, indexes)

            var customCommands = new List<string>();
            //use webHelper.MapPath instead of HostingEnvironment.MapPath which is not available in unit tests
            customCommands.AddRange(ParseCommands(HostingEnvironment.MapPath("~/App_Data/MySql.Indexes.sql"), false));
            //use webHelper.MapPath instead of HostingEnvironment.MapPath which is not available in unit tests
            customCommands.AddRange(ParseCommands(HostingEnvironment.MapPath("~/App_Data/MySql.StoredProcedures.sql"), false));

            var initializer = new CreateTablesIfNotExist<NopObjectContext>(tablesToValidate, customCommands.ToArray());
            Database.SetInitializer(initializer);
        }

        protected virtual string[] ParseCommands(string filePath, bool throwExceptionIfNonExists)
        {
            if (!File.Exists(filePath))
            {
                if (throwExceptionIfNonExists)
                    throw new ArgumentException(string.Format("Specified file doesn‘t exist - {0}", filePath));
                else
                    return new string[0];
            }


            var statements = new List<string>();
            using (var stream = File.OpenRead(filePath))
            using (var reader = new StreamReader(stream))
            {
                var statement = "";
                while ((statement = readNextStatementFromStream(reader)) != null)
                {
                    statements.Add(statement);
                }
            }

            return statements.ToArray();
        }

        protected virtual string readNextStatementFromStream(StreamReader reader)
        {
            var sb = new StringBuilder();

            string lineOfText;

            while (true)
            {
                lineOfText = reader.ReadLine();
                if (lineOfText == null)
                {
                    if (sb.Length > 0)
                        return sb.ToString();
                    else
                        return null;
                }

                //MySql doesn‘t support GO, so just use a commented out GO as the separator
                if (lineOfText.TrimEnd().ToUpper() == "-- GO")
                    break;

                sb.Append(lineOfText + Environment.NewLine);
            }

            return sb.ToString();
        }

        /// <summary>
        /// A value indicating whether this data provider supports stored procedures
        /// </summary>
        public override bool StoredProceduredSupported
        {
            get { return true; }
        }

        /// <summary>
        /// Gets a support database parameter object (used by stored procedures)
        /// </summary>
        /// <returns>Parameter</returns>
        public override DbParameter GetParameter()
        {
            return new MySqlParameter();
        }
    }
}

if (dbExists)
{
    bool createTables = false;
    if (_tablesToValidate != null && _tablesToValidate.Length > 0)
    {
        //we have some table names to validate
        var existingTableNames = new List<string>(context.Database.SqlQuery<string>("SELECT table_name FROM INFORMATION_SCHEMA.TABLES WHERE table_type = ‘BASE TABLE‘"));
        createTables = existingTableNames.Intersect(_tablesToValidate, StringComparer.InvariantCultureIgnoreCase).Count() == 0;
    }
    else
    {
        //check whether tables are already created
        int numberOfTables = 0;
        foreach (var t1 in context.Database.SqlQuery<int>("SELECT COUNT(*) FROM INFORMATION_SCHEMA.TABLES WHERE table_type = ‘BASE TABLE‘ "))
            numberOfTables = t1;

        createTables = numberOfTables == 0;
    }

    if (createTables)
    {
        //create all tables
        var dbCreationScript = ((IObjectContextAdapter)context).ObjectContext.CreateDatabaseScript();
        context.Database.ExecuteSqlCommand(dbCreationScript);

        //Seed(context);
        context.SaveChanges();

        if (_customCommands != null && _customCommands.Length > 0)
        {
            foreach (var command in _customCommands)
                context.Database.ExecuteSqlCommand(command);
        }
    }
}

if (dbExists)
{
    string sql = string.Empty;
    string countSql = string.Empty;
    if (context.Database.Connection.GetType() == typeof(MySqlConnection))
    {
        sql = string.Format("SELECT table_name FROM INFORMATION_SCHEMA.TABLES WHERE table_type = ‘BASE TABLE‘ AND table_schema = ‘{0}‘", context.Database.Connection.Database);
        countSql = string.Format("SELECT COUNT(*) FROM INFORMATION_SCHEMA.TABLES WHERE table_type = ‘BASE TABLE‘ AND table_schema = ‘{0}‘", context.Database.Connection.Database);
    }
    else
    {
        sql = @"SELECT table_name FROM INFORMATION_SCHEMA.TABLES WHERE table_type = ‘BASE TABLE‘";
        countSql = @"SELECT COUNT(*) FROM INFORMATION_SCHEMA.TABLES WHERE table_type = ‘BASE TABLE‘ ";
    }

    bool createTables = false;
    if (_tablesToValidate != null && _tablesToValidate.Length > 0)
    {
        //we have some table names to validate
        var existingTableNames = new List<string>(context.Database.SqlQuery<string>(sql));
        createTables = existingTableNames.Intersect(_tablesToValidate, StringComparer.InvariantCultureIgnoreCase).Count() == 0;
    }
    else
    {
        //check whether tables are already created
        int numberOfTables = 0;
        foreach (var t1 in context.Database.SqlQuery<int>(countSql))
            numberOfTables = t1;

        createTables = numberOfTables == 0;
    }

    if (createTables)
    {
        //create all tables
        var dbCreationScript = ((IObjectContextAdapter)context).ObjectContext.CreateDatabaseScript();

        //Need to fix some of the script for MySql
        if (context.Database.Connection.GetType() == typeof(MySqlConnection))
        {
            //MySql doesn‘t support varbinary(MAX) so it generates the script with varbinary only without
            //a size specified, so change to longblob...could probably do this in the mapping for these properties instead
            dbCreationScript = dbCreationScript.Replace("`PictureBinary` varbinary,", "`PictureBinary` LONGBLOB,");
            dbCreationScript = dbCreationScript.Replace("`DownloadBinary` varbinary,", "`DownloadBinary` LONGBLOB,");

            //Order is a keyword so need to put in quotes
            dbCreationScript = dbCreationScript.Replace("REFERENCES Order (Id)", "REFERENCES `Order` (Id)");

            //Some of the constraint names are too long for MySql, so shorten them
            //dbCreationScript = dbCreationScript.Replace("ProductReview_TypeConstraint_From_CustomerContent_To_ProductReview", "ProductReview_CustomerContent_ProductReview");
            //dbCreationScript = dbCreationScript.Replace("PollVotingRecord_TypeConstraint_From_CustomerContent_To_PollVotingRecord", "PollVotingRecord_CustomerContent_PollVotingRecord");
            //dbCreationScript = dbCreationScript.Replace("ProductReviewHelpfulness_TypeConstraint_From_CustomerContent_To_ProductReviewHelpfulness", "ProductReviewHelpfulnes_CustomerContent_ProductReviewHelpfulnes");
        }

        context.Database.ExecuteSqlCommand(dbCreationScript);

        //Seed(context);
        context.SaveChanges();

        if (_customCommands != null && _customCommands.Length > 0)
        {
            foreach (var command in _customCommands)
                context.Database.ExecuteSqlCommand(command);
        }
    }
}

//MySql properties
public string MySqlConnectionInfo { get; set; }
[AllowHtml]
public string MySqlServerName { get; set; }
[AllowHtml]
public string MySqlDatabaseName { get; set; }
[AllowHtml]
public string MySqlUsername { get; set; }
[AllowHtml]
public string MySqlPassword { get; set; }
public bool MySqlServerCreateDatabase { get; set; }
[AllowHtml]
public string MySqlDatabaseConnectionString { get; set; }

private bool mySqlDatabaseExists(string connectionString)
{
    try
    {
        //just try to connect
        using (var conn = new MySqlConnection(connectionString))
        {
            conn.Open();
        }
        return true;
    }
    catch
    {
        return false;
    }
}

private string createMySqlDatabase(string connectionString)
{
    try
    {
        //parse database name
        var builder = new MySqlConnectionStringBuilder(connectionString);
        var databaseName = builder.Database;
        //now create connection string to ‘master‘ dabatase. It always exists.
        builder.Database = string.Empty; // = "master";
        var masterCatalogConnectionString = builder.ToString();
        string query = string.Format("CREATE DATABASE {0} COLLATE utf8_unicode_ci", databaseName);

        using (var conn = new MySqlConnection(masterCatalogConnectionString))
        {
            conn.Open();
            using (var command = new MySqlCommand(query, conn))
            {
                command.ExecuteNonQuery();
            }
        }

        return string.Empty;
    }
    catch (Exception ex)
    {
        return string.Format("An error occured when creating database: {0}", ex.Message);
    }
}

private string createMySqlConnectionString(string serverName, string databaseName, string userName, string password, UInt32 timeout = 0)
{
    var builder = new MySqlConnectionStringBuilder();
    builder.Server = serverName;
    builder.Database = databaseName.ToLower();
    builder.UserID = userName;
    builder.Password = password;
    builder.PersistSecurityInfo = false;
    builder.AllowUserVariables = true;
    builder.DefaultCommandTimeout = 30000;

    builder.ConnectionTimeout = timeout;
    return builder.ConnectionString;
}