diff --git a/goss-restorethread.rb b/goss-restorethread.rb index 60aac25..11d29f9 100644 --- a/goss-restorethread.rb +++ b/goss-restorethread.rb @@ -114,42 +114,42 @@ class GossamerForumsImporter < ImportScripts::Base SQL # POST IMPORT - For each topic, the time of the last / most recent post/reply @db.execute <<-SQL - CREATE TABLE IF NOT EXISTS topic_last_post_time_final ( + CREATE TABLE IF NOT EXISTS topic_last_post_time_final2 ( topic_id INTEGER PRIMARY KEY, last_post_time INTEGER ); SQL # POST IMPORT - For each topic, increment post_count as we add posts. @db.execute <<-SQL - CREATE TABLE IF NOT EXISTS topic_post_count_final ( + CREATE TABLE IF NOT EXISTS topic_post_count_final2 ( topic_id INTEGER PRIMARY KEY, post_count INTEGER DEFAULT 0 ); SQL # POST IMPORT - For each user (_id), increment topic_count as we add topics (to see total topics per user) @db.execute <<-SQL - CREATE TABLE IF NOT EXISTS user_topic_count_final ( + CREATE TABLE IF NOT EXISTS user_topic_count_final2 ( user_id INTEGER PRIMARY KEY, topic_count INTEGER DEFAULT 0 ); SQL # POST IMPORT - For each user (_id), increment post_count as we add posts (to see total posts per user) @db.execute <<-SQL - CREATE TABLE IF NOT EXISTS user_post_count_final ( + CREATE TABLE IF NOT EXISTS user_post_count_final2 ( user_id INTEGER PRIMARY KEY, post_count INTEGER DEFAULT 0 ); SQL # POST IMPORT - For each topic, the user_id for the last poster / replier @db.execute <<-SQL - CREATE TABLE IF NOT EXISTS topic_last_post_user_final ( + CREATE TABLE IF NOT EXISTS topic_last_post_user_final2 ( topic_id INTEGER PRIMARY KEY, user_id INTEGER ); SQL # POST IMPORT - The number of posts in a given topic, incremented as we add a new reply post to a topic. @db.execute <<-SQL - CREATE TABLE IF NOT EXISTS topic_post_numbers_final ( + CREATE TABLE IF NOT EXISTS topic_post_numbers_final2 ( topic_id INTEGER PRIMARY KEY, post_number INTEGER DEFAULT 0 ); @@ -253,51 +253,51 @@ class GossamerForumsImporter < ImportScripts::Base end def fetch_db_topic_last_post_time(topic_id) - @db.get_first_value "SELECT last_post_time FROM topic_last_post_time_final WHERE topic_id = ?", topic_id + @db.get_first_value "SELECT last_post_time FROM topic_last_post_time_final2 WHERE topic_id = ?", topic_id end def fetch_db_topic_last_post_user(topic_id) - @db.get_first_value "SELECT user_id FROM topic_last_post_user_final WHERE topic_id = ?", topic_id + @db.get_first_value "SELECT user_id FROM topic_last_post_user_final2 WHERE topic_id = ?", topic_id end def fetch_db_topic_post_count(topic_id) - @db.get_first_value "SELECT post_count FROM topic_post_count_final WHERE topic_id = ?", topic_id + @db.get_first_value "SELECT post_count FROM topic_post_count_final2 WHERE topic_id = ?", topic_id end def fetch_db_user_topic_count(user_id) - @db.get_first_value "SELECT topic_count FROM user_topic_count_final WHERE user_id = ?", user_id + @db.get_first_value "SELECT topic_count FROM user_topic_count_final2 WHERE user_id = ?", user_id end def fetch_db_user_post_count(user_id) - @db.get_first_value "SELECT post_count FROM user_post_count_final WHERE user_id = ?", user_id + @db.get_first_value "SELECT post_count FROM user_post_count_final2 WHERE user_id = ?", user_id end def fetch_db_topic_post_numbers(topic_id) - @db.get_first_value "SELECT post_number FROM topic_post_numbers_final WHERE topic_id = ?", topic_id + @db.get_first_value "SELECT post_number FROM topic_post_numbers_final2 WHERE topic_id = ?", topic_id end def update_db_topic_last_post_time(topic_id, last_post_time) - @db.execute "INSERT OR REPLACE INTO topic_last_post_time_final (topic_id, last_post_time) VALUES (?, ?)", topic_id, last_post_time + @db.execute "INSERT OR REPLACE INTO topic_last_post_time_final2 (topic_id, last_post_time) VALUES (?, ?)", topic_id, last_post_time end def update_db_topic_last_post_user(topic_id, user_id) - @db.execute "INSERT OR REPLACE INTO topic_last_post_user_final (topic_id, user_id) VALUES (?, ?)", topic_id, user_id + @db.execute "INSERT OR REPLACE INTO topic_last_post_user_final2 (topic_id, user_id) VALUES (?, ?)", topic_id, user_id end def update_db_topic_post_count(topic_id, post_count) - @db.execute "INSERT OR REPLACE INTO topic_post_count_final (topic_id, post_count) VALUES (?, ?)", topic_id, post_count + @db.execute "INSERT OR REPLACE INTO topic_post_count_final2 (topic_id, post_count) VALUES (?, ?)", topic_id, post_count end def update_db_user_topic_count(user_id, topic_count) - @db.execute "INSERT OR REPLACE INTO user_topic_count_final (user_id, topic_count) VALUES (?, ?)", user_id, topic_count + @db.execute "INSERT OR REPLACE INTO user_topic_count_final2 (user_id, topic_count) VALUES (?, ?)", user_id, topic_count end def update_db_user_post_count(user_id, post_count) - @db.execute "INSERT OR REPLACE INTO user_post_count_final (user_id, post_count) VALUES (?, ?)", user_id, post_count + @db.execute "INSERT OR REPLACE INTO user_post_count_final2 (user_id, post_count) VALUES (?, ?)", user_id, post_count end def update_db_topic_post_numbers(topic_id, post_number) - @db.execute "INSERT OR REPLACE INTO topic_post_numbers_final (topic_id, post_number) VALUES (?, ?)", topic_id, post_number + @db.execute "INSERT OR REPLACE INTO topic_post_numbers_final2 (topic_id, post_number) VALUES (?, ?)", topic_id, post_number end # Fetch the highest processed post_id from the highest_processed_post_id table @@ -1839,13 +1839,13 @@ class GossamerForumsImporter < ImportScripts::Base end end - def update_topic_stats_final + def update_topic_stats_final2 # Update topics with the correct last post time, post count, and last post user puts "Update topics with the correct last post time, post count, and last post user" - @db.execute("SELECT * FROM topic_last_post_time_final").each do |row| + @db.execute("SELECT * FROM topic_last_post_time_final2").each do |row| topic_id, last_post_time = row - puts "update_topic_stats_final topic_id #{topic_id}" + puts "update_topic_stats_final2 topic_id #{topic_id}" begin topic = Topic.find(topic_id) @@ -2221,6 +2221,9 @@ class GossamerForumsImporter < ImportScripts::Base ### update_topic_stats_final ### update_user_stats_finalfinal +# update_topic_stats_final2 +# update_user_stats_finalfinal2 + ### export_url_mapping_to_csv("/bitnami/discourse/sqlite/gossamer-migration-url-mapping#{timestamp}") ### export_nginx_rewrite_rules("/bitnami/discourse/sqlite/gossamer-redirects#{timestamp}.conf")