WZExport/Utilitys/BaseMySqlDataService.cs

using Chloe.Infrastructure;
using Chloe.MySql;
using MySql.Data.MySqlClient;
using System.Data;
using WZExport.Models;

namespace WZExport.Utilitys
{
    internal class MySqlConnectionFactory : IDbConnectionFactory
    {
        readonly string _connString = null;

        public MySqlConnectionFactory(string connString)
        {
            this._connString = connString;
        }
        public IDbConnection CreateConnection()
        {
            IDbConnection conn = new MySqlConnection(this._connString);
            /*如果有必要需要包装一下驱动的 MySqlConnection*/
            //conn = new Chloe.MySql.ChloeMySqlConnection(conn); 
            return conn;
        }
    }

    /// <summary>
    ///数据操作
    /// </summary>
    internal partial class DatabaseService
    {
        static DatabaseService _instance;

        /// <summary>
        /// 当前实例
        /// </summary>
        /// <returns></returns>
        internal static DatabaseService Current => _instance ?? (_instance = new DatabaseService());

        /// <summary>
        /// 构造数据库连接
        /// </summary>
        public Chloe.IDbContext GetDbContext()
        {
            var conStr = DBConfig.GetChooseConnet();
            return new MySqlContext(new MySqlConnectionFactory(conStr));
        }
    }
}