summaryrefslogtreecommitdiff
path: root/lib/Dakkar/TweetArchive/Store.pm
diff options
context:
space:
mode:
Diffstat (limited to 'lib/Dakkar/TweetArchive/Store.pm')
-rw-r--r--lib/Dakkar/TweetArchive/Store.pm4
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/Dakkar/TweetArchive/Store.pm b/lib/Dakkar/TweetArchive/Store.pm
index c3840ea..cc64a87 100644
--- a/lib/Dakkar/TweetArchive/Store.pm
+++ b/lib/Dakkar/TweetArchive/Store.pm
@@ -216,7 +216,7 @@ DECLARE
p RECORD;
ids INTEGER[];
BEGIN
- FOR f IN SELECT * FROM friends ORDER BY taken_at ASC LOOP
+ FOR f IN SELECT * FROM friends ORDER BY taken_at DESC LIMIT 1 LOOP
RAISE NOTICE 'migrating friends at %s', f.taken_at;
ids := '{}';
FOR p IN INSERT INTO people(data)
@@ -229,7 +229,7 @@ BEGIN
INSERT INTO new_friends(taken_at,users) VALUES (f.taken_at,ids);
END LOOP;
- FOR f IN SELECT * FROM followers ORDER BY taken_at ASC LOOP
+ FOR f IN SELECT * FROM followers ORDER BY taken_at DESC LIMIT 1 LOOP
RAISE NOTICE 'migrating followers at %s', f.taken_at;
ids := '{}';
FOR p IN INSERT INTO people(data)