Class: Sequel::Postgres::Adapter
- Defined in:
- lib/sequel_core/adapters/postgres.rb
Constant Summary collapse
- SELECT_CURRVAL =
"SELECT currval('%s')".freeze
- SELECT_PK_AND_SERIAL_SEQUENCE =
Shamelessly appropriated from ActiveRecord’s Postgresql adapter.
<<-end_sql SELECT attr.attname, 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 dep.refobjid = '%s'::regclass end_sql
- SELECT_PK_AND_CUSTOM_SEQUENCE =
<<-end_sql SELECT attr.attname, 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 t.oid = '%s'::regclass AND cons.contype = 'p' AND def.adsrc ~* 'nextval' end_sql
- SELECT_PK =
<<-end_sql SELECT pg_attribute.attname FROM pg_class, pg_attribute, pg_index WHERE pg_class.oid = pg_attribute.attrelid AND pg_class.oid = pg_index.indrelid AND pg_index.indkey[0] = pg_attribute.attnum AND pg_index.indisprimary = 't' AND pg_class.relname = '%s' end_sql
Instance Attribute Summary collapse
-
#transaction_depth ⇒ Object
Returns the value of attribute transaction_depth.
Class Method Summary collapse
Instance Method Summary collapse
- #connected? ⇒ Boolean
- #execute(sql, &block) ⇒ Object
- #last_insert_id(table) ⇒ Object
- #pkey_and_sequence(table) ⇒ Object
- #primary_key(table) ⇒ Object
Instance Attribute Details
#transaction_depth ⇒ Object
Returns the value of attribute transaction_depth.
82 83 84 |
# File 'lib/sequel_core/adapters/postgres.rb', line 82 def transaction_depth @transaction_depth end |
Class Method Details
.string_to_bool(s) ⇒ Object
166 167 168 169 170 171 172 173 174 |
# File 'lib/sequel_core/adapters/postgres.rb', line 166 def self.string_to_bool(s) if(s.blank?) nil elsif(s.downcase == 't' || s.downcase == 'true') true else false end end |
Instance Method Details
#connected? ⇒ Boolean
59 60 61 |
# File 'lib/sequel_core/adapters/postgres.rb', line 59 def connected? status == Adapter::CONNECTION_OK end |
#execute(sql, &block) ⇒ Object
63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 |
# File 'lib/sequel_core/adapters/postgres.rb', line 63 def execute(sql, &block) q = nil begin q = exec(sql) rescue PGError => e unless connected? reset q = exec(sql) else raise e end end begin block ? block[q] : q.cmd_tuples ensure q.clear end end |
#last_insert_id(table) ⇒ Object
86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 |
# File 'lib/sequel_core/adapters/postgres.rb', line 86 def last_insert_id(table) @table_sequences ||= {} if !@table_sequences.include?(table) pkey_and_seq = pkey_and_sequence(table) if pkey_and_seq @table_sequences[table] = pkey_and_seq[1] end end if seq = @table_sequences[table] execute(SELECT_CURRVAL % seq) do |r| return r.getvalue(0,0).to_i unless r.nil? || (r.ntuples == 0) end end nil # primary key sequence not found end |
#pkey_and_sequence(table) ⇒ Object
146 147 148 149 150 151 152 153 154 |
# File 'lib/sequel_core/adapters/postgres.rb', line 146 def pkey_and_sequence(table) execute(SELECT_PK_AND_SERIAL_SEQUENCE % table) do |r| return [r.getvalue(0,2), r.getvalue(0,2)] unless r.nil? || (r.ntuples == 0) end execute(SELECT_PK_AND_CUSTOM_SEQUENCE % table) do |r| return [r.getvalue(0,0), r.getvalue(0,1)] unless r.nil? || (r.ntuples == 0) end end |