класс ActiveRecord::ConnectionAdapters::PostgreSQLAdapter

Родитель:: ActiveRecord::ConnectionAdapters::AbstractAdapter
Включенные модули:: ActiveRecord::ConnectionAdapters::PostgreSQLAdapter::Quoting, ActiveRecord::ConnectionAdapters::PostgreSQLAdapter::ReferentialIntegrity, ActiveRecord::ConnectionAdapters::PostgreSQLAdapter::SchemaStatements, ActiveRecord::ConnectionAdapters::PostgreSQLAdapter::DatabaseStatements

Адаптер PostgreSQL работает с родным C-драйвером (bitbucket.org/ged/ruby-pg).

Параметры:

:host - По умолчанию используется Unix-сокет в /tmp. На машинах без Unix-сокетов используется подключение к localhost.
:port - По умолчанию 5432.
:username - По умолчанию совпадает с именем операционной системы пользователя, запускающего приложение.
:password - Пароль, используемый, если сервер требует аутентификацию по паролю.
:database - По умолчанию совпадает с именем пользователя.
:schema_search_path - Необязательный путь поиска схем для подключения, заданный как строка с перечислением имен схем через запятую. Совместимо со старым параметром :schema_order.
:encoding - Необязанное кодирование клиента, используемое в вызове SET client_encoding TO <encoding> подключения.
:min_messages - Необязательное минимальное количество сообщений клиента, используемое в вызове SET client_min_messages TO <min_messages> подключения.
:variables - Необязательный хеш дополнительных параметров, которые будут использованы в вызовах SET SESSION key = val подключения.
:insert_returning - Необязательный boolean для управления использованием RETURNING для INSERT запросов. По умолчанию true.

Все остальные параметры используются как параметры подключения к libpq. См. www.postgresql.org/docs/9.1/static/libpq-connect.html для списка параметров.

Кроме того, параметры подключения libpq по умолчанию могут быть заданы переменными среды. См. www.postgresql.org/docs/9.1/static/libpq-envars.html .

Константы

ADAPTER_NAME
FOREIGN_KEY_VIOLATION: См. www.postgresql.org/docs/9.1/static/errcodes-appendix.html
NATIVE_DATABASE_TYPES
UNIQUE_VIOLATION

Публичные методы класса

new(connection, logger, connection_parameters, config) Показать исходный код

Инициализирует и подключается к адаптеру PostgreSQL.

Вызывает метод родительского класса ActiveRecord::ConnectionAdapters::QueryCache.new

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 552
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

  @type_map = OID::TypeMap.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]) : true
end

Открытые методы экземпляра

active?() Показать исходный код

Это соединение активно и готово к запросам?

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 588
def active?
  @connection.query 'SELECT 1'
  true
rescue PGError
  false
end

active_threadsafe?() Показать исходный код

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 595
def active_threadsafe?
  @connection.connect_poll != PG::PGRES_POLLING_FAILED
end

adapter_name() Показать исходный код

Возвращает 'PostgreSQL' как имя адаптера для идентификации.

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 454
def adapter_name
  ADAPTER_NAME
end

clear_cache!() Показать исходный код

Очищает кэш подготовленных запросов.

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 583
def clear_cache!
  @statements.clear
end

disable_extension(name) Показать исходный код

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

disconnect!() Показать исходный код

Отключается от базы данных, если уже подключено. В противном случае этот метод ничего не делает.

Вызывает метод суперкласса ActiveRecord::ConnectionAdapters::AbstractAdapter#disconnect!

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 613
def disconnect!
  super
  @connection.close rescue nil
end

enable_extension(name) Показать исходный код

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

extension_enabled?(name) Показать исходный код

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 674
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() Показать исходный код

Вызывает метод суперкласса ActiveRecord::ConnectionAdapters::AbstractAdapter#extensions

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 682
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() Показать исходный код

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

migration_keys() Показать исходный код

Добавляет `:array` как допустимый ключ миграции

Вызывает метод суперкласса ActiveRecord::ConnectionAdapters::ColumnDumper#migration_keys

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 468
def migration_keys
  super + [:array]
end

prepare_column_options(column, types) Показать исходный код

Добавляет опцию `:array` к набору по умолчанию, предоставленному AbstractAdapter

Вызывает метод суперкласса ActiveRecord::ConnectionAdapters::ColumnDumper#prepare_column_options

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 460
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!() Показать исходный код

Закрывает, а затем снова открывает соединение.

Вызывает метод суперкласса ActiveRecord::ConnectionAdapters::AbstractAdapter#reconnect!

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

reset!() Показать исходный код

Вызывает метод суперкласса ActiveRecord::ConnectionAdapters::AbstractAdapter#reset!

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 606
def reset!
  clear_cache!
  super
end

schema_creation() Показать исходный код

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

session_auth=(user) Показать исходный код

Устанавливает авторизованного пользователя для этого сеанса

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

set_standard_conforming_strings() Показать исходный код

Включает стандартно-совместимые строки, если доступно.

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 633
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?() Показать исходный код

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 644
def supports_ddl_transactions?
  true
end

supports_explain?() Показать исходный код

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 648
def supports_explain?
  true
end

supports_extensions?() Показать исходный код

Возвращает true, если pg > 9.1

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

supports_index_sort_order?() Показать исходный код

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 478
def supports_index_sort_order?
  true
end

supports_insert_with_returning?() Показать исходный код

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 640
def supports_insert_with_returning?
  true
end

supports_migrations?() Показать исходный код

Возвращает true, так как этот адаптер соединения поддерживает миграции.

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 623
def supports_migrations?
  true
end

supports_partial_index?() Показать исходный код

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 482
def supports_partial_index?
  true
end

supports_ranges?() Показать исходный код

Range типы данных были введены только в PostgreSQL 9.2

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

supports_statement_cache?() Показать исходный код

Возвращает true, так как этот адаптер соединения поддерживает кэширование подготовленных запросов.

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 474
def supports_statement_cache?
  true
end

supports_transaction_isolation?() Показать исходный код

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 486
def supports_transaction_isolation?
  true
end

table_alias_length() Показать исходный код

Возвращает длину поддерживаемого идентификатора, настроенного для PostgreSQL.

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

use_insert_returning?() Показать исходный код

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 721
def use_insert_returning?
  @use_insert_returning
end

valid_type?(type) Показать исходный код

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

Защищенные методы экземпляра

postgresql_version() Показать исходный код

Возвращает версию подключенного сервера PostgreSQL.

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 736
def postgresql_version
  @connection.server_version
end

translate_exception(exception, message) Показать исходный код

Вызывает метод суперкласса ActiveRecord::ConnectionAdapters::AbstractAdapter#translate_exception

# File activerecord/lib/active_record/connection_adapters/postgresql_adapter.rb, line 744
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