Contents

class StandardBatchInsert
  include FromHash
  attr_accessor :rows, :table_name
  fattr(:column_names) { rows.first.sorted_column_names }
  fattr(:values_sql) do
    "VALUES " + rows.map { |x| x.insert_values_sql }.join(", ")
  end
  fattr(:columns_sql) do
    "(" + column_names.join(", ") + ")"
  end
  fattr(:insert_sql) do
    "INSERT into #{table_name} #{columns_sql} #{values_sql};"
  end
  def insert!
    ActiveRecord::Base.connection.execute(insert_sql) 
  end
end
    
class OracleBatchInsert < StandardBatchInsert
  fattr(:insert_sql) do
    str = ["INSERT ALL "]
    rows.each do |row|
      str << "INTO #{table_name} #{columns_sql} VALUES #{row.insert_values_sql}"
    end
    str.join("\n") + "\nSELECT * from dual"
  end
end

class BatchInsert
  def self.get_class
    if %w(oci oci8 oracle).include?(MasterLoader.instance.db_ops[:adapter])
      OracleBatchInsert
    else
      StandardBatchInsert
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
GFunk911-dataload-0.8.4	lib/dataload/batch_insert.rb
GFunk911-dataload-0.8.5	lib/dataload/batch_insert.rb
GFunk911-dataload-0.9.0	lib/dataload/batch_insert.rb
GFunk911-dataload-0.9.1	lib/dataload/batch_insert.rb