Событие SQLDependency Onchange всегда запускается без изменения данных

Я использую его в консольном проекте.
.NET Framework: 4.5

В моем тестовом коде всегда срабатывает SQLDependency onChange, хотя в базе данных нет изменений данных.

class Program
{
private static string _connStr;

static void Main(string[] args)
{
    _connStr = "data source=xxx.xxx.xx.xx;User Id=xxx;Password=xxx; Initial Catalog=xxx";
    SqlDependency.Start(_connStr);
    UpdateGrid();
    Console.Read();
}


private static void UpdateGrid()
{
    using (SqlConnection connection = new SqlConnection(_connStr))
    {
        using (SqlCommand command = new SqlCommand("select msgdtl,msgid From NotifyMsg", connection))
        {
            command.CommandType = CommandType.Text;
            connection.Open();
            SqlDependency dependency = new SqlDependency(command);
            dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);

            SqlDataReader sdr = command.ExecuteReader();
            Console.WriteLine();
            while (sdr.Read())
            {
                Console.WriteLine("msgdtl:{0}\t (msgid:{1})", sdr["msgdtl"].ToString(), sdr["msgid"].ToString());
            }
            sdr.Close();
        }
    }
}

private static void dependency_OnChange(object sender, SqlNotificationEventArgs e)
{
    UpdateGrid();
}

когда я начинаю работать, событие onChange срабатывает и никогда не останавливается. Но в моей базе нет никаких изменений.


asp.net sqldependency
person wtf512    schedule 19.04.2015    source источник

Ответы (2)


arrow_upward
4
arrow_downward

Попробуйте проверить объект SqlNotificationEventArgs в методе dependency_OnChnage. Похоже, у вас там ошибка. Однажды у меня было такое же поведение SqlDependency, и проблема была решена путем изменения select msgdtl,msgid From NotifyMsg на select msgdtl,msgid From dbo.NotifyMsg (был добавлен оператор dbo).

Но я должен вас предупредить: будьте осторожны с использованием SqlDependency - у него есть проблемы с утечки памяти. Однако вы можете использовать реализацию класса SqlDependency с открытым исходным кодом — SqlDependencyEx. Он использует триггер базы данных и собственное уведомление Service Broker для получения событий об изменениях таблицы. Это пример использования:

int changesReceived = 0;
using (SqlDependencyEx sqlDependency = new SqlDependencyEx(
          TEST_CONNECTION_STRING, TEST_DATABASE_NAME, TEST_TABLE_NAME)) 
{
    sqlDependency.TableChanged += (o, e) => changesReceived++;
    sqlDependency.Start();

    // Make table changes.
    MakeTableInsertDeleteChanges(changesCount);

    // Wait a little bit to receive all changes.
    Thread.Sleep(1000);
}

Assert.AreEqual(changesCount, changesReceived);

С помощью SqlDependecyEx вы можете отслеживать INSERT, DELETE, UPDATE отдельно и получать фактические измененные данные (xml) в объекте args события. Надеюсь, это поможет.

person dyatchenko    schedule 21.04.2015
comment
SqlDependecyEx более удобен, так как мне нужно отслеживать только вставку! Спасибо за рекомендацию! - person wtf512; 23.04.2015

arrow_upward
0
arrow_downward

существует пользовательская реализация SqlDependency, которая сообщает вам об измененных записях таблицы:

   var _con= "data source=.; initial catalog=MyDB; integrated security=True";

   static void Main()
   {
       using (var dep = new SqlTableDependency<Customer>(_con, "Customer"))
       {
           dep.OnChanged += Changed;
           dep.Start();

           Console.WriteLine("Press a key to exit");
           Console.ReadKey();

           dep.Stop();
        }
   }

   static void Changed(object sender, RecordChangedEventArgs<Customer> e)
   {
       if (e.ChangeType != ChangeType.None)
       {
           for (var index = 0; index < e.ChangedEntities.Count; index++)
           {
               var changedEntity = e.ChangedEntities[index];
               Console.WriteLine("DML operation: " + e.ChangeType);
               Console.WriteLine("ID: " + changedEntity.Id);
               Console.WriteLine("Name: " + changedEntity.Name);
               Console.WriteLine("Surame: " + changedEntity.Surname);
           }
       }
   }

Вот ссылка: [https://tabledependency.codeplex.com]

person Christian Del Bianco    schedule 11.08.2015