Contents

class Upsert
  # @private
  module SQLite3_Database
    def chunk
      return if buffer.empty?
      row = buffer.shift
      %{INSERT OR IGNORE INTO #{quote_ident(table_name)} (#{row.columns_sql}) VALUES (#{row.values_sql});UPDATE #{quote_ident(table_name)} SET #{row.set_sql} WHERE #{row.where_sql}}
    end

    def execute(sql)
      connection.execute_batch sql
    end

    def quote_string(v)
      SINGLE_QUOTE + SQLite3::Database.quote(v) + SINGLE_QUOTE
    end

    def quote_binary(v)
      X_AND_SINGLE_QUOTE + v.unpack("H*")[0] + SINGLE_QUOTE
    end

    def quote_time(v)
      quote_string [v.strftime(ISO8601_DATETIME), sprintf(USEC_SPRINTF, v.usec)].join('.')
    end
    
    def quote_ident(k)
      DOUBLE_QUOTE + SQLite3::Database.quote(k.to_s) + DOUBLE_QUOTE
    end

    def quote_boolean(v)
      s = v ? 't' : 'f'
      quote_string s
    end

    def quote_big_decimal(v)
      v.to_f
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
upsert-0.3.4	lib/upsert/sqlite3_database.rb
upsert-0.3.3	lib/upsert/sqlite3_database.rb