mirror of https://github.com/sipwise/db-schema.git
This reverts commit db9c2a05f6
.
Change-Id: I8dae173a22d3cc8fb18a5ef3dc2da9ea1b534319
changes/95/2195/1
parent
e52d7570fe
commit
08136a0355
@ -1,6 +0,0 @@
|
||||
SET AUTOCOMMIT=0;
|
||||
USE billing;
|
||||
|
||||
drop procedure if exists fill_billing_fees;
|
||||
|
||||
COMMIT;
|
@ -1,40 +0,0 @@
|
||||
SET AUTOCOMMIT=0;
|
||||
USE billing;
|
||||
|
||||
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");
|
||||
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 ;
|
||||
|
||||
COMMIT;
|
Loading…
Reference in new issue