在unity中利用内嵌数据库sqlite

前言

• 这个任务是因为我在给别人写外包，必要数据库。
  
• 假如利用MySQL，实在是太笨重了，必要额外安装MySQL这个软件
  
• 所以我决定用sqlite这个嵌入式数据库。
  

网络上两种环境

• 第一种是利用这两个dll来进行毗连并创建，在本身电脑上就可以很轻易的找到，我这里利用的是everythingTool工具，所以比较方便找到了。
  
  
  
  
  
  
  
• 视频教程B站视频
  
• 第二种是github上某人写的一个毗连库
  视频教程
  
• 我这里利用的是第二种
  
• 数据库可视化工具用的sqliteStudio
  
• GitHub毗连
  

如何利用

• 导入插件
  插件
  
• 写脚本，毗连数据库。
  
• 再者，创建数据表
  
• 留意事项
  
• 1.他这个插件会根据你的类自动创建对应的表的表头，假如你必要主键，就必要继承IPrimaryKey
  
• 而且因为我没找到怎么让她自动天生主键，所以我是本身用Guid来填充的
  
• 2.在测试阶段退出player后肯定要关闭和数据库的connection，否则你没有办法删除天生的表。
  

三个脚本

• 脚本是我根据插件里面自带的例子更改而成的
  
• model模型类，用来对表的数据做映射
  
• Table类-提供基本的对表的增编削查的操作，比如按照ID搜索，按照名字搜索等等。
  
• ModelManager，用table的方法来提供对上层的支持
  

1. using SQLite4Unity3d;
2. using System.Collections;
3. using System.Collections.Generic;
4. using UnityEngine;
6. public enum Role
7. {
8.     None = 0,
9.     InWork = 1,
10.     LoseWork = 2,
11.     ExitWork = 3,
12.     Other = 4,
13. }
15. public enum Major
16. {
17.     None = 0,
18.     Machine = 1,
19.     NotMachine = 2
20. }
22. public interface IPrimaryKey
23. {
24.     public string ID { get; set; }
25. }
26. public class User : IPrimaryKey
27. {
28.     [PrimaryKey]
29.     public string ID { get; set; }
30.     public string UserName { get; set; }
31.     public string Password { get; set; }
32.     public Role Role { get; set; } = Role.None;
33.     public string Name { get; set; }
34.     public int StudyNumber { get; set; }
35.     public Major MajorCode { get; set; }
37. }

复制代码

• 通用的表类
  

1. using SQLite4Unity3d;
2. using UnityEngine;
3. #if !UNITY_EDITOR
4. using System.Collections;
5. using System.IO;
6. #endif
7. using System.Collections.Generic;
10. public class UserTable : TableService<User>
11. {
13.     public User FindByUserName(string name)
14.     {
15.         return _connection.Table<User>().Where(x => x.UserName == name).FirstOrDefault();
16.     }
17. }
18. public class TableService<T> where T : IPrimaryKey, new()
19. {
21.     protected static SQLiteConnection _connection;
24.     public static void DisConnect()
25.     {
26.         _connection.Dispose();
27.     }
29.     const string DatabaseName = "Crane.db";
30.     static TableService()
31.     {
33. #if UNITY_EDITOR
34.         var dbPath = string.Format(@"Assets/StreamingAssets/{0}", DatabaseName);
35. #else
36.         // check if file exists in Application.persistentDataPath
37.         var filepath = string.Format("{0}/{1}", Application.persistentDataPath, DatabaseName);
39.         if (!File.Exists(filepath))
40.         {
41.             Debug.Log("Database not in Persistent path");
42.             // if it doesn't ->
43.             // open StreamingAssets directory and load the db ->
45. #if UNITY_ANDROID
46.             var loadDb = new WWW("jar:file://" + Application.dataPath + "!/assets/" + DatabaseName);  // this is the path to your StreamingAssets in android
47.             while (!loadDb.isDone) { }  // CAREFUL here, for safety reasons you shouldn't let this while loop unattended, place a timer and error check
48.             // then save to Application.persistentDataPath
49.             File.WriteAllBytes(filepath, loadDb.bytes);
50. #elif UNITY_IOS
51.                  var loadDb = Application.dataPath + "/Raw/" + DatabaseName;  // this is the path to your StreamingAssets in iOS
52.                 // then save to Application.persistentDataPath
53.                 File.Copy(loadDb, filepath);
54. #elif UNITY_WP8
55.                 var loadDb = Application.dataPath + "/StreamingAssets/" + DatabaseName;  // this is the path to your StreamingAssets in iOS
56.                 // then save to Application.persistentDataPath
57.                 File.Copy(loadDb, filepath);
59. #elif UNITY_WINRT
60.                 var loadDb = Application.dataPath + "/StreamingAssets/" + DatabaseName;  // this is the path to your StreamingAssets in iOS
61.                 // then save to Application.persistentDataPath
62.                 File.Copy(loadDb, filepath);
63.                
64. #elif UNITY_STANDALONE_OSX
65.                 var loadDb = Application.dataPath + "/Resources/Data/StreamingAssets/" + DatabaseName;  // this is the path to your StreamingAssets in iOS
66.                 // then save to Application.persistentDataPath
67.                 File.Copy(loadDb, filepath);
68. #else
69.         var loadDb = Application.dataPath + "/StreamingAssets/" + DatabaseName;  // this is the path to your StreamingAssets in iOS
70.         // then save to Application.persistentDataPath
71.         File.Copy(loadDb, filepath);
73. #endif
75.             Debug.Log("Database written");
76.         }
78.         var dbPath = filepath;
79. #endif
80.         _connection = new SQLiteConnection(dbPath, SQLiteOpenFlags.ReadWrite | SQLiteOpenFlags.Create);
81.         Debug.Log("Final PATH: " + dbPath);
82.         var count = _connection.GetTableInfo(typeof(T).Name).Count;
83.         //创建对应的Table
84.         if (count == 0)
85.         {
86.             _connection.CreateTable<T>();
87.         }
89.     }
91.     public int InsertData(T obj)
92.     {
93.         return _connection.Insert(obj);
94.     }
96.     public int Delete(T obj)
97.     {
98.         return _connection.Delete(obj);
99.     }
101.     public int Update(T obj)
102.     {
103.         return _connection.Update(obj);
104.     }
106.     public T FindByID(string ID)
107.     {
108.         return _connection.Table<T>().Where(x => x.ID == ID).FirstOrDefault();
110.     }
113.     //public void CreateDB<T>()
114.     //{
115.     //    _connection.CreateTable<T>();
116.     //}
118.     //public IEnumerable<Person> GetPersons()
119.     //{
121.     //    //_connection.
122.     //    return _connection.Table<Person>();
123.     //}
125.     //public IEnumerable<Person> GetPersonsNamedRoberto()
126.     //{
127.     //    return _connection.Table<Person>().Where(x => x.Name == "Roberto");
128.     //}
130.     //public Person GetJohnny()
131.     //{
132.     //    return _connection.Table<Person>().Where(x => x.Name == "Johnny").FirstOrDefault();
133.     //}
135.     //public Person CreatePerson()
136.     //{
137.     //    var p = new Person
138.     //    {
139.     //        Name = "Johnny",
140.     //        Surname = "Mnemonic",
141.     //        Age = 21
142.     //    };
143.     //    _connection.Insert(p);
144.     //    return p;
145.     //}
146. }

复制代码

• ModelMaanger
  

1. using System;
2. using System.Collections;
3. using System.Collections.Generic;
4. using System.Security.Cryptography;
5. using System.Text;
6. using Unity.VisualScripting;
7. using UnityEngine;
9. public class ModelManager
10. {
13.     public static UserTable UserTable;
15.     public static ModelManager Inst { get; private set; } = new ModelManager();
16.     static ModelManager()
17.     {
18.         UserTable = new UserTable();
19.     }
21.     private ModelManager()
22.     {
24.     }
26.     public void OnQuit()
27.     {
28.         UserTable.DisConnect();
29.     }
31.     public void RegisterUser(User user)
32.     {
33.         user.ID = Guid.NewGuid().ToString();
34.         user.Password = EnCryption(user.Password + salt);
35.         UserTable.InsertData(user);
36.     }
37.     public bool IsExistName(string name, out User user)
38.     {
39.         var currUser = UserTable.FindByUserName(name);
40.         user = currUser;
41.         return currUser != null;
42.     }
44.     public bool IsExistName(string name)
45.     {
46.         var currUser = UserTable.FindByUserName(name);
47.         return currUser != null;
48.     }
50.     public void UpdatePassword(User user, string password)
51.     {
52.         user.Password = EnCryption(password + salt);
53.         UserTable.Update(user);
54.     }
56.     public bool IsMatchName(string name, string password, out bool passwordRight)
57.     {
58.         var currUser = UserTable.FindByUserName(name);
59.         if (currUser == null)
60.         {
61.             passwordRight = false;
62.             return false;
63.         }
64.         else
65.         {
66.             passwordRight = EnCryption(password + salt) == currUser.Password;
67.             return true;
68.         }
69.     }
70.     string salt = "sdsax";
71.     public string EnCryption(string content)
72.     {
73.         using (MD5 md5Hash = MD5.Create())
74.         {
75.             byte[] data = md5Hash.ComputeHash(Encoding.UTF8.GetBytes(content));
77.             StringBuilder builder = new StringBuilder();
78.             for (int i = 0; i < data.Length; i++)
79.             {
80.                 builder.Append(data[i].ToString("x2")); // 将每个字节转换为十六进制并添加到结果中
81.             }
83.             return builder.ToString();
84.         }
85.     }
86. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。