为ASP.NET封装的SQL数据库访问类(2)
点击次数:21 次 发布日期:2008-11-26 14:07:20 作者:源代码网
|
源代码网推荐 /// 运行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)。 源代码网推荐 源代码网供稿. |
