简介
sqlite简介
sqlite,是一款轻型的关系型数据库。它的设计目标是嵌入式。
它能够支持Windows/Linux/Unix等等主流的操作系统,同时能够跟很多程序语言相结合,比如 C++、C#、Object-C、PHP、Java等。
我是做手游开发的,在手机上使用sqlite 存储数据是很方便的。
System.Data.sqlite实践前期准备
- System.Data.sqlite 库下载,用于C#操作sqlite的dll文件。下载地址:http://system.data.sqlite.org/index.html/doc/trunk/www/downloads.wiki
- sqlite可视化工具下载,用于查看sqlite库数据表数据。下载地址:http://www.sqliteexpert.com/download.html
Tips:
1.根据自己的电脑是64bit或者32bit 以及使用的.NET Freamwork版本下载相应的的System.Data.sqlite。 下载解压文件如:
本文测试用的只有System.Data.sqlite.dll。对于sqlite库数据的增删改查已经足够用了。
2.sqlite数据库文件以.db为后缀。安装sqlite可视化工具后如图:
mydb是我测试用的数据库。
实践
对sqlite的增、删、改、查。
测试环境:VS2015 语言:C#
创建控制台新工程,引入System.Data.sqlite.dll文件。
1.编写sqlite 操作类,对sqlite数据操作进行封装为sqliteHelper,代码如下:
/// <summary> /// sqlite 操作类 </summary> class sqliteHelper { <summary> 数据库连接定义 </summary> private sqliteConnection dbConnection; sql命令定义 private sqliteCommand dbCommand; 数据读取定义 private sqliteDataReader dataReader; 构造函数 </summary> <param name="connectionString">连接sqlite库字符串</param> public sqliteHelper(string connectionString) { try { dbConnection = new sqliteConnection(connectionString); dbConnection.Open(); }catch(Exception e) { Log(e.ToString()); } } 执行sql命令 <returns>The query.</returns> <param name="queryString">sql命令字符串public sqliteDataReader ExecuteQuery(string queryString) { try { dbCommand = dbConnection.CreateCommand(); dbCommand.CommandText = queryString; dataReader = dbCommand.ExecuteReader(); }catch(Exception e) { Log(e.Message); } return dataReader; } 关闭数据库连接 public void CloseConnection() { //销毁Commend if(dbCommand !=null) { dbCommand.Cancel(); } dbCommand = null; 销毁Reader if(dataReader != null) { dataReader.Close(); } dataReader = 销毁Connection if(dbConnection != null) { dbConnection.Close(); } dbConnection = null; } 读取整张数据表 The full table.<param name="tableName">数据表名称public sqliteDataReader ReadFullTable(string tableName) { string queryString = "SELECT * FROM " + tableName; return ExecuteQuery(queryString); } 向指定数据表中插入数据 The values.</param> <param name="values">插入的数值public sqliteDataReader InsertValues(string tableName,string[] values) { 获取数据表中字段数目 int fieldCount = ReadFullTable(tableName).FieldCount; 当插入的数据长度不等于字段数目时引发异常 if (values.Length != fieldCount) { throw new sqliteException(values.Length!=fieldCount"); } INSERT INTO " + tableName + VALUES (" + '"+ values[0]+"; for (int i = 1; i < values.Length; i++) { queryString += ,"+values[i] + "; } queryString += )return ExecuteQuery(queryString); } 更新指定数据表内的数据 <param name="colNames">字段名<param name="colValues">字段名对应的数据<param name="key">关键字<param name="value">关键字对应的值<param name="operation">运算符:=,128);line-height:1.5;"><,>public sqliteDataReader UpdateValues(string[] colNames,255);line-height:1.5;">string[] colValues,255);line-height:1.5;">string key,255);line-height:1.5;">string value,255);line-height:1.5;">string operation==") { 当字段名称和字段数值不对应时引发异常 if (colNames.Length != colValues.Length) { colNames.Length!=colValues.LengthUPDATE SET " + colNames[0] + " + colValues[1; i < colValues.Length; i++) { queryString += " + colNames[i] + " + colValues[i] + WHERE " + key + operation + " + value + 删除指定数据表内的数据 public sqliteDataReader DeleteValuesOR(string[] operations) { if (colNames.Length != colValues.Length || operations.Length != colNames.Length || operations.Length != colValues.Length) { colNames.Length!=colValues.Length || operations.Length!=colNames.Length || operations.Length!=colValues.LengthDELETE FROM 0] + operations[OR " + colNames[i] + operations["; } public sqliteDataReader DeleteValuesAND( AND " + colNames[i] + operations[i] + 创建数据表 </summary> + The table.数据表名<param name="colTypes">字段名类型public sqliteDataReader CreateTable(string[] colTypes) { CREATE TABLE IF NOT EXISTS ( " " + colTypes[0]; 1; i < colNames.Length; i++) { queryString += " + colTypes[i]; } queryString += ) Reads the table. Table name.<param name="items">Items.Col names.<param name="operations">Operations.Col values.public sqliteDataReader ReadTable(string[] items,255);line-height:1.5;">string[] operations,255);line-height:1.5;">string[] colValues) { SELECT " + items[1; i < items.Length; i++) { queryString += " + items[i]; } queryString += FROM " + operations[0; i < colNames.Length; i++) { queryString += " + operations[i] + 本类log <param name="s"></param> static void Log(string s) { Console.WriteLine(class sqliteHelper:::" + s); } }
Tips:1.别忘了引入:using System.Data.sqlite;
2.引入System.Data.sqlite.dll的同时,需要将System.Data.sqlite.dll.config文件放在同级目录下。否则加载dll文件时报错。
class Program { private static sqliteHelper sql; void Main(string[] args) { sql = new sqliteHelper(data source=mydb.db"); 创建名为table1的数据表 sql.CreateTable(table1",255);line-height:1.5;">new string[] { IDNameAgeEmail" },0);line-height:1.5;">INTEGERTEXT" }); 插入两条数据 sql.InsertValues(string[]{1张三22Zhang@163.com" }); sql.InsertValues(2李四25Li4@163.com" }); 更新数据,将Name="张三"的记录中的Name改为"Zhang3" sql.UpdateValues(ZhangSanZhang3"); 删除Name="张三"且Age=26的记录,DeleteValuesOR方法类似 sql.DeleteValuesAND(" }); 读取整张表 sqliteDataReader reader = sql.ReadFullTable("); while (reader.Read()) { 读取ID Log(""+reader.GetInt32(reader.GetOrdinal("))); 读取Name Log(""+reader.GetString(reader.GetOrdinal(读取Age Log(读取Email Log(reader.GetString(reader.GetOrdinal("))); } while (true) { Console.ReadLine(); } } ""+s); } }