postgresql_adapter.rb 29.2 KB
Newer Older
D
Initial  
David Heinemeier Hansson 已提交
1
require 'active_record/connection_adapters/abstract_adapter'
2
require 'active_record/connection_adapters/statement_pool'
3
require 'active_record/connection_adapters/postgresql/oid'
4
require 'active_record/connection_adapters/postgresql/cast'
5
require 'active_record/connection_adapters/postgresql/array_parser'
6 7 8 9
require 'active_record/connection_adapters/postgresql/quoting'
require 'active_record/connection_adapters/postgresql/schema_statements'
require 'active_record/connection_adapters/postgresql/database_statements'
require 'active_record/connection_adapters/postgresql/referential_integrity'
10
require 'arel/visitors/bind_visitor'
11 12 13

# Make sure we're using pg high enough for PGResult#values
gem 'pg', '~> 0.11'
14
require 'pg'
D
Initial  
David Heinemeier Hansson 已提交
15

D
Dan McClain 已提交
16 17
require 'ipaddr'

D
Initial  
David Heinemeier Hansson 已提交
18
module ActiveRecord
19
  module ConnectionHandling
20 21 22 23 24 25
    VALID_CONN_PARAMS = [:host, :hostaddr, :port, :dbname, :user, :password, :connect_timeout,
                         :client_encoding, :options, :application_name, :fallback_application_name,
                         :keepalives, :keepalives_idle, :keepalives_interval, :keepalives_count,
                         :tty, :sslmode, :requiressl, :sslcert, :sslkey, :sslrootcert, :sslcrl,
                         :requirepeer, :krbsrvname, :gsslib, :service]

D
Initial  
David Heinemeier Hansson 已提交
26
    # Establishes a connection to the database that's used by all Active Record objects
J
Jon Leighton 已提交
27
    def postgresql_connection(config) # :nodoc:
28
      conn_params = config.symbolize_keys
D
Initial  
David Heinemeier Hansson 已提交
29

30
      conn_params.delete_if { |_, v| v.nil? }
31 32 33 34

      # Map ActiveRecords param names to PGs.
      conn_params[:user] = conn_params.delete(:username) if conn_params[:username]
      conn_params[:dbname] = conn_params.delete(:database) if conn_params[:database]
D
Initial  
David Heinemeier Hansson 已提交
35

36 37 38
      # Forward only valid config params to PGconn.connect.
      conn_params.keep_if { |k, _| VALID_CONN_PARAMS.include?(k) }

39
      # The postgres drivers don't allow the creation of an unconnected PGconn object,
40
      # so just pass a nil connection object for the time being.
41
      ConnectionAdapters::PostgreSQLAdapter.new(nil, logger, conn_params, config)
42 43
    end
  end
44

45 46 47
  module ConnectionAdapters
    # PostgreSQL-specific extensions to column definitions in a table.
    class PostgreSQLColumn < Column #:nodoc:
48
      attr_accessor :array
49
      # Instantiates a new PostgreSQL column definition in a table.
50 51
      def initialize(name, default, oid_type, sql_type = nil, null = true)
        @oid_type = oid_type
52 53 54 55 56 57 58
        if sql_type =~ /\[\]$/
          @array = true
          super(name, self.class.extract_value_from_default(default), sql_type[0..sql_type.length - 3], null)
        else
          @array = false
          super(name, self.class.extract_value_from_default(default), sql_type, null)
        end
59
      end
60

61 62
      # :stopdoc:
      class << self
63
        include ConnectionAdapters::PostgreSQLColumn::Cast
64
        include ConnectionAdapters::PostgreSQLColumn::ArrayParser
65
        attr_accessor :money_precision
66 67 68
      end
      # :startdoc:

69 70 71 72 73 74 75 76 77 78 79
      # Extracts the value from a PostgreSQL column default definition.
      def self.extract_value_from_default(default)
        # This is a performance optimization for Ruby 1.9.2 in development.
        # If the value is nil, we return nil straight away without checking
        # the regular expressions. If we check each regular expression,
        # Regexp#=== will call NilClass#to_str, which will trigger
        # method_missing (defined by whiny nil in ActiveSupport) which
        # makes this method very very slow.
        return default unless default

        case default
B
bUg 已提交
80 81
          when /\A'(.*)'::(num|date|tstz|ts|int4|int8)range\z/m
            $1
82 83 84
          # Numeric types
          when /\A\(?(-?\d+(\.\d*)?\)?)\z/
            $1
85
          # Character types
86
          when /\A\(?'(.*)'::.*\b(?:character varying|bpchar|text)\z/m
87
            $1
88
          # Binary data types
89 90
          when /\A'(.*)'::bytea\z/m
            $1
91
          # Date/time types
92 93 94 95 96 97 98 99 100
          when /\A'(.+)'::(?:time(?:stamp)? with(?:out)? time zone|date)\z/
            $1
          when /\A'(.*)'::interval\z/
            $1
          # Boolean type
          when 'true'
            true
          when 'false'
            false
101
          # Geometric types
102 103
          when /\A'(.*)'::(?:point|line|lseg|box|"?path"?|polygon|circle)\z/
            $1
104
          # Network address types
105 106 107 108 109
          when /\A'(.*)'::(?:cidr|inet|macaddr)\z/
            $1
          # Bit string types
          when /\AB'(.*)'::"?bit(?: varying)?"?\z/
            $1
110
          # XML type
111 112
          when /\A'(.*)'::xml\z/m
            $1
113
          # Arrays
114 115
          when /\A'(.*)'::"?\D+"?\[\]\z/
            $1
116 117 118
          # Hstore
          when /\A'(.*)'::hstore\z/
            $1
119 120 121
          # JSON
          when /\A'(.*)'::json\z/
            $1
122
          # Object identifier types
123 124
          when /\A-?\d+\z/
            $1
125
          else
126 127 128
            # Anything else is blank, some user type, or some function
            # and we can't know the value of that, so return nil.
            nil
129
        end
130
      end
131

132 133 134 135 136 137 138
      def type_cast(value)
        return if value.nil?
        return super if encoded?

        @oid_type.type_cast value
      end

139
      private
140 141 142 143 144 145 146 147

        def extract_limit(sql_type)
          case sql_type
          when /^bigint/i;    8
          when /^smallint/i;  2
          when /^timestamp/i; nil
          else super
          end
148 149
        end

150 151 152 153 154
        # Extracts the scale from PostgreSQL-specific data types.
        def extract_scale(sql_type)
          # Money type has a fixed scale of 2.
          sql_type =~ /^money/ ? 2 : super
        end
155

156 157 158 159 160 161 162 163 164
        # Extracts the precision from PostgreSQL-specific data types.
        def extract_precision(sql_type)
          if sql_type == 'money'
            self.class.money_precision
          elsif sql_type =~ /timestamp/i
            $1.to_i if sql_type =~ /\((\d+)\)/
          else
            super
          end
165 166
        end

167 168 169 170 171 172 173 174 175 176 177
        # Maps PostgreSQL-specific data types to logical Rails types.
        def simplified_type(field_type)
          case field_type
          # Numeric and monetary types
          when /^(?:real|double precision)$/
            :float
          # Monetary types
          when 'money'
            :decimal
          when 'hstore'
            :hstore
178 179
          when 'ltree'
            :ltree
180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195
          # Network address types
          when 'inet'
            :inet
          when 'cidr'
            :cidr
          when 'macaddr'
            :macaddr
          # Character types
          when /^(?:character varying|bpchar)(?:\(\d+\))?$/
            :string
          # Binary data types
          when 'bytea'
            :binary
          # Date/time types
          when /^timestamp with(?:out)? time zone$/
            :datetime
196
          when /^interval(?:|\(\d+\))$/
197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218
            :string
          # Geometric types
          when /^(?:point|line|lseg|box|"?path"?|polygon|circle)$/
            :string
          # Bit strings
          when /^bit(?: varying)?(?:\(\d+\))?$/
            :string
          # XML type
          when 'xml'
            :xml
          # tsvector type
          when 'tsvector'
            :tsvector
          # Arrays
          when /^\D+\[\]$/
            :string
          # Object identifier types
          when 'oid'
            :integer
          # UUID type
          when 'uuid'
            :uuid
219 220 221
          # JSON type
          when 'json'
            :json
222 223 224
          # Small and big integer types
          when /^(?:small|big)int$/
            :integer
B
bUg 已提交
225 226
          when /(num|date|tstz|ts|int4|int8)range$/
            field_type.to_sym
227 228 229 230
          # Pass through all types that are not specific to PostgreSQL.
          else
            super
          end
231
        end
D
Initial  
David Heinemeier Hansson 已提交
232 233
    end

234
    # The PostgreSQL adapter works with the native C (https://bitbucket.org/ged/ruby-pg) driver.
235 236 237
    #
    # Options:
    #
238 239
    # * <tt>:host</tt> - Defaults to a Unix-domain socket in /tmp. On machines without Unix-domain sockets,
    #   the default is to connect to localhost.
P
Pratik Naik 已提交
240
    # * <tt>:port</tt> - Defaults to 5432.
241 242 243
    # * <tt>:username</tt> - Defaults to be the same as the operating system name of the user running the application.
    # * <tt>:password</tt> - Password to be used if the server demands password authentication.
    # * <tt>:database</tt> - Defaults to be the same as the user name.
244
    # * <tt>:schema_search_path</tt> - An optional schema search path for the connection given
245
    #   as a string of comma-separated schema names. This is backward-compatible with the <tt>:schema_order</tt> option.
246
    # * <tt>:encoding</tt> - An optional client encoding that is used in a <tt>SET client_encoding TO
247
    #   <encoding></tt> call on the connection.
248
    # * <tt>:min_messages</tt> - An optional client min messages that is used in a
249
    #   <tt>SET client_min_messages TO <min_messages></tt> call on the connection.
250 251
    # * <tt>:variables</tt> - An optional hash of additional parameters that
    #   will be used in <tt>SET SESSION key = val</tt> calls on the connection.
A
AvnerCohen 已提交
252
    # * <tt>:insert_returning</tt> - An optional boolean to control the use or <tt>RETURNING</tt> for <tt>INSERT</tt> statements
253
    #   defaults to true.
254 255 256 257 258 259 260
    #
    # Any further options are used as connection parameters to libpq. See
    # http://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 http://www.postgresql.org/docs/9.1/static/libpq-envars.html .
261
    class PostgreSQLAdapter < AbstractAdapter
262 263 264 265
      class ColumnDefinition < ActiveRecord::ConnectionAdapters::ColumnDefinition
        attr_accessor :array
      end

266
      module ColumnMethods
267 268 269 270
        def xml(*args)
          options = args.extract_options!
          column(args[0], 'xml', options)
        end
271 272 273 274 275

        def tsvector(*args)
          options = args.extract_options!
          column(args[0], 'tsvector', options)
        end
276

B
bUg 已提交
277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300
        def int4range(name, options = {})
          column(name, 'int4range', options)
        end

        def int8range(name, options = {})
          column(name, 'int8range', options)
        end

        def tsrange(name, options = {})
          column(name, 'tsrange', options)
        end

        def tstzrange(name, options = {})
          column(name, 'tstzrange', options)
        end

        def numrange(name, options = {})
          column(name, 'numrange', options)
        end

        def daterange(name, options = {})
          column(name, 'daterange', options)
        end

301 302 303
        def hstore(name, options = {})
          column(name, 'hstore', options)
        end
304

305 306 307 308
        def ltree(name, options = {})
          column(name, 'ltree', options)
        end

309 310 311 312 313 314 315 316 317 318 319
        def inet(name, options = {})
          column(name, 'inet', options)
        end

        def cidr(name, options = {})
          column(name, 'cidr', options)
        end

        def macaddr(name, options = {})
          column(name, 'macaddr', options)
        end
320 321 322 323

        def uuid(name, options = {})
          column(name, 'uuid', options)
        end
324 325 326 327

        def json(name, options = {})
          column(name, 'json', options)
        end
328 329 330 331
      end

      class TableDefinition < ActiveRecord::ConnectionAdapters::TableDefinition
        include ColumnMethods
332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348

        def column(name, type = nil, options = {})
          super
          column = self[name]
          column.array = options[:array]

          self
        end

        private

        def new_column_definition(base, name, type)
          definition = ColumnDefinition.new base, name, type
          @columns << definition
          @columns_hash[name] = definition
          definition
        end
349 350
      end

351 352 353 354
      class Table < ActiveRecord::ConnectionAdapters::Table
        include ColumnMethods
      end

355
      ADAPTER_NAME = 'PostgreSQL'
356 357

      NATIVE_DATABASE_TYPES = {
358 359 360 361 362 363 364 365 366 367
        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" },
B
bUg 已提交
368 369 370 371 372 373
        daterange:   { name: "daterange" },
        numrange:    { name: "numrange" },
        tsrange:     { name: "tsrange" },
        tstzrange:   { name: "tstzrange" },
        int4range:   { name: "int4range" },
        int8range:   { name: "int8range" },
374 375 376 377 378 379 380 381
        binary:      { name: "bytea" },
        boolean:     { name: "boolean" },
        xml:         { name: "xml" },
        tsvector:    { name: "tsvector" },
        hstore:      { name: "hstore" },
        inet:        { name: "inet" },
        cidr:        { name: "cidr" },
        macaddr:     { name: "macaddr" },
382
        uuid:        { name: "uuid" },
383
        json:        { name: "json" },
384
        ltree:       { name: "ltree" }
385 386
      }

387 388 389 390 391
      include Quoting
      include ReferentialIntegrity
      include SchemaStatements
      include DatabaseStatements

392
      # Returns 'PostgreSQL' as adapter name for identification purposes.
393
      def adapter_name
394
        ADAPTER_NAME
395 396
      end

397 398 399 400 401 402 403 404 405 406 407 408 409
      # Adds `:array` option to the default set provided by the
      # AbstractAdapter
      def prepare_column_options(column, types)
        spec = super
        spec[:array] = 'true' if column.respond_to?(:array) && column.array
        spec
      end

      # Adds `:array` as a valid migration key
      def migration_keys
        super + [:array]
      end

410 411
      # Returns +true+, since this connection adapter supports prepared statement
      # caching.
412 413 414 415
      def supports_statement_cache?
        true
      end

416 417 418 419
      def supports_index_sort_order?
        true
      end

420 421 422 423
      def supports_partial_index?
        true
      end

424 425 426 427
      def supports_transaction_isolation?
        true
      end

428 429 430 431
      class StatementPool < ConnectionAdapters::StatementPool
        def initialize(connection, max)
          super
          @counter = 0
432
          @cache   = Hash.new { |h,pid| h[pid] = {} }
433 434
        end

435 436 437 438
        def each(&block); cache.each(&block); end
        def key?(key);    cache.key?(key); end
        def [](key);      cache[key]; end
        def length;       cache.length; end
439 440 441 442 443 444

        def next_key
          "a#{@counter + 1}"
        end

        def []=(sql, key)
445 446
          while @max <= cache.size
            dealloc(cache.shift.last)
447 448
          end
          @counter += 1
449
          cache[sql] = key
450 451 452
        end

        def clear
453
          cache.each_value do |stmt_key|
454 455
            dealloc stmt_key
          end
456
          cache.clear
457 458
        end

459 460 461 462 463
        def delete(sql_key)
          dealloc cache[sql_key]
          cache.delete sql_key
        end

464
        private
465

466 467 468
          def cache
            @cache[Process.pid]
          end
469

470 471 472 473 474 475 476 477 478
          def dealloc(key)
            @connection.query "DEALLOCATE #{key}" if connection_active?
          end

          def connection_active?
            @connection.status == PGconn::CONNECTION_OK
          rescue PGError
            false
          end
479 480
      end

481 482 483 484
      class BindSubstitution < Arel::Visitors::PostgreSQL # :nodoc:
        include Arel::Visitors::BindVisitor
      end

485 486
      # Initializes and connects a PostgreSQL adapter.
      def initialize(connection, logger, connection_parameters, config)
487
        super(connection, logger)
488

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

495
        @connection_parameters, @config = connection_parameters, config
496

497 498
        # @local_tz is initialized as nil to avoid warnings when connect tries to use it
        @local_tz = nil
499 500
        @table_alias_length = nil

501
        connect
502
        @statements = StatementPool.new @connection,
503
                                        self.class.type_cast_config_to_integer(config.fetch(:statement_limit) { 1000 })
504 505 506 507 508

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

509
        initialize_type_map
510
        @local_tz = execute('SHOW TIME ZONE', 'SCHEMA').first["TimeZone"]
511
        @use_insert_returning = @config.key?(:insert_returning) ? self.class.type_cast_config_to_boolean(@config[:insert_returning]) : true
512 513
      end

X
Xavier Noria 已提交
514
      # Clears the prepared statements cache.
515 516 517 518
      def clear_cache!
        @statements.clear
      end

519 520
      # Is this connection alive and ready for queries?
      def active?
521 522
        @connection.query 'SELECT 1'
        true
523
      rescue PGError
524
        false
525 526 527 528
      end

      # Close then reopen the connection.
      def reconnect!
529
        super
530 531
        @connection.reset
        configure_connection
532
      end
533

534 535 536 537 538
      def reset!
        clear_cache!
        super
      end

539 540
      # Disconnects from the database if already connected. Otherwise, this
      # method does nothing.
541
      def disconnect!
542
        super
543 544
        @connection.close rescue nil
      end
545

546
      def native_database_types #:nodoc:
547
        NATIVE_DATABASE_TYPES
548
      end
549

550
      # Returns true, since this connection adapter supports migrations.
551 552
      def supports_migrations?
        true
553 554
      end

555
      # Does PostgreSQL support finding primary key on non-Active Record tables?
556 557 558 559
      def supports_primary_key? #:nodoc:
        true
      end

560 561 562
      # Enable standard-conforming strings if available.
      def set_standard_conforming_strings
        old, self.client_min_messages = client_min_messages, 'panic'
563
        execute('SET standard_conforming_strings = on', 'SCHEMA') rescue nil
564 565
      ensure
        self.client_min_messages = old
566 567
      end

568
      def supports_insert_with_returning?
569
        true
570 571
      end

572 573 574
      def supports_ddl_transactions?
        true
      end
575

576
      # Returns true, since this connection adapter supports savepoints.
577 578 579
      def supports_savepoints?
        true
      end
580

581 582 583 584 585
      # Returns true.
      def supports_explain?
        true
      end

A
Aaron Patterson 已提交
586
      # Returns true if pg > 9.2
587 588 589 590
      def supports_extensions?
        postgresql_version >= 90200
      end

A
Andrew White 已提交
591 592 593 594 595
      # Range datatypes weren't introduced until PostgreSQL 9.2
      def supports_ranges?
        postgresql_version >= 90200
      end

596
      def enable_extension(name)
597 598 599
        exec_query("CREATE EXTENSION IF NOT EXISTS #{name}").tap {
          reload_type_map
        }
600 601 602
      end

      def disable_extension(name)
603 604 605
        exec_query("DROP EXTENSION IF EXISTS #{name} CASCADE").tap {
          reload_type_map
        }
606 607 608
      end

      def extension_enabled?(name)
R
Rafael Mendonça França 已提交
609
        if supports_extensions?
610 611 612 613
          res = exec_query "SELECT EXISTS(SELECT * FROM pg_available_extensions WHERE name = '#{name}' AND installed_version IS NOT NULL)",
            'SCHEMA'
          res.column_types['exists'].type_cast res.rows.first.first
        end
614 615
      end

616 617 618 619 620
      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
621
          super
622 623 624
        end
      end

625
      # Returns the configured supported identifier length supported by PostgreSQL
626
      def table_alias_length
K
kennyj 已提交
627
        @table_alias_length ||= query('SHOW max_identifier_length', 'SCHEMA')[0][0].to_i
628
      end
629

630 631 632 633 634 635 636
      def add_column_options!(sql, options)
        if options[:array] || options[:column].try(:array)
          sql << '[]'
        end
        super
      end

637 638
      # Set the authorized user for this session
      def session_auth=(user)
639
        clear_cache!
A
Aaron Patterson 已提交
640
        exec_query "SET SESSION AUTHORIZATION #{user}"
641 642
      end

643
      module Utils
644 645
        extend self

646 647 648 649 650 651 652 653 654 655
        # Returns an array of <tt>[schema_name, table_name]</tt> extracted from +name+.
        # +schema_name+ is nil if not specified in +name+.
        # +schema_name+ and +table_name+ exclude surrounding quotes (regardless of whether provided in +name+)
        # +name+ supports the range of schema/table references understood by PostgreSQL, for example:
        #
        # * <tt>table_name</tt>
        # * <tt>"table.name"</tt>
        # * <tt>schema_name.table_name</tt>
        # * <tt>schema_name."table.name"</tt>
        # * <tt>"schema.name"."table name"</tt>
656
        def extract_schema_and_table(name)
657 658 659 660 661
          table, schema = name.scan(/[^".\s]+|"[^"]*"/)[0..1].collect{|m| m.gsub(/(^"|"$)/,'') }.reverse
          [schema, table]
        end
      end

662 663
      def use_insert_returning?
        @use_insert_returning
664 665
      end

666
      protected
667

668
        # Returns the version of the connected PostgreSQL server.
669
        def postgresql_version
670
          @connection.server_version
671 672
        end

673 674 675 676
        # See http://www.postgresql.org/docs/9.1/static/errcodes-appendix.html
        FOREIGN_KEY_VIOLATION = "23503"
        UNIQUE_VIOLATION      = "23505"

677
        def translate_exception(exception, message)
678 679
          return exception unless exception.respond_to?(:result)

680
          case exception.result.try(:error_field, PGresult::PG_DIAG_SQLSTATE)
681
          when UNIQUE_VIOLATION
682
            RecordNotUnique.new(message, exception)
683
          when FOREIGN_KEY_VIOLATION
684
            InvalidForeignKey.new(message, exception)
685 686 687 688 689
          else
            super
          end
        end

D
Initial  
David Heinemeier Hansson 已提交
690
      private
691

692 693 694 695 696
        def reload_type_map
          OID::TYPE_MAP.clear
          initialize_type_map
        end

697
        def initialize_type_map
698
          result = execute('SELECT oid, typname, typelem, typdelim, typinput FROM pg_type', 'SCHEMA')
699
          leaves, nodes = result.partition { |row| row['typelem'] == '0' }
700

701 702 703 704 705
          # populate the leaf nodes
          leaves.find_all { |row| OID.registered_type? row['typname'] }.each do |row|
            OID::TYPE_MAP[row['oid'].to_i] = OID::NAMES[row['typname']]
          end

706 707
          arrays, nodes = nodes.partition { |row| row['typinput'] == 'array_in' }

708 709 710 711 712
          # populate composite types
          nodes.find_all { |row| OID::TYPE_MAP.key? row['typelem'].to_i }.each do |row|
            vector = OID::Vector.new row['typdelim'], OID::TYPE_MAP[row['typelem'].to_i]
            OID::TYPE_MAP[row['oid'].to_i] = vector
          end
713 714 715 716 717 718

          # populate array types
          arrays.find_all { |row| OID::TYPE_MAP.key? row['typelem'].to_i }.each do |row|
            array = OID::Array.new  OID::TYPE_MAP[row['typelem'].to_i]
            OID::TYPE_MAP[row['oid'].to_i] = array
          end
719 720
        end

721 722
        FEATURE_NOT_SUPPORTED = "0A000" # :nodoc:

723 724
        def exec_no_cache(sql, binds)
          @connection.async_exec(sql)
725
        end
726

727
        def exec_cache(sql, binds)
728 729 730 731 732 733 734 735 736 737 738 739 740 741
          stmt_key = prepare_statement sql

          # Clear the queue
          @connection.get_last_result
          @connection.send_query_prepared(stmt_key, binds.map { |col, val|
            type_cast(val, col)
          })
          @connection.block
          @connection.get_last_result
        rescue PGError => e
          # Get the PG code for the failure.  Annoyingly, the code for
          # prepared statements whose return value may have changed is
          # FEATURE_NOT_SUPPORTED.  Check here for more details:
          # http://git.postgresql.org/gitweb/?p=postgresql.git;a=blob;f=src/backend/utils/cache/plancache.c#l573
742
          begin
743 744 745 746 747 748 749 750 751
            code = e.result.result_error_field(PGresult::PG_DIAG_SQLSTATE)
          rescue
            raise e
          end
          if FEATURE_NOT_SUPPORTED == code
            @statements.delete sql_key(sql)
            retry
          else
            raise e
752 753 754 755 756 757 758 759 760 761 762 763 764
          end
        end

        # Returns the statement identifier for the client side cache
        # of statements
        def sql_key(sql)
          "#{schema_search_path}-#{sql}"
        end

        # Prepare the statement if it hasn't been prepared, return
        # the statement key.
        def prepare_statement(sql)
          sql_key = sql_key(sql)
765
          unless @statements.key? sql_key
766
            nextkey = @statements.next_key
767
            @connection.prepare nextkey, sql
768
            @statements[sql_key] = nextkey
769
          end
770
          @statements[sql_key]
771
        end
772

P
Pratik Naik 已提交
773
        # The internal PostgreSQL identifier of the money data type.
774
        MONEY_COLUMN_TYPE_OID = 790 #:nodoc:
775 776
        # The internal PostgreSQL identifier of the BYTEA data type.
        BYTEA_COLUMN_TYPE_OID = 17 #:nodoc:
777 778 779 780

        # Connects to a PostgreSQL server and sets up the adapter depending on the
        # connected server's characteristics.
        def connect
781
          @connection = PGconn.connect(@connection_parameters)
782 783 784 785

          # Money type has a fixed precision of 10 in PostgreSQL 8.2 and below, and as of
          # PostgreSQL 8.3 it has a fixed precision of 19. PostgreSQLColumn.extract_precision
          # should know about this but can't detect it there, so deal with it here.
786 787
          PostgreSQLColumn.money_precision = (postgresql_version >= 80300) ? 19 : 10

788 789 790
          configure_connection
        end

791
        # Configures the encoding, verbosity, schema search path, and time zone of the connection.
792
        # This is called by #connect and should not be called manually.
793 794
        def configure_connection
          if @config[:encoding]
795
            @connection.set_client_encoding(@config[:encoding])
796
          end
797
          self.client_min_messages = @config[:min_messages] || 'warning'
798
          self.schema_search_path = @config[:schema_search_path] || @config[:schema_order]
799 800 801 802

          # Use standard-conforming strings if available so we don't have to do the E'...' dance.
          set_standard_conforming_strings

803
          # If using Active Record's time zone support configure the connection to return
804
          # TIMESTAMP WITH ZONE types in UTC.
805
          # (SET TIME ZONE does not use an equals sign like other SET variables)
806
          if ActiveRecord::Base.default_timezone == :utc
807
            execute("SET time zone 'UTC'", 'SCHEMA')
808
          elsif @local_tz
809
            execute("SET time zone '#{@local_tz}'", 'SCHEMA')
810
          end
811 812 813 814 815 816 817 818 819 820 821 822

          # SET statements from :variables config hash
          # http://www.postgresql.org/docs/8.3/static/sql-set.html
          variables = @config[:variables] || {}
          variables.map do |k, v|
            if v == ':default' || v == :default
              # Sets the value to the global or compile default
              execute("SET SESSION #{k.to_s} TO DEFAULT", 'SCHEMA')
            elsif !v.nil?
              execute("SET SESSION #{k.to_s} TO #{quote(v)}", 'SCHEMA')
            end
          end
823 824
        end

825
        # Returns the current ID of a table's sequence.
826
        def last_insert_id(sequence_name) #:nodoc:
827 828 829
          Integer(last_insert_id_value(sequence_name))
        end

D
Doug Cole 已提交
830 831 832 833 834
        def last_insert_id_value(sequence_name)
          last_insert_id_result(sequence_name).rows.first.first
        end

        def last_insert_id_result(sequence_name) #:nodoc:
835
          exec_query("SELECT currval('#{sequence_name}')", 'SQL')
D
Initial  
David Heinemeier Hansson 已提交
836 837
        end

838
        # Executes a SELECT query and returns the results, performing any data type
839
        # conversions that are required to be performed here instead of in PostgreSQLColumn.
840
        def select(sql, name = nil, binds = [])
841
          exec_query(sql, name, binds)
842 843 844
        end

        def select_raw(sql, name = nil)
845
          res = execute(sql, name)
846
          results = result_as_array(res)
847
          fields = res.fields
848
          res.clear
849
          return fields, results
M
Marcel Molina 已提交
850 851
        end

852
        # Returns the list of a table's column names, data types, and default values.
853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869
        #
        # The underlying query is roughly:
        #  SELECT column.name, column.type, default.value
        #    FROM column LEFT JOIN default
        #      ON column.table_id = default.table_id
        #     AND column.num = default.column_num
        #   WHERE column.table_id = get_table_id('table_name')
        #     AND column.num > 0
        #     AND NOT column.is_dropped
        #   ORDER BY column.num
        #
        # If the table name is not prefixed with a schema, the database will
        # take the first match from the schema search path.
        #
        # Query implementation notes:
        #  - format_type includes the column size constraint, e.g. varchar(50)
        #  - ::regclass is a function that gives the id for a table name
870
        def column_definitions(table_name) #:nodoc:
871
          exec_query(<<-end_sql, 'SCHEMA').rows
872 873
              SELECT a.attname, format_type(a.atttypid, a.atttypmod),
                     pg_get_expr(d.adbin, d.adrelid), a.attnotnull, a.atttypid, a.atttypmod
874 875 876 877 878
                FROM pg_attribute a LEFT JOIN pg_attrdef d
                  ON a.attrelid = d.adrelid AND a.attnum = d.adnum
               WHERE a.attrelid = '#{quote_table_name(table_name)}'::regclass
                 AND a.attnum > 0 AND NOT a.attisdropped
               ORDER BY a.attnum
879
          end_sql
D
Initial  
David Heinemeier Hansson 已提交
880
        end
881 882

        def extract_pg_identifier_from_name(name)
883
          match_data = name.start_with?('"') ? name.match(/\"([^\"]+)\"/) : name.match(/([^\.]+)/)
884 885

          if match_data
886 887
            rest = name[match_data[0].length, name.length]
            rest = rest[1, rest.length] if rest.start_with? "."
J
José Valim 已提交
888
            [match_data[1], (rest.length > 0 ? rest : nil)]
889 890
          end
        end
891

892 893 894 895 896
        def extract_table_ref_from_insert_sql(sql)
          sql[/into\s+([^\(]*).*values\s*\(/i]
          $1.strip if $1
        end

897
        def create_table_definition
898 899
          TableDefinition.new(self)
        end
900 901 902 903

        def update_table_definition(table_name, base)
          Table.new(table_name, base)
        end
D
Initial  
David Heinemeier Hansson 已提交
904 905 906
    end
  end
end