using System;
using System.Diagnostics;
using System.Threading;
using NewLife.Log;
using NewLife.Model;

namespace XCode.DataAccessLayer
{
    partial class DAL
    {
        static DAL()
        {
            var ioc = ObjectContainer.Current;
            ioc.AddTransient<IDataTable, XTable>();

            InitLog();
            InitConnections();
        }

        #region Sql日志输出
        /// <summary>是否调试</summary>
        public static Boolean Debug { get; set; } = Setting.Current.Debug;

        /// <summary>输出日志</summary>
        /// <param name="format"></param>
        /// <param name="args"></param>
        public static void WriteLog(String format, params Object[] args)
        {
            if (!Debug) return;

            //InitLog();
            XTrace.WriteLine(format, args);
        }

        /// <summary>输出日志</summary>
        /// <param name="format"></param>
        /// <param name="args"></param>
        [Conditional("DEBUG")]
        public static void WriteDebugLog(String format, params Object[] args)
        {
            if (!Debug) return;

            //InitLog();
            XTrace.WriteLine(format, args);
        }

        static Int32 hasInitLog = 0;
        internal static void InitLog()
        {
            if (Interlocked.CompareExchange(ref hasInitLog, 1, 0) > 0) return;

            // 输出当前版本
            System.Reflection.Assembly.GetExecutingAssembly().WriteVersion();
        }
        #endregion

        #region SQL拦截器
        private static readonly ThreadLocal<Action<String>> _filter = new();
        /// <summary>本地过滤器（本线程SQL拦截）</summary>
        public static Action<String> LocalFilter { get => _filter.Value; set => _filter.Value = value; }

        /// <summary>APM跟踪器</summary>
        public ITracer Tracer { get; set; }

        /// <summary>全局APM跟踪器</summary>
        public static ITracer GlobalTracer { get; set; } = DefaultTracer.Instance;
        #endregion

        #region 辅助函数
        /// <summary>已重载。</summary>
        /// <returns></returns>
        public override String ToString() => Db.ToString();

        /// <summary>建立数据表对象</summary>
        /// <returns></returns>
        internal static IDataTable CreateTable() => ObjectContainer.Current.Resolve<IDataTable>();

        /// <summary>是否支持批操作</summary>
        /// <returns></returns>
        public Boolean SupportBatch
        {
            get
            {
                if (DbType is DatabaseType.MySql or DatabaseType.Oracle or DatabaseType.SQLite) return true;

                //#if !__CORE__
                // SqlServer对批处理有BUG，将在3.0中修复
                // https://github.com/dotnet/corefx/issues/29391
                if (DbType == DatabaseType.SqlServer) return true;
                //#endif

                return false;
            }
        }
        #endregion
    }
}