ORM映射框架总结--数据操作(五)

 1  /* *
 2   * 
 3   * 2009-4-22
 4   * 
 5   * 
 6   * 数据库操作加载驱动接口，
 7   * 提供了数据库操作的各种命令
 8   *  */
 9  using  System;
10  using  System.Collections.Generic;
11  using  System.Linq;
12  using  System.Text;
13  using  System.Data;
14 
15  namespace  CommonData.Data
16  {
17       public   interface  IDbProvider:IDisposable
18      {
19           string  ConnectionString {  get ;  set ; }
20 
21          IDbConnection Connection {  get ;  set ; }
22 
23          IDbCommand Command {  get ;  set ; }
24 
25          IDbDataAdapter Adapter {  get ;  set ; }
26 
27           void  Open();
28 
29           void  Close();
30 
31           // --------------------控制事务
32           void  BeginTransaction();
33 
34           void  RollBack();
35 
36           void  Commit();
37 
38 
39           // -------------------数据提供加载驱动
40          IDbProvider CreateInstance();
41      }
42  }
43 

  1  /* *
  2   * 
  3   * 2009-4-22
  4   * 
  5   * 
  6   * 数据提供加载驱动类
  7   *  */
  8  using  System;
  9  using  System.Collections.Generic;
 10  using  System.Linq;
 11  using  System.Text;
 12  using  System.Data;
 13  using  System.Data.SqlClient;
 14  using  CommonData.Data;
 15 
 16  namespace  CommonData.Data
 17  {
 18       public   class  SqlProvider:IDbProvider
 19      {
 20           private   string  connectionString  =   " server=.\\SQLEXPRESS;database=Fengling;Integrated Security=true " ;
 21           ///   <summary>
 22           ///  数据库连接字符串
 23           ///   </summary>
 24           public   string  ConnectionString
 25          {
 26               get  
 27              {
 28                   if  (connectionString  ==   null )
 29                  {
 30                     & nbsp;connectionString  =   " server=.\\SQLEXPRESS;database=Fengling;Integrated Security=true " ;
 31                  }
 32                   return  connectionString;
 33              }
 34               set
 35              {
 36                  connectionString&nb sp; =  value;
 37              }
 38          }
 39 
 40           private  IDbConnection connection = null ;
 41           ///   <summary>
 42           ///  数据库连接对象
 43           ///   </summary>
 44           public  IDbConnection Connection
 45          {
 46               get
 47              {
 48                   if  (connection  ==   null )
 49                  {
 50                     & nbsp;connection  =   new  SqlConnection(connectionString);
 51                  }
 52                   return  connection;
 53              }
 54               set
 55              {
 56                  connection = value;
 57             }
 58         }
 59 
 60         private IDbCommand command = null;
 61         /// <summary>
 62         /// 数据库命令操作对象
 63         /// </summary>
 64         public IDbCommand Command
 65         {
 66             get
 67             {
 68                 if (command == null)
 69                 {
 70                    & nbsp;command = new SqlCommand();
 71                    & nbsp;command.Connection = connection;
 72                 }
 73                 return command;
 74             }
 75             set
 76             {
 77                 command = value;
 78             }
 79         }
 80 
 81         private IDbDataAdapter adapter = null;
 82         /// <summary>
 83         /// 数据库适配器对象
 84         /// </summary>
 85         public IDbDataAdapter Adapter
 86         {
 87             get
 88             {
 89                 if (adapter == null)
 90                 {
 91                    & nbsp;adapter = new SqlDataAdapter(command as SqlCommand);
 92                 }
 93                 return adapter;
 94             }
 95             set
 96             {
 97                 adapter = value;
 98             }
 99         }
100 
101         /// <summary>
102         /// 数据库事务对象
103         /// </summary>
104         private IDbTransaction transaction = null;
105         
106         /// <summary>
107         /// 打开数据库连接
108         /// </summary>
109         public void Open()
110         {
111             if (connection != null)
112             {
113                 connection.Open ();
114             }
115         }
116 
117         /// <summary>
118         /// 关闭数据库连接
119         /// </summary>
120         public void Close()
121         {
122             if (connection != null)
123             {
124                 connection.Close ();
125             }
126         }
127 
128         /// <summary>
129         /// 开始事务
130         /// </summary>
131         public void BeginTransaction()
132         {
133             transaction = connection.BeginTransaction();
134             command.Transaction = transaction;
135         }
136 
137         /// <summary>
138         /// 事务回滚
139         /// </summary>
140         public void RollBack()
141         {
142             if (transaction != null)
143             {
144                 transaction.Rollbac k();
145                 command.Transaction  = null;
146                 transaction.Dispose ();
147             }
148         }
149 
150         /// <summary>
151         /// 事务提交
152         /// </summary>
153         public void Commit()
154         {
155             if (transaction != null)
156             {
157                 transaction.Commit ();
158                 command.Transaction  = null;
159                 transaction.Dispose ();
160             }
161         }
162 
163         /// <summary>
164         /// 创建数据库加载驱动
165         /// </summary>
166         /// <returns></returns>
167         public IDbProvider CreateInstance()
168         {
169             return new SqlProvider();
170         }
171 
172         /// <summary>
173         /// 释放内存空间
174         /// </summary>
175         public void Dispose()
176         {
177             GC.SuppressFinalize(this);
178         }
179     }
180 }
181