sql-server - 動的 SQL、パラメーター化されたクエリ

Question

SQL AlwaysON の正常性情報を取得するクエリを作成しました。最後に where 句を追加して、AvailabilityGroupName と DatabaseName をフィルター処理するだけです。クエリを入力すると機能します: 'select * from results where AvailabilityGroupName = 'LAB-VIP-USADB' AND DatabaseName = 'CPS''. ただし、最初にクエリを nvarchar 変数 @sql に格納し、後で変数に格納されたクエリを実行すると、「キーワード 'EXEC' 付近の構文が正しくありません」というエラー メッセージが表示されました。クエリをパラメーター化する理由は、1 つの可用性グループに複数のデータベースが含まれる可能性があるためです。パラメータ化された入力はPRTGから取得されるため、その特定のデータベースの可用性グループにクエリを実行します。

DECLARE @sql NVARCHAR(MAX)

SET @sql='SELECT * FROM Results WHERE AvailabilityGroupName = ''LAB-VIP-USADB'' AND DatabaseName = ''CPS'''
--select @sql
;
WITH basicaginfo AS(
SELECT 
      
       ag.name AS AvailabilityGroupName,
       cs.replica_server_name AS NodeName,
       rs.role_desc,
       rs.synchronization_health_desc,
       DB_NAME(drs.database_id) AS DatabaseName
       


FROM 
       sys.availability_groups ag
                    JOIN
       sys.dm_hadr_availability_replica_cluster_states cs on ag.group_id = cs.group_id
                    JOIN
       sys.dm_hadr_availability_replica_states rs ON (ag.group_id=rs.group_id AND cs.replica_id = rs.replica_id)
                    JOIN
       sys.dm_hadr_database_replica_states drs ON (ag.group_id=drs.group_id AND cs.replica_id = drs.replica_id)
             

					),

   
       AG_Stats AS 
                    (
                    SELECT AR.replica_server_name,
                              HARS.role_desc, 
                              Db_name(DRS.database_id) [DBName], 
                              DRS.last_commit_time
                    FROM   sys.dm_hadr_database_replica_states DRS 
                    INNER JOIN sys.availability_replicas AR ON DRS.replica_id = AR.replica_id 
                    INNER JOIN sys.dm_hadr_availability_replica_states HARS ON AR.group_id = HARS.group_id 
                           AND AR.replica_id = HARS.replica_id 
                    ),
       Pri_CommitTime AS 
                    (
                    SELECT replica_server_name
                                 , DBName
                                 , last_commit_time
                    FROM   AG_Stats
                    WHERE  role_desc = 'PRIMARY'
                    ),
       Sec_CommitTime AS 
                    (
                    SELECT replica_server_name
                                 , DBName
                                 , last_commit_time
                    FROM   AG_Stats
                    WHERE  role_desc = 'SECONDARY'
                    ),
		Results AS
					(
					SELECT 
						AvailabilityGroupName, 
						DatabaseName, 
						[LAB-SCB-SQL01],
						[LAB-SCB-SQL02], 
						[LAB-LAS-SQL01], 
						[LAB-LAS-SQL02], 
						[Max_Sync_Lag_Secs]
					FROM(
							SELECT 
								bb.AvailabilityGroupName, 
								bb.DatabaseName,
								bb.NodeName,
								bb.synchronization_health_desc,
								MAX( DATEDIFF(ss,s.last_commit_time,p.last_commit_time)) OVER ( PARTITION BY NULL ) AS [Max_Sync_Lag_Secs]
   
							FROM 
								basicaginfo bb
									LEFT JOIN
								Pri_CommitTime p ON p.DBName=bb.DatabaseName 
									LEFT JOIN 
								Sec_CommitTime s ON bb.NodeName = s.replica_server_name
						) AS Data
					PIVOT(

							MAX( synchronization_health_desc ) FOR [NodeName] IN( [LAB-SCB-SQL01], [LAB-SCB-SQL02], [LAB-LAS-SQL01], [LAB-LAS-SQL02] )
						 ) AS PivotedData
					)
EXEC(@sql)