标签：string 数据库 item Unity command key Mysql table public

下载对应版本的dll文件,包括Unity版本和MysqlServer版本
本项目使用的是
MysqlServer8.0
Unity2020.3.21
所以下载的dll文件需要满足这两个版本
1.mysql8.0以上
2.4.5以及4.5以下(只是猜测,4.6以上unity也确实不能识别)

综上,选择了8.0.11版本,网址如下
https://downloads.mysql.com/archives/c-net/

下面是具体脚本:

using MySql.Data.MySqlClient;
using System.Data;
using System.Collections.Generic;
using Debug = UnityEngine.Debug;
namespace CSharpMysql
{
    /*
        select * from item where guid = 1000;
        insert into item(guid) values(1231);
        insert into item guid=123,item_id=21312;
        UPDATE table_name SET field1=new-value1, field2=new-value2 [WHERE Clause]
        DELETE FROM table_name [WHERE Clause]
    */
    public static class MysqlHelper
    {
        private static MySqlConnection connection;
        static MysqlHelper()
        {
            connection = new MySqlConnection(MySqlConnectString.New().ToString());
        }


        public static DataTable SelectFrom(string table)
        {
            MySqlCommand command = new MySqlCommand();
            command.CommandText = $"select * from {table};";
            return ExecuteReader(command);
        }
        // MySQL 的 WHERE 子句的字符串比较是不区分大小写的。 你可以使用 BINARY 关键字来设定 WHERE 子句的字符串比较是区分大小写的。
        public static DataTable SelectFrom(string table, params MysqlData[] datas)
        {
            MySqlCommand command = new MySqlCommand();
            var builder = AppendJoin(" and ", datas);
            command.CommandText = $"select * from {table} where BINARY {builder};";
            Debug.Log(command.CommandText);
            foreach (var item in datas)
            {
                command.Parameters.AddWithValue($"@{item.key}", item.value);
            }
            return ExecuteReader(command);
        }
        public static int InsertInto(string table, params MysqlData[] datas)
        {
            MySqlCommand command = new MySqlCommand();

            var builder = AppendJoin(",", datas);
            command.CommandText = $"insert into {table} set {builder};";
            Debug.Log(command.CommandText);
            foreach (var item in datas)
            {
                command.Parameters.AddWithValue($"@{item.key}", item.value);
            }
            return ExecuteNonQuery(command);
        }
        public static int Update(string table, MysqlData[] updateDatas, params MysqlData[] whereDatas)
        {
            List<string> updateStrList = new List<string>();
            foreach (var item in updateDatas)
            {
                updateStrList.Add($"{item.key}=@1{item.key}");
            }
            var updateStr = AppendJoin(",", updateStrList);

            List<string> whereStrList = new List<string>();
            foreach (var item in whereDatas)
            {
                whereStrList.Add($"{item.key}=@2{item.key}");
            }
            var whereStr = AppendJoin(" and ", whereStrList);


            MySqlCommand command = new MySqlCommand();
            command.CommandText = $"update {table} set {updateStr} where {whereStr};";
            Debug.Log(command.CommandText);
            foreach (var item in updateDatas)
            {
                command.Parameters.AddWithValue($"@1{item.key}", item.value);
            }
            foreach (var item in whereDatas)
            {
                command.Parameters.AddWithValue($"@2{item.key}", item.value);
            }
            return ExecuteNonQuery(command);
        }
        public static int Delete(string table, params MysqlData[] datas)
        {
            MySqlCommand command = new MySqlCommand();
            var builder = AppendJoin(" and ", datas);
            command.CommandText = $"delete from {table} where {builder};";
            Debug.Log(command.CommandText);
            foreach (var item in datas)
            {
                command.Parameters.AddWithValue($"@{item.key}", item.value);
            }
            return ExecuteNonQuery(command);
        }


        private static DataTable ExecuteReader(MySqlCommand command)
        {
            connection.Open();
            command.Connection = connection;
            MySqlDataAdapter dataAdapter = new MySqlDataAdapter(command);
            DataTable table = new DataTable();
            dataAdapter.Fill(table);
            connection.Close();
            return table;
        }
        private static int ExecuteNonQuery(MySqlCommand command)
        {
            connection.Open();
            command.Connection = connection;
            MySqlDataAdapter dataAdapter = new MySqlDataAdapter(command);
            var rowNum = command.ExecuteNonQuery();
            connection.Close();
            return rowNum;
        }



        private static string AppendJoin<T>(string separator, List<T> values)
        {
            string str = "";
            for (int i = 0; i < values.Count; i++)
            {
                if (i == values.Count - 1)
                {
                    str += values[i];
                }
                else
                {
                    str += values[i] + separator;
                }
            }
            return str;
        }
        private static string AppendJoin(string separator, params object[] values)
        {
            string str = "";
            for (int i = 0; i < values.Length; i++)
            {
                if (i == values.Length - 1)
                {
                    str += values[i];
                }
                else
                {
                    str += values[i] + separator;
                }
            }
            return str;
        }
    }
}


namespace CSharpMysql
{
    public class MysqlData
    {
        public string key { get; private set; }
        public object value { get; private set; }
        public MysqlData(string key, object value)
        {
            this.key = key;
            this.value = value;
        }
        

        public override string ToString()
        {
            return $"{key}=@{key}";
        }
    }
}
namespace CSharpMysql
{
    public class MySqlConnectString
    {
        public string server = "127.0.0.1";
        public int port = 3306;
        public string user = "root";
        public string password = "root";
        public string database = "test";

        public override string ToString()
        {
            return $"server={server};user={user};database={database};port={port};password={password}";
        }

        public static MySqlConnectString New()
        {
            return new MySqlConnectString();
        }
    }
}

标签：string,数据库,item,Unity,command,key,Mysql,table,public
来源： https://blog.csdn.net/wanghao1230707/article/details/122689581

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。