SqlDependency数据库同步signalr 推送消息-syncnavigator数据库同步syncnavigator 授权码

购买事宜请联系QQ:1793040usingSystem;usingSystem。

Configuration;usingSystem。

Data;usingSystem。

Data。

SqlClient;

namespaceSqlDependencyTest{classProgram{privatestaticstring_connStr;

staticvoidMain(string[]args){_connStr=ConfigurationManager。

ConnectionStrings[ConnStr]。

ToString();SqlDependency。

Start(_connStr);//传入连接字符串,启动基于数据库的监听UpdateGrid();

Console。

Read();}

privatestaticvoidUpdateGrid(){using(SqlConnectionconnection=newSqlConnection(_connStr)){//依赖是基于某一张表的,而且查询语句只能是简单查询语句,不能带top或*,同时必须指定所有者,即类似[dbo]。

[]using(SqlCommandcommand=newSqlCommand(selectID,UserID,[Message]From[dbo]。

[Messages],connection)){command。

CommandType=CommandType。

Text;connection。

Open();SqlDependencydependency=newSqlDependency(command);dependency。

OnChange+=newOnChangeEventHandler(dependency_OnChange);

SqlDataReadersdr=command。

ExecuteReader();Console。

WriteLine();while(sdr。

Read()){Console。

WriteLine(Id:{0} UserId:{1} Message:{2},sdr[ID]。

ToString(),sdr[UserId]。

ToString(),

sdr[Message]。

ToString());}sdr。

Close();}}}