当前位置:首页 > 网络编程 > WEB编程 > ASP.net >  为ASP.NET封装的SQL数据库访问类(2)

 为ASP.NET封装的SQL数据库访问类(2)

点击次数:21 次 发布日期:2008-11-26 14:07:20 作者:源代码网
源代码网推荐      /// <summary>
源代码网推荐   /// 运行SQL语句,返回DataSet对象
源代码网推荐   /// </summary>
源代码网推荐   /// <param name="procName">SQL语句</param>
源代码网推荐   /// <param name="prams">DataSet对象</param>
源代码网推荐   public DataSet RunProc(string SQL ,DataSet Ds)
源代码网推荐   {
源代码网推荐   SqlConnection Conn;
源代码网推荐   Conn = new SqlConnection(ConnStr);
源代码网推荐   Conn.Open();
源代码网推荐   SqlDataAdapter Da;
源代码网推荐   //Da = CreateDa(SQL, Conn);
源代码网推荐   Da = new SqlDataAdapter(SQL,Conn);
源代码网推荐   try
源代码网推荐   {
源代码网推荐   Da.Fill(Ds);
源代码网推荐   }
源代码网推荐   catch(Exception Err)
源代码网推荐   {
源代码网推荐   throw Err;
源代码网推荐   }
源代码网推荐   Dispose(Conn);
源代码网推荐   return Ds;
源代码网推荐   }
源代码网推荐  
源代码网推荐   /// <summary>
源代码网推荐   /// 运行SQL语句,返回DataSet对象
源代码网推荐   /// </summary>
源代码网推荐   /// <param name="procName">SQL语句</param>
源代码网推荐   /// <param name="prams">DataSet对象</param>
源代码网推荐   /// <param name="dataReader">表名</param>
源代码网推荐   public DataSet RunProc(string SQL ,DataSet Ds,string tablename)
源代码网推荐   {
源代码网推荐   SqlConnection Conn;
源代码网推荐   Conn = new SqlConnection(ConnStr);
源代码网推荐   Conn.Open();
源代码网推荐   SqlDataAdapter Da;
源代码网推荐   Da = CreateDa(SQL);
源代码网推荐   try
源代码网推荐   {
源代码网推荐   Da.Fill(Ds,tablename);
源代码网推荐   }
源代码网推荐   catch(Exception Ex)
源代码网推荐   {
源代码网推荐   throw Ex;
源代码网推荐   }
源代码网推荐   Dispose(Conn);
源代码网推荐   return Ds;
源代码网推荐   }
源代码网推荐  
源代码网推荐   /// <summary>
源代码网推荐   /// 运行SQL语句,返回DataSet对象
源代码网推荐   /// </summary>
源代码网推荐   /// <param name="procName">SQL语句</param>
源代码网推荐   /// <param name="prams">DataSet对象</param>
源代码网推荐   /// <param name="dataReader">表名</param>
源代码网推荐   public DataSet RunProc(string SQL , DataSet Ds ,int StartIndex ,int PageSize, string tablename )
源代码网推荐   {
源代码网推荐   SqlConnection Conn;
源代码网推荐   Conn = new SqlConnection(ConnStr);
源代码网推荐   Conn.Open();
源代码网推荐   SqlDataAdapter Da ;
源代码网推荐   Da = CreateDa(SQL);
源代码网推荐   try
源代码网推荐   {
源代码网推荐   Da.Fill(Ds, StartIndex, PageSize, tablename);
源代码网推荐   }
源代码网推荐   catch(Exception Ex)
源代码网推荐   {
源代码网推荐   throw Ex;
源代码网推荐   }
源代码网推荐   Dispose(Conn);
源代码网推荐   return Ds;
源代码网推荐   }
源代码网推荐  
源代码网推荐   /// <summary>
源代码网推荐   /// 检验是否存在数据
源代码网推荐   /// </summary>
源代码网推荐   /// <returns></returns>
源代码网推荐   public bool ExistDate(string SQL)
源代码网推荐   {
源代码网推荐   SqlConnection Conn;
源代码网推荐   Conn = new SqlConnection(ConnStr);
源代码网推荐   Conn.Open();
源代码网推荐   SqlDataReader Dr ;
源代码网推荐   Dr = CreateCmd(SQL,Conn).ExecuteReader();
源代码网推荐   if (Dr.Read())
源代码网推荐   {
源代码网推荐   Dispose(Conn);
源代码网推荐   return true;
源代码网推荐   }
源代码网推荐   else
源代码网推荐   {
源代码网推荐   Dispose(Conn);
源代码网推荐   return false;
源代码网推荐   }
源代码网推荐   }
源代码网推荐  
源代码网推荐   /// <summary>
源代码网推荐   /// 返回SQL语句执行结果的第一行第一列
源代码网推荐   /// </summary>
源代码网推荐   /// <returns>字符串</returns>
源代码网推荐   public string ReturnValue(string SQL)
源代码网推荐   {
源代码网推荐   SqlConnection Conn;
源代码网推荐   Conn = new SqlConnection(ConnStr);
源代码网推荐   Conn.Open();
源代码网推荐   string result;
源代码网推荐   SqlDataReader Dr ;
源代码网推荐   try
源代码网推荐   {
源代码网推荐   Dr = CreateCmd(SQL,Conn).ExecuteReader();
源代码网推荐   if (Dr.Read())
源代码网推荐   {
源代码网推荐   result = Dr[0].ToString();
源代码网推荐   Dr.Close();
源代码网推荐   }
源代码网推荐   else
源代码网推荐   {
源代码网推荐   result = "";
源代码网推荐   Dr.Close();
源代码网推荐   }
源代码网推荐   }
源代码网推荐   catch
源代码网推荐   {
源代码网推荐   throw new Exception(SQL);
源代码网推荐   }
源代码网推荐   Dispose(Conn);
源代码网推荐   return result;
源代码网推荐   }
源代码网推荐  
源代码网推荐   /// <summary>
源代码网推荐   /// 返回SQL语句第一列,第ColumnI列,
源代码网推荐   /// </summary>
源代码网推荐   /// <returns>字符串</returns>
源代码网推荐   public string ReturnValue(string SQL, int ColumnI)
源代码网推荐   {
源代码网推荐   SqlConnection Conn;
源代码网推荐   Conn = new SqlConnection(ConnStr);
源代码网推荐   Conn.Open();
源代码网推荐   string result;
源代码网推荐   SqlDataReader Dr ;
源代码网推荐   try
源代码网推荐   {
源代码网推荐   Dr = CreateCmd(SQL,Conn).ExecuteReader();
源代码网推荐   }
源代码网推荐   catch
源代码网推荐   {
源代码网推荐   throw new Exception(SQL);
源代码网推荐   }
源代码网推荐   if (Dr.Read())
源代码网推荐   {
源代码网推荐   result = Dr[ColumnI].ToString();
源代码网推荐   }
源代码网推荐   else
源代码网推荐   {
源代码网推荐   result = "";
源代码网推荐   }
源代码网推荐   Dr.Close();
源代码网推荐   Dispose(Conn);
源代码网推荐   return result;
源代码网推荐   }
源代码网推荐  
源代码网推荐   /// <summary>
源代码网推荐   /// 生成一个存储过程使用的sqlcommand.
源代码网推荐   /// </summary>
源代码网推荐   /// <param name="procName">存储过程名.</param>
源代码网推荐   /// <param name="prams">存储过程入参数组.</param>
源代码网推荐   /// <returns>sqlcommand对象.</returns>
源代码网推荐   public SqlCommand CreateCmd(string procName, SqlParameter[] prams)
源代码网推荐   {
源代码网推荐   SqlConnection Conn;
源代码网推荐   Conn = new SqlConnection(ConnStr);
源代码网推荐   Conn.Open();
源代码网推荐   SqlCommand Cmd = new SqlCommand(procName, Conn);
源代码网推荐   Cmd.CommandType = CommandType.StoredProcedure;
源代码网推荐   if (prams != null)
源代码网推荐   {
源代码网推荐   foreach (SqlParameter parameter in prams)
源代码网推荐   {
源代码网推荐   if(parameter != null)
源代码网推荐   {
源代码网推荐   Cmd.Parameters.Add(parameter);
源代码网推荐   }
源代码网推荐   }
源代码网推荐   }
源代码网推荐   return Cmd;
源代码网推荐   }
源代码网推荐  
源代码网推荐   /// <summary>
源代码网推荐   /// 为存储过程生成一个SqlCommand对象
源代码网推荐   /// </summary>
源代码网推荐   /// <param name="procName">存储过程名</param>
源代码网推荐   /// <param name="prams">存储过程参数</param>
源代码网推荐   /// <returns>SqlCommand对象</returns>
源代码网推荐   private SqlCommand CreateCmd(string procName, SqlParameter[] prams,SqlDataReader Dr)
源代码网推荐   {
源代码网推荐   SqlConnection Conn;
源代码网推荐   Conn = new SqlConnection(ConnStr);
源代码网推荐   Conn.Open();
源代码网推荐   SqlCommand Cmd = new SqlCommand(procName, Conn);
源代码网推荐   Cmd.CommandType = CommandType.StoredProcedure;
源代码网推荐   if (prams != null)
源代码网推荐   {
源代码网推荐   foreach (SqlParameter parameter in prams)
源代码网推荐   Cmd.Parameters.Add(parameter);
源代码网推荐   }
源代码网推荐   Cmd.Parameters.Add(
源代码网推荐   new SqlParameter("ReturnValue", SqlDbType.Int, 4,
源代码网推荐   ParameterDirection.ReturnValue, false, 0, 0,
源代码网推荐   string.Empty, DataRowVersion.Default, null));
源代码网推荐  
源代码网推荐   return Cmd;
源代码网推荐   }
源代码网推荐  
源代码网推荐   /// <summary>
源代码网推荐   /// 运行存储过程,返回.
源代码网推荐   /// </summary>
源代码网推荐   /// <param name="procName">存储过程名</param>
源代码网推荐   /// <param name="prams">存储过程参数</param>
源代码网推荐   /// <param name="dataReader">SqlDataReader对象</param>
源代码网推荐   public void RunProc(string procName, SqlParameter[] prams, SqlDataReader Dr)
源代码网推荐   {
源代码网推荐  
源代码网推荐   SqlCommand Cmd = CreateCmd(procName, prams, Dr);
源代码网推荐   Dr = Cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
源代码网推荐   return;
源代码网推荐   }
源代码网推荐  
源代码网推荐   /// <summary>
源代码网推荐   /// 运行存储过程,返回.
源代码网推荐   /// </summary>
源代码网推荐   /// <param name="procName">存储过程名</param>
源代码网推荐   /// <param name="prams">存储过程参数</param>
源代码网推荐   public string RunProc(string procName, SqlParameter[] prams)
源代码网推荐   {
源代码网推荐   SqlDataReader Dr;
源代码网推荐   SqlCommand Cmd = CreateCmd(procName, prams);
源代码网推荐   Dr = Cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
源代码网推荐   if(Dr.Read())
源代码网推荐   {
源代码网推荐   return Dr.GetValue(0).ToString();
源代码网推荐   }
源代码网推荐   else
源代码网推荐   {
源代码网推荐   return "";
源代码网推荐   }
源代码网推荐   }
源代码网推荐  
源代码网推荐   /// <summary>
源代码网推荐   /// 运行存储过程,返回dataset.
源代码网推荐   /// </summary>
源代码网推荐   /// <param name="procName">存储过程名.</param>
源代码网推荐   /// <param name="prams">存储过程入参数组.</param>
源代码网推荐   /// <returns>dataset对象.</returns>
源代码网推荐   public DataSet RunProc(string procName,SqlParameter[] prams,DataSet Ds)
源代码网推荐   {
源代码网推荐   SqlCommand Cmd = CreateCmd(procName,prams);
源代码网推荐   SqlDataAdapter Da = new SqlDataAdapter(Cmd);
源代码网推荐   try
源代码网推荐   {
源代码网推荐   Da.Fill(Ds);
源代码网推荐   }
源代码网推荐   catch(Exception Ex)
源代码网推荐   {
源代码网推荐   throw Ex;
源代码网推荐   }
源代码网推荐   return Ds;
源代码网推荐   }
源代码网推荐  
源代码网推荐   }
源代码网推荐  }
源代码网推荐  
源代码网推荐  
源代码网推荐    做人要厚道,请注明转自酷网动力(www.ASPCOOL.COM)。
源代码网推荐


源代码网供稿.
网友评论 (0)
会员中心
网络编程
本站推荐
网络编程之精华