sipwise
/
db-schema
mirror of https://github.com/sipwise/db-schema.git
1
0
Fork 0
Code Issues Releases Wiki Activity

TT#54914 fix provisoniong.voip_peer_rules triggers ip_addr join

Browse Source 
* provisioning.voip_peer_rules triggers use internally
      a join by IP address to insert/update entries in
      kamailio.lcr_rule_target. in cases where there are 2 hosts
      per peering group with the same IP address, the triggers
      fail because they select duplicate peer hosts. to address
      that the "lcr_rule_target join" in the relevant triggers
      is adjusted to join the hosts tables by gw_name isntead,
      since gw_name is guaranteed unique per peer group
      (controlled by a unique key)

Change-Id: I36669efc22bb62ad34c57aac4d978435dbb26f0c
(cherry picked from commit b6d98d8464)
changes/27/28427/1
Kirill Solomko 6 years ago
parent 36d32fb19e
commit d2596b9c14
2 changed files with 152 additions and 0 deletions
Show Stats Download Patch File Download Diff File

76
db_scripts/diff/15520.down
Unescape View File

@ -0,0 +1,76 @@
USE provisioning;
DROP TRIGGER IF EXISTS voip_prul_crepl_trig;
DELIMITER ;;
/*!50003 CREATE*/ /*!50017 DEFINER=`sipwise`@`localhost`*/ /*!50003 TRIGGER voip_prul_crepl_trig AFTER INSERT ON voip_peer_rules
FOR EACH ROW BEGIN
IF NEW.enabled = 1 THEN
INSERT INTO kamailio.lcr_rule (lcr_id, prefix, request_uri, from_uri, stopper, enabled, group_id)
VALUES(1, NEW.callee_prefix, NEW.callee_pattern, NEW.caller_pattern, NEW.stopper, 1, NEW.group_id);
INSERT INTO kamailio.lcr_rule_target (lcr_id, rule_id, gw_id, priority, weight)
SELECT gw.lcr_id, LAST_INSERT_ID(), gw.id, vpg.priority, vph.weight
FROM kamailio.lcr_gw gw
INNER JOIN provisioning.voip_peer_hosts vph ON vph.ip = gw.ip_addr
AND gw.lcr_id = 1
AND vph.group_id = gw.group_id
INNER JOIN provisioning.voip_peer_groups vpg ON vpg.id = vph.group_id
WHERE vph.group_id <=> NEW.group_id;
END IF;
END */;;
DELIMITER ;
DROP TRIGGER IF EXISTS voip_prul_urepl_trig;
DELIMITER ;;
/*!50003 CREATE*/ /*!50017 DEFINER=`sipwise`@`localhost`*/ /*!50003 TRIGGER voip_prul_urepl_trig AFTER UPDATE ON voip_peer_rules
FOR EACH ROW BEGIN
IF OLD.enabled = 1 AND NEW.enabled = 1 THEN
UPDATE kamailio.lcr_rule
SET prefix = NEW.callee_prefix,
request_uri = NEW.callee_pattern,
from_uri = NEW.caller_pattern,
stopper = NEW.stopper,
group_id = NEW.group_id
WHERE prefix <=> OLD.callee_prefix
AND request_uri <=> OLD.callee_pattern
AND from_uri <=> OLD.caller_pattern
AND group_id <=> OLD.group_id
AND stopper <=> OLD.stopper;
IF OLD.group_id != NEW.group_id THEN
DELETE FROM kamailio.lcr_rule_target WHERE rule_id = OLD.id;
INSERT INTO kamailio.lcr_rule_target (lcr_id, rule_id, gw_id, priority, weight)
SELECT gw.lcr_id, OLD.id, gw.id, vpg.priority, vph.weight
FROM kamailio.lcr_gw gw
INNER JOIN provisioning.voip_peer_hosts vph ON vph.ip = gw.ip_addr
AND gw.lcr_id = 1
AND vph.group_id = gw.group_id
INNER JOIN provisioning.voip_peer_groups vpg ON vpg.id = vph.group_id
WHERE vph.group_id <=> NEW.group_id;
END IF;
ELSEIF OLD.enabled = 0 AND NEW.enabled = 1 THEN
INSERT INTO kamailio.lcr_rule (lcr_id, prefix, request_uri, from_uri, stopper, enabled, group_id)
VALUES(1, NEW.callee_prefix, NEW.callee_pattern, NEW.caller_pattern, NEW.stopper, 1, NEW.group_id);
INSERT INTO kamailio.lcr_rule_target (lcr_id, rule_id, gw_id, priority, weight)
SELECT gw.lcr_id, LAST_INSERT_ID(), gw.id, vpg.priority, vph.weight
FROM kamailio.lcr_gw gw
INNER JOIN provisioning.voip_peer_hosts vph ON vph.ip = gw.ip_addr
AND gw.lcr_id = 1
AND vph.group_id = gw.group_id
INNER JOIN provisioning.voip_peer_groups vpg ON vpg.id = vph.group_id
WHERE vph.group_id <=> NEW.group_id;
ELSEIF OLD.enabled = 1 AND NEW.enabled = 0 THEN
DELETE FROM kamailio.lcr_rule
WHERE prefix <=> OLD.callee_prefix
AND request_uri <=> OLD.callee_pattern
AND from_uri <=> OLD.caller_pattern
AND group_id <=> OLD.group_id
AND stopper <=> OLD.stopper
LIMIT 1;
END IF;
END */;;
DELIMITER ;

76
db_scripts/diff/15520.up
Unescape View File

@ -0,0 +1,76 @@
USE provisioning;
DROP TRIGGER IF EXISTS voip_prul_crepl_trig;
DELIMITER ;;
/*!50003 CREATE*/ /*!50017 DEFINER=`sipwise`@`localhost`*/ /*!50003 TRIGGER voip_prul_crepl_trig AFTER INSERT ON voip_peer_rules
FOR EACH ROW BEGIN
IF NEW.enabled = 1 THEN
INSERT INTO kamailio.lcr_rule (lcr_id, prefix, request_uri, from_uri, stopper, enabled, group_id)
VALUES(1, NEW.callee_prefix, NEW.callee_pattern, NEW.caller_pattern, NEW.stopper, 1, NEW.group_id);
INSERT INTO kamailio.lcr_rule_target (lcr_id, rule_id, gw_id, priority, weight)
SELECT gw.lcr_id, LAST_INSERT_ID(), gw.id, vpg.priority, vph.weight
FROM kamailio.lcr_gw gw
INNER JOIN provisioning.voip_peer_hosts vph ON vph.name = gw.gw_name
AND gw.lcr_id = 1
AND vph.group_id = gw.group_id
INNER JOIN provisioning.voip_peer_groups vpg ON vpg.id = vph.group_id
WHERE vph.group_id <=> NEW.group_id;
END IF;
END */;;
DELIMITER ;
DROP TRIGGER IF EXISTS voip_prul_urepl_trig;
DELIMITER ;;
/*!50003 CREATE*/ /*!50017 DEFINER=`sipwise`@`localhost`*/ /*!50003 TRIGGER voip_prul_urepl_trig AFTER UPDATE ON voip_peer_rules
FOR EACH ROW BEGIN
IF OLD.enabled = 1 AND NEW.enabled = 1 THEN
UPDATE kamailio.lcr_rule
SET prefix = NEW.callee_prefix,
request_uri = NEW.callee_pattern,
from_uri = NEW.caller_pattern,
stopper = NEW.stopper,
group_id = NEW.group_id
WHERE prefix <=> OLD.callee_prefix
AND request_uri <=> OLD.callee_pattern
AND from_uri <=> OLD.caller_pattern
AND group_id <=> OLD.group_id
AND stopper <=> OLD.stopper;
IF OLD.group_id != NEW.group_id THEN
DELETE FROM kamailio.lcr_rule_target WHERE rule_id = OLD.id;
INSERT INTO kamailio.lcr_rule_target (lcr_id, rule_id, gw_id, priority, weight)
SELECT gw.lcr_id, OLD.id, gw.id, vpg.priority, vph.weight
FROM kamailio.lcr_gw gw
INNER JOIN provisioning.voip_peer_hosts vph ON vph.name = gw.gw_name
AND gw.lcr_id = 1
AND vph.group_id = gw.group_id
INNER JOIN provisioning.voip_peer_groups vpg ON vpg.id = vph.group_id
WHERE vph.group_id <=> NEW.group_id;
END IF;
ELSEIF OLD.enabled = 0 AND NEW.enabled = 1 THEN
INSERT INTO kamailio.lcr_rule (lcr_id, prefix, request_uri, from_uri, stopper, enabled, group_id)
VALUES(1, NEW.callee_prefix, NEW.callee_pattern, NEW.caller_pattern, NEW.stopper, 1, NEW.group_id);
INSERT INTO kamailio.lcr_rule_target (lcr_id, rule_id, gw_id, priority, weight)
SELECT gw.lcr_id, LAST_INSERT_ID(), gw.id, vpg.priority, vph.weight
FROM kamailio.lcr_gw gw
INNER JOIN provisioning.voip_peer_hosts vph ON vph.name = gw.gw_name
AND gw.lcr_id = 1
AND vph.group_id = gw.group_id
INNER JOIN provisioning.voip_peer_groups vpg ON vpg.id = vph.group_id
WHERE vph.group_id <=> NEW.group_id;
ELSEIF OLD.enabled = 1 AND NEW.enabled = 0 THEN
DELETE FROM kamailio.lcr_rule
WHERE prefix <=> OLD.callee_prefix
AND request_uri <=> OLD.callee_pattern
AND from_uri <=> OLD.caller_pattern
AND group_id <=> OLD.group_id
AND stopper <=> OLD.stopper
LIMIT 1;
END IF;
END */;;
DELIMITER ;
Write Preview
Loading…
Cancel
Save