SQL依赖线程

Question

我正在实现 SQLdepenency 的过程中，我想知道在依赖处理程序执行的情况下，它会从主进程中旋转不同的线程吗？当事件处理程序触发时会发生什么？我需要担心任何多线程问题吗？

public void CreateSqlDependency()
{
    try
    {
        using (SqlConnection connection = (SqlConnection)DBFactory.GetDBFactoryConnection(Constants.SQL_PROVIDER_NAME))
        {
            SqlCommand command = (SqlCommand)DBFactory.GetCommand(Constants.SQL_PROVIDER_NAME);
            command.CommandText = watchQuery;
            command.CommandType = CommandType.Text;
            SqlDependency dependency = new SqlDependency(command);
            //Create the callback object 
            dependency.OnChange += new OnChangeEventHandler(this.QueueChangeNotificationHandler); 
            SqlDependency.Start(connectionString);

            DataTable dataTable = DBFactory.ExecuteSPReDT(command);
        }

    }
    catch (SqlException sqlExp)
    {
        throw sqlExp;
    }
    catch (Exception ex)
    {
        throw ex;
    }
}

public void QueueChangeNotificationHandler(object caller, SqlNotificationEventArgs e)
{
    if(e.Info == SqlNotificationInfo.Insert)
        Fire();
}

Answer 1

它在一个单独的线程中工作，但只有一个这样的线程用于所有通知。查看本文中的 SQLDependency 部分

Answer 2

MSDN 上的 SqlDependency 文档提到了以下可能性： OnChange 事件可能在与启动命令执行的线程不同的线程上生成。

您应该阅读使用 SqlDependency (ADO.NET) 检测更改文章MSDN 解释了类似的情况。

Answer 3

它将生成一个新的工作线程来等待依赖项通知——但这就是您想要的（否则您的主程序循环将被搁置，等待可能永远不会发生的事情！）。

此页面中的示例代码显示了如何避免获取依赖/查询通知的工作线程无权更新 UI 的问题；他们的方法将任务传递给 UI 线程，这样任务就会成功（参见步骤 #12）。

Answer 4

它确实在不同的线程中生成！您可以创建一个简单的 Windows 应用程序来测试这一点，您将看到 OnChange 处理程序如何无法直接修改任何 UI 控件（您会得到类似“跨线程操作无效：从其他线程访问的控件 XXX”的信息）比创建它的线程“）。为了克服这个问题，您可以调用 BeginInvoke。

这是一个简单的 Windows 应用程序来测试 SqlDependency（我希望你能想象一下 UI）。

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Data.Linq;
using System.Data.Linq.SqlClient;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Data.SqlClient;

namespace TestSqlDependancies
{
public partial class SqlDependencyTester : Form
    {
        SqlDependency sqlDepenency = null;
        SqlCommand command;
        SqlNotificationEventArgs msg;
        public Form1()
        {
            InitializeComponent();
        }

        private void label1_Click(object sender, EventArgs e)
        {
        }
        public delegate void InvokeDelegate();
        void sqlDepenency_OnChange(object sender, SqlNotificationEventArgs e)
        {
            msg = e;
            this.BeginInvoke(new InvokeDelegate(Notify));
        }

        private void Notify()
        {
            listBox1.Items.Add(DateTime.Now.ToString("HH:mm:ss:fff") + " - Notfication received. SqlDependency " + (sqlDepenency.HasChanges ? " has changes." : " reports no change. ") + msg.Type.ToString() + "-" + msg.Info.ToString());
        }

        private void button1_Click(object sender, EventArgs e)
        {
            SetDependency();
        }

        private void SetDependency()
        {
            try
            {
                using (TicketDataContext dc = new TicketDataContext())
                {
                    SqlDependency.Start(dc.Connection.ConnectionString);
                    command = new SqlCommand(textBox1.Text, (SqlConnection)dc.Connection);
                    sqlDepenency = new SqlDependency(command);
                    sqlDepenency.OnChange += new OnChangeEventHandler(sqlDepenency_OnChange);
                    command.Connection.Open();
                    command.ExecuteReader();
                }
            }
            catch (Exception e)
            {
                listBox1.Items.Add(DateTime.Now.ToString("HH:mm:ss:fff") + e.Message);
            }
        }
    }
}