自己常用到的自定义公共类(已测试通过)

using System;

using System.Data;

using System.Data.SqlClient;

using System.Configuration;

using System.IO;

/*

* AUTHOR:ZHANGLEI

* CREATE DATE:2007.1.5

* 功能：ＢＬＬ层，实现了数据库操作的封装

* 并且提供了足够的执行存储过程的参数组合

* DESCRIPTION:本类中用到了方法重载

* ExecuteDataSet方法在本类中实现了四次重载

* */

namespace job_17

{

/// <summary>

/// job17 的摘要说明。

/// </summary>

public class job17

{

private readonly string P_Con=ConfigurationSettings.AppSettings["P_Con"].ToString();

public job17()

{

//

// TODO: 在此处添加构造函数逻辑

//

}

#region "执行任意参数组合的存储过程"

/// <summary>

/// 命令准备操作，提供足够多的参数组合

/// 本类中一个比较重要的方法

/// </summary>

public void preparecommand(SqlConnection myconn,SqlCommand mycomm,SqlTransaction trans,CommandType cmdType,string cmdText,SqlParameter[] param) //注意里面的参数

{

if (myconn.State!=ConnectionState.Open)

{

myconn.Open();

}

mycomm.Connection=myconn;

mycomm.CommandText=cmdText;

if (trans!=null)

{

mycomm.Transaction=trans;

}

mycomm.CommandType=cmdType;

if (param!=null)

{

foreach(SqlParameter parameter in param)

{

mycomm.Parameters.Add(parameter);

}

}

}

/// <summary>

/// 第一个返回DataSet类型的ExecuteDataSet方法

/// </summary>

public DataSet ExecuteDataSet(SqlConnection myconn,CommandType cmdType,string cmdText,SqlParameter[] commandpara)

{

SqlCommand mycomm=new SqlCommand();

preparecommand(myconn,mycomm,(SqlTransaction)null,cmdType,cmdText,commandpara);

SqlDataAdapter adpt=new SqlDataAdapter(mycomm); //调用上方的preparecommand方法

DataSet ds=new DataSet();

adpt.Fill(ds);

mycomm.Parameters.Clear();

return ds;

}

/// <summary>

/// 第二个返回DataSet类型的ExecuteDataSet方法

/// 是在第一个方法的基础上实现，实现了ExecuteDataSet方法的重载

/// </summary>

public DataSet ExecuteDataSet (string connstr,CommandType cmdType,string cmdText,SqlParameter[] cmdpara)//方法重载，在第一种的基础上重载,以便提供足够多的参数组合

{

using(SqlConnection myconn=new SqlConnection(connstr))

{

return ExecuteDataSet(myconn,cmdType,cmdText,cmdpara);

}

}

/// <summary>

/// 第三个返回DataSet类型的ExecuteDataSet方法

/// 提供使用存储过程时不带参数的组合

/// </summary>

public DataSet ExecuteDataSet(SqlConnection myconn,CommandType cmdType,string cmdText)

{

return ExecuteDataSet(myconn,cmdType,cmdText,(SqlParameter[])null);

}

/// <summary>

/// 第四个返回DataSet类型的ExecuteDataSet方法

/// 提供使用存储过程时不带参数的组合

/// </summary>

public DataSet ExecuteDataSet (string connstr,CommandType cmdType,string cmdText)

{

return ExecuteDataSet(connstr,cmdType,cmdText,(SqlParameter[])null);

}

#endregion

#region "执行返回结果的sql语句"

/// <summary>

/// 返回结果的类型为DataTable

/// </summary>

public DataTable ExecuteDataTablesql(string sql)

{

SqlConnection myconn=new SqlConnection(P_Con);

SqlDataAdapter adpt=new SqlDataAdapter(sql,myconn);

DataSet ds=new DataSet();

adpt.Fill(ds);

return  ds.Tables[0];

}

/// <summary>

/// 返回结果的类型为SqlDataReader

/// </summary>

public SqlDataReader ExecuteDataReadersql(string sql)

{

SqlConnection myconn=new SqlConnection(P_Con);

SqlDataReader dr=null;

SqlCommand mycomm=new SqlCommand(sql,myconn);

try

{

myconn.Open();

dr=mycomm.ExecuteReader();

}

catch

{

//    StreamWriter sw=new StreamWriter(@"c:\err.txt",true,System.Text.Encoding.GetEncoding("GB2312"));

//    sw.WriteLine("============================出错信息==========================");

//    sw.WriteLine("出错时间："+DateTime.Now.ToString()+"");

//    sw.WriteLine(ex.ToString());

//    sw.Close();

throw;

}

return dr;

}

/// <summary>

/// 返回结果的类型为DataSet

/// </summary>

public DataSet ExecutesqlDS(string sql)

{

SqlConnection myconn=new SqlConnection(P_Con);

SqlDataAdapter adpt=new SqlDataAdapter (sql,myconn);

DataSet ds=new DataSet();

adpt.Fill(ds);

return ds;

}

#endregion

#region "执行不返回结果的sql语句"

/// <summary>

/// 执行不返回结果的sql语句

/// </summary>

public void ExecuteNonsql(string sql)

{

SqlConnection myconn=new SqlConnection(P_Con);

SqlCommand mycomm=new SqlCommand(sql,myconn);

try

{

myconn.Open();

mycomm.ExecuteNonQuery();

myconn.Close();

}

catch(Exception e)

{

//   StreamWriter sw=new StreamWriter(@"c:\err.txt",true,System.Text.Encoding.GetEncoding("GB2312"));

//    sw.WriteLine("============================出错信息==========================");

//    sw.WriteLine("出错时间："+DateTime.Now.ToString()+"");

//    sw.WriteLine(e.ToString());

//    sw.Close();

throw new Exception(e.Message,e);

}

}

#endregion

#region "启用带事务的sql语句如(insert,update)"

/// <summary>

/// 使用事务处理

/// </summary>

public void ExecuteTransql(string sql)

{

SqlConnection myconn=new SqlConnection(P_Con);

SqlCommand mycomm=new SqlCommand(sql,myconn);

SqlTransaction trans=null;

try

{

myconn.Open();

trans=myconn.BeginTransaction();

mycomm.Transaction=trans;

mycomm.ExecuteNonQuery();

trans.Commit();

}

catch(Exception ex)

{

trans.Rollback();

throw new Exception(ex.Message,ex);

}

}

#endregion

}

}