数据访问函数库 —— SQL语句部分。

/* 2008 4 25 更新 */

我的数据访问函数库的源码。整个类有1400行，原先就是分开来写的，现在更新后还是分开来发一下吧。

第二部分：SQL语句部分。传入SQL语句，执行相关的操作。

  1//查询语句部分
  2        运行查询语句返回记录（DataSet、DataTable、DataRow、String[]、String）#region 运行查询语句返回记录（DataSet、DataTable、DataRow、String[]、String）
  3    
  4        /**//// 
  5        /// 运行SQL查询语句 返回DataSet。可以传入多条查询语句，返回的DataSet里会有多个DataTable
  6        /// 
  7        /// 查询语句。比如select * from tableName
  8        /// 返回DataSet
  9        函数实现 — — RunSqlDataSet#region 函数实现 — — RunSqlDataSet
 10        public DataSet RunSqlDataSet(string SQL)
 11        {    
 12            SetCommand(SQL,1);        //设置command
 13            SqlDataAdapter da = new SqlDataAdapter(cm);
 14            try
 15            {
 16                DataSet DS = new DataSet();
 17                da.Fill(DS);
 18                return DS;
 19            }
 20            catch(Exception ex)
 21            {
 22                SetErrorMsg("RunSqlDataSet",SQL,ex.Message );    //处理错误
 23                return null;
 24            }
 25            finally
 26            {
 27                //自动关闭了，不用手动关闭。
 28                da.Dispose();
 29            }
 30        }
 31        #endregion
 32
 33
 34        /**//// 
 35        /// 运行SQL查询语句 返回DataTable。
 36        /// 
 37        /// 查询语句。比如select * from tableName
 38        /// 返回DataTable
 39        函数实现 — — RunSqlDataTable#region 函数实现 — — RunSqlDataTable
 40        public DataTable RunSqlDataTable(string SQL)
 41        {    
 42            SetCommand(SQL,1);        //设置command
 43            SqlDataAdapter da = new SqlDataAdapter(cm);
 44            try
 45            {
 46                DataTable DT = new DataTable();
 47                da.Fill(DT);
 48                return DT;
 49            }
 50            catch(Exception ex)
 51            {
 52                SetErrorMsg("RunSqlDataTable",SQL,ex.Message );    //处理错误
 53                return null;
 54            }
 55            finally
 56            {
 57                //自动关闭了，不用手动关闭。
 58                da.Dispose();
 59            }
 60        }
 61        #endregion
 62
 63    
 64        /**//// 
 65        /// 运行SQl语句返回第一条记录。返回DataRow
 66        /// 
 67        /// 查询语句。比如select * from tableName
 68        /// 
 69        函数实现 — — RunSqlDataRow#region 函数实现 — — RunSqlDataRow
 70        public DataRow RunSqlDataRow(string SQL)
 71        {    
 72            SetCommand(SQL,1);        //设置command
 73            SqlDataAdapter da = new SqlDataAdapter(cm);
 74            try
 75            {
 76                DataTable DT = new DataTable();
 77                da.Fill(DT);
 78                if (DT.Rows.Count > 0)
 79                    return DT.Rows[0];
 80                else 
 81                    return null;
 82            }
 83            catch(Exception ex)
 84            {
 85                SetErrorMsg("RunSqlDataRow",SQL,ex.Message );    //处理错误
 86                return null;
 87            }
 88            finally
 89            {
 90                //自动关闭了，不用手动关闭。
 91                da.Dispose();
 92            }
 93            
 94        }
 95        #endregion
 96
 97
 98        /**//// 
 99        /// 运行SQl语句返回第一条记录的数组。返回字符串数组
100        /// 
101        /// 查询语句。比如select top 1 * from tableName
102        /// 
103        函数实现 — — RunSqlStrings#region 函数实现 — — RunSqlStrings
104        public string[] RunSqlStrings(string SQL)
105        {    
106            //返回ID 传入查询语句，返回第一条记录的第一的字段的值
107            SetCommand(SQL,1);        //设置command
108            SqlDataReader r = null;
109            try
110            {
111                if (cm.Connection.State == ConnectionState.Broken || cm.Connection.State == ConnectionState.Closed )
112                    cm.Connection.Open();
113                
114                r =  cm.ExecuteReader();
115                string[] strValue = null;
116                if (r.Read() )
117                {
118                    int ArrLength = r.FieldCount;
119                
120                    strValue = new string[ArrLength];
121                    for(int i=0;i<ArrLength;i++)
122                        strValue[i] = r.GetValue(i).ToString();
123                    
124                }
125                
126                return strValue;
127            }
128            catch(Exception ex)
129            {
130                SetErrorMsg("RunSqlStrs",SQL,ex.Message );    //处理错误
131                return null;
132            }
133            finally
134            {
135                if (r != null)
136                    r.Close();
137                
138                if (!isUseTrans)
139                    cm.Connection.Close();
140                
141            }
142        }
143        #endregion
144
145        /**//// 
146        /// 运行SQl语句返回每一条记录的第一个字段的数组。返回字符串数组
147        /// 
148        /// 查询语句。比如select myName from tableName
149        /// 用于统计记录数的SQL语句。如果传入数字的话，则直接使用数字作为记录数。
150        /// 
151        函数实现 — — RunSqlStringsByRow#region 函数实现 — — RunSqlStringsByRow
152        public string[] RunSqlStringsByRow(string SQL,string SQLForCount)
153        {
154            //先获取记录数
155            int RowCount = 0;
156            if (Functions.IsInt(SQLForCount))
157            {
158                RowCount = Int32.Parse(SQLForCount);
159            }
160            else
161            {
162                string strRowCount = RunSqlGetID(SQLForCount);
163                if (strRowCount == null)
164                    return null;
165                
166                RowCount = Int32.Parse(strRowCount);
167            }
168            if (RowCount <1)
169                return null;
170            
171            //传入查询语句，返回每条记录的第一的字段的值
172            SetCommand(SQL,1);        //设置command
173            SqlDataReader r = null;
174            try
175            {
176                if (cm.Connection.State == ConnectionState.Broken || cm.Connection.State == ConnectionState.Closed )
177                    cm.Connection.Open();
178                
179                string[] strValue = new string[RowCount];
180                r =  cm.ExecuteReader();
181                int i = 0;
182                while (r.Read())
183                {
184                    strValue[i] = r[0].ToString();
185                    i++;
186                }
187                return  strValue;
188
189                
190            }
191            catch(Exception ex)
192            {
193                SetErrorMsg("RunSqlStringsByRow",SQL,ex.Message );    //处理错误
194                return null;
195            }
196            finally
197            {
198                if (r != null)
199                    r.Close();
200                
201                if (!isUseTrans)
202                    cm.Connection.Close();
203                
204            }
205        }
206        #endregion
207
208        /**//// 
209        /// 运行SQl语句返回每一条记录的第一个字段的数组。返回字符串数组
210        /// 
211        /// 查询语句。比如select myName from tableName
212        /// 
213        函数实现 — — RunSqlStringsByRow#region 函数实现 — — RunSqlStringsByRow
214        public string[] RunSqlStringsByRow(string SQL)
215        {
216            
217            //传入查询语句，返回每条记录的第一的字段的值
218            SetCommand(SQL,1);        //设置command
219            SqlDataReader r = null;
220            try
221            {
222                if (cm.Connection.State == ConnectionState.Broken || cm.Connection.State == ConnectionState.Closed )
223                    cm.Connection.Open();
224                
225                r =  cm.ExecuteReader();
226                //int i = 0;
227                System.Collections.IList li = new System.Collections.ArrayList();
228                while (r.Read())
229                    li.Add(r[0].ToString());
230                    
231                string[] strValue = new string[li.Count];
232                
233                li.CopyTo(strValue,0);
234
235                return strValue;
236                
237            }
238            catch(Exception ex)
239            {
240                SetErrorMsg("RunSqlStringsByRow",SQL,ex.Message );    //处理错误
241                return null;
242            }
243            finally
244            {
245                if (r != null)
246                    r.Close();
247                if (!isUseTrans)
248                    cm.Connection.Close();
249                
250            }
251        }
252        #endregion
253
254        /**//// 
255        /// 运行SQl语句返回第一条记录的第一列的值。
256        /// 
257        /// 查询语句。比如select top 1 ID from tableName where userName='aa'。会返回ID的内容
258        /// 
259        函数实现 — — RunSqlGetID#region 函数实现 — — RunSqlGetID
260        public   string RunSqlGetID(string SQL)
261        {    
262            SetCommand(SQL,1);        //设置command
263            SqlDataReader r = null;
264            try
265            {
266                if (cm.Connection.State == ConnectionState.Broken || cm.Connection.State == ConnectionState.Closed )
267                    cm.Connection.Open();
268                    
269                r =  cm.ExecuteReader(CommandBehavior.SingleRow);
270                string re = "";
271                if (r.Read())
272                    re = r.GetValue(0).ToString();
273                else
274                    re = null;
275                
276                return re;
277                
278            }
279            catch(Exception ex)
280            {
281                SetErrorMsg("RunSqlGetID",SQL,ex.Message );    //处理错误
282                return null;
283            }
284            finally
285            {
286                if (r != null)
287                    r.Close();
288                
289                if (!isUseTrans)
290                    cm.Connection.Close();
291                
292            }
293        }
294        #endregion
295        
296        #endregion
297
298        运行查询语句不返回记录集（无返回记录、检查持否存在指定的记录）#region 运行查询语句不返回记录集（无返回记录、检查持否存在指定的记录）
299        /**//// 
300        /// 运行SQL查询语句，不返回记录集。用于添加、修改、删除等操作
301        /// 
302        /// 查询语句。比如insert into tableName 、update tableName
303        /// 
304        函数实现 — — RunSql#region 函数实现 — — RunSql
305        public void RunSql(string SQL)
306        {    
307            SetCommand(SQL,1);        //设置command
308            try
309            {
310                if (cm.Connection.State == ConnectionState.Broken || cm.Connection.State == ConnectionState.Closed )
311                    cm.Connection.Open();
312                executeRowCount = cm.ExecuteNonQuery();
313            }
314            catch(Exception ex)
315            {
316                SetErrorMsg("RunSql",SQL,ex.Message );    //处理错误
317            }
318            finally
319            {
320                if (!isUseTrans)
321                    cm.Connection.Close();
322            }
323        }
324        #endregion
325
326        
327        /**//// 
328        /// 执行一条SQL语句，看是否能查到记录 有：返回true；没有返回false，用于判断是否重名
329        /// 
330        /// 查询语句。比如select ID from tableName where userName='aa'
331        /// 
332        函数实现 — — RunSqlExists#region 函数实现 — — RunSqlExists
333        public bool RunSqlExists( string SQL)
334        {
335            SetCommand(SQL,1);        //设置command
336            SqlDataReader r = null;
337            try
338            {
339                if (cm.Connection.State == ConnectionState.Broken || cm.Connection.State == ConnectionState.Closed )
340                    cm.Connection.Open();
341                    
342                r =  cm.ExecuteReader();
343                bool re = true;
344                if (r.HasRows)
345                     re = true;
346                else
347                     re = false;
348
349                return re;
350            }
351            catch(Exception ex)
352            {
353                errorMsg = "运行RunSqlExists函数时出现错误。
错误信息：" + ex.Message;
354                SetErrorMsg("RunSqlDataSet",SQL,ex.Message );    //处理错误
355                return true;
356            }
357            finally
358            {
359                if (r != null)
360                    r.Close();
361                
362                if (!isUseTrans)
363                    cm.Connection.Close();
364            }
365        }
366        #endregion
367
368        #endregion
369
370        查询语句的方式添加、修改数据#region 查询语句的方式添加、修改数据
371        
372        /**//// 
373        /// 添加记录。传入表名，字段数组，值数组，返回新生成记录的ID
374        /// 
375        /// 要添加记录的表的名称
376        /// 字段名数组
377        /// 字段对应的值的数组
378        /// 
379        public   string InsertDataStr(string TableName  ,  string[] ziduan  ,  string[] msg )
380        {
381            //添加数据    返回新添加的ID
382            System.Text.StringBuilder SQL = new System.Text.StringBuilder(300);
383            SQL.Append("insert into ");                    //insert into 
384            SQL.Append(TableName);
385            SQL.Append(" ([");
386            int i;
387            for( i = 0 ;i< ziduan.Length ;i++)        //字段
388            {
389                if (msg[i] != "_n_")
390                {
391                    SQL.Append(ziduan[i]);
392                    SQL.Append("],[");
393                }
394            }
395            SQL = SQL.Remove(SQL.Length -2,2);
396
397            SQL.Append(")  values ('");
398
399            for( i = 0;i<ziduan.Length ;i++)
400            {
401                if (msg[i] != "_n_")
402                {
403                    SQL.Append(msg[i]);
404                    SQL.Append("','");
405                }
406            }
407            SQL = SQL.Remove(SQL.Length -2,2);
408
409            SQL.Append(")  select scope_identity() as a1");
410            
411            string re = RunSqlGetID(SQL.ToString());
412            SQL.Length = 1;
413            if (re == null)
414                return "-1";
415            else
416                return re;
417        }
418        
419        /**//// 
420        /// 修改记录。传入表名，字段数组，值数组 ，修改条件
421        /// 
422        /// 要修改记录的表的名称
423        /// 字段名数组
424        /// 字段对应的值的数组
425        /// 条件 ，加在where 后面的语句
426        /// 
427        public bool UpdateData( string TableName ,string[] ziduan ,string[] msg ,string tiaojian) 
428        {
429            System.Text.StringBuilder SQL = new System.Text.StringBuilder(300);
430            SQL.Append("update ");                    //update
431            SQL.Append(TableName);
432            SQL.Append(" set ");
433            int i;
434            for (i = 0 ;i< ziduan.Length ;i++)
435            {
436                if (msg[i] != "_n_")
437                {
438                    SQL.Append("[");
439                    SQL.Append(ziduan[i]);                    //update
440                    SQL.Append("]='");
441                    SQL.Append(msg[i]);
442                    SQL.Append("',");
443                }
444            }
445            SQL = SQL.Remove(SQL.Length-1,1);    //去掉最后一个 ","
446            SQL.Append(" where ");
447            SQL.Append(tiaojian);
448            
449            RunSql(SQL.ToString());
450            return true;
451        
452        }
453
454        "20071220增加的通过 FormTableCntrlInfo 保存数据的方法"#region "20071220增加的通过 FormTableCntrlInfo 保存数据的方法"
455        /**//// 
456        /// 添加记录。传入表名，FormTableCntrlInfo，返回新生成记录的ID
457        /// 
458        /// 要添加记录的表的名称
459        /// FormTableCntrlInfo
460        /// 
461        public   string InsertDataStr(string TableName  , FormTableCntrlInfo[] cInfo )
462        {
463            //添加数据    返回新添加的ID
464            System.Text.StringBuilder SQL = new System.Text.StringBuilder(300);
465            SQL.Append("insert into ");                    //insert into 
466            SQL.Append(TableName);
467            SQL.Append(" ([");
468            int i;
469            for( i = 0 ;i < cInfo.Length ;i++)        //字段
470            {
471                if (cInfo[i].FieldValue != "_n_")
472                {
473                    SQL.Append(cInfo[i].FieldName);
474                    SQL.Append("],[");
475                }
476            }
477            SQL = SQL.Remove(SQL.Length -2,2);
478
479            SQL.Append(")  values ('");
480
481            for( i = 0;i < cInfo.Length ;i++)
482            {
483                if (cInfo[i].FieldValue != "_n_")
484                {
485                    SQL.Append(cInfo[i].FieldValue);
486                    SQL.Append("','");
487                }
488            }
489            SQL = SQL.Remove(SQL.Length -2,2);
490
491            SQL.Append(")  select scope_identity() as a1");
492            
493            string re = RunSqlGetID(SQL.ToString());
494            SQL.Length = 1;
495            if (re == null)
496                return "-1";
497            else
498                return re;
499        }
500        
501        /**//// 
502        /// 修改记录。传入表名，FormTableCntrlInfo，修改条件
503        /// 
504        /// 要修改记录的表的名称
505        /// FormTableCntrlInfo
506        /// 条件 ，加在where 后面的语句
507        /// 
508        public bool UpdateData( string TableName ,FormTableCntrlInfo[] cInfo ,string tiaojian) 
509        {
510            System.Text.StringBuilder SQL = new System.Text.StringBuilder(300);
511            SQL.Append("update ");                    //update
512            SQL.Append(TableName);
513            SQL.Append(" set ");
514            int i;
515            for (i = 0 ;i< cInfo.Length ;i++)
516            {
517                if (cInfo[i].FieldValue != "_n_")
518                {
519                    SQL.Append("[");
520                    SQL.Append(cInfo[i].FieldName);                    //update
521                    SQL.Append("]='");
522                    SQL.Append(cInfo[i].FieldValue);
523                    SQL.Append("',");
524                }
525            }
526            SQL = SQL.Remove(SQL.Length-1,1);    //去掉最后一个 ","
527            SQL.Append(" where ");
528            SQL.Append(tiaojian);
529            
530            RunSql(SQL.ToString());
531            return true;
532        
533        }
534
535        #endregion
536        
537        #endregion
538