Подтвердить что ты не робот

Автоматическое обновление приложения при изменении данных в SQL Server

Я использую SQL Server, и у меня есть 3 сервера приложений. Когда таблица в моей базе данных изменилась, мне необходимо, чтобы эти серверы приложений обновляли локальные кэшированные данные. Я использую триггер для известных изменений и отправляю сообщение через очередь сервис-брокера. Затем я создаю хранимую процедуру и назначаю ее для активации хранимой процедуры моей очереди. В этой хранимой процедуре я получаю сообщение, но я не знаю. Как мне вызвать метод refresh в моем приложении.

Ответ 1

У меня была аналогичная проблема, и с нижеприведенным кодом была разрешена эта проблема

class QueryNotification
    {
        public DataSet DataToWatch { get; set; }
        public SqlConnection Connection { get; set; }
        public SqlCommand Command { get; set; }

        public string GetSQL()
        {
            return "SELECT * From YourTable";
        }

        public string GetConnection()
        {
            return ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;
        }

        public bool CanRequestNotifications()
        {

            try
            {
                var perm = new SqlClientPermission(PermissionState.Unrestricted);
                perm.Demand();
                return true;
            }
            catch
            {
                return false;
            }
        }

        public void GetData()
        {
            DataToWatch.Clear();
            Command.Notification = null;
            var dependency =
                new SqlDependency(Command);
            dependency.OnChange += dependency_OnChange;

            using (var adapter =
                new SqlDataAdapter(Command))
            {
                adapter.Fill(DataToWatch, "YourTableName");
            }
        }

        private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
        {

            var i = (ISynchronizeInvoke)sender;

            if (i.InvokeRequired)
            {

                var tempDelegate = new OnChangeEventHandler(dependency_OnChange);

                object[] args = { sender, e };

                i.BeginInvoke(tempDelegate, args);

                return;
            }

            var dependency = (SqlDependency)sender;

            dependency.OnChange -= dependency_OnChange;

            GetData();
        }


    }

Update:

Проверить разрешение:

 public bool CanRequestNotifications()
        {

            try
            {
                var perm = new SqlClientPermission(PermissionState.Unrestricted);
                perm.Demand();
                return true;
            }
            catch
            {
                return false;
            }
        }

Для экземпляра в вашем окне загружается:

if (!_queryNotification.CanRequestNotifications())
            {
                MessageBox.Show("ERROR:Cannot Connect To Database");
            }

            SqlDependency.Stop(_queryNotification.GetConnection());
            SqlDependency.Start(_queryNotification.GetConnection());

            if (_queryNotification.Connection == null)
            {
                _queryNotification.Connection = new SqlConnection(_queryNotification.GetConnection());
            }

            if (_queryNotification.Command == null)
            {
                _queryNotification.Command = new SqlCommand(_queryNotification.GetSQL(),
_queryNotification.Connection);
            }
            if (_queryNotification.DataToWatch == null)
            {
                _queryNotification.DataToWatch = new DataSet();
            }

            GetData();

Ответ 2

Вы должны посмотреть на использование класса SqlDependency.

Дополнительная информация: http://msdn.microsoft.com/en-us/library/system.data.sqlclient.sqldependency(v=vs.110).aspx

Ответ 3

Я могу предложить вам попробовать решить проблему с помощью TCP. Каждое приложение прослушивает порт, и когда другое приложение обновляет db, он отправляет сообщение другим приложениям, говорящим, что им нужно обновить.

Надеюсь, это была хорошая идея.