Unity3d 连接 MySQL 数据库(使用DataSet)

王者再临

1. 
   
2. using UnityEngine;
   
3. 
   
4. 　　using System;
   
5. 
   
6. 　　using System.Collections;
   
7. 
   
8. 　　using System.Data;
   
9. 
   
10. 　　using MySql.Data.MySqlClient;
    
11. 
    
12. 　　public class CMySql : MonoBehaviour {
    
13. 
    
14. 　　// Global variables
    
15. 
    
16. 　　public static MySqlConnection dbConnection;//Just like MyConn.conn in StoryTools before
    
17. 
    
18. 　　static string host = “192.168.1.100”;
    
19. 
    
20. 　　static string id = “mysql”;
    
21. 
    
22. 　　static string pwd = “123456”;
    
23. 
    
24. 　　static string database = “test”;
    
25. 
    
26. 　　static string result = “”;
    
27. 
    
28. 　　private string strCommand = “Select * from unity3d_test ORDER BY id;”;
    
29. 
    
30. 　　public static DataSet MyObj;
    
31. 
    
32. 　　void OnGUI()
    
33. 
    
34. 　　{
    
35. 
    
36. 　　host = GUILayout.TextField( host, 200, GUILayout.Width(200));
    
37. 
    
38. 　　id = GUILayout.TextField( id, 200, GUILayout.Width(200));
    
39. 
    
40. 　　pwd = GUILayout.TextField( pwd, 200, GUILayout.Width(200));
    
41. 
    
42. 　　if(GUILayout.Button(“Test”))
    
43. 
    
44. 　　{
    
45. 
    
46. 　　string connectionString = string.Format(“Server = {0}; Database = {1}; User ID = {2}; Password = {3};”,host,database,id,pwd);
    
47. 
    
48. 　　openSqlConnection(connectionString);
    
49. 
    
50. 　　MyObj = GetDataSet(strCommand);
    
51. 
    
52. 　　}
    
53. 
    
54. 　　GUILayout.Label(result);
    
55. 
    
56. 　　}
    
57. 
    
58. 　　// On quit
    
59. 
    
60. 　　public static void OnApplicationQuit() {
    
61. 
    
62. 　　closeSqlConnection();
    
63. 
    
64. 　　}
    
65. 
    
66. 　　// Connect to database
    
67. 
    
68. 　　private static void openSqlConnection(string connectionString) {
    
69. 
    
70. 　　dbConnection = new MySqlConnection(connectionString);
    
71. 
    
72. 　　dbConnection.Open();
    
73. 
    
74. 　　result = dbConnection.ServerVersion;
    
75. 
    
76. 　　//Debug.Log(“Connected to database.”+result);
    
77. 
    
78. 　　}
    
79. 
    
80. 　　// Disconnect from database
    
81. 
    
82. 　　private static void closeSqlConnection() {
    
83. 
    
84. 　　dbConnection.Close();
    
85. 
    
86. 　　dbConnection = null;
    
87. 
    
88. 　　//Debug.Log(“Disconnected from database.”+result);
    
89. 
    
90. 　　}
    
91. 
    
92. 　　// MySQL Query
    
93. 
    
94. 　　public static void doQuery(string sqlQuery) {
    
95. 
    
96. 　　IDbCommand dbCommand = dbConnection.CreateCommand();
    
97. 
    
98. 　　dbCommand.CommandText = sqlQuery;
    
99. 
    
100. 　　IDataReader reader = dbCommand.ExecuteReader();
     
101. 
     
102. 　　reader.Close();
     
103. 
     
104. 　　reader = null;
     
105. 
     
106. 　　dbCommand.Dispose();
     
107. 
     
108. 　　dbCommand = null;
     
109. 
     
110. 　　}
     
111. 
     
112. 　　#region Get DataSet
     
113. 
     
114. 　　public  DataSet GetDataSet(string sqlString)
     
115. 
     
116. 　　{
     
117. 
     
118. 　　//string sql = UnicodeAndANSI.UnicodeAndANSI.UnicodeToUtf8(sqlString);
     
119. 
     
120. 　　DataSet ds = new DataSet();
     
121. 
     
122. 　　try
     
123. 
     
124. 　　{
     
125. 
     
126. 　　MySqlDataAdapter da = new MySqlDataAdapter(sqlString, dbConnection);
     
127. 
     
128. 　　da.Fill(ds);
     
129. 
     
130. 　　}
     
131. 
     
132. 　　catch (Exception ee)
     
133. 
     
134. 　　{
     
135. 
     
136. 　　throw new Exception(“SQL:” + sqlString + “\n” + ee.Message.ToString());
     
137. 
     
138. 　　}
     
139. 
     
140. 　　return ds;
     
141. 
     
142. 　　}
     
143. 
     
144. 　　#endregion
     
145. 
     
146. 　　}
     
147. 
     
148. using UnityEngine;
     
149. 
     
150. 　　using System;
     
151. 
     
152. 　　using System.Collections;
     
153. 
     
154. 　　using System.Data;
     
155. 
     
156. 　　public class DataBaseTest : MonoBehaviour {
     
157. 
     
158. 　　public GUISkin myGUISkin = new GUISkin();
     
159. 
     
160. 　　string strID = “”;
     
161. 
     
162. 　　string strName = “”;
     
163. 
     
164. 　　string strSex = “”;
     
165. 
     
166. 　　int Index = 1;
     
167. 
     
168. 　　// Use this for initialization
     
169. 
     
170. 　　void Start () {
     
171. 
     
172. 　　}
     
173. 
     
174. 　　void OnGUI()
     
175. 
     
176. 　　{
     
177. 
     
178. 　　GUI.skin = myGUISkin;
     
179. 
     
180. 　　if (GUI.Button(new Rect(100,320,100,100),“Click Me”))
     
181. 
     
182. 　　{
     
183. 
     
184. 　　foreach(DataRow dr in CMySql.MyObj.Tables[0].Rows)
     
185. 
     
186. 　　{
     
187. 
     
188. 　　if (Index.ToString() == dr[“ID”].ToString())
     
189. 
     
190. 　　{
     
191. 
     
192. 　　strID = dr[“ID”].ToString();
     
193. 
     
194. 　　strName =  dr[“Name”].ToString();
     
195. 
     
196. 　　strSex = dr[“Sex”].ToString();
     
197. 
     
198. 　　break;
     
199. 
     
200. 　　}
     
201. 
     
202. 　　}
     
203. 
     
204. 　　Index++;
     
205. 
     
206. 　　if(Index > 5)
     
207. 
     
208. 　　{
     
209. 
     
210. 　　Index = 1;
     
211. 
     
212. 　　}
     
213. 
     
214. 　　}
     
215. 
     
216. 　　GUI.Label(new Rect(320,100,150,70),“DataBaseTest”);
     
217. 
     
218. 　　GUI.Label(new Rect(300,210,150,70),strID);
     
219. 
     
220. 　　GUI.Label(new Rect(300,320,150,70),strName);
     
221. 
     
222. 　　GUI.Label(new Rect(300,430,150,70),strSex);
     
223. 
     
224. 　　}
     
225. 
     
226. 　　}

复制代码

2.导入dll

　　同先前的帖子 , 将MySql.data.dll Import至Assets底下 , 然后再到Unity\Editor\Data\Frameworks\Mono.framework 中将System.Data.dll 也一起Import至Assets内 , 当然 , 如果想显示中文的话 , 请参考中文视频教学 , 建立一个GUISkin与字型。

　　3.建立数据库内容

　　主要是因为代码中的这段内容

　　static string host = “192.168.1.100”;

　　static string id = “mysql”;

　　static string pwd = “123456”;

　　static string database = “test”;

　　private string strCommand = “Select * from unity3d_test ORDER BY id;”;

　　其中host ,id , pwd 请自行设定 , 简单的说就是连进你的MySQL啦~

　　然后建立一个名为test的Database , 在这个test下建立一张table , 取名为 unity3d_test ,接下来就为这张unity3d_test建立3个栏位 : ID , Name , Sex (记得将ID设定为primary key 且默认值为1)再来自行填入5笔资料(5笔资料的原因是脚本那边是设定成5笔资料一个循环 , 使用者可以自行更改脚本试试)

　　4.建立GameObject

　　建立完GameObject后将上面两个脚本挂上去 , 如果有建立GUISkin , 记得指定GUISkin

　　5.执行

　　执行后先按Test按钮来连接数据库 , 然后再按“Click Me”来显示数据库内的内容

　　6.总结

　　以上部份是有关连线至数据库后 , 再将资料用DataSet的方式获得出来再加以显示至介面上。