Monday, 21 August 2017

connection db

using System;
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;
using System.Data.SqlClient;

/// <summary>
/// Summary description for ConnectionDB
/// </summary>
namespace BusinessObjects
{
    public class ConnectionDB
    {
        private int _CommandTimeout = 0;
        private SqlConnection conBD = new SqlConnection();
        private SqlConnection conBDRpt = new SqlConnection();

        public ConnectionDB()
        {
            conBD = new SqlConnection(ConfigurationManager.ConnectionStrings["ConnectionStringIns"].ToString());
            conBDRpt = new SqlConnection(ConfigurationManager.ConnectionStrings["ConnectionStringIns"].ToString());
        }

        private Boolean Con_Open(SqlConnection con)
        {
            if (con.State == ConnectionState.Closed)
            {
                con.Open();
            }
            return true;
        }

        private Boolean Con_Close(SqlConnection con)
        {
            if (con.State == ConnectionState.Open)
            {
                con.Close();
            }
            return true;
        }

        public DataSet GetDataSet(string str)
        {
            DataSet dsGDS = new DataSet();
            try
            {
                Con_Open(conBD);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBD;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.Text;
                    cmd.CommandText = str;
                    SqlDataAdapter da = new SqlDataAdapter(cmd);
                    da.Fill(dsGDS, "tbl");
                }
                Con_Close(conBD);
                return dsGDS;
            }
            catch (Exception ex)
            {
                dsGDS = null;
                Con_Close(conBD);
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(str), ex.ToString());
                return dsGDS;
            }
            finally
            {
                if (dsGDS != null)
                    dsGDS.Dispose();
                Con_Close(conBD);
            }
        }

        public DataSet GetDataSet227(string str)
        {
            DataSet dtGDS227 = new DataSet();
            try
            {
                Con_Open(conBDRpt);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBDRpt;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.Text;
                    cmd.CommandText = str;
                    SqlDataAdapter da = new SqlDataAdapter(cmd);
                    da.Fill(dtGDS227, "tbl");
                }
                Con_Close(conBDRpt);
                return dtGDS227;
            }
            catch (Exception ex)
            {
                dtGDS227 = null;
                Con_Close(conBDRpt);
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(str), ex.ToString());
                return dtGDS227;
            }
            finally
            {
                if (dtGDS227 != null)
                    dtGDS227.Dispose();
                Con_Close(conBDRpt);
            }
        }

        public DataTable GetDataTable(string str)
        {
            DataTable dtGDT = new DataTable();
            try
            {
                Con_Open(conBD);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBD;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.Text;
                    cmd.CommandText = str;
                    SqlDataAdapter da = new SqlDataAdapter(cmd);
                    da.Fill(dtGDT);
                }
                Con_Close(conBD);
                return dtGDT;
            }
            catch (Exception ex)
            {
                dtGDT = null;
                Con_Close(conBD);
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(str), ex.ToString());
                return dtGDT;
            }
            finally
            {
                if (dtGDT != null)
                    dtGDT.Dispose();
                Con_Close(conBD);
            }
        }

        public DataTable GetDataTable227(string str)
        {
            DataTable dtGDT227 = new DataTable();
            try
            {
                Con_Open(conBDRpt);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBDRpt;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.Text;
                    cmd.CommandText = str;
                    SqlDataAdapter da = new SqlDataAdapter(cmd);
                    da.Fill(dtGDT227);
                }
                Con_Close(conBDRpt);
                return dtGDT227;
            }
            catch (Exception ex)
            {
                dtGDT227 = null;
                Con_Close(conBDRpt);
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(str), ex.ToString());
                return dtGDT227;
            }
            finally
            {
                if (dtGDT227 != null)
                    dtGDT227.Dispose();
                Con_Close(conBDRpt);
            }
        }

        public DataTable GetDataTable(string SpName, SqlParameter[] p)
        {
            DataTable dtGD = new DataTable();
            try
            {
                Con_Open(conBD);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBD;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.StoredProcedure;
                    cmd.CommandText = SpName;
                    cmd.Parameters.AddRange(p);
                    SqlDataAdapter da = new SqlDataAdapter(cmd);
                    da.Fill(dtGD);
                }
                Con_Close(conBD);
                return dtGD;
            }
            catch (SqlException es)
            {
                Con_Close(conBD);
                dtGD = null;
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(SpName), es.ToString());
                return dtGD;
            }
            catch (Exception ex)
            {
                Con_Close(conBD);
                dtGD = null;
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(SpName), ex.ToString());
                return dtGD;
            }
            finally
            {
                if (dtGD != null)
                    dtGD.Dispose();
                Con_Close(conBD);
            }
        }

        public object Execute_Scaler(string Query)
        {
            try
            {
                Con_Open(conBD);
                object valES = new object();
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBD;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.Text;
                    cmd.CommandText = Query;
                    valES = cmd.ExecuteScalar();
                }
                Con_Close(conBD);
                return valES;
            }
            catch (Exception ex)
            {
                Con_Close(conBD);
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(Query), ex.ToString());
                return null;
            }
            finally
            {
                Con_Close(conBD);
            }
        }

        public object Execute_Scaler227(string Query)
        {
            try
            {
                Con_Open(conBDRpt);
                object valES227 = new object();
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBDRpt;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.Text;
                    cmd.CommandText = Query;
                    valES227 = cmd.ExecuteScalar();
                }
                Con_Close(conBDRpt);
                return valES227;
            }
            catch (Exception ex)
            {
                Con_Close(conBDRpt);
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(Query), ex.ToString());
                return null;
            }
            finally
            {
                Con_Close(conBDRpt);
            }
        }

        public object Execute_Scaler227(string SpName, SqlParameter[] p)
        {
            object objScal227;
            try
            {
                Con_Open(conBDRpt);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBDRpt;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.StoredProcedure;
                    cmd.CommandText = SpName;
                    cmd.Parameters.AddRange(p);
                    objScal227 = cmd.ExecuteScalar();
                }
                Con_Close(conBDRpt);
                return objScal227;
            }
            catch (Exception ex)
            {
                Con_Close(conBDRpt);
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(SpName), ex.ToString());
                return null;
            }
            finally
            {
                Con_Close(conBDRpt);
            }
        }

        public object Execute_Scaler(string SpName, SqlParameter[] p)
        {
            object objScal;
            try
            {
                Con_Open(conBD);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBD;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.StoredProcedure;
                    cmd.CommandText = SpName;
                    cmd.Parameters.AddRange(p);
                    objScal = cmd.ExecuteScalar();
                }
                Con_Close(conBD);
                return objScal;
            }
            catch (Exception ex)
            {
                Con_Close(conBD);
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(SpName), ex.ToString());
                return null;
            }
            finally
            {
                Con_Close(conBD);
            }
        }

        public bool Execute_NonQuery(string SpName, SqlParameter[] p)
        {
            try
            {
                Con_Open(conBD);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBD;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.StoredProcedure;
                    cmd.CommandText = SpName;
                    cmd.Parameters.AddRange(p);
                    cmd.ExecuteNonQuery();
                }
                Con_Close(conBD);
                return true;
            }
            catch (Exception ex)
            {
                Con_Close(conBD);
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(SpName), ex.ToString());
                return false;
            }
            finally
            {
                Con_Close(conBD);
            }
        }

        public bool Execute_NonQuery227(string SpName, SqlParameter[] p)
        {
            try
            {
                Con_Open(conBDRpt);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBDRpt;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.StoredProcedure;
                    cmd.CommandText = SpName;
                    cmd.Parameters.AddRange(p);
                    cmd.ExecuteNonQuery();
                }
                Con_Close(conBDRpt);
                return true;
            }
            catch (Exception ex)
            {
                Con_Close(conBDRpt);
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(SpName), ex.ToString());
                return false;
            }
            finally
            {
                Con_Close(conBDRpt);
            }
        }

        public bool Execute_NonQuery(string SpName, SqlParameter[] p, ref int RowAffected)
        {
            try
            {
                Con_Open(conBD);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBD;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.StoredProcedure;
                    cmd.CommandText = SpName;
                    cmd.Parameters.AddRange(p);
                    RowAffected = cmd.ExecuteNonQuery();
                }
                Con_Close(conBD);
                return true;
            }
            catch (Exception ex)
            {
                Con_Close(conBD);
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(SpName), ex.ToString());
                RowAffected = 0;
                return false;
            }
            finally
            {
                Con_Close(conBD);
            }
        }

        public bool Execute_NonQuery(string Query)
        {
            try
            {
                Con_Open(conBD);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBD;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.Text;
                    cmd.CommandText = Query;
                    cmd.ExecuteNonQuery();
                }
                Con_Close(conBD);
                return true;
            }
            catch (Exception ex)
            {
                Con_Close(conBD);
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(Query), ex.ToString());
                return false;
            }
            finally
            {
                Con_Close(conBD);
            }
        }

        public bool Execute_NonQuery(string Query, ref int RowAffected)
        {
            try
            {
                Con_Open(conBD);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBD;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.Text;
                    cmd.CommandText = Query;
                    //cmd.Parameters.Add(p);
                    RowAffected = cmd.ExecuteNonQuery();
                }
                Con_Close(conBD);
                return true;
            }
            catch (Exception ex)
            {
                Con_Close(conBD);
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(Query), ex.ToString());
                RowAffected = 0;
                return false;
            }
            finally
            {
                Con_Close(conBD);
            }
        }

        public bool GetRecords(string SpName, SqlParameter[] p, ref DataTable dtGR)
        {
            try
            {
                Con_Open(conBD);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBD;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.StoredProcedure;
                    cmd.CommandText = SpName;
                    cmd.Parameters.AddRange(p);
                    SqlDataAdapter da = new SqlDataAdapter(cmd);
                    DataSet dsGetRec = new DataSet();
                    da.Fill(dsGetRec);
                    dtGR = dsGetRec.Tables[0];
                    dsGetRec.Dispose();
                }
                if (dtGR != null)// && dt.Rows.Count > 0)
                {
                    Con_Close(conBD);
                    return true;
                }
                else
                {
                    Con_Close(conBD);
                    dtGR = null;
                    return false;
                }
            }
            catch (SqlException es)
            {
                Con_Close(conBD);
                dtGR = null;
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(SpName), es.ToString());
                return false;
            }
            catch (Exception ex)
            {
                Con_Close(conBD);
                dtGR = null;
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(SpName), ex.ToString());
                return false;
            }
            finally
            {
                if (dtGR != null)
                    dtGR.Dispose();
                Con_Close(conBD);
            }
        }

        public bool GetRecords227(string SpName, SqlParameter[] p, ref DataTable dtGR227)
        {
            try
            {
                Con_Open(conBDRpt);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBDRpt;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.StoredProcedure;
                    cmd.CommandText = SpName;
                    cmd.Parameters.AddRange(p);
                    SqlDataAdapter da = new SqlDataAdapter(cmd);
                    DataSet dsGR227 = new DataSet();
                    da.Fill(dsGR227);
                    dtGR227 = dsGR227.Tables[0];
                    dsGR227.Dispose();
                }
                if (dtGR227 != null)// && dt.Rows.Count > 0)
                {
                    Con_Close(conBDRpt);
                    return true;
                }
                else
                {
                    Con_Close(conBDRpt);
                    dtGR227 = null;
                    return false;
                }
            }
            catch (SqlException es)
            {
                Con_Close(conBDRpt);
                dtGR227 = null;
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(SpName), es.ToString());
                return false;
            }
            catch (Exception ex)
            {
                Con_Close(conBDRpt);
                dtGR227 = null;
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(SpName), ex.ToString());
                return false;
            }
            finally
            {
                if (dtGR227 != null)
                    dtGR227.Dispose();
                Con_Close(conBDRpt);
            }
        }

        public DataSet GetData(string SpName, SqlParameter[] p)
        {
            //DataTable dt = new DataTable();
            DataSet dsGD = new DataSet();
            try
            {
                Con_Open(conBD);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBD;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.StoredProcedure;
                    cmd.CommandText = SpName;
                    cmd.Parameters.AddRange(p);
                    SqlDataAdapter da = new SqlDataAdapter(cmd);
                    da.Fill(dsGD);
                }
                Con_Close(conBD);
                return dsGD;
            }
            catch (SqlException es)
            {
                Con_Close(conBD);
                dsGD = null;
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(SpName), es.ToString());
                return dsGD;
            }
            catch (Exception ex)
            {
                Con_Close(conBD);
                dsGD = null;
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(SpName), ex.ToString());
                return dsGD;
            }
            finally
            {
                if (dsGD != null)
                    dsGD.Dispose();
                Con_Close(conBD);
            }
        }

        public DataSet GetData227(string SpName, SqlParameter[] p)
        {
            //DataTable dt = new DataTable();
            DataSet dsGD227 = new DataSet();
            try
            {
                Con_Open(conBDRpt);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBDRpt;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.StoredProcedure;
                    cmd.CommandText = SpName;
                    cmd.Parameters.AddRange(p);
                    SqlDataAdapter da = new SqlDataAdapter(cmd);
                    da.Fill(dsGD227);
                }
                return dsGD227;
            }
            catch (SqlException es)
            {
                dsGD227 = null;
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(SpName), es.ToString());
                return dsGD227;
            }
            catch (Exception ex)
            {
                dsGD227 = null;
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(SpName), ex.ToString());
                return dsGD227;
            }
            finally
            {
                if (dsGD227 != null)
                    dsGD227.Dispose();
                Con_Close(conBDRpt);
            }
        }

        public bool GetRecords(string Query, ref DataTable dtGR)
        {
            try
            {
                Con_Open(conBD);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBD;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.Text;
                    cmd.CommandText = Query;
                    //cmd.Parameters.Add(p);
                    SqlDataAdapter da = new SqlDataAdapter(cmd);
                    DataSet dsGR = new DataSet();
                    da.Fill(dsGR);
                    dtGR = dsGR.Tables[0];
                    dsGR.Dispose();
                }
                if (dtGR != null)// && dt.Rows.Count > 0)
                {
                    Con_Close(conBD);
                    return true;
                }
                else
                {
                    Con_Close(conBD);
                    dtGR = null;
                    return false;
                }
            }
            catch (SqlException es)
            {
                Con_Close(conBD);
                dtGR = null;
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(Query), es.ToString());
                return false;
            }
            catch (Exception ex)
            {
                Con_Close(conBD);
                dtGR = null;
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(Query), ex.ToString());
                return false;
            }
            finally
            {
                if (dtGR != null)
                    dtGR.Dispose();
                Con_Close(conBD);
            }
        }

        public bool GetRecords227(string Query, ref DataTable dtGR227)
        {
            try
            {
                Con_Open(conBDRpt);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBDRpt;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.Text;
                    cmd.CommandText = Query;
                    //cmd.Parameters.Add(p);
                    SqlDataAdapter da = new SqlDataAdapter(cmd);
                    DataSet dsGR227 = new DataSet();
                    da.Fill(dsGR227);
                    dtGR227 = dsGR227.Tables[0];
                    dsGR227.Dispose();
                }
                if (dtGR227 != null)// && dt.Rows.Count > 0)
                {
                    Con_Close(conBDRpt);
                    return true;
                }
                else
                {
                    Con_Close(conBDRpt);
                    dtGR227 = null;
                    return false;
                }
            }
            catch (SqlException es)
            {
                Con_Close(conBDRpt);
                dtGR227 = null;
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(Query), es.ToString());
                return false;
            }
            catch (Exception ex)
            {
                Con_Close(conBDRpt);
                dtGR227 = null;
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(Query), ex.ToString());
                return false;
            }
            finally
            {
                if (dtGR227 != null)
                    dtGR227.Dispose();
                Con_Close(conBDRpt);
            }
        }

        public DataSet GetXIRR(string str)
        {
            DataSet dsGetXIRR = new DataSet();
            SqlConnection conn227 = new SqlConnection(ConfigurationManager.ConnectionStrings["RptBDesk"].ToString());
            try
            {
                Con_Open(conn227);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conn227;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.Text;
                    cmd.CommandText = str;
                    SqlDataAdapter da = new SqlDataAdapter(cmd);
                    da.Fill(dsGetXIRR, "tbl");
                }
                Con_Close(conn227);
                return dsGetXIRR;
            }
            catch (SqlException ex)
            {
                Con_Close(conn227);
                dsGetXIRR = null;
                return dsGetXIRR;
            }
            catch (Exception ex)
            {
                Con_Close(conn227);
                dsGetXIRR = null;
                CommonHelper.InsertErorLog(0, 0, CommonHelper.FmtSQLString(str), ex.ToString());
                return dsGetXIRR;
            }
            finally
            {
                if (dsGetXIRR != null)
                    dsGetXIRR.Dispose();
                Con_Close(conn227);
            }
        }

        public object GetObject(string collumnName, string tableName, string searchCondition, bool isScalar)
        {
            object objScal;
            try
            {
                Con_Open(conBD);
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.Connection = conBD;
                    cmd.CommandTimeout = _CommandTimeout;
                    cmd.CommandType = CommandType.StoredProcedure;
                    cmd.CommandText = "WP_GetObject";
                    cmd.Parameters.AddWithValue("@collumn", collumnName);
                    cmd.Parameters.AddWithValue("@table", tableName);
                    cmd.Parameters.AddWithValue("@searchCriteria", searchCondition);
                    if (isScalar)
                        objScal = cmd.ExecuteScalar();
                    else
                    {
                        SqlDataAdapter da = new SqlDataAdapter(cmd);
                        DataTable dtGetObject = new DataTable();
                        da.Fill(dtGetObject);
                        objScal = dtGetObject;
                    }
                }
                Con_Close(conBD);
                return objScal;
            }
            catch (Exception ex)
            {
                Con_Close(conBD);
                CommonHelper.InsertErorLog(0, 0, "WP_GetObject : " + CommonHelper.FmtSQLString(tableName), ex.ToString());
                return null;
            }
            finally
            {
                Con_Close(conBD);
            }
        }
    }
}

No comments:

Post a Comment