Module: ActiveRecord::ConnectionAdapters::AmazonTimestream::SchemaStatements

Included in:
ActiveRecord::ConnectionAdapters::AmazonTimestreamAdapter
Defined in:
lib/active_record/connection_adapters/amazon_timestream/schema_statements.rb

Instance Method Summary collapse

Instance Method Details

#columns(table_name, _name = nil) ⇒ Object 



14
15
16
17
18
19
 
# File 'lib/active_record/connection_adapters/amazon_timestream/schema_statements.rb', line 14

def columns(table_name, _name = nil)
  response = @connection.query({ query_string: "DESCRIBE \"#{@database}\".\"#{table_name}\"" })
  response.rows.map do |r|
    AmazonTimestreamColumn.new r.data[0].scalar_value, nil, lookup_cast_type(r.data[1].scalar_value)
  end
end

#data_sources ⇒ Object 



29
30
31
 
# File 'lib/active_record/connection_adapters/amazon_timestream/schema_statements.rb', line 29

def data_sources
  tables
end

#primary_key(_table_name) ⇒ Object 



25
26
27
 
# File 'lib/active_record/connection_adapters/amazon_timestream/schema_statements.rb', line 25

def primary_key(_table_name)
  nil
end

#table_exists?(table_name) ⇒ Boolean

Returns:

  • (Boolean) 


21
22
23
 
# File 'lib/active_record/connection_adapters/amazon_timestream/schema_statements.rb', line 21

def table_exists?(table_name)
  tables.include?(table_name)
end

#tables(_name = nil) ⇒ Object 



9
10
11
12
 
# File 'lib/active_record/connection_adapters/amazon_timestream/schema_statements.rb', line 9

def tables(_name = nil)
  response = @connection.query({ query_string: "SHOW TABLES FROM \"#{@database}\"" })
  response.rows.map { |r| r.data[0].scalar_value }
end