BN089-BS开发框架MVC4版/source20131023/Zephyr.Net/Zephyr.Core/Core/Db.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

/*************************************************************************
 * 文件名称 ：Db.cs                          
 * 描述说明 ：定义数据库连接
 * 
 * 创建信息 : create by liuhuisheng.xm@gmail.com on 2012-11-10
 * 修订信息 : modify by (person) on (date) for (reason)
 * 
 * 版权信息 : Copyright (c) 2013 厦门纵云信息科技有限公司 www.zoewin.com
 **************************************************************************/

using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;
using log4net;
using Zephyr.Data;

namespace Zephyr.Core
{
    public class Db
    {
        public static IDbContext Context()
        {
            return Context(APP.DB_DEFAULT_CONN_NAME);
        }
      
        public static IDbProvider Provider(string providerName) 
        {
            var providers = new Dictionary<string, IDbProvider>(){
                {"DB2",new DB2Provider()},
                {"MySql",new MySqlProvider()},
                {"Oracle",new OracleProvider()},
                {"PostgreSql",new PostgreSqlProvider()},
                {"SqlAzure",new SqlAzureProvider()},
                {"Sqlite",new SqliteProvider()},
                {"SqlServerCompact",new SqlServerCompactProvider()},
                {"SqlServer",new SqlServerProvider()}
            };
            return providers[providerName] != null ? providers[providerName] : new SqlServerProvider();
        }
        

        public static IDbContext Context(string ConnName)
        {
            var Log = LogManager.GetLogger(ConnName);
            var setting = ConfigurationManager.ConnectionStrings[ConnName];
            var db = new DbContext().ConnectionString(setting.ConnectionString, Provider(setting.ProviderName));
           
            db.OnExecuting(x =>
            {
                if (APP.OnDbExecuting != null) APP.OnDbExecuting(x);
                var sql = x.Command.CommandText;
                for (int i = x.Command.Parameters.Count - 1;i>=0;i--)
                {
                    var item = x.Command.Parameters[i] as IDataParameter;
                    sql = sql.Replace(item.ParameterName, String.Format("'{0}'", item.Value));
                }
 
                Log.Debug(sql);