From e346959f16b826bde41d452dbfb92481e91d6184 Mon Sep 17 00:00:00 2001 From: Thierry Schork Date: Tue, 8 Apr 2025 11:43:24 +0200 Subject: [PATCH] [DEPRECATED] SymmetricDS setup for the BAG replication --- HCI - BAG symmetricDS/setup bag repli.sql | 39 ++++++++++++++++------- 1 file changed, 27 insertions(+), 12 deletions(-) diff --git a/HCI - BAG symmetricDS/setup bag repli.sql b/HCI - BAG symmetricDS/setup bag repli.sql index 5c91274..0ff0d48 100644 --- a/HCI - BAG symmetricDS/setup bag repli.sql +++ b/HCI - BAG symmetricDS/setup bag repli.sql @@ -3,7 +3,7 @@ */ USE [dba_reporting] -SELECT * from SYM_NODE +SELECT * FROM SYM_NODE --SELECT * FROM SYM_NODE_GROUP SELECT * FROM SYM_NODE_GROUP_LINK @@ -15,20 +15,35 @@ SELECT * FROM SYM_TRIGGER_ROUTER ORDER BY [router_id] --SELECT * FROM [dbo].[sym_outgoing_batch] RETURN +UPDATE [dbo].[sym_node_group_link] SET [sync_sql_enabled]=1 + --set push to cloud, pull to onprem UPDATE [dbo].[sym_node_group_link] SET [data_event_action]='W' WHERE [source_node_group_id]='cloud' UPDATE [dbo].[sym_node_group_link] SET [data_event_action]='P' WHERE [source_node_group_id]='onprem' --set router target schemas. sl2007 is the target on cloud, sl2007_azure is the target on prem UPDATE dbo.[sym_router] SET [target_catalog_name]='sl2007', [target_schema_name]='dbo' WHERE [router_id] = 'onprem to cloud' -UPDATE dbo.[sym_router] SET [target_catalog_name]='sl2007_azure', [target_schema_name]='dbo' WHERE [router_id] = 'cloud to onprem' +UPDATE dbo.[sym_router] SET [target_catalog_name]='sl2007', [target_schema_name]='dbo' WHERE [router_id] = 'cloud to onprem' --create a single channel for all tables to push to cloud INSERT INTO dbo.SYM_CHANNEL (channel_id, processing_order, max_batch_size, max_batch_to_send,extract_period_millis, batch_algorithm, enabled, description,data_loader_type) SELECT channel_id, processing_order, max_batch_size, max_batch_to_send,extract_period_millis, batch_algorithm, enabled, description,data_loader_type FROM( - VALUES ('sl2007_push', 10, 1000, 10, 0, 'default', 1, 'sl2007 data to push to cloud','bulk') - ,('sl2007_pull',20,1000,10,0,'default',1,'sl2007 push from cloud to on-prem','bulk') + VALUES ('sl2007_push', 10, 1000, 10, 0, 'default', 1, 'sl2007 data to push to cloud','default') + ,('sl2007_pull',20,1000,10,0,'default',1,'sl2007 push from cloud to on-prem','default') + + ,('sl2007_pull__preparation_ignore',20,1000,10,0,'default',1,'sl2007 preparation_ignore pull from cloud to on-prem','default') + ,('sl2007_push__preparation_ignore',20,1000,10,0,'default',1,'sl2007 preparation_ignore push from on-prem to cloud','default') + + ,('sl2007_pull__preparation_new',20,1000,10,0,'default',1,'sl2007 preparation_new pull from cloud to on-prem','default') + ,('sl2007_push__preparation_new',20,1000,10,0,'default',1,'sl2007 preparation_new push from on-prem to cloud','default') + + ,('sl2007_pull__pack_ignore',20,1000,10,0,'default',1,'sl2007 pack_ignore pull from cloud to on-prem','default') + ,('sl2007_push__pack_ignore',20,1000,10,0,'default',1,'sl2007 pack_ignore push from on-prem to cloud','default') + + ,('sl2007_pull__pack_new',20,1000,10,0,'default',1,'sl2007 pack_new pull from cloud to on-prem','default') + ,('sl2007_push__pack_new',20,1000,10,0,'default',1,'sl2007 pack_new push from on-prem to cloud','default') + )x(channel_id, processing_order, max_batch_size, max_batch_to_send,extract_period_millis, batch_algorithm, enabled, description,data_loader_type) WHERE NOT EXISTS(SELECT 1 FROM [dbo].[sym_channel] c WHERE c.[channel_id] = x.[channel_id]); @@ -43,10 +58,10 @@ FROM ( ,('push_PARTNER', 'PARTNER', 'sl2007_push', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','time_stamp') ,('push_PACKPARTNER_MUTATION', 'PACKPARTNER_MUTATION', 'sl2007_push', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','time_stamp') ,('push_ATCDESCR', 'ATCDESCR', 'sl2007_push', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','time_stamp') - ,('push_PREPARATION_IGNORE', 'PREPARATION_IGNORE', 'sl2007_push', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','time_stamp') - ,('push_PACK_IGNORE', 'PACK_IGNORE', 'sl2007_push', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','time_stamp') - ,('push_PACK_NEW', 'PACK_NEW', 'sl2007_push', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','time_stamp') - ,('push_PREPARATION_NEW', 'PREPARATION_NEW', 'sl2007_push', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','time_stamp') + ,('push_PREPARATION_IGNORE', 'PREPARATION_IGNORE', 'sl2007_push__preparation_ignore', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','time_stamp') + ,('push_PACK_IGNORE', 'PACK_IGNORE', 'sl2007_push__pack_ignore', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','time_stamp') + ,('push_PACK_NEW', 'PACK_NEW', 'sl2007_push__pack_new', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','time_stamp') + ,('push_PREPARATION_NEW', 'PREPARATION_NEW', 'sl2007_push__preparation_new', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','time_stamp') ,('push_PACK_MUTATION', 'PACK_MUTATION', 'sl2007_push', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','time_stamp') ,('push_PREPARATION_MUTATION', 'PREPARATION_MUTATION', 'sl2007_push', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','time_stamp') ,('push_PREPARATION', 'PREPARATION', 'sl2007_push', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','time_stamp') @@ -122,10 +137,10 @@ FROM ( ,('pull_ORIGINAL_FREIKAUF', 'ORIGINAL_FREIKAUF', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo',NULL) ,('pull_OriginalGenericMapping', 'OriginalGenericMapping', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo',NULL) ,('pull_PACK', 'PACK', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP') - ,('pull_PACK_IGNORE', 'PACK_IGNORE', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP') + ,('pull_PACK_IGNORE', 'PACK_IGNORE', 'sl2007_pull__pack_ignore', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP') ,('pull_PACK_LIMPTS', 'PACK_LIMPTS', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP') ,('pull_PACK_MUTATION', 'PACK_MUTATION', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP') - ,('pull_PACK_NEW', 'PACK_NEW', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP') + ,('pull_PACK_NEW', 'PACK_NEW', 'sl2007_pull__pack_new', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP') ,('pull_PACKPARTNER', 'PACKPARTNER', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP') ,('pull_PACKPARTNER_IGNORE', 'PACKPARTNER_IGNORE', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP') ,('pull_PACKPARTNER_MUTATION', 'PACKPARTNER_MUTATION', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP') @@ -136,12 +151,12 @@ FROM ( ,('pull_PIMPORT', 'PIMPORT', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo',NULL) ,('pull_PreiseNeu', 'PreiseNeu', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo',NULL) ,('pull_PREPARATION', 'PREPARATION', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP') - ,('pull_PREPARATION_IGNORE', 'PREPARATION_IGNORE', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP') + ,('pull_PREPARATION_IGNORE', 'PREPARATION_IGNORE', 'sl2007_pull__preparation_ignore', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP') ,('pull_PREPARATION_MUTATION', 'PREPARATION_MUTATION', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP') ,('pull_PREPARATION_NAME', 'PREPARATION_NAME', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo',NULL) ,('pull_PREPARATION_NAME_BOOK', 'PREPARATION_NAME_BOOK', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo',NULL) ,('pull_PREPARATION_NAME_save_vorGammendef20120404', 'PREPARATION_NAME_save_vorGammendef20120404', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo',NULL) - ,('pull_PREPARATION_NEW', 'PREPARATION_NEW', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP') + ,('pull_PREPARATION_NEW', 'PREPARATION_NEW', 'sl2007_pull__preparation_new', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP') ,('pull_PREPARATIONTASK', 'PREPARATIONTASK', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP') ,('pull_PrepGenGroup', 'PrepGenGroup', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo',NULL) ,('pull_PREPIT', 'PREPIT', 'sl2007_pull', CURRENT_TIMESTAMP, CURRENT_TIMESTAMP,'sl2007','dbo','TIME_STAMP')