当前位置：首页 > 资讯 > 技术文档

c#异步读取数据库与异步更新ui的代码实现

时间：2021-11-20 14:34 编辑：来源：阅读：
扫一扫，手机访问

摘要：c#异步读取数据库与异步更新ui的代码实现

异步读取数据库,在数据绑定的时候会出现点问题,就是窗体界面会无法关闭,要结束任务才能结束进程。例如下面代码 [b]首先按习惯的方法，设定线程更新UI[/b] a2.CheckForIllegalCrossThreadCalls = false; //a2为窗体名称 [b]下面的代码就是从数据库里取得数据并绑定[/b]

[u]复制代码[/u] 代码如下:

private void button1_Click(object sender, EventArgs e)
        {
            SqlConnection con;
            SqlCommand com;
            try
            {
                con = new SqlConnection("UID=sa;Password=123;Initial Catalog=AD;Data Source=192.168.1.1;Asynchronous Processing=true");
                con.Open();
                com = new SqlCommand("select top 100 * from tb_user", con);
                com.BeginExecuteReader(new AsyncCallback(delDataBin), com);
            }
            catch (Exception ex)
            {
                MessageBox.Show("程序发生错误,信息: " + ex.Message);
            }
        }

        private void delDataBin(IAsyncResult ar)
        {
            if (ar.IsCompleted)
            {
                SqlCommand com = (SqlCommand)ar.AsyncState;
                SqlDataReader dr = com.EndExecuteReader(ar);
                DataTable dt = new DataTable();
                dt.Load(dr);
                dr.Close();

                this.dataGridView1.DataSource = dt;  //绑定数据            

            }
        }

到这里完成的绑定的工作，运行查看一下效果，其实这样是会出现窗体假死的现象。下面通过Invoke 来实现首先声明委托 public delegate void updateDG(DataTable dt); 然后通过dataBin来绑定DataGridView

[u]复制代码[/u] 代码如下:

        public void dataBin(DataTable dt)
        {
            dataGridView1.DataSource = dt;
            return;
        } 

[b]在线程里面调用下面方法[/b]

[u]复制代码[/u] 代码如下:

//绑定数据
                if (this.InvokeRequired)
                {
                    updateDG ur = new updateDG(dataBin);
                    this.Invoke(ur, dt);
                }

完整的代码如下:

[u]复制代码[/u] 代码如下:

        private void button1_Click(object sender, EventArgs e)
        {
            SqlConnection con;
            SqlCommand com;
            try
            {
                con = new SqlConnection("UID=sa;Password=123;Initial Catalog=AD;Data Source=192.168.1.1;Asynchronous Processing=true");
                con.Open();
                com = new SqlCommand("select top 100 * from tb_user", con);
                com.BeginExecuteReader(new AsyncCallback(delDataBin), com);
            }
            catch (Exception ex)
            {
                MessageBox.Show("程序发生错误,信息: " + ex.Message);
            }
        }

        private void delDataBin(IAsyncResult ar)
        {
            if (ar.IsCompleted)
            {
                SqlCommand com = (SqlCommand)ar.AsyncState;
                SqlDataReader dr = com.EndExecuteReader(ar);
                DataTable dt = new DataTable();
                dt.Load(dr);
                dr.Close();

                //this.dataGridView1.DataSource = dt;//绑定数据

                if (this.InvokeRequired)
                {
                    updateDG ur = new updateDG(dataBin);
                    this.Invoke(ur, dt);
                }
            }
        }

        public delegate void updateDG(DataTable dt);

        public void dataBin(DataTable dt)
        {
            dataGridView1.DataSource = dt;
            return;
        }           

查运行查看一下，你就会发现结果了

全部评论(0)

上一篇：PHP简单实现冒泡排序的方法
下一篇：centos下file_put_contents()无法写入文件的原因及解决方法

资讯排行榜
更多>>