代码 //执行SQL语句 public static void ExecSqlCommand() { DbHelper db = new DbHelper(); DbCommand command = db.GetSqlStringCommond("select * from t1_insert"); db.ExecuteNonQuery(command); } //执行存储过程 public static void ExecStoredProcedure() { DbHelper db = new DbHelper(); DbCommand command = db.GetStoredProcCommond("t1_insert"); db.AddInParameter(command, "@id", DbType.String, "heihei"); db.AddInParameter(command, "@id", DbType.String, "heihei"); db.ExecuteNonQuery(command); } //返回DataTable public static void GetDataTable() { DbHelper db = new DbHelper(); DbCommand command = db.GetSqlStringCommond("t1_findall"); DataTable dt = db.ExecuteDataTable(command); } //获取各种返回值 public static void GetAllParameter() { DbHelper db = new DbHelper(); DbCommand command = db.GetStoredProcCommond("t2_insert"); db.AddInParameter(command, "@timeticks", DbType.Int64, DateTime.Now.Ticks); db.AddOutParameter(command, "@outString", DbType.String, 20); db.AddReturnParameter(command, "@returnValue", DbType.Int32); db.ExecuteNonQuery(command); string s = db.GetParameter(command, "@outString").Value as string;//out parameter int r = Convert.ToInt32(db.GetParameter(command, "@returnValue").Value);//return value } //DateReader操作 public static void GetDataReader() { DbHelper db = new DbHelper(); DbCommand command = db.GetStoredProcCommond("t2_insert"); db.AddInParameter(command, "@timeticks", DbType.Int64, DateTime.Now.Ticks); db.AddOutParameter(command, "@outString", DbType.String, 20); db.AddReturnParameter(command, "@returnValue", DbType.Int32); using (DbDataReader reader = db.ExecuteReader(command)) { //dt.Load(reader); } string s = db.GetParameter(command, "@outString").Value as string;//out parameter int r = Convert.ToInt32(db.GetParameter(command, "@returnValue").Value);//return value } //获取DataSet public static void GetDataSet() { DbHelper db = new DbHelper(); DbCommand command = db.GetSqlStringCommond("select * from t1"); DataSet ds = db.ExecuteDataSet(command); } //事务的使用.(项目中需要将基本的数据库操作组合成一个完整的业务流时,代码级的事务是必不可少的哦) public void DoBusiness() { using (Trans t = new Trans()) { try { D1(t); throw new Exception();//如果有异常,会回滚滴 D2(t); t.Commit(); } catch { t.RollBack(); } } } public void D1(Trans t) { DbHelper db = new DbHelper(); DbCommand cmd = db.GetStoredProcCommond("t2_insert"); db.AddInParameter(cmd, "@timeticks", DbType.Int64, DateTime.Now.Ticks); db.AddOutParameter(cmd, "@outString", DbType.String, 20); db.AddReturnParameter(cmd, "@returnValue", DbType.Int32); if (t == null) db.ExecuteNonQuery(cmd); else db.ExecuteNonQuery(cmd,t); string s = db.GetParameter(cmd, "@outString").Value as string;//out parameter int r = Convert.ToInt32(db.GetParameter(cmd, "@returnValue").Value);//return value } public void D2(Trans t) { DbHelper db = new DbHelper(); DbCommand cmd = db.GetSqlStringCommond("insert t1 (id)values(‘..‘)"); if (t == null) db.ExecuteNonQuery(cmd); else db.ExecuteNonQuery(cmd, t); }
其中 DbCommand 位于 using System.Data.Common 命名空间