/////////////////////////////////////////////////////////////////////////////
//	File Description    : 为外部创建DataAccess的实例，并提供常用的数据访问方法。
//	Copyright           : joyin
// -------------------------------------------------------------------------
//	Date Created		: Mar 26, 2010
//	Author		        : jiangxinjun
//
/////////////////////////////////////////////////////////////////////////////

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;
using HanHe.Utility;
using HanHe.Utility.Data;
using HH.WMS.Entitys.Common;
using HH.WMS.Common;
using HH.WMS.Entitys;

namespace HH.WMS.DAL
{
    /// <summary>
    /// 为外部创建DataAccess的实例，并提供常用的数据访问方法。
    /// </summary>
    public static class DAOManager
    {
        #region Create
        /// <summary>
        /// 创建DataAccessObject对象
        /// </summary>
        /// <typeparam name="T">DataAccessObject对象类型</typeparam>
        /// <returns>返回DataAccessObject实例</returns>
        public static T Create<T>()
            where T : BaseDAL, new()
        {
            return ObjectCreator.Create<T>();
        }
        #endregion

        #region RollbackTransaction
        /// <summary>
        /// 对事物执行Rollback回滚
        /// </summary>
        /// <param name="trans">事务对象</param>
        /// <remarks>多次对同一个事务对象，直接调用Rollback方法的时候，会产生异常。DbTransaction.Rollback回滚事务对象，可以避免多次调用而产生的异常。</remarks>
        public static void RollbackTransaction(DbTransaction trans)
        {
            if (trans != null && trans.Connection != null && ComDbName.MySQL != ConstantBase.APP_DATA_TYPE.ToUpper())
            {
                //trans.Commit();
                trans.Rollback();
            }
        }
        #endregion

        #region ExecuteTransaction

        /// <summary>
        /// 对某一个动作，执行事务
        /// </summary>
        /// <param name="actionTransaction">执行事务的动作</param>
        /// <remarks>如果参数trans不为null的话：调用此方法的过程中，trans是不会做Commit，必须方法外部做Commit；但如果出现异常，trans会执行Rollback。</remarks>
        public static SqlExecuteResult ExecuteTransaction(Func<DbTransaction, SqlExecuteResult> actionTransaction)
        {
            return ExecuteTransaction(BaseDAL.CreateDataAccess(BaseDAL.DATABASE_NAME)
                , actionTransaction);
        }

        /// <summary>
        /// 对某一个动作，执行事务
        /// </summary>
        /// <param name="db">数据库工具类</param>
        /// <param name="actionTransaction">执行事务的动作</param>
        /// <remarks>如果参数trans不为null的话：调用此方法的过程中，trans是不会做Commit，必须方法外部做Commit；但如果出现异常，trans会执行Rollback。</remarks>
        public static SqlExecuteResult ExecuteTransaction(Database db, Func<DbTransaction, SqlExecuteResult> actionTransaction)
        {
            SqlExecuteResult result = null;

            if (actionTransaction != null)
            {
                using (DbConnection conn = db.CreateConnection())
                {
                    conn.Open();

                    DbTransaction trans = conn.BeginTransaction();

                    try
                    {
                        result = actionTransaction(trans);
                        if (result == null || !result.Success)
                        {
                            DAOManager.RollbackTransaction(trans);
                        }
                        else
                        {
                            trans.Commit();
                        }
                    }
                    catch (Exception ex)
                    {
                        DAOManager.RollbackTransaction(trans);
                        //捕捉了异常，并把异常封装在SqlExecuteResult中
                        result = new SqlExecuteResult()
                        {
                            Success = false,
                            Exception = ex
                        };
                    }
                    finally
                    {
                        conn.Close();
                    }
                }
            }
            return result;
        }
        #endregion

        #region LoadTableSchema
        private static object lockObjLoadTableSchema = new object();
        /// <summary>
        /// 缓存表结构
        /// </summary>
        /// <remarks>
        /// Key为字段名称（大写）；Value为字段信息
        /// </remarks>
        private static Dictionary<string, Dictionary<string, DatabaseColumnStruct>> tableSchemasCache =
            new Dictionary<string, Dictionary<string, DatabaseColumnStruct>>();

        /// <summary>
        /// 读取表结构
        /// </summary>
        /// <param name="tableName">表名称</param>
        /// <param name="db">数据库访问工具类</param>
        /// <returns>字段信息列表</returns>
        public static Dictionary<string, DatabaseColumnStruct> LoadTableSchema(string tableName, Database db)
        {
            tableName = tableName.ToUpper();

            if (!tableSchemasCache.ContainsKey(tableName))
            {
                lock (lockObjLoadTableSchema)
                {
                    Dictionary<string, DatabaseColumnStruct> cols = new Dictionary<string, DatabaseColumnStruct>();
                    //读取表结构，并加载到缓存中
                    DataTable schemaInfos = new DataTable();
                    string sql = string.Format("SELECT TOP 0 * FROM {0} ", tableName);
                    using (IDataReader dr = db.ExecuteReader(db.GetSqlStringCommand(sql)))
                    {
                        schemaInfos = dr.GetSchemaTable();
                    }
                    foreach (DataRow schemaInfo in schemaInfos.Rows)
                    {
                        cols.Add(schemaInfo["ColumnName"].ToString().ToUpper()      //字段名称为Key
                            , new DatabaseColumnStruct()
                            {
                                ColumnIndex = Convert.ToInt32(schemaInfo["ColumnOrdinal"]),
                                DbType = (Type)schemaInfo["DataType"],
                                DbTypeName = schemaInfo["DataTypeName"].ToString(),
                                AllowDBNull = (bool)schemaInfo["AllowDBNull"],
                                IsIdentity = (bool)schemaInfo["IsIdentity"],
                                Name = schemaInfo["ColumnName"].ToString(),
                                Size = (int)schemaInfo["ColumnSize"]
                            });
                    }

                    tableSchemasCache.Add(tableName, cols);
                }
            }

            return tableSchemasCache[tableName];
        }
        #endregion
    }
}