diff --git a/db_scripts/diff/11729_not_replicated.down b/db_scripts/diff/11729_not_replicated.down new file mode 100644 index 00000000..5949996e --- /dev/null +++ b/db_scripts/diff/11729_not_replicated.down @@ -0,0 +1,10 @@ +use sipstats; + +alter ignore table messages remove partitioning; +alter table messages partition by range (id) (partition pmax values less than maxvalue); + +alter ignore table message_packets remove partitioning; +alter table message_packets partition by range (message) (partition pmax values less than maxvalue); + +alter ignore table packets remove partitioning; +alter table packets partition by range (id) (partition pmax values less than maxvalue); diff --git a/db_scripts/diff/11729_not_replicated.up b/db_scripts/diff/11729_not_replicated.up new file mode 100644 index 00000000..31dd6d44 --- /dev/null +++ b/db_scripts/diff/11729_not_replicated.up @@ -0,0 +1,21 @@ +use sipstats; + +alter ignore table messages remove partitioning; +set @mx = (select (coalesce(max(id), 0)) + 700000 from messages); +set @stm = concat('alter table messages partition by range (id) (partition p', @mx, ' values less than (', @mx, '))'); +prepare st from @stm; +execute st; +deallocate prepare st; + +alter ignore table message_packets remove partitioning; +set @stm = concat('alter table message_packets partition by range (message) (partition p', @mx, ' values less than (', @mx, '))'); +prepare st from @stm; +execute st; +deallocate prepare st; + +alter ignore table packets remove partitioning; +set @mx = (select (coalesce(max(id), 0)) + 700000 from packets); +set @stm = concat('alter table packets partition by range (id) (partition p', @mx, ' values less than (', @mx, '))'); +prepare st from @stm; +execute st; +deallocate prepare st;