From 597e71c21676da3a8ba4edf5c87baa5f16383e80 Mon Sep 17 00:00:00 2001
From: Raphael Sofaer <raphael@joindiaspora.com>
Date: Wed, 30 Mar 2011 16:18:57 -0700
Subject: [PATCH] Yep, there are violating records

---
 db/migrate/20110330230206_pm_foreign_keys.rb | 27 ++++++++++++++++++++
 1 file changed, 27 insertions(+)

diff --git a/db/migrate/20110330230206_pm_foreign_keys.rb b/db/migrate/20110330230206_pm_foreign_keys.rb
index 0b63c72a5..98fcd3a1d 100644
--- a/db/migrate/20110330230206_pm_foreign_keys.rb
+++ b/db/migrate/20110330230206_pm_foreign_keys.rb
@@ -1,5 +1,32 @@
 class PmForeignKeys < ActiveRecord::Migration
+  def self.delete_disconnected_cvs
+    execute <<SQL
+    DELETE conversation_visibilities FROM conversation_visibilities
+      LEFT OUTER JOIN conversations ON conversation_visibilities.conversation_id = conversations.id
+      LEFT OUTER JOIN people ON conversation_visibilities.person_id = people.id
+    WHERE people.id IS NULL OR conversations.id IS NULL
+SQL
+  end
+  def self.delete_disconnected_messages
+    execute <<SQL
+    DELETE messages FROM messages
+      LEFT OUTER JOIN conversations ON messages.conversation_id = conversations.id
+      LEFT OUTER JOIN people ON messages.author_id = people.id
+    WHERE people.id IS NULL OR conversations.id IS NULL
+SQL
+  end
+  def self.delete_disconnected_conversations
+    execute <<SQL
+    DELETE conversations FROM conversations
+      LEFT OUTER JOIN people ON conversations.author_id = people.id
+    WHERE people.id IS NULL
+SQL
+  end
   def self.up
+    delete_disconnected_conversations
+    delete_disconnected_messages
+    delete_disconnected_cvs
+
     add_foreign_key :conversation_visibilities, :conversations, :dependent => :delete
     add_foreign_key :conversation_visibilities, :people, :dependent => :delete