ActiveRecord::ConnectionAdapters::PostgreSQL::SchemaStatements

add_exclusion_constraint(table_name, expression, **options) 链接

为表添加新的排除约束。expression 是一个包含排除元素和运算符列表的 字符串 表示。

add_exclusion_constraint :products, "price WITH =, availability_range WITH &&", using: :gist, name: "price_check"

生成

ALTER TABLE "products" ADD CONSTRAINT price_check EXCLUDE USING gist (price WITH =, availability_range WITH &&)

options 哈希可以包含以下键

:name: 约束名称。默认为 excl_rails_<identifier>。
:deferrable: 指定排除约束是否可延迟。有效值为 false 或 :immediate 或 :deferred 来指定默认行为。默认为 false。
:using: 指定创建此排除约束时使用的索引方法（例如 :btree, :gist 等）。
:where: 指定表中子集的排除约束（PostgreSQL 内部为此创建部分索引）。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 782
def add_exclusion_constraint(table_name, expression, **options)
  options = exclusion_constraint_options(table_name, expression, options)
  at = create_alter_table(table_name)
  at.add_exclusion_constraint(expression, options)

  execute schema_creation.accept(at)
end

add_foreign_key(from_table, to_table, **options) 链接

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 598
def add_foreign_key(from_table, to_table, **options)
  assert_valid_deferrable(options[:deferrable])

  super
end

add_unique_constraint(table_name, column_name = nil, **options) 链接

为表添加新的唯一约束。

add_unique_constraint :sections, [:position], deferrable: :deferred, name: "unique_position", nulls_not_distinct: true

生成

ALTER TABLE "sections" ADD CONSTRAINT unique_position UNIQUE (position) DEFERRABLE INITIALLY DEFERRED

如果您想将现有的唯一索引更改为可延迟的，可以使用 :using_index 来创建可延迟的唯一约束。

add_unique_constraint :sections, deferrable: :deferred, name: "unique_position", using_index: "index_sections_on_position"

options 哈希可以包含以下键

:name: 约束名称。默认为 uniq_rails_<identifier>。
:deferrable: 指定唯一约束是否可延迟。有效值为 false 或 :immediate 或 :deferred 来指定默认行为。默认为 false。
:using_index: 指定现有唯一索引的名称。默认为 nil。
:nulls_not_distinct: 创建一种将 NULL 值视为相等的唯一约束。注意：仅支持 PostgreSQL 版本 15.0.0 及更高版本。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 833
def add_unique_constraint(table_name, column_name = nil, **options)
  options = unique_constraint_options(table_name, column_name, options)
  at = create_alter_table(table_name)
  at.add_unique_constraint(column_name, options)

  execute schema_creation.accept(at)
end

client_min_messages() 链接

返回当前客户端消息级别。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 314
def client_min_messages
  query_value("SHOW client_min_messages", "SCHEMA")
end

client_min_messages=(level) 链接

设置客户端消息级别。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 319
def client_min_messages=(level)
  internal_execute("SET client_min_messages TO '#{level}'", "SCHEMA")
end

collation() 链接

返回当前数据库的排序规则。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 252
def collation
  query_value("SELECT datcollate FROM pg_database WHERE datname = current_database()", "SCHEMA")
end

create_database(name, options = {}) 链接

创建一个新的 PostgreSQL 数据库。选项包括 :owner、:template、:encoding（默认为 utf8）、:locale_provider、:locale、:collation、:ctype、:tablespace 和 :connection_limit（请注意，MySQL 使用 :charset 而 PostgreSQL 使用 :encoding）。

示例

create_database config[:database], config
create_database 'foo_development', encoding: 'unicode'

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 23
def create_database(name, options = {})
  options = { encoding: "utf8" }.merge!(options.symbolize_keys)

  option_string = options.each_with_object(+"") do |(key, value), memo|
    memo << case key
            when :owner
              " OWNER = \"#{value}\""
            when :template
              " TEMPLATE = \"#{value}\""
            when :encoding
              " ENCODING = '#{value}'"
            when :locale_provider
              " LOCALE_PROVIDER = '#{value}'"
            when :locale
              " LOCALE = '#{value}'"
            when :collation
              " LC_COLLATE = '#{value}'"
            when :ctype
              " LC_CTYPE = '#{value}'"
            when :tablespace
              " TABLESPACE = \"#{value}\""
            when :connection_limit
              " CONNECTION LIMIT = #{value}"
            else
              ""
    end
  end

  execute "CREATE DATABASE #{quote_table_name(name)}#{option_string}"
end

create_schema(schema_name, force: nil, if_not_exists: nil) 链接

为给定的模式名称创建模式。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 273
def create_schema(schema_name, force: nil, if_not_exists: nil)
  if force && if_not_exists
    raise ArgumentError, "Options `:force` and `:if_not_exists` cannot be used simultaneously."
  end

  if force
    drop_schema(schema_name, if_exists: true)
  end

  execute("CREATE SCHEMA#{' IF NOT EXISTS' if if_not_exists} #{quote_schema_name(schema_name)}")
end

ctype() 链接

返回当前数据库的 ctype。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 257
def ctype
  query_value("SELECT datctype FROM pg_database WHERE datname = current_database()", "SCHEMA")
end

current_database() 链接

返回当前数据库的名称。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 229
def current_database
  query_value("SELECT current_database()", "SCHEMA")
end

current_schema() 链接

返回当前模式的名称。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 234
def current_schema
  query_value("SELECT current_schema", "SCHEMA")
end

drop_schema(schema_name, **options) 链接

删除给定模式名称的模式。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 286
def drop_schema(schema_name, **options)
  execute "DROP SCHEMA#{' IF EXISTS' if options[:if_exists]} #{quote_schema_name(schema_name)} CASCADE"
end

encoding() 链接

返回当前数据库的编码格式。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 247
def encoding
  query_value("SELECT pg_encoding_to_char(encoding) FROM pg_database WHERE datname = current_database()", "SCHEMA")
end

exclusion_constraints(table_name) 链接

返回给定表的排除约束数组。排除约束表示为 ExclusionConstraintDefinition 对象。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 692
        def exclusion_constraints(table_name)
          scope = quoted_scope(table_name)

          exclusion_info = internal_exec_query(<<-SQL, "SCHEMA")
            SELECT conname, pg_get_constraintdef(c.oid) AS constraintdef, c.condeferrable, c.condeferred
            FROM pg_constraint c
            JOIN pg_class t ON c.conrelid = t.oid
            JOIN pg_namespace n ON n.oid = c.connamespace
            WHERE c.contype = 'x'
              AND t.relname = #{scope[:name]}
              AND n.nspname = #{scope[:schema]}
          SQL

          exclusion_info.map do |row|
            method_and_elements, predicate = row["constraintdef"].split(" WHERE ")
            method_and_elements_parts = method_and_elements.match(/EXCLUDE(?: USING (?<using>\S+))? \((?<expression>.+)\)/)
            predicate.remove!(/ DEFERRABLE(?: INITIALLY (?:IMMEDIATE|DEFERRED))?/) if predicate
            predicate = predicate.from(2).to(-3) if predicate # strip 2 opening and closing parentheses

            deferrable = extract_constraint_deferrable(row["condeferrable"], row["condeferred"])

            options = {
              name: row["conname"],
              using: method_and_elements_parts["using"].to_sym,
              where: predicate,
              deferrable: deferrable
            }

            ExclusionConstraintDefinition.new(table_name, method_and_elements_parts["expression"], options)
          end
        end

foreign_keys(table_name) 链接

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 604
        def foreign_keys(table_name)
          scope = quoted_scope(table_name)
          fk_info = internal_exec_query(<<~SQL, "SCHEMA", allow_retry: true, materialize_transactions: false)
            SELECT t2.oid::regclass::text AS to_table, c.conname AS name, c.confupdtype AS on_update, c.confdeltype AS on_delete, c.convalidated AS valid, c.condeferrable AS deferrable, c.condeferred AS deferred, c.conrelid, c.confrelid,
              (
                SELECT array_agg(a.attname ORDER BY idx)
                FROM (
                  SELECT idx, c.conkey[idx] AS conkey_elem
                  FROM generate_subscripts(c.conkey, 1) AS idx
                ) indexed_conkeys
                JOIN pg_attribute a ON a.attrelid = t1.oid
                AND a.attnum = indexed_conkeys.conkey_elem
              ) AS conkey_names,
              (
                SELECT array_agg(a.attname ORDER BY idx)
                FROM (
                  SELECT idx, c.confkey[idx] AS confkey_elem
                  FROM generate_subscripts(c.confkey, 1) AS idx
                ) indexed_confkeys
                JOIN pg_attribute a ON a.attrelid = t2.oid
                AND a.attnum = indexed_confkeys.confkey_elem
              ) AS confkey_names
            FROM pg_constraint c
            JOIN pg_class t1 ON c.conrelid = t1.oid
            JOIN pg_class t2 ON c.confrelid = t2.oid
            JOIN pg_namespace n ON c.connamespace = n.oid
            WHERE c.contype = 'f'
              AND t1.relname = #{scope[:name]}
              AND n.nspname = #{scope[:schema]}
            ORDER BY c.conname
          SQL

          fk_info.map do |row|
            to_table = Utils.unquote_identifier(row["to_table"])

            column = decode_string_array(row["conkey_names"])
            primary_key = decode_string_array(row["confkey_names"])

            options = {
              column: column.size == 1 ? column.first : column,
              name: row["name"],
              primary_key: primary_key.size == 1 ? primary_key.first : primary_key
            }

            options[:on_delete] = extract_foreign_key_action(row["on_delete"])
            options[:on_update] = extract_foreign_key_action(row["on_update"])
            options[:deferrable] = extract_constraint_deferrable(row["deferrable"], row["deferred"])

            options[:validate] = row["valid"]

            ForeignKeyDefinition.new(table_name, to_table, options)
          end
        end

foreign_table_exists?(table_name) 链接

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 662
def foreign_table_exists?(table_name)
  query_values(data_source_sql(table_name, type: "FOREIGN TABLE"), "SCHEMA").any? if table_name.present?
end

foreign_tables() 链接

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 658
def foreign_tables
  query_values(data_source_sql(type: "FOREIGN TABLE"), "SCHEMA")
end

index_name_exists?(table_name, index_name) 链接

验证具有给定名称的索引是否存在。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 73
        def index_name_exists?(table_name, index_name)
          table = quoted_scope(table_name)
          index = quoted_scope(index_name)

          query_value(<<~SQL, "SCHEMA").to_i > 0
            SELECT COUNT(*)
            FROM pg_class t
            INNER JOIN pg_index d ON t.oid = d.indrelid
            INNER JOIN pg_class i ON d.indexrelid = i.oid
            LEFT JOIN pg_namespace n ON n.oid = t.relnamespace
            WHERE i.relkind IN ('i', 'I')
              AND i.relname = #{index[:name]}
              AND t.relname = #{table[:name]}
              AND n.nspname = #{table[:schema]}
          SQL
        end

remove_exclusion_constraint(table_name, expression = nil, **options) 链接

从表中删除指定的排除约束。

remove_exclusion_constraint :products, name: "price_check"

如果存在，expression 参数将被忽略。这在迁移的 change 方法中可能有助于回滚。在这种情况下，expression 将被 add_exclusion_constraint 使用。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 805
def remove_exclusion_constraint(table_name, expression = nil, **options)
  excl_name_to_delete = exclusion_constraint_for!(table_name, expression: expression, **options).name

  remove_constraint(table_name, excl_name_to_delete)
end

remove_unique_constraint(table_name, column_name = nil, **options) 链接

从表中删除指定的唯一约束。

remove_unique_constraint :sections, name: "unique_position"

如果存在，column_name 参数将被忽略。这在迁移的 change 方法中可能有助于回滚。在这种情况下，column_name 将被 add_unique_constraint 使用。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 860
def remove_unique_constraint(table_name, column_name = nil, **options)
  unique_name_to_delete = unique_constraint_for!(table_name, column: column_name, **options).name

  remove_constraint(table_name, unique_name_to_delete)
end

rename_index(table_name, old_name, new_name) 链接

重命名表的索引。如果新索引名称的长度超过允许的限制，则引发错误。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 586
def rename_index(table_name, old_name, new_name)
  validate_index_length!(table_name, new_name)

  schema, = extract_schema_qualified_name(table_name)
  execute "ALTER INDEX #{quote_table_name(schema) + '.' if schema}#{quote_column_name(old_name)} RENAME TO #{quote_table_name(new_name)}"
end

rename_schema(schema_name, new_name) 链接

重命名给定模式名称的模式。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 291
def rename_schema(schema_name, new_name)
  execute "ALTER SCHEMA #{quote_schema_name(schema_name)} RENAME TO #{quote_schema_name(new_name)}"
end

rename_table(table_name, new_name, **options) 链接

重命名表。如果表的主键序列名称存在且与 Active Record 的默认值匹配，则也会重命名该序列。

示例

rename_table('octopuses', 'octopi')

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 454
def rename_table(table_name, new_name, **options)
  validate_table_length!(new_name) unless options[:_uses_legacy_table_name]
  clear_cache!
  schema_cache.clear_data_source_cache!(table_name.to_s)
  schema_cache.clear_data_source_cache!(new_name.to_s)
  execute "ALTER TABLE #{quote_table_name(table_name)} RENAME TO #{quote_table_name(new_name)}"
  pk, seq = pk_and_sequence_for(new_name)
  if pk
    # PostgreSQL automatically creates an index for PRIMARY KEY with name consisting of
    # truncated table name and "_pkey" suffix fitting into max_identifier_length number of characters.
    max_pkey_prefix = max_identifier_length - "_pkey".size
    idx = "#{table_name[0, max_pkey_prefix]}_pkey"
    new_idx = "#{new_name[0, max_pkey_prefix]}_pkey"
    execute "ALTER INDEX #{quote_table_name(idx)} RENAME TO #{quote_table_name(new_idx)}"

    # PostgreSQL automatically creates a sequence for PRIMARY KEY with name consisting of
    # truncated table name and "#{primary_key}_seq" suffix fitting into max_identifier_length number of characters.
    max_seq_prefix = max_identifier_length - "_#{pk}_seq".size
    if seq && seq.identifier == "#{table_name[0, max_seq_prefix]}_#{pk}_seq"
      new_seq = "#{new_name[0, max_seq_prefix]}_#{pk}_seq"
      execute "ALTER TABLE #{seq.quoted} RENAME TO #{quote_table_name(new_seq)}"
    end
  end
  rename_table_indexes(table_name, new_name, **options)
end

schema_exists?(name) 链接

如果模式存在，则返回 true。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 68
def schema_exists?(name)
  query_value("SELECT COUNT(*) FROM pg_namespace WHERE nspname = #{quote(name)}", "SCHEMA").to_i > 0
end

schema_names() 链接

返回模式名称的数组。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 262
        def schema_names
          query_values(<<~SQL, "SCHEMA")
            SELECT nspname
              FROM pg_namespace
             WHERE nspname !~ '^pg_.*'
               AND nspname NOT IN ('information_schema')
             ORDER by nspname;
          SQL
        end

schema_search_path() 链接

返回活动模式搜索路径。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 309
def schema_search_path
  @schema_search_path ||= query_value("SHOW search_path", "SCHEMA")
end

schema_search_path=(schema_csv) 链接

将模式搜索路径设置为逗号分隔的模式名称字符串。以 $ 开头的名称必须加引号（例如 $user => ‘$user’）。请参阅：www.postgresql.org/docs/current/static/ddl-schemas.html

此方法不应手动调用，而应在 database.yml 中设置。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 300
def schema_search_path=(schema_csv)
  return if schema_csv == @schema_search_path
  if schema_csv
    internal_execute("SET search_path TO #{schema_csv}")
    @schema_search_path = schema_csv
  end
end

serial_sequence(table, column) 链接

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 334
def serial_sequence(table, column)
  query_value("SELECT pg_get_serial_sequence(#{quote(table)}, #{quote(column)})", "SCHEMA")
end

unique_constraints(table_name) 链接

返回给定表的唯一约束数组。唯一约束表示为 UniqueConstraintDefinition 对象。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 726
        def unique_constraints(table_name)
          scope = quoted_scope(table_name)

          unique_info = internal_exec_query(<<~SQL, "SCHEMA", allow_retry: true, materialize_transactions: false)
            SELECT c.conname, c.conrelid, c.condeferrable, c.condeferred, pg_get_constraintdef(c.oid) AS constraintdef,
            (
              SELECT array_agg(a.attname ORDER BY idx)
              FROM (
                SELECT idx, c.conkey[idx] AS conkey_elem
                FROM generate_subscripts(c.conkey, 1) AS idx
              ) indexed_conkeys
              JOIN pg_attribute a ON a.attrelid = t.oid
              AND a.attnum = indexed_conkeys.conkey_elem
            ) AS conkey_names
            FROM pg_constraint c
            JOIN pg_class t ON c.conrelid = t.oid
            JOIN pg_namespace n ON n.oid = c.connamespace
            WHERE c.contype = 'u'
              AND t.relname = #{scope[:name]}
              AND n.nspname = #{scope[:schema]}
          SQL

          unique_info.map do |row|
            columns = decode_string_array(row["conkey_names"])

            nulls_not_distinct = row["constraintdef"].start_with?("UNIQUE NULLS NOT DISTINCT")
            deferrable = extract_constraint_deferrable(row["condeferrable"], row["condeferred"])

            options = {
              name: row["conname"],
              nulls_not_distinct: nulls_not_distinct,
              deferrable: deferrable
            }

            UniqueConstraintDefinition.new(table_name, columns, options)
          end
        end

validate_check_constraint(table_name, **options) 链接

验证给定的检查约束。

validate_check_constraint :products, name: "price_check"

options 哈希接受与 add_check_constraint 相同的键。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 963
def validate_check_constraint(table_name, **options)
  chk_name_to_validate = check_constraint_for!(table_name, **options).name

  validate_constraint table_name, chk_name_to_validate
end

validate_constraint(table_name, constraint_name) 链接

验证给定约束。

验证 accounts 表上的名为 constraint_name 的约束。

validate_constraint :accounts, :constraint_name

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 930
def validate_constraint(table_name, constraint_name)
  at = create_alter_table table_name
  at.validate_constraint constraint_name

  execute schema_creation.accept(at)
end

validate_foreign_key(from_table, to_table = nil, **options) 链接

验证给定的外键。

验证 accounts.branch_id 上的外键。

validate_foreign_key :accounts, :branches

验证 accounts.owner_id 上的外键。

validate_foreign_key :accounts, column: :owner_id

验证 accounts 表上名为 special_fk_name 的外键。

validate_foreign_key :accounts, name: :special_fk_name

options 哈希接受与 SchemaStatements#add_foreign_key 相同的键。

来源: 显示 | 在 GitHub 上

# File activerecord/lib/active_record/connection_adapters/postgresql/schema_statements.rb, line 952
def validate_foreign_key(from_table, to_table = nil, **options)
  fk_name_to_validate = foreign_key_for!(from_table, to_table: to_table, **options).name

  validate_constraint from_table, fk_name_to_validate
end

模块 ActiveRecord::ConnectionAdapters::PostgreSQL::SchemaStatements

实例公共方法

add_exclusion_constraint(table_name, expression, **options) 链接

add_foreign_key(from_table, to_table, **options) 链接

add_unique_constraint(table_name, column_name = nil, **options) 链接

client_min_messages() 链接

client_min_messages=(level) 链接

collation() 链接

create_database(name, options = {}) 链接

create_schema(schema_name, force: nil, if_not_exists: nil) 链接

ctype() 链接

current_database() 链接

current_schema() 链接

drop_schema(schema_name, **options) 链接

encoding() 链接

exclusion_constraints(table_name) 链接

foreign_keys(table_name) 链接

foreign_table_exists?(table_name) 链接

foreign_tables() 链接

index_name_exists?(table_name, index_name) 链接

remove_exclusion_constraint(table_name, expression = nil, **options) 链接

remove_unique_constraint(table_name, column_name = nil, **options) 链接

rename_index(table_name, old_name, new_name) 链接

rename_schema(schema_name, new_name) 链接

rename_table(table_name, new_name, **options) 链接

schema_exists?(name) 链接

schema_names() 链接

schema_search_path() 链接

schema_search_path=(schema_csv) 链接

serial_sequence(table, column) 链接

unique_constraints(table_name) 链接

validate_check_constraint(table_name, **options) 链接

validate_constraint(table_name, constraint_name) 链接

validate_foreign_key(from_table, to_table = nil, **options) 链接