Class: DataMapper::Adapters::PostgresqlAdapter::Commands::LoadCommand
- Defined in:
- lib/data_mapper/adapters/postgresql_adapter.rb
Instance Method Summary collapse
- #close_reader(pg_result) ⇒ Object
- #eof?(pg_result) ⇒ Boolean
- #execute(sql) ⇒ Object
- #fetch_all(pg_result) ⇒ Object
- #fetch_one(pg_result) ⇒ Object
Instance Method Details
#close_reader(pg_result) ⇒ Object
200 201 202 |
# File 'lib/data_mapper/adapters/postgresql_adapter.rb', line 200 def close_reader(pg_result) pg_result.clear end |
#eof?(pg_result) ⇒ Boolean
196 197 198 |
# File 'lib/data_mapper/adapters/postgresql_adapter.rb', line 196 def eof?(pg_result) pg_result.result.entries.empty? end |
#execute(sql) ⇒ Object
204 205 206 207 |
# File 'lib/data_mapper/adapters/postgresql_adapter.rb', line 204 def execute(sql) @adapter.log.debug(sql) @adapter.connection { |db| db.exec(to_sql) } end |
#fetch_all(pg_result) ⇒ Object
213 214 215 |
# File 'lib/data_mapper/adapters/postgresql_adapter.rb', line 213 def fetch_all(pg_result) load_instances(pg_result.fields, pg_result) end |
#fetch_one(pg_result) ⇒ Object
209 210 211 |
# File 'lib/data_mapper/adapters/postgresql_adapter.rb', line 209 def fetch_one(pg_result) load(process_row(columns(pg_result), pg_result.result[0])) end |