using System; using System.Data; using System.Data.OleDb; using System.Configuration;
namespace yueying.Components { /// <summary> /// DBClass 的摘要说明。 /// </summary> public class DBClass { protected static string strConn = ConfigurationSettings.AppSettings["strConn"]; public DBClass() { // // TODO: 在此处添加构造函数逻辑 // } //功能:执行sql语句,返回bool internal bool ExecuteSql(string strSQL) { bool success=false; OleDbConnection conn = new OleDbConnection(strConn); OleDbCommand myCmd = new OleDbCommand(strSQL,conn); try { conn.Open(); myCmd.ExecuteNonQuery(); success=true; } catch(System.Data.OleDb.OleDbException e) { throw new Exception(e.Message); } finally { myCmd.Dispose(); conn.Close(); } return success;
}
//功能:执行sql语句,如果有记录的话返回1,否则返回0 internal int ExecuteSqlDr(string strSQL) { OleDbConnection myCn = new OleDbConnection(strConn); OleDbCommand myCmd = new OleDbCommand(strSQL,myCn); try { myCn.Open(); OleDbDataReader myDr = myCmd.ExecuteReader(); if(myDr.Read()) { return 1; } else { return 0; } } catch(System.Data.OleDb.OleDbException e) { throw new Exception(e.Message); } finally { myCmd.Dispose(); myCn.Close(); } }
//功能:执行SQL语句,返回DataSet internal DataSet ExecuteSqlDs(string strSQL ,string tablename) { OleDbConnection myCn = new OleDbConnection(strConn); try { myCn.Open(); OleDbDataAdapter myDa = new OleDbDataAdapter(strSQL,myCn); DataSet ds = new DataSet(); myDa.Fill(ds,tablename); return ds; } catch(System.Data.OleDb.OleDbException e) { throw new Exception(e.Message); } finally { myCn.Close(); } }
//执行SQL语句,返回DataReader internal OleDbDataReader ExecuteSqlDataReader(string strSQL) { OleDbConnection myCn = new OleDbConnection(strConn); OleDbCommand myCmd = new OleDbCommand(strSQL,myCn); try { myCn.Open(); return myCmd.ExecuteReader(CommandBehavior.CloseConnection); } catch { myCn.Close(); throw; } }
//执行SQL语句,返回执行cmd的Scalar方法的值 internal int ExecuteSqlScalar(string strSQL) { OleDbConnection myCn = new OleDbConnection(strConn); OleDbCommand myCmd = new OleDbCommand(strSQL,myCn); try { myCn.Open(); object r = myCmd.ExecuteScalar(); if(Object.Equals(r,null)) { throw new Exception("value unavailable!"); } else { return (int)r; } } catch(System.Data.OleDb.OleDbException e) { throw new Exception(e.Message); } finally { myCmd.Dispose(); myCn.Close(); } }
internal object ExecuteSql4ValueEx(string strSQL) { OleDbConnection myCn = new OleDbConnection(strConn); OleDbCommand myCmd = new OleDbCommand(strSQL,myCn); try { myCn.Open(); object r = myCmd.ExecuteScalar(); if(Object.Equals(r,null)) { throw new Exception("object unavailable!"); } else { return r; } } catch(System.Data.OleDb.OleDbException e) { throw new Exception(e.Message); } finally { myCmd.Dispose(); myCn.Close(); } }
} }

|