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 a SET client_encoding TO <encoding> call on the connection.

  • :min_messages - An optional client min messages that is used in a SET client_min_messages TO <min_messages> call on the connection.

  • :variables - An optional hash of additional parameters that will be used in SET SESSION key = val calls on the connection.

  • :insert_returning - An optional boolean to control the use or RETURNING for INSERT statements defaults to true.

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 .

Namespace
Methods
A
C
D
E
I
M
N
P
R
S
T
U
V
Included Modules
Constants
ADAPTER_NAME = 'PostgreSQL'
 
NATIVE_DATABASE_TYPES = { primary_key: "serial primary key", string: { name: "character varying", limit: 255 }, text: { name: "text" }, integer: { name: "integer" }, float: { name: "float" }, decimal: { name: "decimal" }, datetime: { name: "timestamp" }, timestamp: { name: "timestamp" }, time: { name: "time" }, date: { name: "date" }, daterange: { name: "daterange" }, numrange: { name: "numrange" }, tsrange: { name: "tsrange" }, tstzrange: { name: "tstzrange" }, int4range: { name: "int4range" }, int8range: { name: "int8range" }, binary: { name: "bytea" }, boolean: { name: "boolean" }, xml: { name: "xml" }, tsvector: { name: "tsvector" }, hstore: { name: "hstore" }, inet: { name: "inet" }, cidr: { name: "cidr" }, macaddr: { name: "macaddr" }, uuid: { name: "uuid" }, json: { name: "json" }, ltree: { name: "ltree" } }
 
FOREIGN_KEY_VIOLATION = "23503"
 

See www.postgresql.org/docs/9.1/static/errcodes-appendix.html
UNIQUE_VIOLATION = "23505"
 
FEATURE_NOT_SUPPORTED = "0A000"
 
MONEY_COLUMN_TYPE_OID = 790
 

The internal PostgreSQL identifier of the money data type.
BYTEA_COLUMN_TYPE_OID = 17
 

The internal PostgreSQL identifier of the BYTEA data type.
Class Public methods
new(connection, logger, connection_parameters, config)

Initializes and connects a PostgreSQL adapter.

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 532
def initialize(connection, logger, connection_parameters, config)
  super(connection, logger)

  if self.class.type_cast_config_to_boolean(config.fetch(:prepared_statements) { true })
    @prepared_statements = true
    @visitor = Arel::Visitors::PostgreSQL.new self
  else
    @visitor = unprepared_visitor
  end

  @connection_parameters, @config = connection_parameters, config

  # @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.fetch(:statement_limit) { 1000 })

  if postgresql_version < 80200
    raise "Your version of PostgreSQL (#{postgresql_version}) is too old, please upgrade!"
  end

  initialize_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]) : true
end
Instance Public methods
active?()

Is this connection alive and ready for queries?

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 567
def active?
  @connection.connect_poll != PG::PGRES_POLLING_FAILED
rescue PGError
  false
end
adapter_name()

Returns 'PostgreSQL' as adapter name for identification purposes.

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 434
def adapter_name
  ADAPTER_NAME
end
clear_cache!()

Clears the prepared statements cache.

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 562
def clear_cache!
  @statements.clear
end
disable_extension(name)

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 648
def disable_extension(name)
  exec_query("DROP EXTENSION IF EXISTS \"#{name}\" CASCADE").tap {
    reload_type_map
  }
end
disconnect!()

Disconnects from the database if already connected. Otherwise, this method does nothing.

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 587
def disconnect!
  super
  @connection.close rescue nil
end
enable_extension(name)

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 642
def enable_extension(name)
  exec_query("CREATE EXTENSION IF NOT EXISTS \"#{name}\"").tap {
    reload_type_map
  }
end
extension_enabled?(name)

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 654
def extension_enabled?(name)
  if supports_extensions?
    res = exec_query "SELECT EXISTS(SELECT * FROM pg_available_extensions WHERE name = '#{name}' AND installed_version IS NOT NULL) as enabled",
      'SCHEMA'
    res.column_types['enabled'].type_cast res.rows.first.first
  end
end
extensions()

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 662
def extensions
  if supports_extensions?
    res = exec_query "SELECT extname from pg_extension", "SCHEMA"
    res.rows.map { |r| res.column_types['extname'].type_cast r.first }
  else
    super
  end
end
index_algorithms()

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 470
def index_algorithms
  { concurrently: 'CONCURRENTLY' }
end
migration_keys()

Adds `:array` as a valid migration key

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 448
def migration_keys
  super + [:array]
end
prepare_column_options(column, types)

Adds `:array` option to the default set provided by the AbstractAdapter

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 440
def prepare_column_options(column, types)
  spec = super
  spec[:array] = 'true' if column.respond_to?(:array) && column.array
  spec[:default] = "\"#{column.default_function}\"" if column.default_function
  spec
end
reconnect!()

Close then reopen the connection.

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 574
def reconnect!
  super
  @connection.reset
  configure_connection
end
reset!()

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 580
def reset!
  clear_cache!
  super
end
schema_creation()

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 36
def schema_creation
  SchemaCreation.new self
end
session_auth=(user)

Set the authorized user for this session

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 677
def session_auth=(user)
  clear_cache!
  exec_query "SET SESSION AUTHORIZATION #{user}"
end
set_standard_conforming_strings()

Enable standard-conforming strings if available.

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 607
def set_standard_conforming_strings
  old, self.client_min_messages = client_min_messages, 'panic'
  execute('SET standard_conforming_strings = on', 'SCHEMA') rescue nil
ensure
  self.client_min_messages = old
end
supports_ddl_transactions?()

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 618
def supports_ddl_transactions?
  true
end
supports_explain?()

Returns true.

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 628
def supports_explain?
  true
end
supports_extensions?()

Returns true if pg > 9.1

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 633
def supports_extensions?
  postgresql_version >= 90100
end
supports_index_sort_order?()

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 458
def supports_index_sort_order?
  true
end
supports_insert_with_returning?()

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 614
def supports_insert_with_returning?
  true
end
supports_migrations?()

Returns true, since this connection adapter supports migrations.

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 597
def supports_migrations?
  true
end
supports_partial_index?()

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 462
def supports_partial_index?
  true
end
supports_ranges?()

Range datatypes weren't introduced until PostgreSQL 9.2

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 638
def supports_ranges?
  postgresql_version >= 90200
end
supports_savepoints?()

Returns true, since this connection adapter supports savepoints.

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 623
def supports_savepoints?
  true
end
supports_statement_cache?()

Returns true, since this connection adapter supports prepared statement caching.

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 454
def supports_statement_cache?
  true
end
supports_transaction_isolation?()

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 466
def supports_transaction_isolation?
  true
end
table_alias_length()

Returns the configured supported identifier length supported by PostgreSQL

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 672
def table_alias_length
  @table_alias_length ||= query('SHOW max_identifier_length', 'SCHEMA')[0][0].to_i
end
use_insert_returning?()

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 701
def use_insert_returning?
  @use_insert_returning
end
valid_type?(type)

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 705
def valid_type?(type)
  !native_database_types[type].nil?
end
Instance Protected methods
postgresql_version()

Returns the version of the connected PostgreSQL server.

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 712
def postgresql_version
  @connection.server_version
end
translate_exception(exception, message)

Source: show | on GitHub 

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 720
def translate_exception(exception, message)
  return exception unless exception.respond_to?(:result)

  case exception.result.try(:error_field, PGresult::PG_DIAG_SQLSTATE)
  when UNIQUE_VIOLATION
    RecordNotUnique.new(message, exception)
  when FOREIGN_KEY_VIOLATION
    InvalidForeignKey.new(message, exception)
  else
    super
  end
end