using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;
using System.Data.SqlClient;
using System.Text;

using CI.Utils;
using CI.Data.Interfaces;
using Microsoft.Practices.EnterpriseLibrary.Data;

namespace CI.Data
{
    public class Common
    {

        public static DataSet ExecuteDataSet(string storedProc)
        {
            return ExecuteDataSet(storedProc, null);
        }

        public static DataSet ExecuteDataSet(string storedProc, params object[] args)
        {
            Database _db = DatabaseFactory.CreateDatabase("CIBackend");
            DbCommand _cmd = null;

            if (args != null)
                _cmd = _db.GetStoredProcCommand(storedProc, args);
            else
                _cmd = _db.GetStoredProcCommand(storedProc);

            _cmd.CommandTimeout = 200;
            return _db.ExecuteDataSet(_cmd);
        }


        public static object ExecuteScalar(string storedProc)
        {
            return ExecuteScalar(storedProc, null);
        }

        public static object ExecuteScalar(string storedProc, params object[] args)
        {
            Database _db = DatabaseFactory.CreateDatabase("CIBackend");
            DbCommand _cmd = null;

            if (args != null)
                _cmd = _db.GetStoredProcCommand(storedProc, args);
            else
                _cmd = _db.GetStoredProcCommand(storedProc);

            _cmd.CommandTimeout = 200;
            object _ret = _db.ExecuteScalar(_cmd);
            return _ret;
        }

        public static void ExecuteNonQuery(string storedProc)
        {
            ExecuteNonQuery(storedProc, null);
        }

        public static void ExecuteNonQuery(string storedProc, params object[] args)
        {
            Database _db = DatabaseFactory.CreateDatabase("CIBackend");
            DbCommand _cmd = null;

            if (args != null)
                _cmd = _db.GetStoredProcCommand(storedProc, args);
            else
                _cmd = _db.GetStoredProcCommand(storedProc);

            _cmd.CommandTimeout = 200;
            _db.ExecuteNonQuery(_cmd);
        }

        public static DbDataReader ExecuteReader(string storedProc)
        {
            return ExecuteReader(storedProc, null);
        }

        public static DbDataReader ExecuteReader(CommandType commandType, string query)
        {
            Database _db = DatabaseFactory.CreateDatabase("CIBackend");
            return (DbDataReader)_db.ExecuteReader(commandType, query);
        }

        public static DbDataReader ExecuteReader(string storedProc, params object[] args)
        {
            Database _db = DatabaseFactory.CreateDatabase("CIBackend");
            DbCommand _cmd = null;

            if (args != null)
                _cmd = _db.GetStoredProcCommand(storedProc, args);
            else
                _cmd = _db.GetStoredProcCommand(storedProc);

            _cmd.CommandTimeout = 200;

            DbDataReader _reader = (DbDataReader)_db.ExecuteReader(_cmd);
            return _reader;
        }

        public static T Populate<T>(bool singlePopulate, string storedProc) where T : IDbDataReaderPopulate, new()
        {
            return Populate<T>(singlePopulate, storedProc, null);
        }

        public static T Populate<T>(bool singlePopulate, string storedProc, params object[] args) where T : IDbDataReaderPopulate, new()
        {
            Database _db = DatabaseFactory.CreateDatabase("CIBackend");
            DbCommand _cmd = null;

            if (args != null)
                _cmd = _db.GetStoredProcCommand(storedProc, args);
            else
                _cmd = _db.GetStoredProcCommand(storedProc);

            _cmd.CommandTimeout = 200;

            DbDataReader _reader = (DbDataReader)_db.ExecuteReader(_cmd);

            T _item = default(T);
            using (_reader)
            {
                if (_reader.Read())
                {
                    _item = new T();
                    _item.IDbDataReaderPopulate(_reader);
                }
            }
            return _item;
        }

        public static List<T> Populate<T>(string storedProc) where T : IDbDataReaderPopulate, new()
        {
            return Populate<T>(storedProc, null);
        }

        public static List<T> Populate<T>(string storedProc, params object[] args) where T : IDbDataReaderPopulate, new()
        {
            Database _db = DatabaseFactory.CreateDatabase("CIBackend");
            DbCommand _cmd = null;

            if (args != null)
                _cmd = _db.GetStoredProcCommand(storedProc, args);
            else
                _cmd = _db.GetStoredProcCommand(storedProc);

            _cmd.CommandTimeout = 200;

            DbDataReader _reader = (DbDataReader)_db.ExecuteReader(_cmd);

            List<T> _coll = new List<T>();
            using (_reader)
            {
                while (_reader.Read())
                {
                    T _item = new T();
                    _item.IDbDataReaderPopulate(_reader);
                    _coll.Add(_item);
                }
            }
            return _coll;
        }
    }
}