Method: Ayadn::Databases.save_indexed_posts

Defined in:

lib/ayadn/databases.rb

.save_indexed_posts(posts) ⇒ Object

# File 'lib/ayadn/databases.rb', line 611

def self.save_indexed_posts(posts)
  crashes = 0
  begin
    @sql.execute("DELETE FROM TLIndex")
    @sql.transaction do |db_in_transaction|
      posts.each do |k, v|
        if !v.blank?
          insert_data = {}
          insert_data[":post_id"] = v[:id]
          insert_data[":count"] = v[:count]
          insert_data[":content"] = v.to_json.to_s
          db_in_transaction.prepare("INSERT INTO TLIndex(count, post_id, content) VALUES(:count, :post_id, :content);") do |insert|
            insert.execute(insert_data)
          end
        end
      end
    end
  rescue Amalgalite::SQLite3::Error => e
    if crashes < 2
      crashes += 1
      sleep(0.01)
      retry
    else
      puts "ERROR in Databases"
      puts caller
      puts e
      puts ['save_indexed_posts', posts].inspect
      exit
    end
  end
end