连接sqlite数据库操作C#版

最近几天在讨论游戏本地数据存储方式，考虑到跨平台性。最开始打算用xml，但是考虑到xml文件多而杂，而且后期游戏更新。也不是很方便，于是提出了采用sqlite，可是没想到的是原本信心满满的我却遭到了闭门羹，呵呵....原来，不是用 以前做c# winform应用那套dll，unity3d有自己对应的sqlite.dll分别需要三个文件1.Mono.Data.sqlite.dll 在unity安装文件“\Editor\Data\MonoBleedingEdge\lib\mono”可以找到，注意mono文件夹下面 有对应版本号，可以根据自己的项目来决定选择。2.System.Data.dll 同上位置一样可以找到 ，不过建议使用2.0版本3.sqlite3.dll 就在\Unity\Editor下可以找到除此之外，还需要把这3个文件放在你的项目的这个路径下面：\Assets\Plugins\，没有Plugins文件夹就必须创建这个文件夹，然后将这三个dll文件放在该文件夹下面。当然，如果你想能够在PC上面发布成可执行文件，还需要改动一些地方。在unity3d中的Play Setting ->Other Setting 中将Api Compatibility的等级改为.NET 2.0;那么这些操作做完了以后，如果你的代码写得没有问题，那么你就可以成功了。好啦 ，前面准工作完成 下面就直接看测试代码吧首先是一个 sqlite的数据库操作类，该类是我改编的 网上也有很多，不过好像是js编写，于是自己动手改编成了c#希望能对大家有用，呵呵...好了，上类 sqliteDbHelper：using UnityEngine;using System.Collections;//导入sqlite数据集，也就是Plugins文件夹下的那个dll文件using Mono.Data.sqlite;using System;//数据集 是formwork2.0 用vs开发要自己引用框架中的System.Datausing System.Data;public class sqliteDbHelper{ /// /// 声明一个连接对象 /// private sqliteConnection dbConnection; /// /// 声明一个操作数据库命令 /// private sqliteCommand dbCommand; /// /// 声明一个读取结果集的一个或多个结果流 /// private sqliteDataReader reader; /// /// 数据库的连接字符串，用于建立与特定数据源的连接 /// /// 数据库的连接字符串，用于建立与特定数据源的连接 public sqliteDbHelper (string connectionString) { OpenDB (connectionString); Debug.Log(connectionString); } public void OpenDB (string connectionString) { try { dbConnection = new sqliteConnection (connectionString); dbConnection.open(); Debug.Log ("Connected to db"); } catch(Exception e) { string temp1 = e.ToString(); Debug.Log(temp1); } } /// /// 关闭连接 /// public void ClosesqlConnection () { if (dbCommand != null) { dbCommand.dispose(); } dbCommand = null; if (reader != null) { reader.dispose (); } reader = null; if (dbConnection != null) { dbConnection.Close (); } dbConnection = null; Debug.Log ("disconnected from db."); } /// /// 执行查询sqlite语句操作 /// /// /// public sqliteDataReader ExecuteQuery (string sqlQuery) { dbCommand = dbConnection.CreateCommand (); dbCommand.CommandText = sqlQuery; reader = dbCommand.ExecuteReader (); return reader; } /// /// 查询该表所有数据 /// /// 表名 /// public sqliteDataReader ReadFullTable (string tableName) { string query = "SELECT * FROM " + tableName; return ExecuteQuery (query); } /// /// 动态添加表字段到指定表 /// /// 表名 /// 字段集合 /// public sqliteDataReader InsertInto (string tableName,string[] values) { string query = "INSERT INTO " + tableName + " VALUES (" + values[0]; for (int i = 1; i < values.Length; ++i) { query += "," + values; } query += ")"; return ExecuteQuery (query); } /// /// 动态更新表结构 /// /// 表名 /// 字段集 /// 对于集合值 /// 要查询的字段 /// 要查询的字段值 /// public sqliteDataReader UpdateInto (string tableName,string []cols,string []colsvalues,string selectkey,string selectvalue) { string query = "UPDATE "+tableName+" SET "+cols[0]+" = "+colsvalues[0]; for (int i = 1; i < colsvalues.Length; ++i) { query += "," +cols+" ="+ colsvalues; } query += " WHERE "+selectkey+" = "+selectvalue+" "; return ExecuteQuery (query); } /// /// 动态删除指定表字段数据 /// /// 表名 /// 字段 /// 字段值 /// public sqliteDataReader Delete(string tableName,string []colsvalues) { string query = "DELETE FROM "+tableName + " WHERE " +cols[0] +" = " + colsvalues[0]; for (int i = 1; i < colsvalues.Length; ++i) { query += " or " +cols+" = "+ colsvalues; } Debug.Log(query); return ExecuteQuery (query); } /// /// 动态添加数据到指定表 /// /// 表名 /// 字段 /// 值 /// public sqliteDataReader InsertIntoSpecific (string tableName,string[] cols,string[] values) { if (cols.Length != values.Length) { throw new sqliteException ("columns.Length != values.Length"); } string query = "INSERT INTO " + tableName + "(" + cols[0]; for (int i = 1; i < cols.Length; ++i) { query += "," + cols; } query += ") VALUES (" + values[0]; for (int i = 1; i < values.Length; ++i) { query += "," + values; } query += ")"; return ExecuteQuery (query); } /// /// 动态删除表 /// /// 表名 /// public sqliteDataReader DeleteContents (string tableName) { string query = "DELETE FROM " + tableName; return ExecuteQuery (query); } /// /// 动态创建表 /// /// 表名 /// 字段 /// 类型 /// public sqliteDataReader CreateTable (string name,string[] col,string[] colType) { if (col.Length != colType.Length) { throw new sqliteException ("columns.Length != colType.Length"); } string query = "CREATE TABLE " + name + " (" + col[0] + " " + colType[0]; for (int i = 1; i < col.Length; ++i) { query += "," + col + " " + colType; } query += ")"; Debug.Log(query); return ExecuteQuery (query); } /// /// 根据查询条件 动态查询数据信息 /// /// 表 /// 查询数据集合 /// 字段 /// 操作 /// 值 /// public sqliteDataReader SelectWhere (string tableName,string[] items,string[] operation,string[] values) { if (col.Length != operation.Length || operation.Length != values.Length) { throw new sqliteException ("col.Length != operation.Length != values.Length"); } string query = "SELECT " + items[0]; for (int i = 1; i < items.Length; ++i) { query += "," + items; } query += " FROM " + tableName + " WHERE " + col[0] + operation[0] + "'" + values[0] + "' "; for (int i = 1; i < col.Length; ++i) { query += " AND " + col + operation + "'" + values[0] + "' "; } return ExecuteQuery (query); }}复制代码好了 sqlite数据操作类写好后：本来应该按照编码规范来写 因为我本身以前做c#的所有一般使用三层架构Modle实例化对象类 ，DAl数据处理类，IDal数据接口类，Bll业务逻辑类但是呢，目前只为测试 因此我就不一一详细介绍代码内容了，相信会c#的人都会三层架构，呵呵ok，言归正传，下面将贴出unity3d 使用上面sqliteDbHelper操作类sqliteDbTest：using UnityEngine;using System.Collections;using System;using Mono.Data.sqlite;using System.Data;public class sqliteDbTest : MonoBehavIoUr {sqliteDbHelper db ;int id=1;void Start (){ db = new sqliteDbHelper("Data Source=./sqlite.db"); Debug.Log(db.ToString()); /* sqlite@R_797_4044@ db = new sqlite@R_797_4044@("data source=mydb1.db"); db.CreateTable("momo",new string[]{"name","qq","email","blog"},new string[]{"text","text","text"}); db.ClosesqlConnection(); */ } public string name = ""; public string emls = "";void OnGUI(){ if(GUILayout.Button("create table")) { db.CreateTable("mytable",new string[]{"id","name","email"},new string[]{"int","varchar(20)","varchar(50)"}); Debug.Log("create table ok"); } if(GUILayout.Button("insert data")) { db.InsertInto("mytable",new string[] { "" + (++id),"'随风去旅行"+id+"'","'zhangj_live"+id+"@163.com'"});//),"'aaa"+id+"'","'aaa"+id+"@sohu.com'"}); Debug.Log("insert table ok"); } if(GUILayout.Button("search database")) { IDataReader sqReader = db.SelectWhere("mytable",new string[] {"name",new string[]{"id"},new string[]{"="},new string[]{"2"}); while (sqReader.Read()) { //Debug.Log( name= "name="+sqReader.GetString(sqReader.Getordinal("name"));// + emls = "email=" + sqReader.GetString(sqReader.Getordinal("email")); //); } } if (name != "") { GUI.Label(new Rect(100,100,100),name); GUI.Label(new Rect(100,200,emls); // GUILayout.Label(emls); } if(GUILayout.Button("close database")) { db.ClosesqlConnection(); Debug.Log("close table ok"); }}}复制代码上面的代码很简单 ，相信稍微懂点unity3d的，都能看懂 因此就小偷懒一般 没写注释了，呵呵运行结果： 由此可以看出 分别实现了1.动态创建数据库及表结构2.动态创加入数据3,.查询指定字段4.关闭数据连接好了，为了更好的证实我们去创建的数据库看看sqlite.db就是我们动态创建的数据库 用工具打开数据库 ，可以看到我们建好的表“mytable”及字段 切换选项，在数据选项中可以清楚看到我们动态插入的记录 好了，该文先总结于此