在Unity中创建一个数据库管理类和数据库操作方法

这里我们使用Sqlite数据库，Sqlite数据库是一个轻量级、跨平台的关系型数据库，尤其是跨平台更是和Unity非常的搭配，但是应为轻量化，所以不能满足企业级数据库的要求，但是一些小型游戏使用的话足可以满足需求
1.Mono.Data.Sqlite.dll
在unity安装文件“Unity\Editor\Data\MonoBleedingEdge\lib\mono”可以找到，注意mono文件夹下面有对应版本号，可以根据自己的项目来决定选择。
2.System.Data.dll 同上位置一样可以找到，不过建议使用2.0版本
3.sqlite3.dll 就在\Unity\Editor下可以找到
找到这些文件，还没有大功告成下面我们还需要把这3个文件放在你的项目的这个路径下面：\Assets\Plugins\，没有Plugins文件夹就必须创建这个文件夹，然后将这三个dll文件放在该文件夹下面。Plugins是专门存放数组库文件的文件夹，命名必须一字不差，不然会找不到路径

QQ图片20160412145549.png

QQ图片20160412145606.png

好啦，环境准备工作完成下面就直接上代码
首先是一个 Sqlite的数据库操作类，
using UnityEngine;
using System.Collections;
//导入sqlite数据集，也就是Plugins文件夹下的那个dll文件
using Mono.Data.Sqlite;
using System;
//数据集是formwork2.0 用vs开发要自己引用框架中的System.Data
using System.Data;
public class SqliteDbHelper
{
/// <summary>
/// 声明一个连接对象
/// </summary>
private SqliteConnection dbConnection;
/// <summary>
/// 声明一个操作数据库命令
/// </summary>
private SqliteCommand dbCommand;
/// <summary>
/// 声明一个读取结果集的一个或多个结果流
/// </summary>
private SqliteDataReader reader;
/// <summary>
/// 数据库的连接字符串，用于建立与特定数据源的连接
/// </summary>
/// <param name="connectionString">数据库的连接字符串，用于建立与特定数据源的连接</param>
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);
}
}
/// <summary>
/// 关闭连接
/// </summary>
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.");
}
/// <summary>
/// 执行查询sqlite语句操作
/// </summary>
/// <param name="sqlQuery"></param>
/// <returns></returns>
public SqliteDataReader ExecuteQuery (string sqlQuery)
{
dbCommand = dbConnection.CreateCommand ();
dbCommand.CommandText = sqlQuery;
reader = dbCommand.ExecuteReader ();
return reader;
}
/// <summary>
/// 查询该表所有数据
/// </summary>
/// <param name="tableName">表名</param>
/// <returns></returns>
public SqliteDataReader ReadFullTable (string tableName)
{
string query = "SELECT * FROM " + tableName;
return ExecuteQuery (query);
}
/// <summary>
/// 动态添加表字段到指定表
/// </summary>
/// <param name="tableName">表名</param>
/// <param name="values">字段集合</param>
/// <returns></returns>
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);
}
/// <summary>
/// 动态更新表结构
/// </summary>
/// <param name="tableName">表名</param>
/// <param name="cols">字段集</param>
/// <param name="colsvalues">对于集合值</param>
/// <param name="selectkey">要查询的字段</param>
/// <param name="selectvalue">要查询的字段值</param>
/// <returns></returns>
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);
}
/// <summary>
/// 动态删除指定表字段数据
/// </summary>
/// <param name="tableName">表名</param>
/// <param name="cols">字段</param>
/// <param name="colsvalues">字段值</param>
/// <returns></returns>
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+" = "+ colsvalues;
}
Debug.Log(query);
return ExecuteQuery (query);
}
/// <summary>
/// 动态添加数据到指定表
/// </summary>
/// <param name="tableName">表名</param>
/// <param name="cols">字段</param>
/// <param name="values">值</param>
/// <returns></returns>
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);
}
/// <summary>
/// 动态删除表
/// </summary>
/// <param name="tableName">表名</param>
/// <returns></returns>
public SqliteDataReader DeleteContents (string tableName)
{
string query = "DELETE FROM " + tableName;
return ExecuteQuery (query);
}
/// <summary>
/// 动态创建表
/// </summary>
/// <param name="name">表名</param>
/// <param name="col">字段</param>
/// <param name="colType">类型</param>
/// <returns></returns>
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);
}
/// <summary>
/// 根据查询条件动态查询数据信息
/// </summary>
/// <param name="tableName">表</param>
/// <param name="items">查询数据集合</param>
/// <param name="col">字段</param>
/// <param name="operation">操作</param>
/// <param name="values">值</param>
/// <returns></returns>
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;
}
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);
}
}
下面是数据库的操作类
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());
   /*
    SqliteDbAccess db = new SqliteDbAccess("data source=mydb1.db");
  db.CreateTable("momo",new string[]{"name","qq","email","blog"},
   new string[]{"text","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","email"},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, 100), name);
            GUI.Label(new Rect(100, 200, 100, 100), emls);
            //  GUILayout.Label(emls);
        }
  if(GUILayout.Button("close database"))
  {
   db.CloseSqlConnection();
   Debug.Log("close table ok");
  }

}

}

运行以后

QQ图片20160412150845.jpg

注意，创建的Sqlite数据库的表放在StreamingAssets文件夹下，这也是系统的指定路径，用来存放数据库的表文件

QQ图片20160412151108.png

我使用的数据库可视化工具是SQLiteManager，在他里面创建表就可以了

QQ图片20160412151407.png

最后编辑于：2017.12.03 04:06:24

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 206,482评论 6赞 481
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 88,377评论 2赞 382
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 152,762评论 0赞 342
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 55,273评论 1赞 279
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 64,289评论 5赞 373
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 49,046评论 1赞 285
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 38,351评论 3赞 400
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,988评论 0赞 259
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 43,476评论 1赞 300
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,948评论 2赞 324
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 38,064评论 1赞 333
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 33,712评论 4赞 323
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 39,261评论 3赞 307
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 30,264评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 31,486评论 1赞 262
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 45,511评论 2赞 354
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 42,802评论 2赞 345

在Unity中创建一个数据库管理类和数据库操作方法

推荐阅读更多精彩内容