[转载]C#使用 SQLite 数据库 开发的配置过程及基本操作类,实例程序:工商银行贵金属行情查看小工具 - vicky liang - 博客园

[转载]C#使用 SQLite 数据库 开发的配置过程及基本操作类,实例程序:工商银行贵金属行情查看小工具 – vicky liang – 博客园.

–首发于博客园, 转载请保留此链接  博客原文地址

本文运行环境: Win7 X64, VS2010

1. SQLite 的优点:

SQLite 是一款轻型数据库,开发包只有十几M, 相对于 MSSQL 几个 G 的体积来说简直是小 Case, 而且在打包成的软件里只需要添加相关的 DLL 就可以在其他的电脑运行,这一点来说比 Access 数据库还要来得方便。

SQLite虽然很小巧,但是支持的SQL语句不会太逊色于其他开源数据库。

更多详情参见百科:SQLite

2. 开发包下载

SQLite 官方下载网址

本文所用开发包:sqlite-netFx40-setup-bundle-x86-2010-1.0.93.0.exe 

3. VS 2010 使用 SQLite

3.1 安装 SQLite

3.1.1. 安装部件有3个选项:Full installation(完全安装), Compact installation(精简安装), Custom installation(自定义安装), 本文所选为 Full installation

3.1.2 默认为不勾选 Instatll the designer components for Visual Studio 2010, 可以把这个选上

 

3.1.2 先在本地创建一个空白文件,扩展名为*.db,

添加 SQLite 连接: Server Explorer -> Data Connections -> Add Connection …

Data Source 为 SQLite Database file

由于表结构一般是一次性创作,所以添加数据库后使用视图直接建立数据表结构,不必使用代码创建

3.1.3 添加 SQLite 引用

Solution Explorer -> Reference -> Add Reference…        找到SQLite 安装路径添加 System.Data.SQLite.dll 引用

该类库包含SQLiteConnection , SQLiteCommand,SQLiteDataAdapter 等连接操作数据库需要的类

3.1.4 新建 SQLiteHelper 类,主要是db 连接的基本信息,如路径,以及一些数据表的基本操作方法(根据个人需要):

1 public class SQLiteHelper
2 {
3 public SQLiteConnection Connection
4 {
5 get
6 {
7 if (_cn == null)
8 {
9 Settings settings = new Settings();
10 string connection = settings.Connection.ToString();
11 _cn = new SQLiteConnection(connection);
12 }
13 return _cn;
14 }
15 }
16
17 private SQLiteConnection _cn = null;
18
19 public DataTable GetDataTable(string query)
20 {
21 DataTable dt = new DataTable();
22 try
23 {
24 Connection.Open();
25 GetAdapter(query).Fill(dt);
26 }
27 catch
28 { }
29 finally
30 {
31 Connection.Close();
32 }
33 return dt;
34 }
35
36 public bool Update(string tableName, DataTable dt)
37 {
38 try
39 {
40 Connection.Open();
41 string tableStructureQuery = string.Format("SELECT * FROM {0} WHERE 1 = 0", tableName);
42 SQLiteDataAdapter da = GetAdapter(tableStructureQuery);
43 da.Update(dt);
44 }
45 catch (Exception ex)
46 {
47 MessageBox.Show(ex.Message);
48 }
49 finally
50 {
51 Connection.Close();
52 }
53 return true;
54 }
55
56 public SQLiteDataAdapter GetAdapter(string query)
57 {
58 SQLiteCommand selectCommand = new SQLiteCommand(query, Connection);
59 SQLiteDataAdapter adapter = new SQLiteDataAdapter(selectCommand);
60 SQLiteCommandBuilder sb = new SQLiteCommandBuilder(adapter);
61 return adapter;
62 }
63
64 public bool ExecuteScript(string query)
65 {
66 try
67 {
68 SQLiteCommand selectCommand = new SQLiteCommand(query, Connection);
69 Connection.Open();
70 selectCommand.ExecuteNonQuery();
71 }
72 catch
73 {
74 return false;
75 }
76 finally
77 {
78 Connection.Close();
79 }
80
81 return true;
82 }
83 }
84
85 public static class DataViewHelper
86 {
87 public static DataView Clone(this DataView source, string filter)
88 {
89 if (source == null)
90 {
91 throw new ApplicationException("Source cannot be null");
92 }
93
94 DataView newView = new DataView(source.Table);
95
96 string viewfilter = source.RowFilter;
97
98 List filters = new List();
99 if (!string.IsNullOrEmpty(viewfilter))
100 filters.Add(string.Format("({0})", viewfilter));
101 if (!string.IsNullOrEmpty(filter))
102 filters.Add(string.Format("({0})", filter));
103
104 newView.RowFilter = string.Join(" AND ", filters.ToArray());
105
106 return newView;
107 }
108
109 public static DataView Clone(this DataView source)
110 {
111 return source.Clone(string.Empty);
112 }
113 }

(1) 其中 Setting.Connection 为 string 类型,只需要指定 db 路径,本文 Connection 为: Data Source=D:\Trade\Trade\DB\Quotation.db

这里提一下 MSSQL 的 连接字符串以示比较,一般情况下 MSSQL 的连接为ConnectionString 类型的配置节点,如:

<add name=”Test” connectionString=”Data Source=ServerName;Initial Catalog=dbName;User ID=xxx;Password=***;”
providerName=”System.Data.SqlClient” />

(2) 可以看到数库表的操作方法 与 其他数据库操作 类似:连接,运行操作命令,关闭

(3) 笔者尝试添加一个 SQLiteParameter.Direction 为 ParameterDirection.Output 的参数 但报错,至今没找到正确的使用方法

(4) 使用 SQLiteConnection 可以用 using 的方式使用,有利于程序内存管理及垃圾回收

3.1.5 新建 DAO 类,继承 SQLiteHelper ,主要是针对具体表 的方法:

1 public class DAO : SQLiteHelper
2 {
3 public DAO(string tableName)
4 {
5 TableName = tableName;
6 }
7 public string SelectTableQuery { get { return "SELECT * FROM " + TableName; } }
8
9 public string TableStructureQuery { get { return SelectTableQuery + " WHERE 1=0"; } }
10
11 public int GetMaxID(string fieldName)
12 {
13 SQLiteHelper helper = new SQLiteHelper();
14 StringBuilder commandText = new StringBuilder();
15 commandText.AppendLine(string.Format(@"SELECT MAX({0}) ", fieldName));
16 commandText.AppendLine(string.Format(@" FROM {0} ", TableName));
17 DataTable dt = helper.GetDataTable(commandText.ToString());
18 if (dt.Rows.Count == 0)
19 return 0;
20 else
21 return int.Parse(dt.Rows[0][0].ToString());
22 }
23
24 public string TableName { get; set; }
25
26 internal DataTable GetDataTableStructor()
27 {
28 return GetDataTable(TableStructureQuery);
29 }
30
31 public bool Update(DataTable dt)
32 {
33 return base.Update(TableName, dt);
34 }
35 }

4. SQLite 实例小程序

Quotation 小程序是用于查看工商银行贵金属报价的小工具(这里只更新纸黄金报价),工行贵金属报价官方网址

用户可以随时查看报价,设置 更新频率(默认更新周期为 120 s )。

下载的报价数据保存到 quotation.db 里,同时用户可以上传个人贵金属账户交易记录。

根据交易记录设置个人买卖差价,选择是否播放音乐提醒用户买入卖出,适用于贵金属短线投资辅助小工具。

 

4.1 使用方法:

4.1.1 下载:Quotation  Setup 和 db 文件 ( setup 文件用 VS 自带工具打包好的MSI 文件 非源代码 )

4.1.2 安装 Setup 文件, PS: 想要了解 db 结构的读者可以用 VS 或其他 SQLite 命令、视图软件查看

4.1.3 更改配置文件,打开 Trade.exe.config , 修改 节点:

<setting name=”Connection” serializeAs=”String”>
<value>Data Source=D:\Trade\Trade\DB\Quotation.db</value>
</setting>

其中 <value>Data Source = db path</value> 是 Quotation.db 的存放路径,注意如果软件安装在 C 盘保存时可能提示无法访问,这时可以把 .config 文件复制出来修改后再替换原来的文件

4.1.4 从 <Load Trx> 菜单命令导入从工行下载好的 txt 文件(不要更改格式)用于比较差价, <Transactions> 查看导入的交易记录,无效的交易记录可以选中后 Transactions -> Close 来关闭记录。

4.1.5 小程序为笔者个人开发,用于学习交流,个人免费使用,著作权解释权归软件作者所有,任何人不得进行反编译及以此向他人收取任何费用,欢迎读者留言提出意见和建议。

4.1.6 程序截图

赞(0) 打赏
分享到: 更多 (0)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏