2017年3月9日 星期四

Unity3D 連接DATABASE/數據庫教學

對上一篇文章是有關我早前開發的一個2D橫向遊戲

當時的想法是宣傳一下自己的開發作品及分享一下開發心得

但我發覺...我根本沒時間去整理 我開發的過程及心得 , 或許未來的新遊戲..可能會吧

好了 不說題外話了 , 今天的主題是如何使用UNITY3D 連接DATABASE

本教學的主要慨念及編碼 來自雨松大神的教學文章 原文出處請看

http://www.xuanyusong.com/archives/2326

要實現這篇教學 你會用到幾樣材料

1. DATABASE SERVER

2. 增加UNITY力量的DLL檔案

3. 二個使用C# 的程式碼
________________________________________________________________________

首先說一下有關DATABASE 部份

如果你不是有點經驗的IT人員 , 自己安裝一個DATABASE可能會比較困難

因此我在這裡推介一個名為 XAMPP的軟件 這個東東很方便

一次可以安裝MYSQL , PHPMYADMIN , PHP, 還有APACHE 等的服務 , 是不是很方便呢 ?

https://www.apachefriends.org/zh_tw/index.html

________________________________________________________________________

再來就是增加UNITY力量的DLL檔案

大家用UNITY時 一開頭的using UnityEngine;  using MySql.Data.MySqlClient;   等等的編碼

就是我說的UNITY力量增複器 , 在這個教學中我們也會用到幾個

你可以到雨松大神的文章中可以下載到

另外你可能遇到一個問題 為何在WINDOWS中 可以成功運行 , 但是在手機上就不可以?

如果不成功 有機會是你設置的網絡不正確, 因為你手機和你電腦在不同的網絡中

還有機會是你沒有把所有DLL 匯入

________________________________________________________________________

最後就是有關程式碼的部份了

先不要被下面的程式碼嚇怕 , 其實很容易使用的

首先第一部份的程式碼

你只需要更改HOST,ID,PWD,DATABASE,PORT等 個人化的資料就可以了

using UnityEngine;  
using System;  
using System.Data;  
using System.Collections;   
using MySql.Data.MySqlClient;
using MySql.Data;
using System.IO;
public class SqlAccess 
{
 
    public static MySqlConnection dbConnection;
//如果只是在本地的话,写localhost就可以。
   // static string host = "localhost";  
//如果是局域网,那么写上本机的局域网IP
// 這裡就的是你要連接的數據庫地址,找到你在第一部份中數據庫伺服器的IP , 之後填上就可以了
static string host = "192.168.1.106";  
    static string id = "root";
    static string pwd = "1234";
    static string database = "xuanyusong"; 
 
public SqlAccess()
{
OpenSql();
}
 

public static void OpenSql()
{
 // 這裡處理了登入的邏輯 0,1,2,3,4 分別對應host, database,id,pwd,3306 的PORT
try
{
string connectionString = string.Format("Server = {0};port={4};Database = {1}; User ID = {2}; Password = {3};",host,database,id,pwd,"3306");
dbConnection = new MySqlConnection(connectionString);
dbConnection.Open(); 
}catch (Exception e)
{
// 使用 TRY CATCH 處理登入失敗的資訊
       throw new Exception("服务器连接失败,请重新检查是否打开MySql服务。" + e.Message.ToString());  
 
}
 
}

// 以下的程式碼都是在建立不同的FUNCTION , 給我的另一個.CS 程式碼使用
public DataSet CreateTable (string name, string[] col, string[] colType)
    {
        if (col.Length != colType.Length) 
{
 
            throw new Exception ("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 DataSet CreateTableAutoID (string name, string[] col, string[] colType)
    {
        if (col.Length != colType.Length) 
{
 
            throw new Exception ("columns.Length != colType.Length");
 
        }
 
        string query = "CREATE TABLE " + name + " (" + col[0] + " " + colType[0] +  " NOT NULL AUTO_INCREMENT";
 
        for (int i = 1; i < col.Length; ++i) {
 
            query += ", " + col[i] + " " + colType[i];
 
        }
 
        query += ", PRIMARY KEY ("+ col[0] +")" + ")";
 
Debug.Log(query);
 
        return  ExecuteQuery(query);
    }
 
//插入一条数据,包括所有,不适用自动累加ID。
// 
public DataSet 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 += ")";
 
Debug.Log(query);
        return ExecuteQuery (query);
 
    }
 
//插入部分ID
public DataSet InsertInto (string tableName, string[] col,string[] values)
    {
 
if (col.Length != values.Length) 
{
 
            throw new Exception ("columns.Length != colType.Length");
 
        }
 
        string query = "INSERT INTO " + tableName + " (" + col[0];
   for (int i = 1; i < col.Length; ++i) 
{
 
            query += ", "+col[i];
 
        }
 
query += ") VALUES (" + "'"+ values[0]+ "'";
        for (int i = 1; i < values.Length; ++i) 
{
 
            query += ", " + "'"+values[i]+ "'";
 
        }
 
        query += ")";
 
Debug.Log(query);
        return ExecuteQuery (query);
 
    }
 
    public DataSet SelectWhere (string tableName, string[] items, string[] col, string[] operation, string[] values)
    {
 
        if (col.Length != operation.Length || operation.Length != values.Length) {
 
            throw new Exception ("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);
 
    } 
 
public DataSet 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 DataSet 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  void Close()
{
 
if(dbConnection != null)
{
dbConnection.Close();
dbConnection.Dispose();
dbConnection = null;
}
 
}
 
    public static DataSet ExecuteQuery(string sqlString)  
    {  
if(dbConnection.State==ConnectionState.Open)
{
      DataSet ds = new DataSet();  
      try  
    {  
 
MySqlDataAdapter da = new MySqlDataAdapter(sqlString, dbConnection); 
da.Fill(ds);
 
    }  
   catch (Exception ee)  
   {
       throw new Exception("SQL:" + sqlString + "/n" + ee.Message.ToString());  
   }
finally
{
}
return ds;
}
   return null;
}
 
}

再來就是應用部份

上面的程式碼為我們打好了一個良好的基礎

你只需要了解我注解的內容就可以使用了

信我吧 沒想像中那麼難的

using UnityEngine;  
using System;  
using System.Data;  
using System.Collections;   
using MySql.Data.MySqlClient;
using MySql.Data;
using System.IO;
public class NewBehaviourScript : MonoBehaviour {
 
string Error = null;
void Start () 
{
try
{
 
SqlAccess sql = new  SqlAccess();
// 使用CreateTableAutoID 建立一個名為MONO的TABLE , 當中包括"id","name","qq","email","blog" , 使用"int","text","text","text","text" 的TYPE
sql.CreateTableAutoID("momo",new string[]{"id","name","qq","email","blog"}, new string[]{"int","text","text","text","text"});
//sql.CreateTable("momo",new string[]{"name","qq","email","blog"}, new string[]{"text","text","text","text"});

// 在MONO的TABLE中為"name","qq","email","blog" 加入 "xuanyusong","289187120","xuanyusong@gmail.com","xuanyusong.com" 的值
sql.InsertInto("momo",new string[]{"name","qq","email","blog"},new string[]{"xuanyusong","289187120","xuanyusong@gmail.com","xuanyusong.com"});
// 在MONO的TABLE中為"name","qq","email","blog" 加入 "ruoruo","34546546","ruoruo@gmail.com","xuanyusong.com" 的值
sql.InsertInto("momo",new string[]{"name","qq","email","blog"},new string[]{"ruoruo","34546546","ruoruo@gmail.com","xuanyusong.com"});

//  在MONO的TABLE中尋找 name 及 qq 的值 , 條件為ID 值 = 1的資料
DataSet ds  = sql.SelectWhere("momo",new string[]{"name","qq"},new string []{"id"},new string []{"="},new string []{"1"});
if(ds != null)
{
 
DataTable table = ds.Tables[0];
 
foreach (DataRow row in table.Rows)
{
  foreach (DataColumn column in table.Columns)
  {
Debug.Log(row[column]);
  }
}
}
 //  更新MONO TABLE中 name,qq 的值為 "'ruoruo'","'11111111'" 條件為 email = xuanyusong@gmail.com 的資料
sql.UpdateInto("momo",new string[]{"name","qq"},new string[]{"'ruoruo'","'11111111'"}, "email", "'xuanyusong@gmail.com'"  );
 //  刪除MONO TABLE 中條件為 ID 是 1 , EMAIL 是000@gmail.com 的資料
sql.Delete("momo",new string[]{"id","email"}, new string[]{"1","'000@gmail.com'"}  );
sql.Close();
}catch(Exception e)
{
Error = e.Message;
}
 
}
 
// Update is called once per frame
void OnGUI () 
{
 
if(Error != null)
{
GUILayout.Label(Error);
}
 
}
}


另外也可以使用INPUTFIELD 作為變數 搜尋/插入新資料/更改資料

public InputField userid  ;

public void selectthedata() {

savethelogin = userid.text;

SqlAccess sql = new  SqlAccess();
ds  = sql.SelectWhere("userdetail",new string[]{"id","name","hp","mp","skill"},new string []{"name"},new string []{" = "},new string []{"'" + savethelogin + "'"});

}

希望大家喜歡這個教學

1. SETUP DB SERVER
2. 匯入DLL
3. 使用程式碼

下次應該會談一下UNITY 最新的UNITY MULTIPLAYER 服務

謝謝大家觀看

熱門文章

Related Posts Plugin for WordPress, Blogger...