原文:http://forum.unity3d.com/threads/28500-SQLite-Class-Easier-Database-Stuff
原始文章主要是使用JavaScript语言建立本地数据库
以前在开发中一直使用IOS源生的数据库,通过传递消息的形式在与Unity3D中进行交互。本文我在详细说说如何使用C#语言来在MAC 操作系统下创建Unity本地数据库,我是C#控哇咔咔~~~
首先你需要得到Mono.Data.Sqlite.dll 文件 与System.Data.dll文件。如果你在Mac 操作系统下使用Unity那么很悲剧,找不到这两个文件,至少我没能找到。后来我在Windows下的Unity安装路径中找到了它。为了方便大家我将这两个文件上传至网盘中,如果没有这两个文件的朋友请下载。
下载地址:http://vdisk.weibo.com/s/abG7k
.zip文件下载完毕后直接解压,然后将Mono.Data.Sqlite.dll 文件 与System.Data.dll文件放在Unity工程中的Assets文件夹中。如下图所示,两个文件已经放置在Project视图当中。
Ok ,我们编写C#脚本,原始文章没有Unity数据库更新与删除的方法,我在这里加上更新与删除的方法,方便大家开发时使用。因为其实Unity中更新与删除数据库也是个比较重要的功能。
注意:下面脚本不要绑定在任何游戏对象身上,大家无需把它当作脚本可以当作一个工具类来使用。
using UnityEngine;
using System;
using System.Collections;
using Mono.Data.Sqlite;
public class DbAccess
{
private SqliteConnection dbConnection;
private SqliteCommand dbCommand;
private SqliteDataReader reader;
public DbAccess (string connectionString)
{
OpenDB (connectionString);
}
public DbAccess ()
{
}
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.");
}
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[i];
}
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[i]+" ="+ colsvalues[i];
}
query += " WHERE "+selectkey+" = "+selectvalue+" ";
return ExecuteQuery (query);
}
public SqliteDataReader Delete(string tableName,string []cols,string []colsvalues)
{
string query = "DELETE FROM "+tableName + " WHERE " +cols[0] +" = " + colsvalues[0];
for (int i = 1; i < colsvalues.Length; ++i) {
query += " or " +cols[i]+" = "+ colsvalues[i];
}
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[i];
}
query += ") VALUES (" + values[0];
for (int i = 1; i < values.Length; ++i) {
query += ", " + values[i];
}
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[i] + " " + colType[i];
}
query += ")";
return ExecuteQuery (query);
}
public SqliteDataReader SelectWhere (string tableName, string[] items, string[] col, 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[i];
}
query += " FROM " + tableName + " WHERE " + col[0] + operation[0] + "'" + values[0] + "' ";
for (int i = 1; i < col.Length; ++i) {
query += " AND " + col[i] + operation[i] + "'" + values[0] + "' ";
}
return ExecuteQuery (query);
}
}
首先是创建本地数据库,我们创建C#脚本Test.cs直接绑定在摄像机中。
using UnityEngine;
using System.Collections;
public class Test : MonoBehaviour
{
void Start ()
{
//创建数据库名称为xuanyusong.db
DbAccess db = new DbAccess("data source=xuanyusong.db");
//创建数据库表,与字段
db.CreateTable("momo",new string[]{"name","qq","email","blog"}, new string[]{"text","text","text","text"});
//关闭对象
db.CloseSqlConnection();
}
}
运行游戏后,数据库对象会自动生成在项目的根目录中。查看数据库的软件我使用的是Navicat Premium,如果没有请大家下载,然后继续。如下图所示,数据库文件xuanyusong.db已经生成在项目的根目录中,接着我使用Navicat Premium软件将这个数据库打开。数据库的表名为momo 打开表后字段包含name、 qq 、email、 blog。都是我们在代码中创建的。
(点击查看大图)
OK,我们继续。首先是插入数据,记得将编码修改成UTF-16 不然中文会乱码。
using UnityEngine;
using System.Collections;
public class Test : MonoBehaviour
{
void Start ()
{
//创建数据库名称为xuanyusong.db
DbAccess db = new DbAccess("data source=xuanyusong.db");
//请注意 插入字符串是 已经要加上'宣雨松' 不然会报错
db.InsertInto("momo", new string[]{ "'宣雨松'","'289187120'","'xuanyusong@gmail.com'","'www.xuanyusong.com'" });
db.CloseSqlConnection();
}
}
接着是更新数据。UpdateInto是我新写的方法,接受更新多条数据。
using UnityEngine;
using System.Collections;
public class Test : MonoBehaviour
{
void Start ()
{
//创建数据库名称为xuanyusong.db
DbAccess db = new DbAccess("data source=xuanyusong.db");
db.UpdateInto("momo",new string[]{"name","qq"},new string[]{"'xuanyusong'","'11111111'"}, "email", "'xuanyusong@gmail.com'" );
db.CloseSqlConnection();
}
}
然后是删除数据DELETE也是我封装的方法。
using UnityEngine;
using System.Collections;
public class Test : MonoBehaviour
{
void Start ()
{
//创建数据库名称为xuanyusong.db
DbAccess db = new DbAccess("data source=xuanyusong.db");
//请注意 插入字符串是 已经要加上'宣雨松' 不然会报错
db.CreateTable("momo",new string[]{"name","qq","email","blog"}, new string[]{"text","text","text","text"});
//我在数据库中连续插入三条数据
db.InsertInto("momo", new string[]{ "'宣雨松'","'289187120'","'xuanyusong@gmail.com'","'www.xuanyusong.com'" });
db.InsertInto("momo", new string[]{ "'雨松MOMO'","'289187120'","'000@gmail.com'","'www.xuanyusong.com'" });
db.InsertInto("momo", new string[]{ "'哇咔咔'","'289187120'","'111@gmail.com'","'www.xuanyusong.com'" });
//然后在删掉两条数据
db.Delete("momo",new string[]{"email","email"}, new string[]{"'xuanyusong@gmail.com'","'000@gmail.com'"} );
db.CloseSqlConnection();
}
}
最后是查找数据。
using UnityEngine;
using System.Collections;
using Mono.Data.Sqlite;
public class Test : MonoBehaviour
{
void Start ()
{
//创建数据库名称为xuanyusong.db
DbAccess db = new DbAccess("data source=xuanyusong.db");
//请注意 插入字符串是 已经要加上'宣雨松' 不然会报错
db.CreateTable("momo",new string[]{"name","qq","email","blog"}, new string[]{"text","text","text","text"});
//我在数据库中连续插入三条数据
db.InsertInto("momo", new string[]{ "'宣雨松'","'289187120'","'xuanyusong@gmail.com'","'www.xuanyusong.com'" });
db.InsertInto("momo", new string[]{ "'雨松MOMO'","'289187120'","'000@gmail.com'","'www.xuanyusong.com'" });
db.InsertInto("momo", new string[]{ "'哇咔咔'","'289187120'","'111@gmail.com'","'www.xuanyusong.com'" });
//然后在删掉两条数据
db.Delete("momo",new string[]{"email","email"}, new string[]{"'xuanyusong@gmail.com'","'000@gmail.com'"} );
//注解1
SqliteDataReader sqReader = db.SelectWhere("momo",new string[]{"name","email"},new string[]{"qq"},new string[]{"="},new string[]{"289187120"});
while (sqReader.Read())
{
Debug.Log(sqReader.GetString(sqReader.GetOrdinal("name")) + sqReader.GetString(sqReader.GetOrdinal("email")));
}
db.CloseSqlConnection();
}
}
注解1:这里的结构非常像安卓的数据库指针,然后while循环把每一条数据都取出来。 sqReader.Gerordinal()方法就是拿到对应列名称的数据。如下图所示,经过一些列的添加与删除的操作最后数据库的内容如下。
如下图所示,我使用Log也将数据库name 与 email的字段打印了出来。最后我在强调一点,我们在OnStart方法中db.CreateTable创建数据库表,如果重复创建系统会抛出错误。避免这个情况请保证你的数据库表只会被创建一次。祝大家学习愉快嘎嘎嘎~~~
留言中看到有朋友说报错,那么MOMO将我的工程打包,提供下在地址
Unity 使用SQLite本地数据库的下载地址如下:http://vdisk.weibo.com/s/abGmB
如下图所示,请先在PlaySettings中修改Api Compatibility Level 改成.NET 2.0,如果不修改会报错
注意:Error building Player: Extracting referenced dlls failed.
无论你编译任何平台都请修改一下这里, 留言中有朋友在编译PC平台中 因为没有修改这里导致无法编译成功。。
IOS平台SQLite的使用:
然后需要修改Test.cs的脚本,在修改一下数据库保存的路径,我们将数据库放在沙盒当中。这样IOS中才可以读取数据库。
using UnityEngine;
using System.Collections;
using Mono.Data.Sqlite;
public class Test : MonoBehaviour
{
void Start ()
{
//数据库文件储存地址
string appDBPath = Application.persistentDataPath + "/xuanyusong.db";
DbAccess db = new DbAccess(@"Data Source=" + appDBPath);
//请注意 插入字符串是 已经要加上'宣雨松' 不然会报错
db.CreateTable("momo",new string[]{"name","qq","email","blog"}, new string[]{"text","text","text","text"});
//我在数据库中连续插入三条数据
db.InsertInto("momo", new string[]{ "'宣雨松'","'289187120'","'xuanyusong@gmail.com'","'www.xuanyusong.com'" });
db.InsertInto("momo", new string[]{ "'雨松MOMO'","'289187120'","'000@gmail.com'","'www.xuanyusong.com'" });
db.InsertInto("momo", new string[]{ "'哇咔咔'","'289187120'","'111@gmail.com'","'www.xuanyusong.com'" });
//然后在删掉两条数据
db.Delete("momo",new string[]{"email","email"}, new string[]{"'xuanyusong@gmail.com'","'000@gmail.com'"} );
//注解1
using (SqliteDataReader sqReader = db.SelectWhere("momo",new string[]{"name","email"},new string[]{"qq"},new string[]{"="},new string[]{"289187120"}))
{
while (sqReader.Read())
{
//目前中文无法显示
Debug.Log(sqReader.GetString(sqReader.GetOrdinal("name")));
Debug.Log(sqReader.GetString(sqReader.GetOrdinal("email")));
}
sqReader.Close();
}
db.CloseSqlConnection();
}
}
下面开始打包成IOS版本,直接运行如下图所示,已经在XCODE的控制台中将字符串信息打印出来。目前我不知道如何读取中文,但是可以确定的是中文信息已经写入数据库中。不信大家可以打开沙盒看看。
using UnityEngine;
using System.Collections;
using Mono.Data.Sqlite;
public class Test : MonoBehaviour
{
void Start ()
{
//数据库文件储存地址
string appDBPath = Application.persistentDataPath + "/xuanyusong.db";
//注意!!!!!!!这行代码的改动
DbAccess db = new DbAccess("URI=file:" + appDBPath);
//请注意 插入字符串是 已经要加上'宣雨松' 不然会报错
db.CreateTable("momo",new string[]{"name","qq","email","blog"}, new string[]{"text","text","text","text"});
//我在数据库中连续插入三条数据
db.InsertInto("momo", new string[]{ "'宣雨松'","'289187120'","'xuanyusong@gmail.com'","'www.xuanyusong.com'" });
db.InsertInto("momo", new string[]{ "'雨松MOMO'","'289187120'","'000@gmail.com'","'www.xuanyusong.com'" });
db.InsertInto("momo", new string[]{ "'哇咔咔'","'289187120'","'111@gmail.com'","'www.xuanyusong.com'" });
//然后在删掉两条数据
db.Delete("momo",new string[]{"email","email"}, new string[]{"'xuanyusong@gmail.com'","'000@gmail.com'"} );
//注解1
using (SqliteDataReader sqReader = db.SelectWhere("momo",new string[]{"name","email"},new string[]{"qq"},new string[]{"="},new string[]{"289187120"}))
{
while (sqReader.Read())
{
Debug.Log("xuanyusong" + sqReader.GetString(sqReader.GetOrdinal("name")));
Debug.Log("xuanyusong" + sqReader.GetString(sqReader.GetOrdinal("email")));
}
sqReader.Close();
}
db.CloseSqlConnection();
}
void Update()
{
if (Input.GetKeyDown(KeyCode.Escape) ¦¦Input.GetKeyDown(KeyCode.Home) )
{
Application.Quit();
}
}
}
如下图所示,Player Settings 请和我保持一致。
using UnityEngine;
using System.Collections;
using Mono.Data.Sqlite;
public class Test : MonoBehaviour
{
string name = null;
string email = null;
string appDBPath = null;
void Start ()
{
//////////--------
//请注意!!!!!!!
//这里的修改
appDBPath = Application.dataPath + "/xuanyusong.db";
DbAccess db = new DbAccess(@"Data Source=" + appDBPath);
//////////--------
//请注意 插入字符串是 已经要加上'宣雨松' 不然会报错
db.CreateTable("momo",new string[]{"name","qq","email","blog"}, new string[]{"text","text","text","text"});
//我在数据库中连续插入三条数据
db.InsertInto("momo", new string[]{ "'宣雨松'","'289187120'","'xuanyusong@gmail.com'","'www.xuanyusong.com'" });
db.InsertInto("momo", new string[]{ "'雨松MOMO'","'289187120'","'000@gmail.com'","'www.xuanyusong.com'" });
db.InsertInto("momo", new string[]{ "'哇咔咔'","'289187120'","'111@gmail.com'","'www.xuanyusong.com'" });
//然后在删掉两条数据
db.Delete("momo",new string[]{"email","email"}, new string[]{"'xuanyusong@gmail.com'","'000@gmail.com'"} );
SqliteDataReader sqReader = db.SelectWhere("momo",new string[]{"name","email"},new string[]{"qq"},new string[]{"="},new string[]{"289187120"});
while (sqReader.Read())
{
Debug.Log(sqReader.GetString(sqReader.GetOrdinal("name")) + sqReader.GetString(sqReader.GetOrdinal("email")));
//取值
name = sqReader.GetString(sqReader.GetOrdinal("name"));
email = sqReader.GetString(sqReader.GetOrdinal("email"));
}
db.CloseSqlConnection();
}
void OnGUI()
{
///为了让大家看的更清楚 我将数据库取出的内容显示在屏幕中
if(name != null)
{
GUILayout.Label("XXXXXXXXXXXXX" + name);
}
if (email!= null)
{
GUILayout.Label("XXXXXXXXXXXXX" + email);
}
if(appDBPath != null)
{
GUILayout.Label("数据库的路径" + appDBPath);
}
}
}
using System.Collections;
using Mono.Data.Sqlite;
//using Mono.Data.SqliteClient;
public class Test : MonoBehaviour
{
string name = null;
string email = null;
string path = null;
void Start ()
{
//数据库文件储存地址
//注意这里的修改!!!!!!!!!!!!!!
string appDBPath = Application.dataPath + "/xuanyusong.db";
//--------------------------
DbAccess db = new DbAccess(@"Data Source=" + appDBPath);
path = appDBPath;
//请注意 插入字符串是 已经要加上'宣雨松' 不然会报错
db.CreateTable("momo",new string[]{"name","qq","email","blog"}, new string[]{"text","text","text","text"});
//我在数据库中连续插入三条数据
db.InsertInto("momo", new string[]{ "'宣雨松'","'289187120'","'xuanyusong@gmail.com'","'www.xuanyusong.com'" });
db.InsertInto("momo", new string[]{ "'雨松MOMO'","'289187120'","'000@gmail.com'","'www.xuanyusong.com'" });
db.InsertInto("momo", new string[]{ "'哇咔咔'","'289187120'","'111@gmail.com'","'www.xuanyusong.com'" });
//然后在删掉两条数据
db.Delete("momo",new string[]{"email","email"}, new string[]{"'xuanyusong@gmail.com'","'000@gmail.com'"} );
//注解1
using (SqliteDataReader sqReader = db.SelectWhere("momo",new string[]{"name","email"},new string[]{"qq"},new string[]{"="},new string[]{"289187120"}))
{
while (sqReader.Read())
{
//目前中文无法显示
Debug.Log("xuanyusong" + sqReader.GetString(sqReader.GetOrdinal("name")));
Debug.Log("xuanyusong" + sqReader.GetString(sqReader.GetOrdinal("email")));
name = sqReader.GetString(sqReader.GetOrdinal("name"));
email = sqReader.GetString(sqReader.GetOrdinal("email"));
}
sqReader.Close();
}
db.CloseSqlConnection();
}
void OnGUI()
{
if(name != null)
{
GUILayout.Label(name);
}
if(email != null)
{
GUILayout.Label(email);
}
if(path != null)
{
GUILayout.Label(path);
}
}
}
2013年5月6号补充
我发现留言中有很多朋友都问我 : SqliteException: SQLite errornear “″: syntax error 这样的错误。
这几天我抽时间看一下这个问题,出现这个问题应该是你需要在程序中载入第三方数据库,而不是自己创建数据库。
解决这个问题的办法其实很简单,当你程序发布以后。 windows下会生成 xx.exe 和 xx_Data文件夹,这时候你把你的第三方数据库拷贝进去就可以,因为我发现编辑模式下assets文件夹中的db文件打包生成windows的以后,这db文件不会完整的拷贝,在xx_Data文件夹中的db文件变成了0KB 。
在MAC OS 中也一样,unity也不会完整的拷贝。只需把数据库拷贝至 对应的路径下就可以。
如果你是在使用移动平台,可以参考 Unity3D研究院之在Unity中打开第三方数据库配合Android开发(三十二)
- 本文固定链接: https://www.xuanyusong.com/archives/831
- 转载请注明: 雨松MOMO于 雨松MOMO程序研究院 发表












首先不修改大神的任何代码,是这样报错
nvalidOperationException: Database is not open
Mono.Data.Sqlite.SqliteCommand.InitializeForReader ()
Mono.Data.Sqlite.SqliteCommand.ExecuteReader (CommandBehavior behavior)
Mono.Data.Sqlite.SqliteCommand.ExecuteReader ()
再报错位置添加了一个Open方法,就是这样报错了
DllNotFoundException: sqlite3
Mono.Data.Sqlite.SQLite3.Open (System.String strFilename, SQLiteOpenFlagsEnum flags, Int32 maxPoolSize, Boolean usePool)
Mono.Data.Sqlite.SqliteConnection.Open ()
不知道要怎么改了,求指点
大神,第一次查询的缓存可以手动释放掉吗?第一次查询非常耗时,第二次查询耗时就会少写。想自己把数据缓存起来
雨松老师,感谢老师的指导,Window版本的Demo微云链接失效了,请问有木有新的链接,比如百度云盘的。在unity中用Sqlite支持Linux么,期待您的回复。
报错了InvalidOperationException: Database is not open
请问下 你在Windows 下面的Unity 连接数据库用的是32位的还是 64位的呢?? 我在win10系统下使用64位的Unity 貌似不能连接到 .accdb数据库。 有没有什么方法可以实现呢?
同样的问题,请问这个问题找到原因没?
public SqliteDataReader ExecuteQuery (string sqlQuery){dbCommand = dbConnection.CreateCommand ();dbCommand.CommandText = sqlQuery;reader = dbCommand.ExecuteReader ();return reader;}楼主,每执行一次sql操作,这里就执行一次,command 就 create 一次,会有内存浪费哎。把 dbCommand = dbConnection.CreateCommand () 放到SQLiteHelper()里面会好一些。
大神,这样每次都会创建dbCommand只创建一次会报错的
博主,我是新手,我在WebPlayer平台下出现这个编译错误:Internal compiler error. See the console log for more information. output was:Unhandled Exception: System.TypeLoadException: Could not load type ‘Mono.Data.Sqlite.SqliteStatement’ from assembly ‘Mono.Data.Sqlite, Version=2.0.0.0, Culture=neutral, PublicKeyToken=0738eb9f132ed756’.麻烦帮忙解释一下,是不是WebPlayer平台下不支持使用Sqlite?
我也遇到了一样的问题,请问您解决了吗?可以分享一下吗?
请问db怎么加密呢
雨松大神 为啥我用你的demo告诉我数据库没有打开
pc上发现 添加实时更新了,但是删除和更新,必须得运行一下unity 才可以,有办法解决么?
更新或者删除数据后然后再读取还是原来数据,但是数据库内的已经更新了,运行一下untiy后数据才更新了,求雨凇大大帮帮忙
雨松大大,我在编译模式下没问题,一旦发布到PC,各种错误就出现了,数据库都没办法生成,说什么没找到dll。