using UnityEngine; using System; using System.Data; using MySql.Data.MySqlClient; using System.IO;using UnityEngine.UI; public class SqlAccess {public static MySqlConnection dbConnection;//如果只是在本地的話，寫localhost就可以。//static string host = "localhost"; //如果是局域網，那么寫上本機的局域網IP//static string host = "服務器地址";//static string database = "數據庫名稱";//static string id = "用戶名";//static string pwd = "密碼";static string host = "服務器地址";static string database = "數據庫名稱";static string id = "用戶名";static string pwd = "密碼";public SqlAccess(){OpenSql();}public static void OpenSql(){try{#region 舊//var settingsPath=Application.dataPath + "/settings.cfg";//if (File.Exists(settingsPath)) {// StreamReader textReader=new StreamReader ( settingsPath , System.Text.Encoding.ASCII );// host = textReader.ReadLine ( );// GameObject.Find("Text1").GetComponent<Text>().text=host.ToString();// }//GameObject.Find("Text").GetComponent<Text>().text=host.ToString();#endregionstring connectionString = string.Format("Server = {0};Database = {1}; User ID = {2}; Password = {3};port={4};", host, database, id, pwd, "3306");dbConnection = new MySqlConnection(connectionString);dbConnection.Open();}catch (Exception e){throw new Exception("服務器連接失敗，請重新檢查是否打開MySql服務。" + e.Message.ToString());}}/// <summary>/// 創建表/// </summary>/// <param name="name">需要創建的表名</param>/// <param name="col">表中的一些字段名</param>/// <param name="colType">字段的數據類型</param>/// <returns></returns>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/// <summary>/// 向表中添加數據/// </summary>/// <param name="tableName">表名</param>/// <param name="col">需要添加數據的字段</param>/// <param name="values">字段中的值</param>/// <returns></returns>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);}/// <summary>/// 返回表的查詢結果/// </summary>/// <returns>The all.</returns>/// <param name="Name">Name.</param>public DataSet SelectAll(string Name){string query = "select * from " + " " + Name;return ExecuteQuery(query);}/// <summary>/// 條件查找/// </summary>/// <returns>The where.</returns>/// <param name="tableName">表名</param>/// <param name="items">選擇的字段</param>/// <param name="col">查找根據的字段</param>/// <param name="operation">查找根據的運算符</param>/// <param name="values">查找根據的值</param>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);}/// <summary>/// 更新表信息/// </summary>/// <returns>The into.</returns>/// <param name="tableName">表名</param>/// <param name="cols">更新的字段</param>/// <param name="colsvalues">更新字段的值</param>/// <param name="selectkey">查找根據的字段</param>/// <param name="selectvalue">字段的值</param>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 UpdateInto1(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);}/// <summary>/// 條件刪除/// </summary>/// <param name="tableName">表名</param>/// <param name="cols">查找根據的字段</param>/// <param name="colsvalues">字段的值</param>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);}/// <summary>/// 關閉數據庫/// </summary>public void Close(){if (dbConnection != null){dbConnection.Close();dbConnection.Dispose();dbConnection = null;}}public DataSet ExistOrNot(string sql){if (dbConnection.State == ConnectionState.Open){//Debug.Log (sql);DataSet ds = new DataSet(); //表的集合try{MySqlDataAdapter da = new MySqlDataAdapter(sql, dbConnection);da.Fill(ds);}catch (Exception ee){throw new Exception("SQL:" + sql + "/n" + ee.Message.ToString());}finally{}return ds;}return null;}/// <summary>/// 返回檢索結果/// </summary>/// <returns>The query.</returns>/// <param name="sqlString">Sql string.</param>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;}/// <summary>/// 讀取數據集/// </summary>/// <param name="ds">Ds.</param>public void ReadDs(DataSet ds){if (ds != null){DataTable user = ds.Tables[0];foreach (DataRow row in user.Rows){foreach (DataColumn colum in user.Columns){//Debug.Log (row[colum]);}}}}}

?

總結

以上是生活随笔為你收集整理的MySQL本人工具使用的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。