mvineetmenon

Symmetric DS MMR configuration with 4 nodes.

Jan 11th, 2019
2,182
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. delete from sym_trigger_router;
  2. delete from sym_trigger;
  3. delete from sym_router;
  4. delete from sym_channel where channel_id in ('accounts');
  5. delete from sym_node_group_link;
  6. delete from sym_node_group;
  7. delete from sym_node_host;
  8. delete from sym_node_identity;
  9. delete from sym_node_security;
  10. delete from sym_node;
  11.  
  12. --------------------------------------------------------------
  13. insert into sym_channel
  14. (channel_id, processing_order, max_batch_size, enabled, description)
  15. values('accounts', 1, 100000, 1, 'sale_transactional data from register and back office');
  16.  
  17. ---------------------------------------------------------------
  18. insert into sym_node_group (node_group_id) values ('corp0');
  19. insert into sym_node_group (node_group_id) values ('corp1');
  20. insert into sym_node_group (node_group_id) values ('corp2');
  21. insert into sym_node_group (node_group_id) values ('corp3');
  22.  
  23. ---------------------------------------------------------------
  24. insert into sym_node_group_link (source_node_group_id, target_node_group_id, data_event_action) values ('corp0', 'corp1', 'P');
  25. insert into sym_node_group_link (source_node_group_id, target_node_group_id, data_event_action) values ('corp0', 'corp2', 'P');
  26. insert into sym_node_group_link (source_node_group_id, target_node_group_id, data_event_action) values ('corp0', 'corp3', 'P');
  27. insert into sym_node_group_link (source_node_group_id, target_node_group_id, data_event_action) values ('corp1', 'corp0', 'P');
  28. insert into sym_node_group_link (source_node_group_id, target_node_group_id, data_event_action) values ('corp1', 'corp2', 'P');
  29. insert into sym_node_group_link (source_node_group_id, target_node_group_id, data_event_action) values ('corp1', 'corp3', 'P');
  30. insert into sym_node_group_link (source_node_group_id, target_node_group_id, data_event_action) values ('corp2', 'corp0', 'P');
  31. insert into sym_node_group_link (source_node_group_id, target_node_group_id, data_event_action) values ('corp2', 'corp1', 'P');
  32. insert into sym_node_group_link (source_node_group_id, target_node_group_id, data_event_action) values ('corp2', 'corp3', 'P');
  33. insert into sym_node_group_link (source_node_group_id, target_node_group_id, data_event_action) values ('corp3', 'corp0', 'P');
  34. insert into sym_node_group_link (source_node_group_id, target_node_group_id, data_event_action) values ('corp3', 'corp1', 'P');
  35. insert into sym_node_group_link (source_node_group_id, target_node_group_id, data_event_action) values ('corp3', 'corp2', 'P');
  36.  
  37. ---------------------------------------------------------------
  38. insert into sym_trigger
  39. (trigger_id,source_table_name,channel_id,last_update_time,create_time)
  40. values('accounts','pgbench_accounts','accounts',current_timestamp,current_timestamp);
  41.  
  42. -----------------------------------------------------------------
  43. insert into sym_router (router_id,source_node_group_id,target_node_group_id,router_type,create_time,last_update_time) values('corp0_2_corp1', 'corp0', 'corp1', 'default',current_timestamp, current_timestamp);
  44. insert into sym_router (router_id,source_node_group_id,target_node_group_id,router_type,create_time,last_update_time) values('corp0_2_corp2', 'corp0', 'corp2', 'default',current_timestamp, current_timestamp);
  45. insert into sym_router (router_id,source_node_group_id,target_node_group_id,router_type,create_time,last_update_time) values('corp0_2_corp3', 'corp0', 'corp3', 'default',current_timestamp, current_timestamp);
  46. insert into sym_router (router_id,source_node_group_id,target_node_group_id,router_type,create_time,last_update_time) values('corp1_2_corp0', 'corp1', 'corp0', 'default',current_timestamp, current_timestamp);
  47. insert into sym_router (router_id,source_node_group_id,target_node_group_id,router_type,create_time,last_update_time) values('corp1_2_corp2', 'corp1', 'corp2', 'default',current_timestamp, current_timestamp);
  48. insert into sym_router (router_id,source_node_group_id,target_node_group_id,router_type,create_time,last_update_time) values('corp1_2_corp3', 'corp1', 'corp3', 'default',current_timestamp, current_timestamp);
  49. insert into sym_router (router_id,source_node_group_id,target_node_group_id,router_type,create_time,last_update_time) values('corp2_2_corp0', 'corp2', 'corp0', 'default',current_timestamp, current_timestamp);
  50. insert into sym_router (router_id,source_node_group_id,target_node_group_id,router_type,create_time,last_update_time) values('corp2_2_corp1', 'corp2', 'corp1', 'default',current_timestamp, current_timestamp);
  51. insert into sym_router (router_id,source_node_group_id,target_node_group_id,router_type,create_time,last_update_time) values('corp2_2_corp3', 'corp2', 'corp3', 'default',current_timestamp, current_timestamp);
  52. insert into sym_router (router_id,source_node_group_id,target_node_group_id,router_type,create_time,last_update_time) values('corp3_2_corp0', 'corp3', 'corp0', 'default',current_timestamp, current_timestamp);
  53. insert into sym_router (router_id,source_node_group_id,target_node_group_id,router_type,create_time,last_update_time) values('corp3_2_corp1', 'corp3', 'corp1', 'default',current_timestamp, current_timestamp);
  54. insert into sym_router (router_id,source_node_group_id,target_node_group_id,router_type,create_time,last_update_time) values('corp3_2_corp2', 'corp3', 'corp2', 'default',current_timestamp, current_timestamp);
  55.  
  56. -------------------------------------------------------------------
  57. insert into sym_trigger_router (trigger_id,router_id,initial_load_order,last_update_time,create_time) values('accounts','corp0_2_corp1', 100, current_timestamp, current_timestamp);
  58. insert into sym_trigger_router (trigger_id,router_id,initial_load_order,last_update_time,create_time) values('accounts','corp0_2_corp2', 100, current_timestamp, current_timestamp);
  59. insert into sym_trigger_router (trigger_id,router_id,initial_load_order,last_update_time,create_time) values('accounts','corp0_2_corp3', 100, current_timestamp, current_timestamp);
  60. insert into sym_trigger_router (trigger_id,router_id,initial_load_order,last_update_time,create_time) values('accounts','corp1_2_corp0', 100, current_timestamp, current_timestamp);
  61. insert into sym_trigger_router (trigger_id,router_id,initial_load_order,last_update_time,create_time) values('accounts','corp1_2_corp2', 100, current_timestamp, current_timestamp);
  62. insert into sym_trigger_router (trigger_id,router_id,initial_load_order,last_update_time,create_time) values('accounts','corp1_2_corp3', 100, current_timestamp, current_timestamp);
  63. insert into sym_trigger_router (trigger_id,router_id,initial_load_order,last_update_time,create_time) values('accounts','corp2_2_corp0', 100, current_timestamp, current_timestamp);
  64. insert into sym_trigger_router (trigger_id,router_id,initial_load_order,last_update_time,create_time) values('accounts','corp2_2_corp1', 100, current_timestamp, current_timestamp);
  65. insert into sym_trigger_router (trigger_id,router_id,initial_load_order,last_update_time,create_time) values('accounts','corp2_2_corp3', 100, current_timestamp, current_timestamp);
  66. insert into sym_trigger_router (trigger_id,router_id,initial_load_order,last_update_time,create_time) values('accounts','corp3_2_corp0', 100, current_timestamp, current_timestamp);
  67. insert into sym_trigger_router (trigger_id,router_id,initial_load_order,last_update_time,create_time) values('accounts','corp3_2_corp1', 100, current_timestamp, current_timestamp);
  68. insert into sym_trigger_router (trigger_id,router_id,initial_load_order,last_update_time,create_time) values('accounts','corp3_2_corp2', 100, current_timestamp, current_timestamp);
  69.  
  70. ---------------------------------------------------------------------
  71. insert into sym_node (node_id,node_group_id,external_id,sync_enabled,sync_url,schema_version,symmetric_version,database_type,database_version,heartbeat_time,timezone_offset,batch_to_send_count,batch_in_error_count,created_at_node_id)
  72. values ('000','corp0','000',1,null,null,null,null,null,current_timestamp,null,0,0,'000');
  73. insert into sym_node (node_id,node_group_id,external_id,sync_enabled,sync_url,schema_version,symmetric_version,database_type,database_version,heartbeat_time,timezone_offset,batch_to_send_count,batch_in_error_count,created_at_node_id)
  74. values ('001','corp1','001',1,null,null,null,null,null,current_timestamp,null,0,0,'000');
  75. insert into sym_node (node_id,node_group_id,external_id,sync_enabled,sync_url,schema_version,symmetric_version,database_type,database_version,heartbeat_time,timezone_offset,batch_to_send_count,batch_in_error_count,created_at_node_id)
  76. values ('002','corp2','002',1,null,null,null,null,null,current_timestamp,null,0,0,'000');
  77. insert into sym_node (node_id,node_group_id,external_id,sync_enabled,sync_url,schema_version,symmetric_version,database_type,database_version,heartbeat_time,timezone_offset,batch_to_send_count,batch_in_error_count,created_at_node_id)
  78. values ('003','corp3','003',1,null,null,null,null,null,current_timestamp,null,0,0,'000');
  79.  
  80. ---------------------------------------------------------------------
  81. insert into sym_node_security (node_id,node_password,registration_enabled,registration_time,initial_load_enabled,initial_load_time,created_at_node_id)
  82.  values ('000','5d1c92bbacbe2edb9e1ca5dbb0e481',0,current_timestamp,0,current_timestamp,'000');
  83. insert into sym_node_security (node_id,node_password,registration_enabled,registration_time,initial_load_enabled,initial_load_time,created_at_node_id)
  84.  values ('001','5d1c923453453454235345dbb0e481',1,null,1,null,'000');
  85. insert into sym_node_security (node_id,node_password,registration_enabled,registration_time,initial_load_enabled,initial_load_time,created_at_node_id)
  86.  values ('002','5d1c92bbacbe2edb9e1ca324234481',1,null,1,null,'000');
  87. insert into sym_node_security (node_id,node_password,registration_enabled,registration_time,initial_load_enabled,initial_load_time,created_at_node_id)
  88.  values ('003','5d32453454be2edb9e1ca324234481',1,null,1,null,'000');
  89.  
  90.  
  91. -----------------------------------------------------------------------
  92. insert into sym_node_identity values ('000');
Add Comment
Please, Sign In to add comment