From 2cc0d141f6be12698e6a44ad43473200736acaed Mon Sep 17 00:00:00 2001
From: Richard Fuchs <rfuchs@sipwise.com>
Date: Sat, 10 Nov 2012 16:09:18 +0000
Subject: [PATCH] change sipstats partitioning

---
 db_scripts/diff/11729_not_replicated.down | 10 ++++++++++
 db_scripts/diff/11729_not_replicated.up   | 21 +++++++++++++++++++++
 2 files changed, 31 insertions(+)
 create mode 100644 db_scripts/diff/11729_not_replicated.down
 create mode 100644 db_scripts/diff/11729_not_replicated.up

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;