sync

amr_count-871e45ec-6fe6-4733-9783-259e7b8c8a06.json

@@ -0,0 +1,6 @@
+{
+  "id": "871e45ec-6fe6-4733-9783-259e7b8c8a06",
+  "prefix": "amr_count",
+  "description": "list a count per tables of amr waiting to be processed",
+  "body": "\r\nDECLARE\r\n\t@OutParam VARCHAR(255),\r\n\t@DatabaseName VARCHAR(255),\r\n\t@OrganizationalUnitId INT,\r\n\t@PharmacyName VARCHAR(500),\r\n\t@ConnecticUser VARCHAR(255),\r\n\t@LatestReplicatedNonPriorizedMonitorRowId INT,\r\n\t@LatestReplicatedPriorizedMonitorRowId INT\r\n\r\n\tEXEC Arizona..sp_bmc_Bmc_Applic_Default @in_job_type = 3, @in_param_int_1 = NULL, @in_param_int_2 = NULL, @in_param_varchar_1 = 'cvCurrentOrganizationalUnit', @out_default_value = @OutParam OUTPUT, @out_param_int_1 = NULL\r\n\tSET @OrganizationalUnitId = CAST(@OutParam  AS INT)\r\n\tSELECT @PharmacyName = AD_name + '-' + ou.ou_code FROM \tArizona..Address (READUNCOMMITTED) INNER JOIN Arizona..Organizational_unit (READUNCOMMITTED) ou on Address_ID = OU_address WHERE ou.Organizational_unit_ID = @OrganizationalUnitId\r\n\t\r\n\tSET @DatabaseName = 'Arizona'\t\r\n\t\t\r\n\tEXEC Arizona..sp_bmc_Bmc_Applic_Default @in_job_type = 3, @in_param_int_1 = NULL, @in_param_int_2 = NULL, @in_param_varchar_1 = 'cvConnecticAMRUser', @out_default_value = @OutParam OUTPUT, @out_param_int_1 = NULL\r\n\tSET @ConnecticUser = @OutParam \r\n\r\n\tSELECT @LatestReplicatedNonPriorizedMonitorRowId = amr.GetLatestReplicatedMonitorRowId(@DatabaseName,0)\r\n\tSELECT @LatestReplicatedPriorizedMonitorRowId = amr.GetLatestReplicatedMonitorRowId(@DatabaseName,1)\r\n\t\t\r\n        SELECT [x].[Database],\r\n               [x].[Table],\r\n               [x].[Non treated MonitorRows of table]\r\n        FROM (\r\n\t\tSELECT \r\n\t\t\t@DatabaseName 'Database',\r\n\t\t\tAMT_table_name 'Table',\r\n\t\t\tCOUNT(AMT_table_name) 'Non treated MonitorRows of table total',\r\n            REPLACE(REPLACE(CONVERT(VARCHAR(100), CONVERT(MONEY, COUNT(AMT_table_name)), 1),',',''''),'.00','') AS 'Non treated MonitorRows of table'\r\n\t\t\tFROM \r\n\t\t\t\tArizona..APS_monitor_row WITH (READUNCOMMITTED)\r\n\t\t\t\tINNER JOIN Arizona..APS_monitor_table (READUNCOMMITTED)\r\n\t\t\t\t\tON AMR_APS_monitor_table = APS_monitor_table_id\r\n\t\t\tWHERE\r\n\t\t\t\tAPS_monitor_row_id > @LatestReplicatedPriorizedMonitorRowId\r\n\t\t\t\tAND AMR_row_GUID IS NOT NULL\r\n\t\t\t\t-- Remove non transactional and not committed records.\r\n\t\t\t\tAND NOT (AMT_wait_for_commit = 1 AND AMR_user = @ConnecticUser AND AMR_type_of_change <> 6)\r\n\t\t\t\tAND AMR_user = @ConnecticUser\r\n\t\t\t\tAND AMT_used_by_connectic = 1\r\n\t\t\tGROUP BY \r\n\t\t\t\tAMT_table_name\r\n\r\n\t\tUNION ALL\r\n\r\n\t\tSELECT \r\n\t\t\t@DatabaseName 'Database',\r\n\t\t\tAMT_table_name 'Table',\r\n\t\t\tCOUNT(AMT_table_name) 'Non treated MonitorRows of table total',\r\n            REPLACE(REPLACE(CONVERT(VARCHAR(100), CONVERT(MONEY, COUNT(AMT_table_name)), 1),',',''''),'.00','') AS 'Non treated MonitorRows of table'\r\n\t\t\tFROM \r\n\t\t\t\tArizona..APS_monitor_row WITH (READUNCOMMITTED)\r\n\t\t\t\tINNER JOIN Arizona..APS_monitor_table (READUNCOMMITTED)\r\n\t\t\t\t\tON AMR_APS_monitor_table = APS_monitor_table_id\r\n\t\t\tWHERE\r\n\t\t\t\tAPS_monitor_row_id > @LatestReplicatedNonPriorizedMonitorRowId\r\n\t\t\t\tAND AMR_row_GUID IS NOT NULL\r\n\t\t\t\t-- Remove non transactional and not committed records.\r\n\t\t\t\tAND NOT (AMT_wait_for_commit = 1 AND AMR_user = @ConnecticUser AND AMR_type_of_change <> 6)\r\n\t\t\t\tAND ISNULL(AMR_user, '') <> @ConnecticUser\r\n\t\t\t\tAND AMT_used_by_connectic = 1\r\n\t\t\tGROUP BY \r\n\t\t\t\tAMT_table_name\r\n\t\t\t\t\r\n\t\t)x \r\n        ORDER BY [x].[Non treated MonitorRows of table total] DESC \r\n"
+}

repl-8c60aa30-593b-4050-b490-044f10ecd07f.json

@@ -1,6 +1,6 @@
 {
   "id": "8c60aa30-593b-4050-b490-044f10ecd07f",
   "prefix": "repl",
-  "description": "",
+  "description": "POS replication ",
-  "body": "SELECT [pos].[POS_hostname], [pos].[POS_MAC_address], [pos].[POS_number], [pos].[POS_type]\r\nFROM [Arizona].[dbo].[Point_of_sale] [pos]\r\nWHERE [pos].[POS_active]=1\r\nAND [pos].[POS_type] IN (1,2)\r\nAND [pos].[POS_number] < 99\r\nORDER BY [pos].[POS_number]\r\n;\r\n\r\nSELECT ActivePos_write.upd.DatabaseVersion() AS currentVersion;\r\n\r\nSELECT SettingValue AS backupSrc\r\n  FROM ActiveSystemServer.cfg.Settings\r\n WHERE SettingId LIKE 'Values.Modules.Replication.DbInitializationBackupPath%'\r\n   AND LEN(SettingValue) > 1;\r\nRETURN\r\n\r\n--last backup\r\nSELECT\r\n    JobName = J.name,\r\n    H.*\r\nFROM\r\n    msdb.dbo.sysjobs AS J\r\n    CROSS APPLY (\r\n        SELECT TOP 20\r\n            JobName = J.name,\r\n            StepNumber = T.step_id,\r\n            StepName = T.step_name,\r\n            StepStatus = CASE T.run_status\r\n                WHEN 0 THEN 'Failed'\r\n                WHEN 1 THEN 'Succeeded'\r\n                WHEN 2 THEN 'Retry'\r\n                WHEN 3 THEN 'Canceled'\r\n                ELSE 'Running' END,\r\n            ExecutedAt = msdb.dbo.agent_datetime(T.run_date, T.run_time),\r\n            ExecutingHours = ((T.run_duration/10000 * 3600 + (T.run_duration/100) % 100 * 60 + T.run_duration % 100 + 31 ) / 60) / 60,\r\n            ExecutingMinutes = ((T.run_duration/10000 * 3600 + (T.run_duration/100) % 100 * 60 + T.run_duration % 100 + 31 ) / 60) % 60,\r\n            Message = T.message\r\n            ,t.[instance_id]\r\n        FROM msdb.dbo.sysjobhistory AS T\r\n        WHERE T.job_id = J.job_id\r\n        ORDER BY t.[instance_id] DESC\r\n    ) AS H\r\nWHERE [J].[name]='D91030 - Backup ActivePos_Read'\r\nAND [H].[StepNumber] = 0\r\nORDER BY J.name\r\n\r\n\r\n--start backup\r\nEXEC msdb.dbo.sp_start_job @job_name = N'D91030 - Backup ActivePos_Read' , @step_name = 'Purge old ActivePos_Read backups'\r\n\r\nWAITFOR DELAY '00:00:05.000'\r\n\r\nWHILE EXISTS(\r\n    SELECT sj.name\r\n       , sja.*\r\n    FROM msdb.dbo.sysjobactivity AS sja\r\n    INNER JOIN msdb.dbo.sysjobs AS sj ON sja.job_id = sj.job_id\r\n    WHERE sj.[name]='D91030 - Backup ActivePos_Read'\r\n       AND sja.start_execution_date IS NOT NULL\r\n       AND sja.stop_execution_date IS NULL\r\n) BEGIN\r\n    --PRINT 'job is still running '+CONVERT(VARCHAR(20), CURRENT_TIMESTAMP, 120);\r\n    DECLARE @t VARCHAR(20) = CONVERT(VARCHAR(20), CURRENT_TIMESTAMP, 120);\r\n    RAISERROR('%s, job is still running', 0, 1, @t) WITH NOWAIT;\r\n    WAITFOR DELAY '00:00:05.000'\r\nEND \r\n\r\n--check POS and PHCY versions\r\nSELECT ActivePos_write.upd.DatabaseVersion() AS currentVersion\r\nEXEC ('SELECT ActivePos_write.upd.DatabaseVersion()') AT xxx\r\n\r\n--force restore after manual copy\r\nEXEC ('exec ActivePos_write.dbo.InitializeActivePosReadFromBackup @BackUpFileWithPath = ''c:\\temp\\ActivePos_read.22.1.223.2401.bak''') AT xxx\r\n\r\n--to start on the pos to force a restore of the backup. adapt version, mac and UNC before running\r\nexec ActiveSystemClient.dbo.DBAReplPosSubscription \r\n\t              @mac = '9C-7B-EF-43-5A-98', \r\n\t              @serverDbVersion = '23.2.23.19501', \r\n\t              @preferedReplinibackup= '\\\\cvi247aps-replinibackup.coop-vitality.ch\\replinibackup\\ActivePos_read.23.2.23.19501.bak'\r\n\r\n\r\n--restart service on pos\r\nEXEC ('EXEC xp_cmdshell ''net stop ActiveposClientService'';EXEC xp_cmdshell ''net start ActiveposClientService''') AT xxx\r\n\r\n--subscription\r\nEXEC ActivePos_read..sp_dropsubscription @publication = N'ActivePosTran', @article = N'all', @subscriber ='xxx'\r\nEXEC ActiveSystemServer.dbo.RepairReplication\r\n"
+  "body": "SELECT [pos].[POS_hostname], [pos].[POS_MAC_address], [pos].[POS_number], [pos].[POS_type]\r\nFROM [Arizona].[dbo].[Point_of_sale] [pos]\r\nWHERE [pos].[POS_active]=1\r\nAND [pos].[POS_type] IN (1,2)\r\nAND [pos].[POS_number] < 99\r\nORDER BY [pos].[POS_number]\r\n;\r\n\r\nSELECT ActivePos_write.upd.DatabaseVersion() AS currentVersion;\r\n\r\nSELECT SettingValue AS backupSrc\r\n  FROM ActiveSystemServer.cfg.Settings\r\n WHERE SettingId LIKE 'Values.Modules.Replication.DbInitializationBackupPath%'\r\n   AND LEN(SettingValue) > 1;\r\n\r\n--last backup\r\nSELECT\r\n    JobName = J.name,\r\n    H.*\r\nFROM\r\n    msdb.dbo.sysjobs AS J\r\n    CROSS APPLY (\r\n        SELECT TOP 20\r\n            JobName = J.name,\r\n            StepNumber = T.step_id,\r\n            StepName = T.step_name,\r\n            StepStatus = CASE T.run_status\r\n                WHEN 0 THEN 'Failed'\r\n                WHEN 1 THEN 'Succeeded'\r\n                WHEN 2 THEN 'Retry'\r\n                WHEN 3 THEN 'Canceled'\r\n                ELSE 'Running' END,\r\n            ExecutedAt = msdb.dbo.agent_datetime(T.run_date, T.run_time),\r\n            ExecutingHours = ((T.run_duration/10000 * 3600 + (T.run_duration/100) % 100 * 60 + T.run_duration % 100 + 31 ) / 60) / 60,\r\n            ExecutingMinutes = ((T.run_duration/10000 * 3600 + (T.run_duration/100) % 100 * 60 + T.run_duration % 100 + 31 ) / 60) % 60,\r\n            Message = T.message\r\n            ,t.[instance_id]\r\n        FROM msdb.dbo.sysjobhistory AS T\r\n        WHERE T.job_id = J.job_id\r\n        ORDER BY t.[instance_id] DESC\r\n    ) AS H\r\nWHERE [J].[name]='D91030 - Backup ActivePos_Read'\r\nAND [H].[StepNumber] = 0\r\nORDER BY J.name\r\n\r\nRETURN\r\n\r\n--start backup\r\nEXEC msdb.dbo.sp_start_job @job_name = N'D91030 - Backup ActivePos_Read' , @step_name = 'Purge old ActivePos_Read backups'\r\n\r\nWAITFOR DELAY '00:00:05.000'\r\n\r\nWHILE EXISTS(\r\n    SELECT sj.name\r\n       , sja.*\r\n    FROM msdb.dbo.sysjobactivity AS sja\r\n    INNER JOIN msdb.dbo.sysjobs AS sj ON sja.job_id = sj.job_id\r\n    WHERE sj.[name]='D91030 - Backup ActivePos_Read'\r\n       AND sja.start_execution_date IS NOT NULL\r\n       AND sja.stop_execution_date IS NULL\r\n) BEGIN\r\n    --PRINT 'job is still running '+CONVERT(VARCHAR(20), CURRENT_TIMESTAMP, 120);\r\n    DECLARE @t VARCHAR(20) = CONVERT(VARCHAR(20), CURRENT_TIMESTAMP, 120);\r\n    RAISERROR('%s, job is still running', 0, 1, @t) WITH NOWAIT;\r\n    WAITFOR DELAY '00:00:05.000'\r\nEND \r\n\r\n--check POS and PHCY versions\r\nSELECT ActivePos_write.upd.DatabaseVersion() AS currentVersion\r\nEXEC ('SELECT ActivePos_write.upd.DatabaseVersion()') AT xxx\r\n\r\n--force restore after manual copy\r\nEXEC ('exec ActivePos_write.dbo.InitializeActivePosReadFromBackup @BackUpFileWithPath = ''c:\\temp\\ActivePos_read.22.1.223.2401.bak''') AT xxx\r\n\r\n--to start on the pos to force a restore of the backup. adapt version, mac and UNC before running\r\nexec ActiveSystemClient.dbo.DBAReplPosSubscription \r\n\t              @mac = '9C-7B-EF-43-5A-98', \r\n\t              @serverDbVersion = '23.2.23.19501', \r\n\t              @preferedReplinibackup= '\\\\cvi247aps-replinibackup.coop-vitality.ch\\replinibackup\\ActivePos_read.23.2.23.19501.bak'\r\n\r\n\r\n--restart service on pos\r\nEXEC ('EXEC xp_cmdshell ''net stop ActiveposClientService'';EXEC xp_cmdshell ''net start ActiveposClientService''') AT xxx\r\n\r\n--subscription\r\nEXEC ActivePos_read..sp_dropsubscription @publication = N'ActivePosTran', @article = N'all', @subscriber ='xxx'\r\nEXEC ActiveSystemServer.dbo.RepairReplication\r\n"
 }