HI Developers,
using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using System.Data.SqlTypes;
using System.Data.Sql;
using System.Configuration;
namespace DAL
{
public static class SqlConnector
{
private static string connection_str = string.Empty;
public static SqlConnection getOpenSqlCon()
{
connection_str = Convert.ToString(ConfigurationSettings.AppSettings["con"]);
SqlConnection con = new SqlConnection(connection_str);
if (con.State != ConnectionState.Open)
{
try
{
con.Open();
}
catch (Exception ex) { }
finally { }
}
return con;
}
public static Boolean closeSqlCon(SqlConnection con)
{
bool result = false;
if (con.State != ConnectionState.Closed)
{
try
{
con.Close();
result = true;
}
catch (Exception) { }
finally { }
}
return result;
}
public static DataSet getDataSet(string query)
{
SqlConnection con = SqlConnector.getOpenSqlCon();
SqlDataAdapter da = new SqlDataAdapter(query, con);
DataSet ds = new DataSet();
try
{
da.Fill(ds);
}
catch (Exception ex) { }
finally { }
SqlConnector.closeSqlCon(con);
return ds;
}
public static int execQ(string query)
{
SqlConnection con = SqlConnector.getOpenSqlCon();
SqlCommand command = new SqlCommand(query, con);
int result = 0;
try
{
result = command.ExecuteNonQuery();
}
catch (Exception ex) { }
finally { }
SqlConnector.closeSqlCon(con);
return result;
}
public static object execQScalar(string query)
{
SqlConnection con = SqlConnector.getOpenSqlCon();
SqlCommand command = new SqlCommand(query, con);
object result = null;
try
{
result = command.ExecuteScalar();
}
catch (Exception ex) { }
finally { }
SqlConnector.closeSqlCon(con);
return result;
}
/// <summary>
/// Executes a stored procedure
/// </summary>
/// <param name="strStoredProc"></param>
/// <param name="sqlParams"></param>
public static void ExecuteSP(string strStoredProc, SqlParameter[] sqlParams)
{
SqlConnection con = SqlConnector.getOpenSqlCon();
SqlCommand SqlComm = new SqlCommand(strStoredProc, con);
SqlComm.CommandType = CommandType.StoredProcedure;
SqlComm.CommandTimeout = 780;
if (sqlParams != null) {
foreach (SqlParameter sqlParam in sqlParams) {
SqlComm.Parameters.Add(sqlParam);
}
}
try {
SqlComm.ExecuteNonQuery();
}
catch (Exception ex)
{
throw ex;
}
finally {
SqlComm = null;
sqlParams = null;
SqlConnector.closeSqlCon(con);
}
}
public static void ExecuteSP(string strStoredProc, SqlParameter[] sqlParams,SqlTransaction tran,SqlConnection con)
{
SqlCommand SqlComm = new SqlCommand(strStoredProc, con,tran);
SqlComm.CommandType = CommandType.StoredProcedure;
SqlComm.CommandTimeout = 780;
if (sqlParams != null)
{
foreach (SqlParameter sqlParam in sqlParams)
{
SqlComm.Parameters.Add(sqlParam);
}
}
try
{
SqlComm.ExecuteNonQuery();
}
catch (Exception ex)
{
throw ex;
}
finally
{
SqlComm = null;
sqlParams = null;
}
}
/// <summary>
///
/// </summary>
/// <param name="strStoredProc"></param>
/// <param name="sqlParams"></param>
public static DataSet getDataSetExecuteSP(string strStoredProc, SqlParameter[] sqlParams)
{
SqlConnection con = SqlConnector.getOpenSqlCon();
SqlCommand SqlComm = new SqlCommand(strStoredProc, con);
SqlComm.CommandType = CommandType.StoredProcedure;
SqlDataAdapter da = new SqlDataAdapter(SqlComm);
DataSet ds = new DataSet();
SqlComm.CommandTimeout =780;
if (sqlParams != null) {
foreach (SqlParameter sqlParam in sqlParams) {
SqlComm.Parameters.Add(sqlParam);
}
}
try
{
da.Fill(ds);
}
catch (Exception ex)
{
}
finally
{
SqlComm = null;
sqlParams = null;
SqlConnector.closeSqlCon(con);
}
return ds;
}
public static DataSet getDataSetExecuteSP(string strStoredProc, SqlParameter[] sqlParams,SqlConnection con, SqlTransaction tran)
{
SqlCommand SqlComm = new SqlCommand(strStoredProc, con,tran);
SqlComm.CommandType = CommandType.StoredProcedure;
SqlDataAdapter da = new SqlDataAdapter(SqlComm);
DataSet ds = new DataSet();
SqlComm.CommandTimeout = 780;
if (sqlParams != null)
{
SqlComm.Parameters.Add(sqlParam);
}
}
try
{
da.Fill(ds);
}
catch (Exception ex)
{
}
finally
{
SqlComm = null;
sqlParams = null;
}
return ds;
}
public static DataTable getDataTableExecuteSP(string strStoredProc, SqlParameter[] sqlParams)
{
SqlConnection con = SqlConnector.getOpenSqlCon();
SqlCommand SqlComm = new SqlCommand(strStoredProc, con);
SqlComm.CommandType = CommandType.StoredProcedure;
SqlDataAdapter da = new SqlDataAdapter(SqlComm);
DataTable dt = new DataTable();
SqlComm.CommandTimeout = 780;
if (sqlParams != null)
{
foreach (SqlParameter sqlParam in sqlParams)
{
SqlComm.Parameters.Add(sqlParam);
}
}
try
{
da.Fill(dt);
}
catch (Exception ex)
{
}
finally
{
SqlComm = null;
sqlParams = null;
SqlConnector.closeSqlCon(con);
}
return dt;
}
public static int ExecuteNonQuery(string strStoredProc, SqlParameter[] sqlParams)
{
SqlConnection con = SqlConnector.getOpenSqlCon();
SqlCommand SqlComm = new SqlCommand(strStoredProc, con);
SqlComm.CommandType = CommandType.StoredProcedure;
int result = 0;
SqlComm.CommandTimeout = 780;
if (sqlParams != null)
{
foreach (SqlParameter sqlParam in sqlParams)
{
SqlComm.Parameters.Add(sqlParam);
}
}
try
{
result = SqlComm.ExecuteNonQuery();
}
catch (Exception ex)
{
}
finally
{
SqlComm = null;
sqlParams = null;
SqlConnector.closeSqlCon(con);
}
return result;
}
}
}
Under bellow I have written a code for sql Connector class,this class is more similar to MicrosftApplicationdataBlock class.
using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using System.Data.SqlTypes;
using System.Data.Sql;
using System.Configuration;
namespace DAL
{
public static class SqlConnector
{
private static string connection_str = string.Empty;
public static SqlConnection getOpenSqlCon()
{
connection_str = Convert.ToString(ConfigurationSettings.AppSettings["con"]);
SqlConnection con = new SqlConnection(connection_str);
if (con.State != ConnectionState.Open)
{
try
{
con.Open();
}
catch (Exception ex) { }
finally { }
}
return con;
}
public static Boolean closeSqlCon(SqlConnection con)
{
bool result = false;
if (con.State != ConnectionState.Closed)
{
try
{
con.Close();
result = true;
}
catch (Exception) { }
finally { }
}
return result;
}
public static DataSet getDataSet(string query)
{
SqlConnection con = SqlConnector.getOpenSqlCon();
SqlDataAdapter da = new SqlDataAdapter(query, con);
DataSet ds = new DataSet();
try
{
da.Fill(ds);
}
catch (Exception ex) { }
finally { }
SqlConnector.closeSqlCon(con);
return ds;
}
public static int execQ(string query)
{
SqlConnection con = SqlConnector.getOpenSqlCon();
SqlCommand command = new SqlCommand(query, con);
int result = 0;
try
{
result = command.ExecuteNonQuery();
}
catch (Exception ex) { }
finally { }
SqlConnector.closeSqlCon(con);
return result;
}
public static object execQScalar(string query)
{
SqlConnection con = SqlConnector.getOpenSqlCon();
SqlCommand command = new SqlCommand(query, con);
object result = null;
try
{
result = command.ExecuteScalar();
}
catch (Exception ex) { }
finally { }
SqlConnector.closeSqlCon(con);
return result;
}
/// <summary>
/// Executes a stored procedure
/// </summary>
/// <param name="strStoredProc"></param>
/// <param name="sqlParams"></param>
public static void ExecuteSP(string strStoredProc, SqlParameter[] sqlParams)
{
SqlConnection con = SqlConnector.getOpenSqlCon();
SqlCommand SqlComm = new SqlCommand(strStoredProc, con);
SqlComm.CommandType = CommandType.StoredProcedure;
SqlComm.CommandTimeout = 780;
if (sqlParams != null) {
foreach (SqlParameter sqlParam in sqlParams) {
SqlComm.Parameters.Add(sqlParam);
}
}
try {
SqlComm.ExecuteNonQuery();
}
catch (Exception ex)
{
throw ex;
}
finally {
SqlComm = null;
sqlParams = null;
SqlConnector.closeSqlCon(con);
}
}
public static void ExecuteSP(string strStoredProc, SqlParameter[] sqlParams,SqlTransaction tran,SqlConnection con)
{
SqlCommand SqlComm = new SqlCommand(strStoredProc, con,tran);
SqlComm.CommandType = CommandType.StoredProcedure;
SqlComm.CommandTimeout = 780;
if (sqlParams != null)
{
foreach (SqlParameter sqlParam in sqlParams)
{
SqlComm.Parameters.Add(sqlParam);
}
}
try
{
SqlComm.ExecuteNonQuery();
}
catch (Exception ex)
{
throw ex;
}
finally
{
SqlComm = null;
sqlParams = null;
}
}
/// <summary>
///
/// </summary>
/// <param name="strStoredProc"></param>
/// <param name="sqlParams"></param>
public static DataSet getDataSetExecuteSP(string strStoredProc, SqlParameter[] sqlParams)
{
SqlConnection con = SqlConnector.getOpenSqlCon();
SqlCommand SqlComm = new SqlCommand(strStoredProc, con);
SqlComm.CommandType = CommandType.StoredProcedure;
SqlDataAdapter da = new SqlDataAdapter(SqlComm);
DataSet ds = new DataSet();
SqlComm.CommandTimeout =780;
if (sqlParams != null) {
foreach (SqlParameter sqlParam in sqlParams) {
SqlComm.Parameters.Add(sqlParam);
}
}
try
{
da.Fill(ds);
}
catch (Exception ex)
{
}
finally
{
SqlComm = null;
sqlParams = null;
SqlConnector.closeSqlCon(con);
}
return ds;
}
public static DataSet getDataSetExecuteSP(string strStoredProc, SqlParameter[] sqlParams,SqlConnection con, SqlTransaction tran)
{
SqlCommand SqlComm = new SqlCommand(strStoredProc, con,tran);
SqlComm.CommandType = CommandType.StoredProcedure;
SqlDataAdapter da = new SqlDataAdapter(SqlComm);
DataSet ds = new DataSet();
SqlComm.CommandTimeout = 780;
if (sqlParams != null)
{
foreach (SqlParameter sqlParam in sqlParams){
SqlComm.Parameters.Add(sqlParam);
}
}
try
{
da.Fill(ds);
}
catch (Exception ex)
{
}
finally
{
SqlComm = null;
sqlParams = null;
}
return ds;
}
public static DataTable getDataTableExecuteSP(string strStoredProc, SqlParameter[] sqlParams)
{
SqlConnection con = SqlConnector.getOpenSqlCon();
SqlCommand SqlComm = new SqlCommand(strStoredProc, con);
SqlComm.CommandType = CommandType.StoredProcedure;
SqlDataAdapter da = new SqlDataAdapter(SqlComm);
DataTable dt = new DataTable();
SqlComm.CommandTimeout = 780;
if (sqlParams != null)
{
foreach (SqlParameter sqlParam in sqlParams)
{
SqlComm.Parameters.Add(sqlParam);
}
}
try
{
da.Fill(dt);
}
catch (Exception ex)
{
}
finally
{
SqlComm = null;
sqlParams = null;
SqlConnector.closeSqlCon(con);
}
return dt;
}
public static int ExecuteNonQuery(string strStoredProc, SqlParameter[] sqlParams)
{
SqlConnection con = SqlConnector.getOpenSqlCon();
SqlCommand SqlComm = new SqlCommand(strStoredProc, con);
SqlComm.CommandType = CommandType.StoredProcedure;
int result = 0;
SqlComm.CommandTimeout = 780;
if (sqlParams != null)
{
foreach (SqlParameter sqlParam in sqlParams)
{
SqlComm.Parameters.Add(sqlParam);
}
}
try
{
result = SqlComm.ExecuteNonQuery();
}
catch (Exception ex)
{
}
finally
{
SqlComm = null;
sqlParams = null;
SqlConnector.closeSqlCon(con);
}
return result;
}
}
}
No comments:
Post a Comment