1. using System;
   
2. using System.Data;
   
3. using System.Data.SqlClient;
   
4. 
   
5. namespace DbHelper
   
6. {
   
7.     public class SqlDbHelper
   
8.     {
   
9.         private SqlConnection conn;
   
10.         private SqlCommand cmd;
    
11.         private SqlDataReader reader;
    
12.         private SqlDataAdapter adapter;
    
13.         private string connectionString = @"server=.;database=student;uid=sa;pwd=scce";
    
14. 
    
15.         public string ConnectionString
    
16.         {
    
17.             get { return this.connectionString; }
    
18.             set { this.connectionString = value; }
    
19.         }
    
20. 
    
21.         /// <summary>
    
22.         /// 获取一个未打开连接的SqlConnection对象
    
23.         /// </summary>
    
24.         /// <returns>SqlConnection对象</returns>
    
25.         public SqlConnection GetConnection()
    
26.         {
    
27.             if (conn != null)
    
28.                 return this.conn;
    
29.             return this.conn = new SqlConnection(connectionString);
    
30.         }
    
31. 
    
32.         /// <summary>
    
33.         /// 使用连接字符串获取未打开连接SqlConnection对象
    
34.         /// </summary>
    
35.         /// <param name="_connStr">连接字符串</param>
    
36.         /// <returns>SqlConnection对象</returns>
    
37.         public SqlConnection GetConnection(string _connStr)
    
38.         {
    
39.             if (this.conn != null)
    
40.                 this.conn.ConnectionString = _connStr;
    
41.             else
    
42.                 this.conn = new SqlConnection(_connStr);
    
43.             return this.conn;
    
44.         }
    
45. 
    
46.         /// <summary>
    
47.         /// 使用指定的Sql语句创建SqlCommand对象
    
48.         /// </summary>
    
49.         /// <param name="sqlStr">Sql语句</param>
    
50.         /// <returns>SqlCommand对象</returns>
    
51.         private SqlCommand GetCommand(string sqlStr)
    
52.         {
    
53.             if (this.conn == null)
    
54.                 this.conn = GetConnection();
    
55.             if (this.cmd == null)
    
56.                 this.cmd = this.GetCommand(sqlStr, CommandType.Text, null);
    
57.             else
    
58.             {
    
59.                 this.cmd.CommandType = CommandType.Text;
    
60.                 this.cmd.Parameters.Clear();
    
61.             }
    
62.             this.cmd.CommandText = sqlStr;
    
63.             return this.cmd;
    
64.         }
    
65. 
    
66.         /// <summary>
    
67.         /// 使用指定的Sql语句,CommandType,SqlParameter数组创建SqlCommand对象
    
68.         /// </summary>
    
69.         /// <param name="sqlStr">Sql语句</param>
    
70.         /// <param name="type">命令类型</param>
    
71.         /// <param name="paras">SqlParameter数组</param>
    
72.         /// <returns>SqlCommand对象</returns>
    
73.         public SqlCommand GetCommand(string sqlStr, CommandType type, SqlParameter[] paras)
    
74.         {
    
75.             if (conn == null)
    
76.                 this.conn = this.GetConnection();
    
77.             if (cmd == null)
    
78.                 this.cmd = conn.CreateCommand();
    
79.             this.cmd.CommandType = type;
    
80.             this.cmd.CommandText = sqlStr;
    
81.             this.cmd.Parameters.Clear();
    
82.             if (paras != null)
    
83.                 this.cmd.Parameters.AddRange(paras);
    
84.             return this.cmd;
    
85.         }
    
86. 
    
87.         /// <summary>
    
88.         /// 执行Sql语句返回受影响的行数
    
89.         /// </summary>
    
90.         /// <param name="sqlStr">Sql语句</param>
    
91.         /// <returns>受影响的行数,失败则返回-1</returns>
    
92.         public int ExecuteNoQuery(string sqlStr)
    
93.         {
    
94.             int line = -1;
    
95.             CheckArgs(sqlStr);
    
96.             try { OpenConn(); line = this.ExecuteNonQuery(sqlStr,CommandType.Text,null); }
    
97.             catch (SqlException e) { throw e; }
    
98.             return line;
    
99.         }
    
100. 
     
101.         /// <summary>
     
102.         /// 使用指定的Sql语句,CommandType,SqlParameter数组执行Sql语句,返回受影响的行数
     
103.         /// </summary>
     
104.         /// <param name="sqlStr">Sql语句</param>
     
105.         /// <param name="type">命令类型</param>
     
106.         /// <param name="paras">SqlParameter数组</param>
     
107.         /// <returns>受影响的行数</returns>
     
108.         public int ExecuteNonQuery(string sqlStr, CommandType type, SqlParameter[] paras)
     
109.         {
     
110.             int line = -1;
     
111.             CheckArgs(sqlStr);
     
112.             if (this.cmd == null)
     
113.                 GetCommand(sqlStr, type, paras);
     
114.             this.cmd.Parameters.Clear();
     
115.             this.cmd.CommandText = sqlStr;
     
116.             this.cmd.CommandType = type;
     
117.             if(paras != null)
     
118.                 this.cmd.Parameters.AddRange(paras);
     
119.             try { OpenConn(); line = this.cmd.ExecuteNonQuery(); }
     
120.             catch (SqlException e) { throw e; }
     
121.             return line;
     
122.         }
     
123. 
     
124.         /// <summary>
     
125.         /// 使用指定Sql语句获取dataTable
     
126.         /// </summary>
     
127.         /// <param name="sqlStr">Sql语句</param>
     
128.         /// <returns>DataTable对象</returns>
     
129.         public DataTable GetDataTable(string sqlStr)
     
130.         {
     
131.             CheckArgs(sqlStr);
     
132.             if (this.conn == null)
     
133.                 this.conn = GetConnection();
     
134.             this.adapter = new SqlDataAdapter(sqlStr, this.conn);
     
135.             DataTable table = new DataTable();
     
136.             try { adapter.Fill(table); }
     
137.             catch (SqlException e) { throw e; }
     
138.             return table;
     
139.         }
     
140. 
     
141.         /// <summary>
     
142.         /// 使用指定的Sql语句获取SqlDataReader
     
143.         /// </summary>
     
144.         /// <param name="sqlStr">sql语句</param>
     
145.         /// <returns>SqlDataReader对象</returns>
     
146.         public SqlDataReader GetSqlDataReader(string sqlStr)
     
147.         {
     
148.             CheckArgs(sqlStr);
     
149.             if (cmd == null)
     
150.                 GetCommand(sqlStr);
     
151.             if(reader != null)
     
152.                 reader.Dispose();
     
153.             try { OpenConn(); this.reader = this.cmd.ExecuteReader(); }
     
154.             catch (SqlException e) { throw e; }
     
155.             return this.reader;
     
156.         }
     
157. 
     
158.         /// <summary>
     
159.         /// 使用事务执行多条Sql语句
     
160.         /// </summary>
     
161.         /// <param name="sqlCommands">sql语句数组</param>
     
162.         /// <returns>全部成功则返回true否则返回false</returns>
     
163.         public bool ExecuteSqls(string[] sqlCommands)
     
164.         {
     
165.             if (sqlCommands == null)
     
166.                 throw new ArgumentNullException();
     
167.             if(this.cmd == null)
     
168.                 GetCommand(null);
     
169.             SqlTransaction tran = null;
     
170.             try
     
171.             {
     
172.                 OpenConn();
     
173.                 tran = this.conn.BeginTransaction();
     
174.                 this.cmd.Transaction = tran;
     
175.                 foreach (string sql in sqlCommands)
     
176.                 {
     
177.                     if (ExecuteNoQuery(sql) == 0)
     
178.                     { tran.Rollback(); return false; }
     
179.                 }
     
180.             }
     
181.             catch (SqlException e)
     
182.             {
     
183.                 if(tran != null)
     
184.                     tran.Rollback();
     
185.                 throw e;
     
186.             }
     
187.             tran.Commit();
     
188.             return true;
     
189.         }
     
190. 
     
191.         private void OpenConn()
     
192.         {
     
193.             try
     
194.             {
     
195.                 if (this.conn.State == ConnectionState.Closed)
     
196.                     conn.Open();
     
197.             }
     
198.             catch (SqlException e) { throw e; }
     
199.         }
     
200. 
     
201.         private void CheckArgs(string sqlStr)
     
202.         {
     
203.             if (sqlStr == null)
     
204.                 throw new ArgumentNullException();
     
205.             if (sqlStr.Length == 0)
     
206.                 throw new ArgumentOutOfRangeException();
     
207.         }
     
208. 
     
209.     }
     
210. }

复制代码

1. using System;
   
2. using System.Data;
   
3. using System.Data.SqlClient;
   
4. 
   
5. namespace DbHelper
   
6. {
   
7.     public class SqlDbHelper
   
8.     {
   
9.         private SqlConnection conn;
   
10.         private SqlCommand cmd;
    
11.         private SqlDataReader reader;
    
12.         private SqlDataAdapter adapter;
    
13.         private string connectionString = @"server=.;database=student;uid=sa;pwd=scce";
    
14. 
    
15.         public string ConnectionString
    
16.         {
    
17.             get { return this.connectionString; }
    
18.             set { this.connectionString = value; }
    
19.         }
    
20. 
    
21.         /// <summary>
    
22.         /// 获取一个未打开连接的SqlConnection对象
    
23.         /// </summary>
    
24.         /// <returns>SqlConnection对象</returns>
    
25.         public SqlConnection GetConnection()
    
26.         {
    
27.             if (conn != null)
    
28.                 return this.conn;
    
29.             return this.conn = new SqlConnection(connectionString);
    
30.         }
    
31. 
    
32.         /// <summary>
    
33.         /// 使用连接字符串获取未打开连接SqlConnection对象
    
34.         /// </summary>
    
35.         /// <param name="_connStr">连接字符串</param>
    
36.         /// <returns>SqlConnection对象</returns>
    
37.         public SqlConnection GetConnection(string _connStr)
    
38.         {
    
39.             if (this.conn != null)
    
40.                 this.conn.ConnectionString = _connStr;
    
41.             else
    
42.                 this.conn = new SqlConnection(_connStr);
    
43.             return this.conn;
    
44.         }
    
45. 
    
46.         /// <summary>
    
47.         /// 使用指定的Sql语句创建SqlCommand对象
    
48.         /// </summary>
    
49.         /// <param name="sqlStr">Sql语句</param>
    
50.         /// <returns>SqlCommand对象</returns>
    
51.         private SqlCommand GetCommand(string sqlStr)
    
52.         {
    
53.             if (this.conn == null)
    
54.                 this.conn = GetConnection();
    
55.             if (this.cmd == null)
    
56.                 this.cmd = this.GetCommand(sqlStr, CommandType.Text, null);
    
57.             else
    
58.             {
    
59.                 this.cmd.CommandType = CommandType.Text;
    
60.                 this.cmd.Parameters.Clear();
    
61.             }
    
62.             this.cmd.CommandText = sqlStr;
    
63.             return this.cmd;
    
64.         }
    
65. 
    
66.         /// <summary>
    
67.         /// 使用指定的Sql语句,CommandType,SqlParameter数组创建SqlCommand对象
    
68.         /// </summary>
    
69.         /// <param name="sqlStr">Sql语句</param>
    
70.         /// <param name="type">命令类型</param>
    
71.         /// <param name="paras">SqlParameter数组</param>
    
72.         /// <returns>SqlCommand对象</returns>
    
73.         public SqlCommand GetCommand(string sqlStr, CommandType type, SqlParameter[] paras)
    
74.         {
    
75.             if (conn == null)
    
76.                 this.conn = this.GetConnection();
    
77.             if (cmd == null)
    
78.                 this.cmd = conn.CreateCommand();
    
79.             this.cmd.CommandType = type;
    
80.             this.cmd.CommandText = sqlStr;
    
81.             this.cmd.Parameters.Clear();
    
82.             if (paras != null)
    
83.                 this.cmd.Parameters.AddRange(paras);
    
84.             return this.cmd;
    
85.         }
    
86. 
    
87.         /// <summary>
    
88.         /// 执行Sql语句返回受影响的行数
    
89.         /// </summary>
    
90.         /// <param name="sqlStr">Sql语句</param>
    
91.         /// <returns>受影响的行数,失败则返回-1</returns>
    
92.         public int ExecuteNoQuery(string sqlStr)
    
93.         {
    
94.             int line = -1;
    
95.             CheckArgs(sqlStr);
    
96.             try { OpenConn(); line = this.ExecuteNonQuery(sqlStr,CommandType.Text,null); }
    
97.             catch (SqlException e) { throw e; }
    
98.             return line;
    
99.         }
    
100. 
     
101.         /// <summary>
     
102.         /// 使用指定的Sql语句,CommandType,SqlParameter数组执行Sql语句,返回受影响的行数
     
103.         /// </summary>
     
104.         /// <param name="sqlStr">Sql语句</param>
     
105.         /// <param name="type">命令类型</param>
     
106.         /// <param name="paras">SqlParameter数组</param>
     
107.         /// <returns>受影响的行数</returns>
     
108.         public int ExecuteNonQuery(string sqlStr, CommandType type, SqlParameter[] paras)
     
109.         {
     
110.             int line = -1;
     
111.             CheckArgs(sqlStr);
     
112.             if (this.cmd == null)
     
113.                 GetCommand(sqlStr, type, paras);
     
114.             this.cmd.Parameters.Clear();
     
115.             this.cmd.CommandText = sqlStr;
     
116.             this.cmd.CommandType = type;
     
117.             if(paras != null)
     
118.                 this.cmd.Parameters.AddRange(paras);
     
119.             try { OpenConn(); line = this.cmd.ExecuteNonQuery(); }
     
120.             catch (SqlException e) { throw e; }
     
121.             return line;
     
122.         }
     
123. 
     
124.         /// <summary>
     
125.         /// 使用指定Sql语句获取dataTable
     
126.         /// </summary>
     
127.         /// <param name="sqlStr">Sql语句</param>
     
128.         /// <returns>DataTable对象</returns>
     
129.         public DataTable GetDataTable(string sqlStr)
     
130.         {
     
131.             CheckArgs(sqlStr);
     
132.             if (this.conn == null)
     
133.                 this.conn = GetConnection();
     
134.             this.adapter = new SqlDataAdapter(sqlStr, this.conn);
     
135.             DataTable table = new DataTable();
     
136.             try { adapter.Fill(table); }
     
137.             catch (SqlException e) { throw e; }
     
138.             return table;
     
139.         }
     
140. 
     
141.         /// <summary>
     
142.         /// 使用指定的Sql语句获取SqlDataReader
     
143.         /// </summary>
     
144.         /// <param name="sqlStr">sql语句</param>
     
145.         /// <returns>SqlDataReader对象</returns>
     
146.         public SqlDataReader GetSqlDataReader(string sqlStr)
     
147.         {
     
148.             CheckArgs(sqlStr);
     
149.             if (cmd == null)
     
150.                 GetCommand(sqlStr);
     
151.             if(reader != null)
     
152.                 reader.Dispose();
     
153.             try { OpenConn(); this.reader = this.cmd.ExecuteReader(); }
     
154.             catch (SqlException e) { throw e; }
     
155.             return this.reader;
     
156.         }
     
157. 
     
158.         /// <summary>
     
159.         /// 使用事务执行多条Sql语句
     
160.         /// </summary>
     
161.         /// <param name="sqlCommands">sql语句数组</param>
     
162.         /// <returns>全部成功则返回true否则返回false</returns>
     
163.         public bool ExecuteSqls(string[] sqlCommands)
     
164.         {
     
165.             if (sqlCommands == null)
     
166.                 throw new ArgumentNullException();
     
167.             if(this.cmd == null)
     
168.                 GetCommand(null);
     
169.             SqlTransaction tran = null;
     
170.             try
     
171.             {
     
172.                 OpenConn();
     
173.                 tran = this.conn.BeginTransaction();
     
174.                 this.cmd.Transaction = tran;
     
175.                 foreach (string sql in sqlCommands)
     
176.                 {
     
177.                     if (ExecuteNoQuery(sql) == 0)
     
178.                     { tran.Rollback(); return false; }
     
179.                 }
     
180.             }
     
181.             catch (SqlException e)
     
182.             {
     
183.                 if(tran != null)
     
184.                     tran.Rollback();
     
185.                 throw e;
     
186.             }
     
187.             tran.Commit();
     
188.             return true;
     
189.         }
     
190. 
     
191.         private void OpenConn()
     
192.         {
     
193.             try
     
194.             {
     
195.                 if (this.conn.State == ConnectionState.Closed)
     
196.                     conn.Open();
     
197.             }
     
198.             catch (SqlException e) { throw e; }
     
199.         }
     
200. 
     
201.         private void CheckArgs(string sqlStr)
     
202.         {
     
203.             if (sqlStr == null)
     
204.                 throw new ArgumentNullException();
     
205.             if (sqlStr.Length == 0)
     
206.                 throw new ArgumentOutOfRangeException();
     
207.         }
     
208. 
     
209.     }
     
210. }

复制代码