【C#进阶】SQLite数据库工具类SQLHelper封装

admin

主要代码如下，分为了三种获取数据的方式：1.执行查询（多个参数）， 可变参数的使用（返回受到影响的行数）
2.获取首行首列值得方法(object就是System.Object的别称，string等价于System.String，int等价于System.Int32)
3.获得查询结果集

1. using System;
   
2. using System.Collections.Generic;
   
3. using System.Linq;
   
4. using System.Text;
   
5. using System.Threading.Tasks;
   
6. 
   
7. //导入命名空间
   
8. using System.Configuration;
   
9. using System.Data.SQLite;
   
10. using System.Data;
    
11. 
    
12. namespace _01复习
    
13. {
    
14.     //封装成为一个工具类
    
15.     public static class SqliteHelper
    
16.     {
    
17.         //从配置文件中读取链接字符串
    
18.         private static string connStr = ConfigurationManager.ConnectionStrings["itcasterCater"].ConnectionString;
    
19. 
    
20.         //执行命令的三个方法：insert, update, delete
    
21.         //1.执行查询（多个参数）， 可变参数的使用（返回受到影响的行数）
    
22.         public static int ExecuteNonQuery(string sql, params SQLiteParameter[] ps)
    
23.         {
    
24.             using (SQLiteConnection conn = new SQLiteConnection(connStr))
    
25.             {
    
26.                 //创建Command对象
    
27.                 SQLiteCommand cmd = new SQLiteCommand(sql, conn);
    
28.                 //添加参数
    
29.                 cmd.Parameters.AddRange(ps);
    
30. 
    
31.                 //打开链接
    
32.                 conn.Open();
    
33.                 //执行命令，返回收到影响的行数
    
34.                 return cmd.ExecuteNonQuery();
    
35.             }
    
36.         }
    
37. 
    
38. 
    
39.         //2.获取首行首列值得方法(object就是System.Object的别称，string等价于System.String，int等价于System.Int32)
    
40.         public static object ExecuteScalar(string sql, params SQLiteParameter[] ps)
    
41.         {
    
42.             using (SQLiteConnection conn = new SQLiteConnection(connStr))
    
43.             {
    
44.                 SQLiteCommand cmd = new SQLiteCommand(sql, conn);
    
45.                 cmd.Parameters.AddRange(ps);
    
46. 
    
47.                 conn.Open();
    
48.                 //执行命令，获得查询结果中的首行首列值，并且返回
    
49.                 return cmd.ExecuteScalar();
    
50.             }
    
51.         }
    
52. 
    
53.         //3.获得结果集
    
54.         public static DataTable GetDataTable(string sql, params SQLiteParameter []ps)
    
55.         {
    
56.             using (SQLiteConnection conn = new SQLiteConnection(connStr))
    
57.             {
    
58.                 //构造适配器对象
    
59.                 SQLiteDataAdapter adapter = new SQLiteDataAdapter(sql, conn);
    
60.                 //构造数据表， 用于接收查询结果
    
61.                 DataTable dt = new DataTable();
    
62.                 //添加参数
    
63.                 adapter.SelectCommand.Parameters.AddRange(ps);
    
64.                 //执行结果
    
65.                 adapter.Fill(dt);
    
66. 
    
67.                 //返回结果集
    
68.                 return dt;
    
69.             }
    
70.         }
    
71. 
    
72. 
    
73.     }
    
74. 
    
75. 
    
76. }
    

复制代码

xcycoming

感谢分享

千江水

路过~