黑马程序员技术交流社区

标题: 我写的一个数据库连接层，大家给点建议 [打印本页]
作者: 笔墨伺候    时间: 2012-10-18 14:08
标题: 我写的一个数据库连接层，大家给点建议

DB.cs（这个是关于access的数据库连接层）
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Web;
  4. using System.Data.OleDb;
  5. using System.Data;

  7. namespace test9
  8. {
  9.     public class DB
  10.     {
  11.         //连接字符串
  12.         // private string conString = ConfigurationManager.ConnectionStrings["site"].ConnectionString;
  13.         private string conString = "Provider=Microsoft.Jet.OLEDB.4.0;Data source=" + HttpContext.Current.Server.MapPath("~/App_Data/site.mdb");
  14.         private OleDbConnection con;      

  16.         //打开一个数据库连接
  17.         private void open()
  18.         {
  19.             if (this.con == null)
  20.             {
  21.                 this.con = new OleDbConnection(conString);
  22.             }
  23.             this.con.Open();
  24.         }

  26.         //关闭一个数据库连接
  27.         private void close()
  28.         {
  29.             if (this.con.State != ConnectionState.Closed)
  30.             {
  31.                 this.con.Close();
  32.             }
  33.         }
  34.         //无返回值查询
  35.         public void noneQ(string sql, params OleDbParameter[] sps)
  36.         {
  37.             this.open();
  38.             using (OleDbCommand cmd = new OleDbCommand(sql, this.con))
  39.             {
  40.                 foreach (OleDbParameter sp in sps)
  41.                 {
  42.                     cmd.Parameters.Add(sp);
  43.                 }
  44.                 cmd.ExecuteNonQuery();
  45.             }
  46.             this.close();
  47.         }
  48.         //返回单个值查询
  49.         public object oneQ(string sql, params OleDbParameter[] sps)
  50.         {
  51.             object re;
  52.             this.open();
  53.             using (OleDbCommand cmd = new OleDbCommand(sql, this.con))
  54.             {
  55.                 foreach (OleDbParameter sp in sps)
  56.                 {
  57.                     cmd.Parameters.Add(sp);
  58.                 }
  59.                 re = cmd.ExecuteScalar();
  60.             }
  61.             this.close();
  62.             return re;

  64.         }
  65.         //返回一个DataTable
  66.         public DataTable excuteTable(string sql, params OleDbParameter[] sps)
  67.         {
  68.             DataTable table;
  69.             this.open();
  70.             using (OleDbCommand cmd = new OleDbCommand(sql, this.con))
  71.             {
  72.                 foreach (OleDbParameter sp in sps)
  73.                 {
  74.                     cmd.Parameters.Add(sp);
  75.                 }
  76.                 DataSet ds = new DataSet();
  77.                 OleDbDataAdapter sda = new OleDbDataAdapter(cmd);
  78.                 sda.Fill(ds);
  79.                 table = ds.Tables[0];

  81.             }
  82.             this.close();
  83.             return table;
  84.         }

  86.         public DataTable excuteTable(string sql)
  87.         {
  88.             DataTable table;
  89.             this.open();
  90.             using (OleDbCommand cmd = new OleDbCommand(sql, this.con))
  91.             {
  92.                 DataSet ds = new DataSet();
  93.                 OleDbDataAdapter sda = new OleDbDataAdapter(cmd);
  94.                 sda.Fill(ds);
  95.                 table = ds.Tables[0];

  97.             }
  98.             this.close();
  99.             return table;
  100.         }
  101.         //带有事务
  102.         public string transaction(params string[] cmds)
  103.         {
  104.             this.open();
  105.             OleDbTransaction ot = con.BeginTransaction();
  106.             OleDbCommand cmd = new OleDbCommand();
  107.             cmd.Transaction = ot;
  108.             cmd.Connection = con;

  110.             try
  111.             {

  113.                 foreach (string cm in cmds)
  114.                 {
  115.                     cmd.CommandText = cm;
  116.                     cmd.ExecuteNonQuery();
  117.                 }

  119.                 ot.Commit();
  120.                 return "操作成功";

  122.             }
  123.             catch (Exception ex)
  124.             {
  125.                 ot.Rollback();
  126.                 return "操作失败，错误信息：" + ex.Message;
  127.             }
  128.             finally
  129.             {
  130.                 this.close();
  131.             }
  132.         }

  134.     }
  135. }
复制代码
大家给提点建议，毕竟这些东西是可以重用的






欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2