我的数据访问函数库的源代码（二）—— SQL语句部分

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了我的数据访问函数库的源代码（二）—— SQL语句部分，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含18600字，纯文字阅读大概需要27分钟。

内容图文

数据访问函数库 —— 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

内容总结

以上是互联网集市为您收集整理的我的数据访问函数库的源代码（二）—— SQL语句部分全部内容，希望文章能够帮你解决我的数据访问函数库的源代码（二）—— SQL语句部分所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

---