diff options
| author | dakkar <dakkar@thenautilus.net> | 2017-05-08 12:34:26 +0100 |
|---|---|---|
| committer | dakkar <dakkar@thenautilus.net> | 2017-05-08 12:34:26 +0100 |
| commit | e46b28c2c0fbe8d8deba6bc33f435e59cade0d25 (patch) | |
| tree | d02a17f2040241a3c17f651a1d9f492cebf9dfe9 | |
| parent | maybe faster people migration (diff) | |
| download | tweet-archive-e46b28c2c0fbe8d8deba6bc33f435e59cade0d25.tar.gz tweet-archive-e46b28c2c0fbe8d8deba6bc33f435e59cade0d25.tar.bz2 tweet-archive-e46b28c2c0fbe8d8deba6bc33f435e59cade0d25.zip | |
giving up, just migrate the current set of people
| -rw-r--r-- | lib/Dakkar/TweetArchive/Store.pm | 4 |
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) |