IDE: VS2005
语言: C#
组件:sqlite-netFx20-setup-bundle-x86-2005-1.0.92.0
简介:
本示例使用sqlite的密码、外键功能。以及关闭临时文件(journal mode=Off)。
通过查询和插入(修改、删除)来演示C#使用sqlite的实用性。
一、设计窗体
拖拽2个TextBox、2个Button、1个DataGridView、1个sqliteConnection、1个sqliteCommand
设置sqliteCommand的Connection属性为sqliteConnection
完整的窗体:
二、功能实现
1. 查询
(1)设置数据桥
dataAdapter = new sqliteDataAdapter(sqliteCommand1);
(2)设置缓存器
cmdBuilder = new sqliteCommandBuilder(dataAdapter);
(3)建立数据表
table = new DataTable(tblName);
(4)连接数据表
dataAdapter.Fill(table);
(5)指定数据源
dataGridView1.DataSource = table;
为了定位表的名称,我们使用查找特定的关键字:from。
int iPos = statementStr.LastIndexOf("from") + 5; String tblName = statementStr.Substring(iPos,(statementStr.Length - 1) - iPos);
2. 插入
按照行来分解Insert语句;也可以执行Update、Delete等语句。
int i = edtStmt.Lines.Length; for (int j = 0; j < i; j++) { String strSta = edtStmt.Lines[j].ToString(); sqliteCommand1.CommandText = strSta; sqliteCommand1.ExecuteNonQuery(); }
三、源代码
Form1.cs
using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Text; using System.Windows.Forms; using System.IO; using System.Data.sqlite; namespace testsqlite { public partial class Form1 : Form { private DataTable table; private sqliteDataAdapter dataAdapter; private sqliteCommandBuilder cmdBuilder; private String strFmt,connStr; private String currDir; public Form1() { InitializeComponent(); currDir = Directory.GetCurrentDirectory(); strFmt = "data source=\"" + currDir + "/{0}\"" + ";page size=32768;" + "cache size=0;" + "Password=20130321;" + "foreign keys=True;" + "journal mode=Off"; } private void btnExec_Click(object sender,EventArgs e) { if (edtStmt.Text.ToLower().IndexOf("insert") < 0) return; connStr = string.Format(strFmt,edtDB.Text); // sqliteConnection1.Close(); sqliteConnection1.ConnectionString = connStr; sqliteConnection1.Open(); int i = edtStmt.Lines.Length; for (int j = 0; j < i; j++) { String strSta = edtStmt.Lines[j].ToString(); sqliteCommand1.CommandText = strSta; sqliteCommand1.ExecuteNonQuery(); } MessageBox.Show("Insert Done"); } private void btnSearch_Click(object sender,EventArgs e) { if (edtStmt.Text.IndexOf(";") < 0) { MessageBox.Show("Please enter a sql statement terminator - ';'"); return; } connStr = string.Format(strFmt,edtDB.Text); String statementStr = edtStmt.Text.ToLower(); int iPos = statementStr.LastIndexOf("from") + 5; String tblName = statementStr.Substring(iPos,(statementStr.Length - 1) - iPos); sqliteConnection1.Close(); sqliteConnection1.ConnectionString = connStr; sqliteConnection1.Open(); sqliteCommand1.CommandText = edtStmt.Text; dataAdapter = new sqliteDataAdapter(sqliteCommand1); cmdBuilder = new sqliteCommandBuilder(dataAdapter); table = new DataTable(tblName); dataAdapter.Fill(table); dataGridView1.DataSource = table; } } }