欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

mysql 數(shù)據(jù)庫(kù)鏈接狀態(tài)確認(rèn)實(shí)驗(yàn)(推薦)

 更新時(shí)間：2022年09月30日 09:13:26   作者：科學(xué)的發(fā)展-只不過(guò)是讀大自然寫(xiě)的代碼  
這篇文章主要介紹了mysql 數(shù)據(jù)庫(kù)鏈接狀態(tài)確認(rèn)實(shí)驗(yàn),通過(guò)本文我選擇 了三種方案給大家詳細(xì)講解，結(jié)合實(shí)例代碼給大家介紹的非常詳細(xì)，需要的朋友可以參考下

1.起因：

在做一個(gè)小系統(tǒng)的時(shí)候，我想數(shù)據(jù)量交互不大，就都用一個(gè)鏈接執(zhí)行算了，還能節(jié)省點(diǎn)資源，但是實(shí)際情況遇到了如下問(wèn)題，在使用的過(guò)程中，有些數(shù)據(jù)操作會(huì)被轉(zhuǎn)移到其他線程，這樣；我這個(gè)簡(jiǎn)單的想法遇到了問(wèn)題，因?yàn)橐粋€(gè)現(xiàn)場(chǎng)在使用這個(gè)鏈接的時(shí)候，其他線程也會(huì)同步插入執(zhí)行數(shù)據(jù)操作，這樣一個(gè)鏈接就會(huì)面臨共用的沖突，怎么辦呢，有如下三種方案：

1.1.數(shù)據(jù)兩次一次一聯(lián)，一用，一釋放。

1.2.強(qiáng)制是數(shù)據(jù)庫(kù)的執(zhí)行放到一個(gè)現(xiàn)場(chǎng)，那么得把所有的執(zhí)行參數(shù)放到隊(duì)列中，有數(shù)據(jù)支持的線程按照隊(duì)列的順序執(zhí)行。也可以在使用的時(shí)候把鏈接索起來(lái)。這樣強(qiáng)制的使數(shù)據(jù)的處理串行。

1.3.做一個(gè)內(nèi)部的鏈接對(duì)象使用池，池中的對(duì)象可供服用，解決重復(fù)鏈接的問(wèn)題，提供多個(gè)對(duì)象解決現(xiàn)場(chǎng)使用沖突的問(wèn)題。

我選擇了方案三，做了如下實(shí)驗(yàn)，記錄如下

2.實(shí)驗(yàn)

2.1 確認(rèn)數(shù)據(jù)鏈接狀態(tài)，使用完的數(shù)據(jù)鏈接是什么狀態(tài)呢？

2.1.1 目的：我想根據(jù)鏈接的狀態(tài)判斷鏈接是在使用中，還是可以給別人使用；就是在可以使用的情況下，我就用該鏈接執(zhí)行，否則使用或者創(chuàng)建其他的鏈接。

代碼。

using System;
using System.Data;
 
namespace 數(shù)據(jù)庫(kù)鏈接狀態(tài)確認(rèn)
{
    /// <summary>
    /// 確認(rèn)數(shù)據(jù)庫(kù)通常執(zhí)行完成是什么狀態(tài)
    /// </summary>
    public class Test1:Singleton<Test1>
    {
        public void main()
        {
            test1();
        }
        private void test1()
        {
            DBmsqlSub dBmsqlSub = new DBmsqlSub();
            string sql = "insert into tb1(v1) values(2)";
            dBmsqlSub.ExecuteNonQuery(sql);
            ConnectionState connectionState = dBmsqlSub.getState();
            Console.WriteLine(connectionState);
            dBmsqlSub.Close();
        }
    }
}

結(jié)果，整理使用后的鏈接狀態(tài)是open,那是不是open的時(shí)候就可以供別人使用了呢，要是在執(zhí)行的時(shí)候也是open狀態(tài)，那我就沒(méi)有判定已經(jīng)了。

數(shù)據(jù)庫(kù)鏈接狀態(tài)確認(rèn)
id0
index:1 isuser:False setuser:False
Open

2.2 數(shù)據(jù)庫(kù)在執(zhí)行的時(shí)候，是不是有一個(gè)執(zhí)行中的狀態(tài)呢？

代碼

using System;
using System.Threading.Tasks;
 
namespace 數(shù)據(jù)庫(kù)鏈接狀態(tài)確認(rèn)
{
    /// <summary>
    /// 目的：確認(rèn)執(zhí)行中的數(shù)據(jù)狀態(tài)
    /// </summary>
    class Test2:Singleton<Test2>
    {
        public void main() {
            DBmsqlSub dBmsqlSub = new DBmsqlSub();
            Task.Factory.StartNew(test2Exe, (Object)dBmsqlSub);
            Task.Factory.StartNew(test2Exe, (Object)dBmsqlSub);
            Task.Factory.StartNew(test2State, dBmsqlSub);
        }
        private void test2Exe(object dBmsqlSub)
        {
            int index = 1;
            while (true)
            {
                index++;
                string sql = "insert into tb1(v1) values(" + index + ")";
                ((DBmsqlSub)dBmsqlSub).ExecuteNonQuery(sql);
                Task.Delay(200);
            }
        }
        private void test2State(object dBmsqlSub)
        {
            while (true)
            {
                Console.WriteLine(((DBmsqlSub)dBmsqlSub).getState());
            }
        }
    }
}

行結(jié)果執(zhí)：即使執(zhí)行中，對(duì)象的鏈接狀態(tài)依然是open，那么用鏈接狀態(tài)作為鏈接是否可用的計(jì)劃泡湯了，那就只能用自添加的對(duì)象來(lái)控制鏈接是否可用了。

Open
Open
Open
Open
id0
Open
Open
Open
Open
Open
Open

2.3 測(cè)試3：添加對(duì)象的狀態(tài)，控制鏈接是否可用

2.3.1 代碼

using MySqlConnector;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
 
namespace 數(shù)據(jù)庫(kù)鏈接狀態(tài)確認(rèn)
{
    class Test3:Singleton<Test3>
    {
        public void main() {
            test1();
            //test1();
        }
        private void test1() {
            Task.Factory.StartNew(test2Exe);
            Task.Factory.StartNew(test2Exe);
            Task.Factory.StartNew(test2Exe);
        }
        private void test2Exe()
        {
            int index = 1;
            while (true)
            {
                index++;
                string sql = "insert into tb1(v1) values(" + index + ")";
                DBmsql.getMy().ExecuteNonQuery(sql);
            }
        }
 
        private object MySqlDataReader(DBmsqlSub dBmsqlSub)
        {
            throw new NotImplementedException();
        }
 
        private void test2State(object dBmsqlSub)
        {
            while (true)
            {
                Console.WriteLine(((DBmsqlSub)dBmsqlSub).getState());
            }
        }
    }
}

2.3.2

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
 
namespace 數(shù)據(jù)庫(kù)鏈接狀態(tài)確認(rèn)
{
    class DBmsql : Singleton<DBmsql>
    {
        List<DBmsqlSub> dBmsqlSubs = new List<DBmsqlSub>();
        /// <summary>
        /// 執(zhí)行sql命令
        /// </summary>
        /// <param name="CommandText"></param>
        public void ExecuteNonQuery(String CommandText)
        {
            getDBmsqlSub().ExecuteNonQuery(CommandText);
        }
 
        /// <summary>
        /// 插入數(shù)據(jù)，并返回插入數(shù)據(jù)的id
        /// </summary>
        /// <param name="CommandText"></param>
        /// <returns></returns>
        public int insertReturn(string CommandText)
        {
            int ret = getDBmsqlSub().insertReturn(CommandText);
            return ret;
        }
        /// <summary>
        /// 執(zhí)行并返回一個(gè)對(duì)象
        /// </summary>
        /// <param name="CommandText"></param>
        /// <returns></returns>
        public object ExecuteScalar(string CommandText)
        {
            object o = getDBmsqlSub().ExecuteScalar(CommandText);
            return o;
        }
        /// <summary>
        /// 獲取數(shù)據(jù)處理對(duì)象
        /// </summary>
        /// <returns></returns>
        private DBmsqlSub getDBmsqlSub()
        {
            DBmsqlSub ret = null;
 
            lock (dBmsqlSubs)
            {
                //避免兩個(gè)同時(shí)取到允許的狀態(tài)
                foreach (DBmsqlSub dBmsqlSub in dBmsqlSubs)
                {
                    if (!dBmsqlSub.IsUrse())
                    {
                        ret = dBmsqlSub;
                        dBmsqlSub.setIsUser(true);
                        Console.WriteLine("get:" + ret.id);
                        break;
                    }
                }
                //避免兩個(gè)同時(shí)創(chuàng)建對(duì)象，產(chǎn)生結(jié)果列表的錯(cuò)誤
                if (ret == null&& dBmsqlSubs.Count<90)
                {
                    DBmsqlSub dBmsqlSub = new DBmsqlSub();
                    dBmsqlSubs.Add(dBmsqlSub);
                    dBmsqlSub.setIsUser(true);
                    ret = dBmsqlSub;
                    Console.WriteLine("get:" + ret.id);
                }
            }
            return ret;
        }
    }
}

2.3.3

using MySqlConnector;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
 
namespace 數(shù)據(jù)庫(kù)鏈接狀態(tài)確認(rèn)
{
    public class Constand {
        public static string mesConnStr = "server=localhost;port=3306;database=db1;user id=root;password=123456;Charset=utf8;";
    }
    class DBmsqlSub
    {
        static int index = 0;
        public int id = 0;
        private bool isUser = false;
        private static NLog.Logger logger = NLog.LogManager.GetCurrentClassLogger();
        MySqlConnection mConn;
        MySqlCommand mCmd;
        public void setIsUser(bool value) {
            lock (this) {
                Console.WriteLine("index:" + index + " isuser:" + isUser+" setuser:"+ value);
                isUser = value;
            }
        }
 
        public MySqlDataReader MySqlDataReader { get; private set; }
 
        public DBmsqlSub()
        {
            id = index++;
            try
            {
                mConn = new MySqlConnection(Constand.mesConnStr);
                mConn.Open();
                mCmd = new MySqlCommand();
                mCmd.Connection = mConn;
            }
            catch (Exception e)
            {
                logger.Error(e.ToString());
            }
        }
        ~DBmsqlSub()
        {
            mConn.Close();
        }
        public void Close()
        {
            mConn.Close();
        }
        public bool isOpen()
        {
            if (mConn.State == ConnectionState.Closed)
            {
                mConn.Open();
            }
            if (mConn.State == ConnectionState.Open)
            {
                return true;
            }
            else
            {
                return false;
            }
        }
        public MySqlCommand getCmd()
        {
            return mCmd;
        }
        /// <summary>
        /// 如果沒(méi)有鏈接，就直接鏈接
        /// </summary>
        private void conn()
        {
            if (mConn.State != ConnectionState.Open)
            {
                mConn.Open();
            }
        }
 
        /// <summary>
        /// 執(zhí)行sql命令
        /// </summary>
        /// <param name="CommandText"></param>
        public void ExecuteNonQuery(String CommandText)
        {
            //setIsUser(true);
            mCmd.CommandText = CommandText;
            try
            {
                Console.WriteLine("id"+id);
                mCmd.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                logger.Error(ex.ToString());
            }
            finally {
                setIsUser(false);
            }
        }
 
        /// <summary>
        /// 插入數(shù)據(jù)，并返回插入數(shù)據(jù)的id
        /// </summary>
        /// <param name="CommandText"></param>
        /// <returns></returns>
        public int insertReturn(string CommandText)
        {
            setIsUser(true);
            int ret = 0;
            MySqlTransaction sqlTransaction = mConn.BeginTransaction();
            try
            {
                mCmd.CommandText = CommandText;
                object o = mCmd.ExecuteScalar();
                sqlTransaction.Commit();
                ret = int.Parse(o.ToString());
            }
            catch (Exception e)
            {
                logger.Error(e.ToString());
                sqlTransaction.Rollback();
            }
            finally
            {
                setIsUser(false);
            }
            return ret;
        }
        /// <summary>
        /// 執(zhí)行并返回一個(gè)對(duì)象
        /// </summary>
        /// <param name="CommandText"></param>
        /// <returns></returns>
        public object ExecuteScalar(string CommandText)
        {
            setIsUser(true);
            object o = null;
            mCmd.CommandText = CommandText;
            try
            {
                o = mCmd.ExecuteScalar();
            }
            catch (Exception ex)
            {
                logger.Error(ex.ToString());
            }
            finally
            {
                setIsUser(false);
            }
            return o;
        }
        public MySqlDataReader ExecuteReader(string CommandText)
        {
            setIsUser(true);
            MySqlDataReader mySqlDataReader = null;
            mCmd.CommandText = CommandText;
            try
            {
                mySqlDataReader  = mCmd.ExecuteReader();
                //mConn.Close();
            }
            catch (Exception ex)
            {
                logger.Error(ex.ToString());
            }
            finally
            {
                setIsUser(false);
            }
            return mySqlDataReader;
        }
        public ConnectionState getState() {
            return mConn.State;
        }
        public bool IsUrse() {
            return isUser;
        }
    }
}

2.3.4

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
 
namespace 數(shù)據(jù)庫(kù)鏈接狀態(tài)確認(rèn)
{
    /// <summary>
    /// 單件構(gòu)象基類
    /// </summary>
    /// <typeparam name="T"></typeparam>
    public class Singleton<T> where T : new()
    {
        static T t = default(T);
        public static T getMy()
        {
            if (t == null)
            {
                t = new T();
            }
            return t;
        }
    }
}

運(yùn)行結(jié)果：可用看出是幾個(gè)鏈接對(duì)象在被循環(huán)的使用，也基本達(dá)到了直接的初衷，用盡可能少的鏈接，完成多線程的調(diào)用情景。

id2
index:5 isuser:True setuser:False
index:5 isuser:False setuser:True
index:5 isuser:True setuser:False
get:3
id3
index:5 isuser:False setuser:True
get:4
id4
index:5 isuser:True setuser:False
index:5 isuser:False setuser:True
get:2
id2
index:5 isuser:True setuser:False
index:5 isuser:False setuser:True
get:3
id3

到此這篇關(guān)于mysql 數(shù)據(jù)庫(kù)鏈接狀態(tài)確認(rèn)實(shí)驗(yàn)的文章就介紹到這了,更多相關(guān)mysql 數(shù)據(jù)庫(kù)鏈接狀態(tài)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

相關(guān)文章

最新評(píng)論