Class: ActiveRecord::ConnectionAdapters::RedshiftAdapter
- Inherits:
-
AbstractAdapter
- Object
- AbstractAdapter
- ActiveRecord::ConnectionAdapters::RedshiftAdapter
- Includes:
- ActiveRecord::ConnectionAdapters::Redshift::DatabaseStatements, ActiveRecord::ConnectionAdapters::Redshift::Quoting, ActiveRecord::ConnectionAdapters::Redshift::ReferentialIntegrity, ActiveRecord::ConnectionAdapters::Redshift::SchemaStatements
- Defined in:
- lib/active_record/connection_adapters/redshift_adapter.rb
Overview
The PostgreSQL adapter works with the native C (bitbucket.org/ged/ruby-pg) driver.
Options:
-
:host
- Defaults to a Unix-domain socket in /tmp. On machines without Unix-domain sockets, the default is to connect to localhost. -
:port
- Defaults to 5432. -
:username
- Defaults to be the same as the operating system name of the user running the application. -
:password
- Password to be used if the server demands password authentication. -
:database
- Defaults to be the same as the user name. -
:schema_search_path
- An optional schema search path for the connection given as a string of comma-separated schema names. This is backward-compatible with the:schema_order
option. -
:encoding
- An optional client encoding that is used in aSET client_encoding TO <encoding>
call on the connection. -
:min_messages
- An optional client min messages that is used in aSET client_min_messages TO <min_messages>
call on the connection. -
:variables
- An optional hash of additional parameters that will be used inSET SESSION key = val
calls on the connection. -
:insert_returning
- Does nothing for Redshift.
Any further options are used as connection parameters to libpq. See www.postgresql.org/docs/9.1/static/libpq-connect.html for the list of parameters.
In addition, default connection parameters of libpq can be set per environment variables. See www.postgresql.org/docs/9.1/static/libpq-envars.html .
Defined Under Namespace
Classes: StatementPool
Constant Summary collapse
- ADAPTER_NAME =
'Redshift'.freeze
- NATIVE_DATABASE_TYPES =
{ primary_key: "integer identity primary key", string: { name: "varchar" }, text: { name: "varchar" }, integer: { name: "integer" }, float: { name: "float" }, decimal: { name: "decimal" }, datetime: { name: "timestamp" }, time: { name: "time" }, date: { name: "date" }, bigint: { name: "bigint" }, boolean: { name: "boolean" }, }
- OID =
:nodoc:
Redshift::OID
- OPERATION_ALIASES =
:nodoc:
{ # :nodoc: "maximum" => "max", "minimum" => "min", "average" => "avg", }
Constants included from ActiveRecord::ConnectionAdapters::Redshift::DatabaseStatements
ActiveRecord::ConnectionAdapters::Redshift::DatabaseStatements::BYTEA_COLUMN_TYPE_OID, ActiveRecord::ConnectionAdapters::Redshift::DatabaseStatements::MONEY_COLUMN_TYPE_OID
Instance Method Summary collapse
-
#active? ⇒ Boolean
Is this connection alive and ready for queries?.
-
#clear_cache! ⇒ Object
Clears the prepared statements cache.
-
#column_name_for_operation(operation, node) ⇒ Object
:nodoc:.
- #disable_extension(name) ⇒ Object
-
#disconnect! ⇒ Object
Disconnects from the database if already connected.
- #enable_extension(name) ⇒ Object
- #extension_enabled?(name) ⇒ Boolean
- #index_algorithms ⇒ Object
-
#initialize(connection, logger, connection_parameters, config) ⇒ RedshiftAdapter
constructor
Initializes and connects a PostgreSQL adapter.
-
#lookup_cast_type(sql_type) ⇒ Object
:nodoc:.
-
#native_database_types ⇒ Object
:nodoc:.
-
#reconnect! ⇒ Object
Close then reopen the connection.
- #reset! ⇒ Object
-
#schema_creation ⇒ Object
:nodoc:.
-
#session_auth=(user) ⇒ Object
Set the authorized user for this session.
-
#set_standard_conforming_strings ⇒ Object
Enable standard-conforming strings if available.
- #supports_ddl_transactions? ⇒ Boolean
- #supports_explain? ⇒ Boolean
- #supports_extensions? ⇒ Boolean
- #supports_foreign_keys? ⇒ Boolean
- #supports_import? ⇒ Boolean
- #supports_index_sort_order? ⇒ Boolean
- #supports_materialized_views? ⇒ Boolean
-
#supports_migrations? ⇒ Boolean
Returns true, since this connection adapter supports migrations.
- #supports_partial_index? ⇒ Boolean
-
#supports_primary_key? ⇒ Boolean
Does PostgreSQL support finding primary key on non-Active Record tables?.
- #supports_ranges? ⇒ Boolean
- #supports_transaction_isolation? ⇒ Boolean
- #supports_views? ⇒ Boolean
-
#table_alias_length ⇒ Object
Returns the configured supported identifier length supported by PostgreSQL.
- #truncate(table_name, name = nil) ⇒ Object
-
#update_table_definition(table_name, base) ⇒ Object
:nodoc:.
- #use_insert_returning? ⇒ Boolean
- #valid_type?(type) ⇒ Boolean
Methods included from ActiveRecord::ConnectionAdapters::Redshift::DatabaseStatements
#begin_db_transaction, #begin_isolated_db_transaction, #commit_db_transaction, #exec_delete, #exec_insert, #exec_query, #exec_rollback_db_transaction, #execute, #explain, #query, #result_as_array, #select_rows, #select_value, #select_values, #sql_for_insert
Methods included from ActiveRecord::ConnectionAdapters::Redshift::SchemaStatements
#add_column, #add_index, #change_column, #change_column_default, #change_column_null, #collation, #columns, #columns_for_distinct, #create_database, #create_schema, #ctype, #current_database, #current_schema, #data_source_exists?, #data_sources, #default_sequence_name, #drop_database, #drop_schema, #drop_table, #encoding, #extract_foreign_key_action, #fetch_type_metadata, #foreign_keys, #index_name_exists?, #index_name_length, #indexes, #new_column, #pk_and_sequence_for, #primary_keys, #recreate_database, #remove_index!, #rename_column, #rename_index, #rename_table, #reset_pk_sequence!, #schema_exists?, #schema_names, #schema_search_path, #schema_search_path=, #serial_sequence, #set_pk_sequence!, #table_exists?, #tables, #type_to_sql, #view_exists?, #views
Methods included from ActiveRecord::ConnectionAdapters::Redshift::ReferentialIntegrity
#disable_referential_integrity, #supports_disable_referential_integrity?
Methods included from ActiveRecord::ConnectionAdapters::Redshift::Quoting
#escape_bytea, #quote_column_name, #quote_default_value, #quote_schema_name, #quote_string, #quote_table_name, #quote_table_name_for_assignment, #quoted_date, #unescape_bytea
Constructor Details
#initialize(connection, logger, connection_parameters, config) ⇒ RedshiftAdapter
Initializes and connects a PostgreSQL adapter.
180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 180 def initialize(connection, logger, connection_parameters, config) super(connection, logger, config) @visitor = Arel::Visitors::PostgreSQL.new self @visitor.extend(ConnectionAdapters::DetermineIfPreparableVisitor) @prepared_statements = false @connection_parameters = connection_parameters # @local_tz is initialized as nil to avoid warnings when connect tries to use it @local_tz = nil @table_alias_length = nil connect @statements = StatementPool.new @connection, self.class.type_cast_config_to_integer(config[:statement_limit]) @type_map = Type::HashLookupTypeMap.new initialize_type_map(type_map) @local_tz = execute('SHOW TIME ZONE', 'SCHEMA').first["TimeZone"] @use_insert_returning = @config.key?(:insert_returning) ? self.class.type_cast_config_to_boolean(@config[:insert_returning]) : false end |
Instance Method Details
#active? ⇒ Boolean
Is this connection alive and ready for queries?
213 214 215 216 217 218 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 213 def active? @connection.query 'SELECT 1' true rescue PG::Error false end |
#clear_cache! ⇒ Object
Clears the prepared statements cache.
204 205 206 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 204 def clear_cache! @statements.clear end |
#column_name_for_operation(operation, node) ⇒ Object
:nodoc:
328 329 330 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 328 def column_name_for_operation(operation, node) # :nodoc: OPERATION_ALIASES.fetch(operation) { operation.downcase } end |
#disable_extension(name) ⇒ Object
293 294 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 293 def disable_extension(name) end |
#disconnect! ⇒ Object
Disconnects from the database if already connected. Otherwise, this method does nothing.
239 240 241 242 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 239 def disconnect! super @connection.close rescue nil end |
#enable_extension(name) ⇒ Object
290 291 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 290 def enable_extension(name) end |
#extension_enabled?(name) ⇒ Boolean
296 297 298 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 296 def extension_enabled?(name) false end |
#index_algorithms ⇒ Object
121 122 123 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 121 def index_algorithms { concurrently: 'CONCURRENTLY' } end |
#lookup_cast_type(sql_type) ⇒ Object
:nodoc:
323 324 325 326 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 323 def lookup_cast_type(sql_type) # :nodoc: oid = execute("SELECT #{quote(sql_type)}::regtype::oid", "SCHEMA").first['oid'].to_i super(oid) end |
#native_database_types ⇒ Object
:nodoc:
244 245 246 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 244 def native_database_types #:nodoc: NATIVE_DATABASE_TYPES end |
#reconnect! ⇒ Object
Close then reopen the connection.
221 222 223 224 225 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 221 def reconnect! super @connection.reset configure_connection end |
#reset! ⇒ Object
227 228 229 230 231 232 233 234 235 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 227 def reset! clear_cache! reset_transaction unless @connection.transaction_status == ::PG::PQTRANS_IDLE @connection.query 'ROLLBACK' end @connection.query 'DISCARD ALL' configure_connection end |
#schema_creation ⇒ Object
:nodoc:
97 98 99 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 97 def schema_creation # :nodoc: Redshift::SchemaCreation.new self end |
#session_auth=(user) ⇒ Object
Set the authorized user for this session
306 307 308 309 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 306 def session_auth=(user) clear_cache! exec_query "SET SESSION AUTHORIZATION #{user}" end |
#set_standard_conforming_strings ⇒ Object
Enable standard-conforming strings if available.
259 260 261 262 263 264 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 259 def set_standard_conforming_strings old, self. = , 'panic' execute('SET standard_conforming_strings = on', 'SCHEMA') rescue nil ensure self. = old end |
#supports_ddl_transactions? ⇒ Boolean
266 267 268 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 266 def supports_ddl_transactions? true end |
#supports_explain? ⇒ Boolean
270 271 272 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 270 def supports_explain? true end |
#supports_extensions? ⇒ Boolean
274 275 276 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 274 def supports_extensions? false end |
#supports_foreign_keys? ⇒ Boolean
113 114 115 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 113 def supports_foreign_keys? true end |
#supports_import? ⇒ Boolean
286 287 288 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 286 def supports_import? true end |
#supports_index_sort_order? ⇒ Boolean
101 102 103 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 101 def supports_index_sort_order? false end |
#supports_materialized_views? ⇒ Boolean
282 283 284 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 282 def supports_materialized_views? false end |
#supports_migrations? ⇒ Boolean
Returns true, since this connection adapter supports migrations.
249 250 251 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 249 def supports_migrations? true end |
#supports_partial_index? ⇒ Boolean
105 106 107 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 105 def supports_partial_index? false end |
#supports_primary_key? ⇒ Boolean
Does PostgreSQL support finding primary key on non-Active Record tables?
254 255 256 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 254 def supports_primary_key? #:nodoc: true end |
#supports_ranges? ⇒ Boolean
278 279 280 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 278 def supports_ranges? false end |
#supports_transaction_isolation? ⇒ Boolean
109 110 111 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 109 def supports_transaction_isolation? false end |
#supports_views? ⇒ Boolean
117 118 119 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 117 def supports_views? true end |
#table_alias_length ⇒ Object
Returns the configured supported identifier length supported by PostgreSQL
301 302 303 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 301 def table_alias_length @table_alias_length ||= query('SHOW max_identifier_length', 'SCHEMA')[0][0].to_i end |
#truncate(table_name, name = nil) ⇒ Object
208 209 210 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 208 def truncate(table_name, name = nil) exec_query "TRUNCATE TABLE #{quote_table_name(table_name)}", name, [] end |
#update_table_definition(table_name, base) ⇒ Object
:nodoc:
319 320 321 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 319 def update_table_definition(table_name, base) #:nodoc: Redshift::Table.new(table_name, base) end |
#use_insert_returning? ⇒ Boolean
311 312 313 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 311 def use_insert_returning? false end |
#valid_type?(type) ⇒ Boolean
315 316 317 |
# File 'lib/active_record/connection_adapters/redshift_adapter.rb', line 315 def valid_type?(type) !native_database_types[type].nil? end |