Files renamed

QueryTemplates/Common Scripts/ErrorLog-queue.sql

@@ -0,0 +1,147 @@
+/*
+  Queue in DBA database to catch ErrorLog records in realtime
+*/
+ALTER DATABASE [DBA] SET ENABLE_BROKER;
+GO
+USE [DBA]
+GO
+
+CREATE SCHEMA Monitor;
+GO
+
+CREATE TABLE [Monitor].[ErrorLog](
+	[PK_Id] [int] IDENTITY(1,1) NOT NULL,
+	[PostTime] [datetime] NULL,
+	[SPID] [int] NULL,
+	[TextData] [nvarchar](max) NULL,
+	[DatabaseID] [int] NULL,
+	[TransactionID] [bigint] NULL,
+	[NTUserName] [nvarchar](128) NULL,
+	[NTDomainName] [nvarchar](128) NULL,
+	[HostName] [nvarchar](128) NULL,
+	[ClientProcessID] [int] NULL,
+	[ApplicationName] [nvarchar](128) NULL,
+	[LoginName] [nvarchar](128) NULL,
+	[StartTime] [datetime] NULL,
+	[Severity] [int] NULL,
+	[ServerName] [nvarchar](128) NULL,
+	[State] [int] NULL,
+	[Error] [int] NULL,
+	[DatabaseName] [nvarchar](128) NULL,
+	[LoginSid] [image] NULL,
+	[RequestID] [int] NULL,
+	[EventSequence] [int] NULL,
+	[IsSystem] [int] NULL,
+	[SessionLoginName] [nvarchar](128) NULL,
+ CONSTRAINT [PK_ErrorLog] PRIMARY KEY CLUSTERED ([PK_Id])
+)
+GO
+
+CREATE QUEUE EventNotificationQueue;
+
+-- Create a service broker service receive the events
+CREATE SERVICE EventNotificationService
+ ON QUEUE EventNotificationQueue ([http://schemas.microsoft.com/SQL/Notifications/PostEventNotification])
+GO
+
+-- Create the event notification for ERRORLOG trace events on the service
+CREATE EVENT NOTIFICATION CaptureErrorLogEvents
+ ON SERVER
+ WITH FAN_IN
+ FOR ERRORLOG
+ TO SERVICE 'EventNotificationService', 'current database';
+GO
+
+CREATE PROCEDURE Monitor.[ProcessEventNotifications]
+  WITH EXECUTE AS OWNER
+AS 
+SET NOCOUNT ON
+DECLARE @message_body xml 
+DECLARE @email_message nvarchar(MAX)
+WHILE (1 = 1)
+BEGIN
+	BEGIN TRANSACTION
+	-- Receive the next available message FROM the queue
+	WAITFOR (
+		RECEIVE TOP(1) -- just handle one message at a time
+			@message_body=message_body
+			FROM dbo.EventNotificationQueue
+	), TIMEOUT 1000  -- if the queue is empty for one second, give UPDATE and go away
+	-- If we didn't get anything, bail out
+	IF (@@ROWCOUNT = 0)
+		BEGIN
+			ROLLBACK TRANSACTION
+			BREAK
+		END 
+
+		INSERT INTO [Monitor].[ErrorLog]
+           ([PostTime]
+           ,[SPID]
+           ,[TextData]
+           ,[DatabaseID]
+           ,[TransactionID]
+           ,[NTUserName]
+           ,[NTDomainName]
+           ,[HostName]
+           ,[ClientProcessID]
+           ,[ApplicationName]
+           ,[LoginName]
+           ,[StartTime]
+           ,[Severity]
+           ,[ServerName]
+           ,[State]
+           ,[Error]
+           ,[DatabaseName]
+           ,[LoginSid]
+           ,[RequestID]
+           ,[EventSequence]
+           ,[IsSystem]
+           ,[SessionLoginName])
+		SELECT 
+			 @message_body.value('(/EVENT_INSTANCE/PostTime)[1]', 'datetime') AS PostTime,
+			 @message_body.value('(/EVENT_INSTANCE/SPID)[1]', 'int' ) AS SPID,
+			 @message_body.value('(/EVENT_INSTANCE/TextData)[1]', 'varchar(max)' ) AS TextData,
+			 @message_body.value('(/EVENT_INSTANCE/DatabaseID)[1]', 'int' ) AS DatabaseID,
+			 @message_body.value('(/EVENT_INSTANCE/TransactionID)[1]', 'bigint' ) AS TransactionID,
+			 @message_body.value('(/EVENT_INSTANCE/NTUserName)[1]', 'nvarchar(128)' ) AS NTUserName,
+			 @message_body.value('(/EVENT_INSTANCE/NTDomainName)[1]', 'nvarchar(128)' ) AS NTDomainName,
+			 @message_body.value('(/EVENT_INSTANCE/HostName)[1]', 'nvarchar(128)' ) AS HostName,
+			 @message_body.value('(/EVENT_INSTANCE/ClientProcessID)[1]', 'int' ) AS ClientProcessID,
+			 @message_body.value('(/EVENT_INSTANCE/ApplicationName)[1]', 'nvarchar(128)' ) AS ApplicationName,
+			 @message_body.value('(/EVENT_INSTANCE/LoginName)[1]', 'nvarchar(128)' ) AS LoginName,
+			 @message_body.value('(/EVENT_INSTANCE/StartTime)[1]', 'datetime' ) AS StartTime,
+			 @message_body.value('(/EVENT_INSTANCE/Severity)[1]', 'int' ) AS Severity,
+			 @message_body.value('(/EVENT_INSTANCE/ServerName)[1]', 'nvarchar(128)' ) AS ServerName,
+			 @message_body.value('(/EVENT_INSTANCE/State)[1]', 'int' ) AS State,
+			 @message_body.value('(/EVENT_INSTANCE/Error)[1]', 'int' ) AS Error,
+			 @message_body.value('(/EVENT_INSTANCE/DatabaseName)[1]', 'nvarchar(128)' ) AS DatabaseName,
+			 @message_body.value('(/EVENT_INSTANCE/LoginSid)[1]', 'binary' ) AS LoginSid,
+			 @message_body.value('(/EVENT_INSTANCE/RequestID)[1]', 'int' ) AS RequestID,
+			 @message_body.value('(/EVENT_INSTANCE/EventSequence)[1]', 'int' ) AS EventSequence,
+			 @message_body.value('(/EVENT_INSTANCE/IsSystem)[1]', 'int' ) AS IsSystem,
+			 @message_body.value('(/EVENT_INSTANCE/SessionLoginName)[1]', 'nvarchar(128)' ) AS SessionLoginName
+
+	
+--  Commit the transaction.  At any point before this, we could roll 
+--  back - the received message would be back on the queue AND the response
+--  wouldn't be sent.
+	COMMIT TRANSACTION
+END
+GO
+
+--  Alter the Queue to add Activation Procedure
+ALTER QUEUE EventNotificationQueue
+WITH 
+ ACTIVATION -- Setup Activation Procedure
+	(STATUS=ON,
+	 PROCEDURE_NAME = [Monitor].[ProcessEventNotifications],  -- Procedure to execute
+	 MAX_QUEUE_READERS = 1, -- maximum concurrent executions of the procedure
+	 EXECUTE AS OWNER) -- account to execute procedure under
+GO
+
+/* Test the Event Notification by raising an Error
+RAISERROR (N'Test ERRORLOG Event!!', 26, 1) WITH LOG;
+GO
+
+SELECT * FROM Monitor.ErrorLog;
+*/