使用存储过程的SQL依赖项

本文关键字：依赖 SQL 存储过程 | 更新日期: 2023-09-27 18:16:08

我在c#代码中使用SqlDependency来提醒我的应用程序，当数据库中一行中的特定列值发生变化时。我可以使用内联SQL实现它。

我想用存储过程替换它，但由于某种原因，代码没有执行存储过程。我从我的应用程序粘贴几行代码。请让我知道如何修改它，以便我可以将内联SQL替换为过程调用来实现相同的目标。

var con = new SqlConnection(ConnectionString);
SqlDependency.Stop(con.ConnectionString);
SqlDependency.Start(con.ConnectionString);
var connection = new SqlConnection(con.ConnectionString);
connection.Open();
try
{
    using (var command = new SqlCommand("inlinesql", connection))
    {
        var dependency = new SqlDependency(command);
        dependency.OnChange += new OnChangeEventHandler(OnDependencyChange);
        using (SqlDataReader rdr = command.ExecuteReader())
        {
            try
            {
                if (rdr.HasRows)
                {
                    _autoEvent.WaitOne();
                }
                else
                {
                    continue;
                }
            }
            finally
            {
                rdr.Close();
            }
        }
    }
}
finally
{
    connection.Close();
    SqlDependency.Stop(con.ConnectionString);
}
void OnDependencyChange(object sender, SqlNotificationEventArgs e)
{
    dosomething();
}

使用存储过程的SQL依赖项

以上var dependency... put:

command.CommandType = CommandType.StoredProcedure;

将inlinesql替换为存储过程的名称。

适合我的示例代码:

using (var sqlConnection = new SqlConnection (_connectionString)) {
  sqlConnection.Open ();
  using (var sqlCommand = sqlConnection.CreateCommand ()) {
    sqlCommand.Parameters.Clear ();
    sqlCommand.CommandType = System.Data.CommandType.StoredProcedure;
    // YOUR STORED PROCEDURE NAME AND PARAMETERS SHOULD COME HERE
    sqlCommand.CommandText = "sp_InsertData";
    sqlCommand.Parameters.AddWithValue ("@Code", e.Entity.Symbol);
    sqlCommand.Parameters.AddWithValue ("@Name", e.Entity.Name);
    sqlCommand.Parameters.AddWithValue ("@Price", e.Entity.Price);
    try {
      var sqlDataInsert = sqlCommand.ExecuteNonQuery ();                    
    } catch (Exception ex) {
       MessageBox.Show (ex.Message, this.Title);
    }
  }
}
相关文章：