lib/upsert/buffer/sqlite3_database.rb in upsert-0.1.0 vs lib/upsert/buffer/sqlite3_database.rb in upsert-0.1.1
- old
+ new
@@ -3,15 +3,12 @@
# @private
class SQLite3_Database < Buffer
include Quoter
def chunk
- return false if rows.empty?
+ return if rows.empty?
row = rows.shift
- %{
- INSERT OR IGNORE INTO "#{table_name}" (#{row.columns_sql}) VALUES (#{row.values_sql});
- UPDATE "#{table_name}" SET #{row.set_sql} WHERE #{row.where_sql}
- }
+ %{INSERT OR IGNORE INTO "#{table_name}" (#{row.columns_sql}) VALUES (#{row.values_sql});UPDATE "#{table_name}" SET #{row.set_sql} WHERE #{row.where_sql}}
end
def execute(sql)
connection.execute_batch sql
end