2

关于 SignalR 和 SQL 依赖关系，查询通知是否不能使用 count(*) 之类的聚合函数？

是否有另一种方法或想法来创建包含聚合函数的查询？

4

2 回答 2

1

是的，如果您想使用 count(*) 之类的聚合函数来查询 sql 依赖关系，我有解决方案。首先在您的存储库中仍然使用 select query 。但是在阅读器中，您只需计算阅读器执行命令的数据。像这样的东西

int count = 0;
command = new SqlCommand(@"select Edolpuz_DB.dbo.TABEL_KONFIRMASI_PEMBAYARAN.ID_BUKTI_PEMBAYARAN from Edolpuz_DB.dbo.TABEL_KONFIRMASI_PEMBAYARAN where Edolpuz_DB.dbo.TABEL_KONFIRMASI_PEMBAYARAN.IS_NEW = @room", connect);
                command.Parameters.AddWithValue("room", true);
                try
                {
                    command.Notification = null;
                    SqlDependency dependency = new SqlDependency(command);
                    dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);
                    if (connect.State == ConnectionState.Open)
                        connect.Close();
                    connect.Open();
                    reader = command.ExecuteReader();
                    while (reader.Read())
                    {
                        count++;
                    }
                    return count;
                }
                catch { return 0; }
                finally { connect.Close(); }
于 2015-02-01T09:50:35.370 回答
0

小心使用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，这会为您提供理想的结果：类似 COUNT 的行为。希望这可以帮助。

于 2015-02-23T12:11:10.523 回答