2012-04-18 71 views
3

我想让SqlDependency对象给我通知,但到目前为止我无法让它工作。SqlDependency简单选择查询总是返回“无效”

,我传送给SQL查询是这样的:

SELECT [SocialMedia].[dbo].[Items].[Id] 
    FROM [SocialMedia].[dbo].[Items] 

我试过它瓦特/和W/O型的支架,具有完全合格的名称,只有变量名,和一切插图中。

Id为Guid类型,我没有看到,他们没有在Creating a Query for Notification文章

的SqlDependency对象的工作我也尝试过发送多列,看看是否会工作的任何提及。

SELECT SocialMedia.dbo.Items.Id, 
     SocialMedia.dbo.Items.DateTimeCreated, 
     SocialMedia.dbo.Items.AuthorId 
    FROM SocialMedia.dbo.Items 

而且这也没有奏效。


这里是我的表的SQL:

USE [SocialMedia] 

SET ANSI_NULLS ON 
SET QUOTED_IDENTIFIER ON 
SET ANSI_PADDING ON 

CREATE TABLE [dbo].[Items](
    [Id] [uniqueidentifier] NOT NULL, 
    [DateTimeCreated] [datetimeoffset](7) NOT NULL, 
    [AuthorId] [uniqueidentifier] NOT NULL, 
    [Source] [varchar](max) NOT NULL, 
    [PlaceId] [uniqueidentifier] NULL, 
    [FullText] [varchar](max) NOT NULL, 
    [Geography] [geography] NULL, 
    [DateTimeAdded] [datetime] NULL, 
CONSTRAINT [PK_Items] PRIMARY KEY CLUSTERED ([Id] ASC) 
       WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, 
       IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, 
       ALLOW_PAGE_LOCKS = ON) ON [PRIMARY] 
) ON [PRIMARY] TEXTIMAGE_ON [PRIMARY] 

GO 

ALTER TABLE [dbo].[Items] WITH CHECK ADD CONSTRAINT [FK_Items_Places] 
FOREIGN KEY([PlaceId]) REFERENCES [dbo].[Places] ([Id]) 

ALTER TABLE [dbo].[Items] CHECK CONSTRAINT [FK_Items_Places] 

GO 
ALTER TABLE [dbo].[Items] WITH CHECK ADD CONSTRAINT [FK_Items_Users] 
FOREIGN KEY([AuthorId]) REFERENCES [dbo].[Users] ([Id]) 

ALTER TABLE [dbo].[Items] CHECK CONSTRAINT [FK_Items_Users] 

我的DB:

USE [master] 
GO 

CREATE DATABASE [SocialMedia] 
CONTAINMENT = NONE 
ON PRIMARY 
(NAME = N'SocialMedia', 
    FILENAME = N'C:\Program Files\Microsoft SQL Server\MSSQL11.DENALI\MSSQL\DATA\SocialMedia.mdf' , 
    SIZE = 1110016KB , MAXSIZE = UNLIMITED, FILEGROWTH = 1024KB) 
LOG ON 
(NAME = N'SocialMedia_log', 
    FILENAME = N'C:\Program Files\Microsoft SQL Server\MSSQL11.DENALI\MSSQL\DATA\SocialMedia_log.ldf' , 
    SIZE = 123648KB , MAXSIZE = 2048GB , FILEGROWTH = 10%) 
GO 

ALTER DATABASE [SocialMedia] SET COMPATIBILITY_LEVEL = 110 
GO 

IF (1 = FULLTEXTSERVICEPROPERTY('IsFullTextInstalled')) BEGIN 
    EXEC [SocialMedia].[dbo].[sp_fulltext_database] @action = 'enable' 
END 
GO 

ALTER DATABASE [SocialMedia] SET ANSI_NULL_DEFAULT OFF 
ALTER DATABASE [SocialMedia] SET ANSI_NULLS ON 
ALTER DATABASE [SocialMedia] SET ANSI_PADDING ON 
ALTER DATABASE [SocialMedia] SET ANSI_WARNINGS ON 
ALTER DATABASE [SocialMedia] SET ARITHABORT ON 
ALTER DATABASE [SocialMedia] SET AUTO_CLOSE OFF 
ALTER DATABASE [SocialMedia] SET AUTO_CREATE_STATISTICS ON 
ALTER DATABASE [SocialMedia] SET AUTO_SHRINK OFF 
ALTER DATABASE [SocialMedia] SET AUTO_UPDATE_STATISTICS ON 
ALTER DATABASE [SocialMedia] SET CURSOR_CLOSE_ON_COMMIT OFF 
ALTER DATABASE [SocialMedia] SET CURSOR_DEFAULT GLOBAL 
ALTER DATABASE [SocialMedia] SET CONCAT_NULL_YIELDS_NULL ON 
ALTER DATABASE [SocialMedia] SET NUMERIC_ROUNDABORT OFF 
ALTER DATABASE [SocialMedia] SET QUOTED_IDENTIFIER ON 
ALTER DATABASE [SocialMedia] SET RECURSIVE_TRIGGERS OFF 
ALTER DATABASE [SocialMedia] SET ENABLE_BROKER 
ALTER DATABASE [SocialMedia] SET AUTO_UPDATE_STATISTICS_ASYNC OFF 
ALTER DATABASE [SocialMedia] SET DATE_CORRELATION_OPTIMIZATION OFF 
ALTER DATABASE [SocialMedia] SET TRUSTWORTHY OFF 
ALTER DATABASE [SocialMedia] SET ALLOW_SNAPSHOT_ISOLATION OFF 
ALTER DATABASE [SocialMedia] SET PARAMETERIZATION SIMPLE 
ALTER DATABASE [SocialMedia] SET READ_COMMITTED_SNAPSHOT OFF 
ALTER DATABASE [SocialMedia] SET HONOR_BROKER_PRIORITY OFF 
ALTER DATABASE [SocialMedia] SET RECOVERY FULL 
ALTER DATABASE [SocialMedia] SET MULTI_USER 
ALTER DATABASE [SocialMedia] SET PAGE_VERIFY CHECKSUM 
ALTER DATABASE [SocialMedia] SET DB_CHAINING OFF 
ALTER DATABASE [SocialMedia] SET FILESTREAM(NON_TRANSACTED_ACCESS = OFF) 
ALTER DATABASE [SocialMedia] SET TARGET_RECOVERY_TIME = 0 SECONDS 
ALTER DATABASE [SocialMedia] SET READ_WRITE 

而我使用运行它的代码:

string connString = ConfigurationManager.ConnectionStrings["ApplicationServices"].ConnectionString; 
conn = new SqlConnection(connString); 
conn.Open(); // open new connection and create command to notify about all new Chat-Messages in -ROOM_NUMBER- const 
using (var sqlCommand = new SqlCommand(GetSearchQueryString(searchItems), conn)) 
{ 
    var sqlDependency = new SqlDependency(sqlCommand 
    //handle onChange event - this will be fired whenever there is a change in database that affacts our query 
    sqlDependency.OnChange += (sender, e) => 
    { 
     //change detected - get all messages... 
     try 
     { 

      var sql = GetSearchQueryString(searchItems); 
      int count = _entities.ExecuteStoreQuery<Guid>(sql).Count(); 

      AsyncManager.Parameters["count"] = count; 
     } 
     finally 
     { 
      AsyncManager.OutstandingOperations.Decrement(); 
     } 
    }; 
    sqlCommand.ExecuteNonQuery(); 
} 

我在节目中早些时候打电话给SqlDependency.Start(ConfigurationManager.ConnectionStrings["ApplicationServices"].ConnectionString);

我错过了什么吗?我觉得我失去了一些明显的...

+0

也许尽量不要配置SqlCommand对象? – yamen 2012-04-18 22:08:47

+0

“不起作用”是什么意思?你能发布错误吗? – usr 2012-04-18 23:45:31

+0

您是否已经完成了服务器端的所有必要设置? (启用clr集成和服务代理,设置权限等) – paul 2012-04-19 09:14:34

回答

8

我发现SqlDependency是非常脆弱的。有时候,如果你做了一些无效的事情,你总是会立即得到通知。没有错误信息。

尝试从查询中删除数据库名称限定。参考该表是这样的:dbo.Items

+1

usr是正确的 - 名称必须是2个部分(不是1,3或4)。 – EBarr 2012-05-15 22:30:10

2

它看起来像你使用三个部分的名称,即描述的步骤

[SocialMedia].[dbo].[Items].[Id]

的文件中明确规定,你需要使用两个部分组成的名称,所以改为

[SocialMedia].[Items].[Id]

1

迈克尔的回答是一个很好的来源,但有一两件事,微软没有提及:

SQL代理将拒绝表上的SELECT语句,该表具有 计算列

如果你尝试,你会得到一个SqlNotificationEventArgs与信息=查询,键入=订阅,和我一样,你会花几个小时试图找出什么是错误的说法,当它的计算列是罪魁祸首。

+0

任何人都知道为此工作?我试图用视图进行替换,但是也没有这样做。 – MBulava 2016-09-22 18:29:43

0

在你的SQL Server执行

ALTER DATABASE YOURDBNAME SET ENABLE_BROKER WITH ROLLBACK立即