using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Collections;
using System.Data.Common;
using System.Data;
using System.Configuration;
using Ant.Data;

namespace Ant.ORM
{
    public class HelpSQLTool
    {
        #region SQL工具

        #region 获取数据库表返回的第一个值
        /// <summary>
        /// 获取数据库表返回的第一个值
        /// </summary>
        /// <param name="comText">执行的sql查询</param>
        /// <returns></returns>
        public object GetFirst(string comText)
        {
            DataAccess db = DataAccessFactory.GetWriteDataDefault;

            try
            {
                db.ExecuteScalar(comText);

                if (db.ExecuteScalar(comText) != null)
                {
                    return db.ExecuteScalar(comText);
                }
                else
                {
                    return "";
                }
            }
            catch (Exception ex)
            {
                
                return null;
            }
            finally
            {
                db.Close();
            }
        }
        #endregion

        #region 判断数据库中是否有值
        /// <summary>
        /// 判断数据库中是否有值
        /// </summary>
        /// <param name="comText">执行的sql查询</param>
        /// <returns></returns>
        public bool GetDataHasRows(string comText)
        {
            DataAccess db = DataAccessFactory.GetWriteDataDefault;
            try
            {
                DbDataReader reader = db.ExecuteDataReader(comText);
                return reader.HasRows;
            }
            catch (Exception ex)
            {
                
                return false;
            }
        }
        #endregion

        #region 获取数据库表的一组数据，返回类型为ArrayList
        /// <summary>
        /// 获取数据库表的一组数据，返回类型为ArrayList
        /// </summary>
        /// <param name="comText">执行的sql查询</param>
        /// <returns></returns>
        public ArrayList GetDataList(string comText)
        {
            try
            {
                DataAccess db = DataAccessFactory.GetWriteDataDefault;

                DbDataReader reader = db.ExecuteDataReader(comText);
                ArrayList list = new ArrayList();
                while (reader.Read())
                {
                    for (int n = 0; n < reader.FieldCount; n++)
                    {
                        list.Add(reader[n].ToString());
                    }
                }
                reader.Close();
                return list;
            }
            catch (Exception ex)
            {
                
                return null;
            }

        }
        #endregion

        #region 获取一行数据，返回类型为DataRow
        /// <summary>
        /// 获取一行数据，返回类型为DataRow
        /// </summary>
        /// <param name="comText">执行的sql语句</param>
        /// <returns></returns>
        public DataRow GetDataRow(string comText)
        {
            try
            {
                DataAccess db = DataAccessFactory.GetWriteDataDefault; DataRow row = null;
                DbDataReader reader = db.ExecuteDataReader(comText);
                while (reader.Read())
                {
                    for (int n = 0; n < reader.FieldCount; n++)
                    {
                        row.ItemArray = new object[] { reader[n] };
                    }
                }
                return row;
            }
            catch (Exception ex)
            {
                
                return null;
            }

        }
        #endregion

        #region 返回数据库表的数据，返回类型为DataTable
        /// <summary>
        /// 返回数据库表的数据，返回类型为DataTable
        /// </summary>
        /// <param name="comText">执行的sql查询</param>
        /// <returns></returns>
        public DataTable ExecuteDataTable(string sql)
        {
            DataAccess db = DataAccessFactory.GetWriteDataDefault;
            return db.ExecuteDataTable(sql);
        }
        #endregion

        #region 返回数据库表的数据，返回类型为DataSet
        /// <summary>
        /// 返回数据库表的数据，返回类型为DataSet
        /// </summary>
        /// <param name="comText">执行的sql查询</param>
        /// <returns></returns>
        public DataSet GetDataSet(string comText)
        {

            DataAccess db = DataAccessFactory.GetWriteDataDefault;
            return db.ExecuteDataSet(comText);
        }
        #endregion

        #region 执行无参存储过程，返回ArrayList
        /// <summary>
        /// 执行无参存储过程，返回ArrayList
        /// </summary>
        /// <param name="comText">执行查询的存储过程名称</param>
        /// <returns></returns>
        public ArrayList GetExecList(string comText)
        {
            try
            {
                DataAccess db = DataAccessFactory.GetWriteDataDefault;

                DbDataReader reader = db.ExecuteDataReader(comText, CommandType.StoredProcedure);
                ArrayList list = new ArrayList();
                while (reader.Read())
                {
                    for (int n = 0; n < reader.FieldCount; n++)
                    {
                        list.Add(reader[n].ToString());
                    }
                }
                return list;
            }
            catch (Exception ex)
            {
                
                return null;
            }

        }
        #endregion

        #region 接受sql语句，返回SqlDataReader
        /// <summary>
        /// 接受sql语句，返回SqlDataReader
        /// </summary>
        /// <param name="comText">执行的sql查询</param>
        /// <returns></returns>
        public DbDataReader GetDataReader(string comText)
        {
            try
            {
                DataAccess db = DataAccessFactory.GetWriteDataDefault;
                DbDataReader reader = db.ExecuteDataReader(comText);
                return reader;
            }
            catch (Exception ex)
            {
                
                return null;
            }

        }
        #endregion

        #region 执行存储过程，返回SqlDataReader
        /// <summary>
        /// 执行存储过程，返回SqlDataReader
        /// </summary>
        /// <param name="comText">要执行的存储过程名称</param>
        /// <returns></returns>
        public DbDataReader GetExecDataReader(string comText)
        {
            try
            {
                DataAccess db = DataAccessFactory.GetWriteDataDefault;
                DbDataReader reader = db.ExecuteDataReader(comText, CommandType.StoredProcedure);
                return reader;
            }
            catch (Exception ex)
            {
                
                return null;
            }

        }
        #endregion

        #region 执行无参存储过程，返回DataTable
        /// <summary>
        /// 执行无参存储过程，返回DataTable
        /// </summary>
        /// <param name="comText">执行的存储过程名称</param>
        /// <returns></returns>
        public DataTable GetExecTable(string comText)
        {
            DataAccess db = DataAccessFactory.GetWriteDataDefault;
            return db.ExecuteDataTable(comText, CommandType.StoredProcedure);
        }
        #endregion

        #region 执行无参的存储过程，返回DataSet
        /// <summary>
        /// 执行无参存储过程，返回DataTable
        /// </summary>
        /// <param name="comText">执行的存储过程名称</param>
        /// <returns></returns>
        public DataSet GetExecDataSet(string comText)
        {
            DataAccess db = DataAccessFactory.GetWriteDataDefault;
            return db.ExecuteDataSet(comText, CommandType.StoredProcedure);
        }
        #endregion

        #endregion
    }
}