C# MariaDB 連接，關閉，創建、增、刪、查、改

最近項目用到C# 以及MariaDB相關知識，在此小計一下。

關於MariaDB的安裝使用參照以下連接文檔：

MariaDB安裝與使用_HeidiSQL工具_IT_wind007的博客-CSDN博客

自帶的HeidiSQL工具覺得界面不太友好，於是自己下載了一個Navicat進行操作，相關操作參照以下連接文檔：

Navicat使用快速入門教程_苜苜的爛筆頭的博客-CSDN博客_navicat使用教程詳解

 

以上步驟完成以后，打開C#工程，C#工程中的“引用”——添加——擴展——勾選MySql.Data，確認即可使用

在需要使用數據庫操作的文件頭添加  using MySql.Data.MySqlClient;

即可調用相關操作。

1、數據庫連接

        public bool ConnectToSql()
        {

            // 對象轉字符串方法
            MySqlConnectionStringBuilder builder = new MySqlConnectionStringBuilder();
            builder.Database = "plc_control";   // 數據庫名
            builder.Server = "localhost";     // IP
            builder.Port = 3306;                // 端口號
            builder.UserID = "root";            // 用戶名
            builder.Password = "root";          // 密碼
            builder.CharacterSet = "utf8mb4";   // 編碼格式

            if (null == conn)
            {
                conn = new MySqlConnection(builder.ToString());
            }

            try
            {
                conn.Open();

                //在open之后調用就可以避免creatTable報錯
                MySqlCommand setcmd = new MySqlCommand("SET character_set_results=utf8mb4", conn);
                int n = setcmd.ExecuteNonQuery();
                setcmd.Dispose();

                Console.WriteLine("連接成功!!!");

                return true;
            }
            catch (Exception e1)
            {
                Console.WriteLine("打印拋出：" + e1.ToString() + builder.ToString());
                return false;
            }
        }

 

2、數據庫關閉

    public void CloseConn()
        {
            if (null != conn)
            {
                if (conn.State == ConnectionState.Open)
                {
                    conn.Close();
                    Console.WriteLine("正常關閉!!!");
                }
            }
        }

 

3、創建（create table）

        private void CreatActionLogTable()
        {
            string strCreat = string.Format(@"CREATE TABLE IF NOT EXISTS actionlog(
                                  `time` datetime DEFAULT NULL,
                                  `user` varchar(24) DEFAULT NULL,
                                  `log` varchar(200) DEFAULT NULL
                                ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE utf8mb4_unicode_ci;");

            ExecuteQuery(strCreat);
        }


     private void ExecuteQuery(string strCreat)
        {
            try
            {
                MySqlCommand myCmd = new MySqlCommand(strCreat, conn);
                myCmd.ExecuteNonQuery();
            }
            catch (MySqlException ex) {
                Console.WriteLine("err:"+ex.Message);
            }
        }

 

4、增（insert）數據的批處理操作

　　　　　//插入指令的批處理操作
        public void ExecuteSqlTranssaction(List<string> sqlStrList)
        {
            //創建執行命令的command對象
            MySqlCommand command = new MySqlCommand();
            command.Connection = conn;

            //開啟mysql事務
            MySqlTransaction transaction = conn.BeginTransaction();
            command.Transaction = transaction;

            try
            {

                if (sqlStrList.Count > 1)
                {
                    for (int i = 0; i < sqlStrList.Count; i++)
                    {
                        string sqlStr = sqlStrList[i].ToString();
                        if (sqlStr.Trim().Length > 1)
                        {
                            command.CommandText = sqlStr;
                            command.ExecuteNonQuery();
                        }

                        if (i > 0 && (i % 500 == 0
                            || i == sqlStrList.Count - 1))
                        {
                            transaction.Commit();

                            if (i != sqlStrList.Count - 1)
                            {
                                transaction = conn.BeginTransaction();
                            }
                        }
                    }
                }
                else
                {
                    for (int i = 0; i < sqlStrList.Count; i++)
                    {
                        string sqlStr = sqlStrList[i].ToString();
                        if (sqlStr.Trim().Length > 1)
                        {
                            command.CommandText = sqlStr;
                            command.ExecuteNonQuery();

                            transaction.Commit();

                        }
                    }
                }
            }
            catch (MySqlException err)
            {

                Console.WriteLine("ExecuteSqlTranssaction error!!!" + err.ToString());

                transaction.Rollback();
                throw new Exception(err.Message);

            }
        }

        private void Insert2actionlog(C_ActionLog tmpActionLog)
        {
            string sqlStr = string.Format("insert into actionlog (time,user,log) " +
                           "values('{0}','{1}','{2}');",
                           tmpActionLog.dateTime,
                           tmpActionLog.user,
                           tmpActionLog.logInfo);

            Console.WriteLine(sqlStr);

            actSqlStrList.Add(sqlStr);
        }

5、刪（delete） 整理碎片

　　　　//多條刪除
        public int DeleteLog(DateTime sTime, DateTime endTime) {

            string startTimeStr = sTime.ToString();
            string endTimeStr = endTime.ToString();

            //需要挑選日期 
            string sqlStr = string.Format("DELETE FROM actionlog WHERE time BETWEEN '{0}' AND '{1}' LIMIT 10000;", startTimeStr, endTimeStr);

            ExecuteQuery(sqlStr);

            //刪除數據以后，整理碎片  大量數據才需要用到
            string alterStr = string.Format("alter table actionlog engine = innodb,ALGORITHM=INPLACE, LOCK=NONE;");
            ExecuteQuery(alterStr);

            return 0;
        }

6、查（select）

        //獲取日志
        public void SelectLogFromSql(short timeFlag, DateTime sTime, DateTime eTime, out List<C_ActionLog> logList)
        {

            logList = new List<C_ActionLog>();

            string sqlStr = "SELECT * FROM actionlog ";
            string timeStr = "";
            string endStr = ";";
            string startTimeStr = sTime.ToString();
            string endTimeStr = eTime.ToString();
            if (1 == timeFlag)
            {//需要挑選日期 
                timeStr = string.Format("WHERE time BETWEEN '{0}' AND '{1}' ", startTimeStr, endTimeStr);

            }

            sqlStr += timeStr + endStr;

            Console.WriteLine(sqlStr);

            MySqlCommand command = new MySqlCommand(sqlStr, conn);
            MySqlDataReader reader = command.ExecuteReader();

            while (reader.Read())
            {
                C_ActionLog ectionLog = new C_ActionLog();

                ectionLog.dateTime = reader.GetDateTime("time");
                ectionLog.user = reader.GetString("user");
                ectionLog.logInfo = reader.GetString("log");

                logList.Add(ectionLog);
            }

            reader.Close();
        }

7、改（Update）

  updateStr = string.Format("UPDATE equipcraftconf SET id={0},craftName='{1}' WHERE staNo={2} AND craftNo={3};",
                    equipCraftConf.id,
                    equipCraftConf.craftInfo.craftName,
                    equipCraftConf.craftInfo.staNo,
                    equipCraftConf.craftInfo.craftNo          
                    );

 ExecuteQuery(updateStr);