WPF非轮询方式更新数据库变化SqlDependency（数据库修改前台自动更新）

上一章节咱们讲到wpf的柱状图组件，它包含了非轮询方式更新数据库变化SqlDependency的内容，可是没有详细解释，如今给你们一个比较简单的例子来讲明这部份内容。

上一章节：

WPF柱状图（支持数据库动态更新）

效果图请加群查看，在群共享里面。

 

在使用SqlDependency以前须要先开启sql server的SQL Server Service Broker服务，用来通知数据变化的服务，命令以下：

alter database 数据库名称 set enable_broker

若是执行成功则执行下列语句，1为开启，0未开启：

select IS_BROKER_ENABLED from master.sys.databases

where name='数据库名称'

若是一直在执行的过程当中那就重启一下sql server服务，如SQL EXPRESS.

第一种方式   

代码以下：

private string label11;   //这个至关于一个介质    在用组件的时候有依赖属性做为绑定项    就不须要这个  这里只是一个简单的demo  因此用这个

        public string Label11
        {
            get { return label11; }
            set { label11 = value; }
        }
    //监听数据库的值变化
        void OnDependencyChange(object sender, SqlNotificationEventArgs e)
        {
            GetTable();
        }
        private static string con = "data source=.;initial catalog=ColumnSeriesDB;uid=sa;pwd=sa;";
        string lal;
     //这个若是有依赖属性就不须要这个    这个是监听属性值的变化
        protected override void OnPropertyChanged(DependencyPropertyChangedEventArgs e)
        {
            base.OnPropertyChanged(e);
            if (lal != null)
                if (Label11 != lal)
                    GetTable();
            lal = Label11;
        }


        private void GetTable()
        {
            this.Dispatcher.Invoke(new System.Action(() =>
               {
                   SqlConnection sqlCon = new SqlConnection(con);
                 //须要监控的数据内容
                   SqlCommand cmd = new SqlCommand("SELECT MinData FROM ColumnSeriesData", sqlCon);
                   cmd.CommandType = CommandType.Text;
                   sqlCon.Open();
                   SqlDependency dep = new SqlDependency(cmd);
                  //数据库的值发生变化时触发该事件
                   dep.OnChange += new OnChangeEventHandler(OnDependencyChange);
                   SqlDataReader reader = cmd.ExecuteReader();
                   List<string> ls = new List<string>();


                   while (reader.Read())
                   {
                       
                       ls.Add(reader["MinData"].ToString());

                       
                   }
                   Label11 = ls[0].ToString();
                   reader.Close();
                   //wpf  值的绑定
                   Binding ToolTipNameBind = new Binding { Source = this, Path = new PropertyPath("Label11") };
                   BindingOperations.SetBinding(this.label1, Label.ContentProperty, ToolTipNameBind);
            }));
            
        }

        
        private void Window_Loaded_1(object sender, RoutedEventArgs e)
        {
            SqlDependency.Start(con);   //开启监听
            GetTable();
            
        }

 

第二种方式   关于在组件开发时的SqlDependency使用代码以下：

public static DependencyProperty Label11Property = DependencyProperty.Register("Label11", typeof(string), typeof(MainWindow));     //定义一个依赖项属性    依赖与Label11  二者为同一个值     第一个参数是要依赖的属性   第二个为类型   第三个为当前的类或窗体名称

        public string Label11
        {
            get { return (string)GetValue(Label11Property); }
            set { SetValue(Label11Property, value); }
        }
        
        void OnDependencyChange(object sender, SqlNotificationEventArgs e)
        {
            GetTable();
        }
        private static string con = "data source=.;initial catalog=ColumnSeriesDB;uid=sa;pwd=sa;";
         //这里就不须要这些了     以前是没有使用依赖属性  数据库的数据变化以后   在这里没法变化   须要监听属性的值   当使用依赖属性以后   二者的值是依赖关系  绑定以后可自动变化
        //string lal;
        //protected override void OnPropertyChanged(DependencyPropertyChangedEventArgs e)
        //{
        //    base.OnPropertyChanged(e);
        //    if (lal != null)
        //        if (Label11 != lal)
        //            GetTable();
        //    lal = Label11;
        //}


        private void GetTable()
        {
            this.Dispatcher.Invoke(new System.Action(() =>
               {
                   SqlConnection sqlCon = new SqlConnection(con);
                   SqlCommand cmd = new SqlCommand("SELECT MinData FROM ColumnSeriesData", sqlCon);
                   cmd.CommandType = CommandType.Text;
                   sqlCon.Open();
                   SqlDependency dep = new SqlDependency(cmd);
                   dep.OnChange += new OnChangeEventHandler(OnDependencyChange);
                   SqlDataReader reader = cmd.ExecuteReader();
                   List<string> ls = new List<string>();


                   while (reader.Read())
                   {
                       
                       ls.Add(reader["MinData"].ToString());

                       
                   }
                   Label11 = ls[0].ToString();
                   reader.Close();
                   Binding ToolTipNameBind = new Binding { Source = this, Path = new PropertyPath("Label11") };
                   BindingOperations.SetBinding(this.label1, Label.ContentProperty, ToolTipNameBind);
            }));
            
        }

        
        private void Window_Loaded_1(object sender, RoutedEventArgs e)
        {
            SqlDependency.Start(con);
            GetTable();
            
        }

 

关于两种方式的不一样 ：

第一种方式   好比在链接数据库的时候    如须要远程链接数据库   在开发组件的时候是不可能将数据库的名称、登陆名、密码等信息写到组件里面的，由于这些不是从数据库中读取的    就使用不到SqlDependency了 ， 因此 在将组件加载到设计器  或者设计平台的时候  数据库名称  数据库登陆名   密码等 是不能用依赖属性直接绑定的  ，就须要这种方式去手动绑定，当修改了数据库的名称等信息的时候触发OnPropertyChanged事件  去从新根据修改的数据库名称去登陆数据库获取数据。

第二种方式只限于在数据库中读取数据。第一种方式比较灵活   能够本身去作想要的属性，让它动态显示。

 

    在这方面有更好的方案欢迎交流。

 

咱们的群：94234450

点击加入QQ群：

不论你遇到什么问题，咱们毫不会让你独自去面对！