Modified Scripts fro Replication

Modified Scripts fro Replication

Author: imajaydwivedi

.vs/SQLDBA-SSMS Solution/v15/.ssms_suo

@@ -199,6 +199,12 @@
           <AssociatedConnUserName />
           <FullPath>sp_Blitz Views Extra.sql</FullPath>
         </FileNode>
+        <FileNode Name="SQLQuery1.sql">
+          <AssociatedConnectionMoniker>8c91a03d-f9b4-46c0-a305-b5dcc79ff907:(local):True</AssociatedConnectionMoniker>
+          <AssociatedConnSrvName>(local)</AssociatedConnSrvName>
+          <AssociatedConnUserName />
+          <FullPath>SQLQuery1.sql</FullPath>
+        </FileNode>
         <FileNode Name="StackOverflow-TopQueries.sql">
           <AssociatedConnectionMoniker />
           <AssociatedConnSrvName />

Baselining/Baselining.ssmssqlproj

@@ -182,8 +182,8 @@
           <FullPath>SQL Server 2012 Diagnostic Information Queries.sql</FullPath>
         </FileNode>
         <FileNode Name="SQL Server 2014 Diagnostic Information Queries.sql">
-          <AssociatedConnectionMoniker />
-          <AssociatedConnSrvName />
+          <AssociatedConnectionMoniker>8c91a03d-f9b4-46c0-a305-b5dcc79ff907:LOCALHOST:True</AssociatedConnectionMoniker>
+          <AssociatedConnSrvName>LOCALHOST</AssociatedConnSrvName>
           <AssociatedConnUserName />
           <FullPath>SQL Server 2014 Diagnostic Information Queries.sql</FullPath>
         </FileNode>

Baselining/SQLQuery1.sql

@@ -467,6 +467,30 @@ WHERE forwarded_record_count > 0
 go
 
 
+/* Get procedure with RECOMPILE HINT */
+SET QUOTED_IDENTIFIER OFF
+if OBJECT_ID('tempdb..#procs_with_compile_hint') is not null drop table #procs_with_compile_hint;
+create table #procs_with_compile_hint (DB nvarchar(256), OBJ_NAME nvarchar(256), OBJ_TYPE nvarchar(120), [definition] nvarchar(2000));
+insert #procs_with_compile_hint
+EXEC sp_MSforeachdb "
+USE [?];
+
+begin try
+	SELECT DB_NAME() AS [DB], o.name AS [OBJ_NAME], o.type_desc AS [OBJ_TYPE], t.definition
+	FROM sys.sql_modules t
+	INNER JOIN sys.objects o
+	ON t.object_id = o.object_id
+	WHERE t.definition LIKE '%RECOMPILE%'
+	OR t.definition LIKE '%recompile%';
+end try
+begin catch
+	print 'Error for '+QUOTENAME(DB_NAME());
+end catch
+";
+select * from #procs_with_compile_hint
+go
+
+
 /*	Find Forwarded Records using Cursor Method for VLDBs	*/
 SET NOCOUNT ON;
 IF OBJECT_ID('tempdb..#objects') IS NOT NULL
@@ -826,7 +850,10 @@ EXEC master..xp_readerrorlog 0,1, N'virtual log files which is excessive.'
 
 --	Foreign Keys Not Trusted.
 	--	https://BrentOzar.com/go/trust
-EXEC sp_msForEachDB '
+if OBJECT_ID('tempdb..#foreign_keys') is not null drop table #foreign_keys;
+create table #foreign_keys (id int identity(1,1) not null, dbName nvarchar(256), TableName nvarchar(500), keyname nvarchar(256));
+insert #foreign_keys
+EXEC sp_MSforeachdb '
 USE [?];
 SELECT	*
 FROM (values (DB_NAME())) as DBs(dbName)
@@ -839,10 +866,9 @@ LEFT JOIN
 		WHERE i.is_not_trusted = 1 AND i.is_not_for_replication = 0
 	) AS r
 	ON	1 = 1
+WHERE TableName is not null
 ';
-/*
-The [SRA] database has foreign keys that were probably disabled, data was changed, and then the key was enabled again.  Simply enabling the key is not enough for the optimizer to use this key - we have to alter the table using the WITH CHECK CHECK CONSTRAINT parameter. (https://www.brentozar.com/blitz/foreign-key-trusted/ ). It turns out this can have a huge performance impact on queries, too, because SQL Server won’t use untrusted constraints to build better execution plans.
-*/
+select * from #foreign_keys
 
 --	Disk Latency Logs
 $serverName = 'dbsep0456';

BlitzQueries/BlitzQueries.ssmssqlproj

@@ -2,14 +2,16 @@ USE tempdb;
 
 DECLARE @s VARCHAR(MAX), @t VARCHAR(MAX);
 DECLARE @tableName varchar(255);
+DECLARE @start_loop bit = 0;
 DECLARE @DeleteFlag tinyint; /* 0 = drop, 1 = truncate, 2 = No Action */
 SET @DeleteFlag = 0;
-SET @tableName = 'tempdb.dbo.WhoIsActive_ResultSet';
+SET @tableName = 'dbo.WhoIsActive';
 
 EXEC sp_WhoIsActive @sort_order = '[start_time] ASC', @get_outer_command=1, @find_block_leaders=1 --,@get_full_inner_text=1
-					,@get_transaction_info=1 ,@get_locks = 1
-					,@get_task_info=2, @get_avg_time=1, @get_additional_info=1
-					,@get_plans=1 /* 1 = current query, 2 = entire batch */
+						,@get_locks = 1
+					--,@get_transaction_info=1
+					--,@get_task_info=2, @get_avg_time=1, @get_additional_info=1
+					--,@get_plans=1 /* 1 = current query, 2 = entire batch */
 					,@return_schema = 1, @schema = @s OUTPUT
 
 SET @s = REPLACE(@s, '<table_name>', @tableName)
@@ -23,71 +25,88 @@ IF @DeleteFlag = 2
 
 EXEC(@t);
 PRINT @t;
-SET @s = 'IF OBJECT_ID('''+@tableName+''') IS NULL BEGIN '+@s+'; CREATE CLUSTERED INDEX [CI_WhoIsActive_ResultSet] ON '+@tableName+' ( [collection_time] ASC, session_id ); END'
+SET @s = 'IF OBJECT_ID('''+@tableName+''') IS NULL BEGIN '+@s+'; CREATE CLUSTERED INDEX [CI_WhoIsActive] ON '+@tableName+' ( [collection_time] ASC, session_id ); END'
 EXEC(@s);
 
+declare @currrent_date datetime2 = getdate();
+while (@start_loop = 1 and @currrent_date > DATEADD(HOUR,-2,GETDATE()))
+begin
+	EXEC sp_WhoIsActive @sort_order = '[start_time] ASC', @get_outer_command=1, @find_block_leaders=1 --,@get_full_inner_text=1
+						,@get_locks = 1
+					--,@get_transaction_info=1
+					--,@get_task_info=2, @get_avg_time=1, @get_additional_info=1
+					--,@get_plans=1 /* 1 = current query, 2 = entire batch */
+						,@destination_table = @tableName;
+
+	-- Delete records when No Blocking was Found
+	delete from dbo.WhoIsActive
+	where collection_time in (select r.collection_time from tempdb.dbo.WhoIsActive as r 
+							group by r.collection_time having count(r.blocking_session_id) = 0);
+
+	waitfor delay '00:01:00'
+end
+--select * from tempdb.dbo.WhoIsActive
+--where [blocking_session_id] is not null
+--or [blocked_session_count] > 0
 
-EXEC sp_WhoIsActive @sort_order = '[start_time] ASC', @get_outer_command=1, @find_block_leaders=1 --,@get_full_inner_text=1
-					,@get_transaction_info=1 ,@get_locks = 1
-					,@get_task_info=2, @get_avg_time=1, @get_additional_info=1
-					,@get_plans=1 /* 1 = current query, 2 = entire batch */
-					,@destination_table = @tableName;
 
--- Delete records when No Blocking was Found
-delete from tempdb.dbo.WhoIsActive_ResultSet
-where collection_time in (select r.collection_time from tempdb.dbo.WhoIsActive_ResultSet as r 
-						group by r.collection_time having count(r.blocking_session_id) = 0);
 
+DECLARE @hour_filter int = 2;
 ;WITH T_BLOCKERS AS
 (
 	-- Find block Leaders
 	SELECT	r.[dd hh:mm:ss.mss], r.[session_id], r.[sql_text],
 			[batch_text] = REPLACE(REPLACE(REPLACE(REPLACE(CAST(COALESCE(r.[sql_command],r.[sql_text]) AS VARCHAR(MAX)),char(13),''),CHAR(10),''),'<?query --',''),'--?>',''),
 			r.[sql_command], r.[login_name], r.[wait_info], r.[tempdb_allocations], r.[tempdb_current], 
 			r.[blocking_session_id], r.[blocked_session_count], r.[reads], r.[writes], r.[physical_reads], r.[CPU], r.[used_memory], r.[status], r.[open_tran_count], 
-			r.[percent_complete], r.[host_name], r.[database_name], r.[program_name], r.locks, r.[start_time], r.[login_time], r.[request_id], r.[collection_time]
+			r.[percent_complete], r.[host_name], r.[database_name], r.[program_name], r.[start_time], r.[login_time], r.[request_id], r.[collection_time] --,locks
 			,[LEVEL] = CAST (REPLICATE ('0', 4-LEN (CAST (r.session_id AS VARCHAR))) + CAST (r.session_id AS VARCHAR) AS VARCHAR (1000))
-	FROM	tempdb.dbo.WhoIsActive_ResultSet AS r
+	FROM	dbo.WhoIsActive AS r with (nolock)
 	WHERE	(ISNULL(r.blocking_session_id,0) = 0 OR ISNULL(r.blocking_session_id,0) = r.session_id)
-		AND EXISTS (SELECT * FROM tempdb.dbo.WhoIsActive_ResultSet AS R2 WHERE R2.collection_time = r.collection_time AND ISNULL(R2.blocking_session_id,0) = r.session_id AND ISNULL(R2.blocking_session_id,0) <> R2.session_id)
+		AND EXISTS (SELECT * FROM dbo.WhoIsActive AS R2 WHERE R2.collection_time = r.collection_time AND ISNULL(R2.blocking_session_id,0) = r.session_id AND ISNULL(R2.blocking_session_id,0) <> R2.session_id)
 	--	
 	UNION ALL
 	--
 	SELECT	r.[dd hh:mm:ss.mss], r.[session_id], r.[sql_text],
 			[batch_text] = REPLACE(REPLACE(REPLACE(REPLACE(CAST(COALESCE(r.[sql_command],r.[sql_text]) AS VARCHAR(MAX)),char(13),''),CHAR(10),''),'<?query --',''),'--?>',''),
 			r.[sql_command], r.[login_name], r.[wait_info], r.[tempdb_allocations], r.[tempdb_current], 
 			r.[blocking_session_id], r.[blocked_session_count], r.[reads], r.[writes], r.[physical_reads], r.[CPU], r.[used_memory], r.[status], r.[open_tran_count], 
-			r.[percent_complete], r.[host_name], r.[database_name], r.[program_name], r.locks, r.[start_time], r.[login_time], r.[request_id], r.[collection_time]
+			r.[percent_complete], r.[host_name], r.[database_name], r.[program_name], r.[start_time], r.[login_time], r.[request_id], r.[collection_time] --,locks
 			,CAST (B.LEVEL + RIGHT (CAST ((1000 + r.session_id) AS VARCHAR (100)), 4) AS VARCHAR (1000)) AS LEVEL
-	FROM	tempdb.dbo.WhoIsActive_ResultSet AS r
+	FROM	dbo.WhoIsActive AS r  with (nolock)
 	INNER JOIN 
 			T_BLOCKERS AS B
 		ON	r.collection_time = B.collection_time
 		AND	r.blocking_session_id = B.session_id
 	WHERE	r.blocking_session_id <> r.session_id
 )
 --select * from T_BLOCKERS
-SELECT	[BLOCKING_TREE] = N'    ' + REPLICATE (N'|         ', LEN (LEVEL)/4 - 1) 
+	
+SELECT	r.[collection_time],
+		[BLOCKING_TREE] = N'    ' + REPLICATE (N'|         ', LEN (LEVEL)/4 - 1) 
 						+	CASE	WHEN (LEN(LEVEL)/4 - 1) = 0
 									THEN 'HEAD -  '
 									ELSE '|------  ' 
 							END
 						+	CAST (r.session_id AS NVARCHAR (10)) + N' ' + (CASE WHEN LEFT(r.[batch_text],1) = '(' THEN SUBSTRING(r.[batch_text],CHARINDEX('exec',r.[batch_text]),LEN(r.[batch_text]))  ELSE r.[batch_text] END),
-		r.[dd hh:mm:ss.mss], r.[wait_info], r.[blocked_session_count], r.[blocking_session_id], --r.[sql_text], r.[sql_command],
-		r.[login_name], r.[host_name], r.[database_name], r.[program_name], r.locks, r.[tempdb_allocations], r.[tempdb_current], 
+		r.[dd hh:mm:ss.mss], r.[wait_info], r.[blocked_session_count], r.[blocking_session_id], r.[sql_text], r.[sql_command],
+		r.[login_name], r.[host_name], r.[database_name], r.[program_name], r.[tempdb_allocations], r.[tempdb_current], 
 		r.[reads], r.[writes], r.[physical_reads], r.[CPU], r.[used_memory], r.[status], r.[open_tran_count], 
-		r.[percent_complete], r.[start_time], r.[login_time], r.[request_id], [sql_command]
-		,r.[collection_time]
+		r.[percent_complete], r.[start_time], r.[login_time], r.[request_id] --,locks
 FROM	T_BLOCKERS AS r
-ORDER BY collection_time, LEVEL ASC;
+WHERE	[collection_time] >= DATEADD(HOUR,-@hour_filter,getdate())
+ORDER BY collection_time desc, LEVEL ASC
+option ( MaxRecursion 0 );
 
 /*
 select @@servername as srvName, r.login_name, r.program_name, r.database_name, count(r.session_id) as session_counts
-from tempdb.dbo.WhoIsActive_ResultSet AS r
+from tempdb.dbo.WhoIsActive AS r
 group by r.login_name, r.program_name, r.database_name
-having count(r.session_id) > (select count(distinct [collection_time]) from tempdb.dbo.WhoIsActive_ResultSet as r)
+having count(r.session_id) > (select count(distinct [collection_time]) from tempdb.dbo.WhoIsActive as r)
 order by session_counts desc
 go
-
 */
 
+
+
+--select * from tempdb.dbo.WhoIsActive

BlitzQueries/Other queries.sql

@@ -1,10 +1,21 @@
+--	Check-SQLServerAvailability
+declare @time datetime;
+select @time = d.create_date
+FROM sys.databases as d
+WHERE d.name = 'tempdb';
+SELECT @@servername as srv, @time as server_uptime, DATEDIFF(MINUTE,@time,GETDATE()) AS [up_time(minutes)], DATEDIFF(HOUR,@time,GETDATE()) AS [up_time(hours)];
 
-declare @start_time datetime, @end_time datetime;
-set @start_time = '2020-08-22 03:00:00.000' --  August 22, 2020 05:16:00
---set @start_time = DATEADD(minute,-120,getdate());
-set @end_time = '2020-08-22 03:30:00.000';
---set @end_time = DATEADD(minute,30,@start_time)
+declare @start_time datetime, @end_time datetime, @err_msg_1 nvarchar(256) = null, @err_msg_2 nvarchar(256) = null;
+--set @start_time = '2020-09-19 03:20:00.000' --  August 22, 2020 05:16:00
+--set @time = DATEADD(minute,-60*12,getdate());
+set @start_time = DATEADD(minute,-20,@time);
+--set @end_time = '2020-08-22 03:30:00.000';
+set @end_time = GETDATE()
+--set @end_time = DATEADD(minute,60*3,@start_time)
+--set @err_msg_1 = 'has been rejected'
+--set @err_msg_2 = '';
 
+--EXEC master.dbo.xp_enumerrorlogs
 declare @NumErrorLogs int;
 exec master.dbo.xp_instance_regread N'HKEY_LOCAL_MACHINE', 
                             N'Software\Microsoft\MSSQLServer\MSSQLServer',
@@ -17,14 +28,18 @@ declare @counter int = isnull(@NumErrorLogs,6);
 while @counter >= 0
 begin
 	insert #errorlog
-	EXEC master.dbo.xp_readerrorlog @counter, 1, NULL, NULL, @start_time, @end_time, "asc";
+	EXEC master.dbo.xp_readerrorlog @counter, 1, @err_msg_1, @err_msg_2, @start_time, @end_time, "asc";
 	set @counter -= 1;
 
 	if exists (select * from #errorlog where LogDate > @end_time)
 		break;
 end
 
-select ROW_NUMBER()over(order by LogDate asc) as id,*
+
+select ROW_NUMBER()over(order by LogDate asc) as id,
+		getdate() as [now],
+			--master.dbo.time2duration(LogDate,'datetime') as [Log-Duration],
+				*
 from #errorlog as e
 where 1 = 1
 --and e.Text like '%pricing%'
@@ -33,10 +48,15 @@ where 1 = 1
 --and e.Text not like 'DbMgrPartnerCommitPolicy::SetSyncState:%'
 --and e.Text not like 'SQL Server blocked access to procedure%'
 --and e.Text not like 'Login failed for user %'
+--and e.Text not like 'I/O is frozen on database%'
+--and e.Text not like 'I/O was resumed on database%'
+--and e.Text not like 'Process ID % was killed by hostname xx, host process ID %'
 --and e.Text not like 'AlwaysOn Availability Groups connection with secondary database terminated for primary database %'
 --and e.Text not like 'AlwaysOn Availability Groups connection with secondary database established for primary database %'
 --and e.Text like '%ALTER DATABASE%'
-order by LogDate asc
+--and e.Text like '%inout%'
+--and e.Text like '%rejected due to breached'
+order by id desc
 
 /*
 select create_date 

Blocking Alert/BlockingTree-Live-WhoIsActive.sql

@@ -31,7 +31,14 @@ Get-ChildItem -Path 'F:\' -Recurse -Force -ErrorAction SilentlyContinue |
     Sort-Object -Property SizeBytes -Descending | Out-GridView
 
 -- 9) Check if -Verbose switch is used
-$PSCmdlet.MyInvocation.BoundParameters["Verbose"].IsPresent
+$Verbose = $false;
+if($PSCmdlet.MyInvocation.BoundParameters["Verbose"].IsPresent -or [String]::IsNullOrEmpty($MyInvocation.PSScriptRoot)) {
+    $Verbose = $true;
+}
+
+if($Verbose) {
+    Write-Host ("{0,-8} {1} - {2}" -f 'INFO:', "$(Get-Date)", "Extract 'Finding' & 'Create TSQL' from Index Summary to match with Non-Prod");
+}
 
 -- 10) Check if Module is installed
 if (Get-Module -ListAvailable -Name SqlServer) {

ErrorLogs/QRY-Search-ErrorLog.sql

@@ -0,0 +1,27 @@
+$threads = 4;
+$server_count = $tsql_Prod_Servers_Result.Count; # List of objects to iterate through
+$counter = 0;
+$jobs = @();
+$server_count = 10 # Remove this line
+do {
+    $running_job_count = (Get-Job -Name "BlitzIndex-*" | ? {$_.State -eq 'Running'}).count;
+    if($running_job_count -lt $threads)
+    {
+        $srvObj = $tsql_Prod_Servers_Result[$counter];
+        $ServerName = $srvObj.FriendlyName;
+        $jobs += Start-Job -Name "BlitzIndex-$ServerName" -ScriptBlock $ScriptBlock;
+        $counter = $counter + 1;
+        Write-Host "Started job for $ServerName";
+    }
+    else {
+        Start-Sleep -Seconds 10;
+    }
+}while($counter -lt $server_count);
+
+$jobs | Wait-Job | Out-Null;
+
+$failed_jobs = $jobs | Where-Object {$this.State -eq 'Failed'};
+$passed_jobs = $jobs | Where-Object {$this.State -ne 'Failed'};
+
+$out = $passed_jobs | Receive-Job;
+$jobs | Remove-Job;

PowerShell Commands/Common-Commands.sql

@@ -0,0 +1,25 @@
+# https://github.com/proxb/PoshRSJob
+Import-Module PoshRSJob;
+$Test = 'test'
+$Something = 1..10
+1..5|start-rsjob -Name {$_} -ScriptBlock {
+        [pscustomobject]@{
+            Result=($_*2)
+            Test=$Using:Test
+            Something=$Using:Something
+        }
+}            
+Get-RSjob | Receive-RSJob
+
+
+
+
+# This shows the streaming aspect with Wait-RSJob
+1..10|Start-RSJob {
+    if (1 -BAND $_){
+        "First ($_)"
+    }Else{
+        Start-sleep -seconds 2
+        "Last ($_)"
+    }
+}|Wait-RSJob|Receive-RSJob|ForEach{"I am $($_)"}

PowerShell Commands/MultiThreading-Powershell-Jobs.sql

@@ -0,0 +1,20 @@
+$Scriptblock = {
+    param($Name)
+    New-Item -Name $Name -ItemType File
+}
+
+$MaxThreads = 5
+$RunspacePool = [runspacefactory]::CreateRunspacePool(1, $MaxThreads)
+$RunspacePool.Open()
+$Jobs = @()
+
+1..10 | Foreach-Object {
+	$PowerShell = [powershell]::Create()
+	$PowerShell.RunspacePool = $RunspacePool
+	$PowerShell.AddScript($ScriptBlock).AddArgument($_)
+	$Jobs += $PowerShell.BeginInvoke()
+}
+
+while ($Jobs.IsCompleted -contains $false) {
+	Start-Sleep 1
+}