快速的数据库操作 - DBHelperSlowXDALFunctions

2017-02-21 22:48:58 访问(1549) 赞(0) 踩(0)

using System;
using System.Collections.Generic;
using System.Data;
using System.Reflection;
using System.Text;

using SlowX.DAL.Helpers;

namespace SlowX.DAL.Functions
{
    /// <summary>
    /// 快速的数据库操作
    /// </summary>
    [Serializable]
    public class DBHelperSlowXDALFunctions
    {


        /// <summary>
        /// 是否连接数据库
        /// </summary>
        /// <returns></returns>
        public static bool IsConnectionDataBase ()
        {
            SlowX.DAL.Helpers.DBHelper dbHelper 
                = 
                SlowX.DAL.Helpers.DBHelper.CreateDBHelper();

            try
            {
                dbHelper.OpenDBHelper();

                dbHelper.EndDBHelper();

                return true;

            }
            catch
            {
                dbHelper.TranDBHelper();

                return false;
            }
            finally
            {
                dbHelper.FinallyDBHelper();
            }
        }

        /// <summary>
        /// 是否连接数据库
        /// </summary>
        /// <param name="_dbConnectionString"></param>
        /// <param name="_emDataBaseHelper"></param>
        /// <param name="_dataBaseVersion"></param>
        /// <returns></returns>
        public static bool IsConnectionDataBase
            (
                string _dbConnectionString,
                SlowX.DAL.Enums.DataBaseHelper.EmDataBaseHelper _emDataBaseHelper,
                int _dataBaseVersion
            )
        {
            SlowX.DAL.Helpers.DBHelper dbHelper 
                = 
                SlowX.DAL.Helpers.DBHelper.CreateDBHelper(_dbConnectionString, _emDataBaseHelper, _dataBaseVersion);

            try
            {
                dbHelper.OpenDBHelper();

                dbHelper.EndDBHelper();

                return true;

            }
            catch 
            {
                dbHelper.TranDBHelper();

                return false;
            }
            finally
            {
                dbHelper.FinallyDBHelper();
            }
        }

        /// <summary>
        /// 执行SQL语句
        /// </summary>
        /// <param name="_dbConnectionString"></param>
        /// <param name="_emDataBaseHelper"></param>
        /// <param name="_dataBaseVersion"></param>
        /// <param name="_SQL"></param>
        /// <returns></returns>
        public static DataSet ExecuteDataSet
            (
                string _dbConnectionString,
                SlowX.DAL.Enums.DataBaseHelper.EmDataBaseHelper _emDataBaseHelper,
                int _dataBaseVersion,
                string _SQL
            )
        {
            DataSet theResult = null;

            SlowX.DAL.Helpers.DBHelper dbHelper = SlowX.DAL.Helpers.DBHelper.CreateDBHelper
                (
                    _dbConnectionString, 
                    _emDataBaseHelper, 
                    _dataBaseVersion
                    );

            try
            {
                dbHelper.OpenDBHelper();

                theResult = dbHelper.ExecuteDataSet(_SQL);

                dbHelper.EndDBHelper();

            }
            catch (Exception err)
            {
                dbHelper.TranDBHelper();

                throw err;
            }
            finally
            {
                dbHelper.FinallyDBHelper();
            }

            return theResult;
        }


        /// <summary>
        /// 获得参数
        /// </summary>
        /// <param name="emDataBaseHelperValue">数据库类型</param>
        /// <returns></returns>
        public static string GetParamSign
            (
                SlowX.DAL.Enums.DataBaseHelper.EmDataBaseHelper emDataBaseHelperValue 
            )
        {
            switch (emDataBaseHelperValue)
            {
                case SlowX.DAL.Enums.DataBaseHelper.EmDataBaseHelper.Oracle:
                    return ":";
                case SlowX.DAL.Enums.DataBaseHelper.EmDataBaseHelper.Access:
                case SlowX.DAL.Enums.DataBaseHelper.EmDataBaseHelper.Excel:
                case SlowX.DAL.Enums.DataBaseHelper.EmDataBaseHelper.SQLServer:
                    return "@";
                default:
                    throw new Exception
               (
                   "方法："
                   + MethodBase.GetCurrentMethod().ReflectedType.FullName
                   + " "
                   + MethodBase.GetCurrentMethod().ToString()
                   + " 发生异常："
                   + "枚举（"
                   + emDataBaseHelperValue.GetType().FullName
                   + "."
                   + emDataBaseHelperValue.ToString()
                   + "）未知，对应的代码尚未实现。"
               );
            }
        }
    }
}