Module: Sequel::Postgres::AdapterMethods
- Defined in:
- lib/sequel/adapters/shared/postgres.rb
Overview
Methods shared by adapter/connection instances.
Constant Summary collapse
- SELECT_CURRVAL =
"SELECT currval('%s')".freeze
- SELECT_CUSTOM_SEQUENCE =
proc do |schema, table| <<-end_sql SELECT '"' || name.nspname || '".' || CASE WHEN split_part(def.adsrc, '''', 2) ~ '.' THEN substr(split_part(def.adsrc, '''', 2), strpos(split_part(def.adsrc, '''', 2), '.')+1) ELSE split_part(def.adsrc, '''', 2) END FROM pg_class t JOIN pg_namespace name ON (t.relnamespace = name.oid) JOIN pg_attribute attr ON (t.oid = attrelid) JOIN pg_attrdef def ON (adrelid = attrelid AND adnum = attnum) JOIN pg_constraint cons ON (conrelid = adrelid AND adnum = conkey[1]) WHERE cons.contype = 'p' AND def.adsrc ~* 'nextval' #{"AND name.nspname = '#{schema}'" if schema} AND t.relname = '#{table}' end_sql end
- SELECT_PK =
proc do |schema, table| <<-end_sql SELECT pg_attribute.attname FROM pg_class, pg_attribute, pg_index, pg_namespace WHERE pg_class.oid = pg_attribute.attrelid AND pg_class.relnamespace = pg_namespace.oid AND pg_class.oid = pg_index.indrelid AND pg_index.indkey[0] = pg_attribute.attnum AND pg_index.indisprimary = 't' #{"AND pg_namespace.nspname = '#{schema}'" if schema} AND pg_class.relname = '#{table}' end_sql end
- SELECT_SERIAL_SEQUENCE =
proc do |schema, table| <<-end_sql SELECT '"' || name.nspname || '".' || seq.relname || '' FROM pg_class seq, pg_attribute attr, pg_depend dep, pg_namespace name, pg_constraint cons WHERE seq.oid = dep.objid AND seq.relnamespace = name.oid AND seq.relkind = 'S' AND attr.attrelid = dep.refobjid AND attr.attnum = dep.refobjsubid AND attr.attrelid = cons.conrelid AND attr.attnum = cons.conkey[1] AND cons.contype = 'p' #{"AND name.nspname = '#{schema}'" if schema} AND seq.relname = '#{table}' end_sql end
Instance Attribute Summary collapse
-
#db ⇒ Object
writeonly
Sets the attribute db.
-
#transaction_depth ⇒ Object
Depth of the current transaction on this connection, used to implement multi-level transactions with savepoints.
Instance Method Summary collapse
-
#apply_connection_settings ⇒ Object
Apply connection settings for this connection.
-
#last_insert_id(sequence) ⇒ Object
Get the last inserted value for the given sequence.
-
#primary_key(schema, table) ⇒ Object
Get the primary key for the given table.
-
#sequence(schema, table) ⇒ Object
Get the primary key and sequence for the given table.
Instance Attribute Details
#db=(value) ⇒ Object (writeonly)
Sets the attribute db
57 58 59 |
# File 'lib/sequel/adapters/shared/postgres.rb', line 57 def db=(value) @db = value end |
#transaction_depth ⇒ Object
Depth of the current transaction on this connection, used to implement multi-level transactions with savepoints.
109 110 111 |
# File 'lib/sequel/adapters/shared/postgres.rb', line 109 def transaction_depth @transaction_depth end |
Instance Method Details
#apply_connection_settings ⇒ Object
Apply connection settings for this connection. Currently, turns standard_conforming_strings ON if Postgres.force_standard_strings is true.
114 115 116 117 118 119 120 121 122 123 124 |
# File 'lib/sequel/adapters/shared/postgres.rb', line 114 def apply_connection_settings if Postgres.force_standard_strings # This setting will only work on PostgreSQL 8.2 or greater # and we don't know the server version at this point, so # try it unconditionally and rescue any errors. execute("SET standard_conforming_strings = ON") rescue nil end if cmm = Postgres. execute("SET client_min_messages = '#{cmm.to_s.upcase}'") end end |
#last_insert_id(sequence) ⇒ Object
Get the last inserted value for the given sequence.
127 128 129 130 131 132 133 |
# File 'lib/sequel/adapters/shared/postgres.rb', line 127 def last_insert_id(sequence) sql = SELECT_CURRVAL % sequence execute(sql) do |r| val = single_value(r) return val.to_i if val end end |
#primary_key(schema, table) ⇒ Object
Get the primary key for the given table.
136 137 138 139 140 141 |
# File 'lib/sequel/adapters/shared/postgres.rb', line 136 def primary_key(schema, table) sql = SELECT_PK[schema, table] execute(sql) do |r| return single_value(r) end end |
#sequence(schema, table) ⇒ Object
Get the primary key and sequence for the given table.
144 145 146 147 148 149 150 151 152 153 154 155 |
# File 'lib/sequel/adapters/shared/postgres.rb', line 144 def sequence(schema, table) sql = SELECT_SERIAL_SEQUENCE[schema, table] execute(sql) do |r| seq = single_value(r) return seq if seq end sql = SELECT_CUSTOM_SEQUENCE[schema, table] execute(sql) do |r| return single_value(r) end end |