Module: AdapterExtensions::AbstractAdapter

Included in:
ActiveRecord::ConnectionAdapters::AbstractAdapter
Defined in:
lib/adapter_extensions/adapters/abstract_adapter.rb

Instance Method Summary collapse

Instance Method Details

#add_select_into_table(new_table_name, sql_query) ⇒ Object

Add a chunk of SQL to the given query that will create a new table and execute the select into that table.

Raises:

  • (NotImplementedError) 


33
34
35
 
# File 'lib/adapter_extensions/adapters/abstract_adapter.rb', line 33

def add_select_into_table(new_table_name, sql_query)
  raise NotImplementedError, "add_select_into_table is an abstract method"
end

#bulk_load(file, table_name, options = {}) ⇒ Object

Bulk loading interface. Load the data from the specified file into the given table. Note that options will be adapter-dependent.

Raises:

  • (ArgumentError) 


16
17
18
19
20
 
# File 'lib/adapter_extensions/adapters/abstract_adapter.rb', line 16

def bulk_load(file, table_name, options={})
  raise ArgumentError, "#{file} does not exist" unless File.exist?(file)
  raise ArgumentError, "#{table_name} does not exist" unless tables.include?(table_name)
  do_bulk_load(file, table_name, options)
end

#support_select_into_table? ⇒ Boolean

SQL select into statement constructs a new table from the results of a select. It is used to select data from a table and create a new table with its result set at the same time. Note that this method name does not necessarily match the implementation. E.g. MySQL's version of this is 'CREATE TABLE ... AS SELECT ...'

Returns:

  • (Boolean) 


27
28
29
 
# File 'lib/adapter_extensions/adapters/abstract_adapter.rb', line 27

def support_select_into_table?
  false
end

#truncate(table_name, options = nil) ⇒ Object

Truncate the specified table - allow to pass an optional string to let the called add extra parameters like RESET IDENTITY for pg



5
6
7
8
9
10
11
12
 
# File 'lib/adapter_extensions/adapters/abstract_adapter.rb', line 5

def truncate(table_name, options=nil)
  statement = [
    'TRUNCATE TABLE',
    table_name,
    options
  ].compact.join(' ')
  execute(statement)
end