From 086250db364477a1068b05970927935ebb69a378 Mon Sep 17 00:00:00 2001
From: Irina Peshinskaya <ipeshinskaya@sipwise.com>
Date: Mon, 11 May 2015 17:40:55 +0300
Subject: [PATCH] MT#7227 Fill billing_fees from temporary location with not
 unique records.

Change-Id: I3171ce5b57b15830b46a187aa332516b2f8ebe17
---
 db_scripts/diff/15167.down | 12 ++++++++
 db_scripts/diff/15167.up   | 62 ++++++++++++++++++++++++++++++++++++++
 2 files changed, 74 insertions(+)
 create mode 100644 db_scripts/diff/15167.down
 create mode 100644 db_scripts/diff/15167.up

diff --git a/db_scripts/diff/15167.down b/db_scripts/diff/15167.down
new file mode 100644
index 00000000..02f2afbb
--- /dev/null
+++ b/db_scripts/diff/15167.down
@@ -0,0 +1,12 @@
+SET AUTOCOMMIT=0;
+USE billing;
+
+drop index billing_fees_unique on billing_fees;
+delete from billing_fees;
+insert into billing_fees select * from billing_fees_raw;
+drop table if exists billing_fees_raw;
+drop procedure if exists fill_billing_fees;
+
+COMMIT;
+
+
diff --git a/db_scripts/diff/15167.up b/db_scripts/diff/15167.up
new file mode 100644
index 00000000..ce539d82
--- /dev/null
+++ b/db_scripts/diff/15167.up
@@ -0,0 +1,62 @@
+SET AUTOCOMMIT=0;
+USE billing;
+
+create table if not exists billing_fees_raw like billing_fees;
+select `AUTO_INCREMENT` into @auto_increment_billing_fees from INFORMATION_SCHEMA.TABLES where TABLE_SCHEMA = database() AND TABLE_NAME   = 'billing_fees';
+
+SET @sql = CONCAT("alter table billing_fees_raw auto_increment=",@auto_increment_billing_fees); 
+PREPARE stmt FROM @sql; 
+EXECUTE stmt; 
+DEALLOCATE PREPARE stmt;
+
+
+DELIMITER //
+DROP PROCEDURE IF EXISTS fill_billing_fees;
+CREATE PROCEDURE fill_billing_fees(IN in_profile_id INT)
+BEGIN
+
+    DECLARE columns varchar(1023);
+    DECLARE statement varchar(1023);
+    
+    SET @profile_id = in_profile_id;
+    
+    SELECT group_concat(COLUMN_NAME) INTO columns FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_SCHEMA = database() AND TABLE_NAME = 'billing_fees_raw' AND COLUMN_NAME NOT IN ('id');
+    
+SET @statement = concat("insert into billing_fees(id,",columns,")
+select min_id,",columns,"
+from billing_fees_raw bnu 
+inner join (
+    select min(i_nu.id) min_id 
+    from billing_fees_raw i_nu 
+    left join billing.billing_fees i_u 
+        on i_nu.billing_profile_id=i_u.billing_profile_id 
+        and i_nu.source=i_u.source 
+        and i_nu.destination=i_u.destination 
+        and i_nu.direction=i_u.direction 
+        and i_nu.type=i_u.type 
+    where i_u.id is null ",
+    if( @profile_id is not null, " and i_nu.billing_profile_id = ? ", " and 1 = ? "),
+    " group by i_nu.billing_profile_id,i_nu.source,i_nu.destination,i_nu.direction,i_nu.type
+) u on bnu.id=u.min_id");
+    select @statement;
+    IF @profile_id is null THEN SET @profile_id = 1; END IF;
+    PREPARE stmt FROM @statement;
+    EXECUTE stmt USING @profile_id;
+    DEALLOCATE PREPARE stmt;
+END//
+
+DELIMITER ;
+
+insert into billing_fees_raw select * from billing_fees;
+delete from billing_fees;
+CREATE UNIQUE INDEX billing_fees_unique on billing_fees (billing_profile_id,source,destination,direction,type);
+
+
+CALL fill_billing_fees(null);
+
+
+ 
+
+COMMIT;
+
+