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 propertiespublic 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;}