<?php class LtDbConnectionAdapterPgsql implements LtDbConnectionAdapter { public function connect($connConf) { if (isset($connConf['pconnect']) && true == $connConf['pconnect']) { $func = 'pg_pconnect'; } else { $func = 'pg_connect'; } return $func("host={$connConf['host']} port={$connConf['port']} user={$connConf['username']} password={$connConf['password']}"); } public function exec($sql, $connResource) { $result = pg_query($connResource, $sql); return pg_affected_rows($result); } public function query($sql, $connResource) { $result = pg_query($connResource, $sql); return pg_fetch_all($result); } // SELECT CURRVAL( // pg_get_serial_sequence('my_tbl_name','id_col_name'));" // ------------------------------------------------------ // CREATE FUNCTION last_insert_id() RETURNS bigint AS $$ // SELECT lastval(); // $$ LANGUAGE SQL VOLATILE; public function lastInsertId($connResource) { $result = pg_query($connResource, "SELECT lastval()"); $row = pg_fetch_array($result, 0, PGSQL_NUM); return $row[0]; } public function escape($sql, $connResource) { return pg_escape_string($sql); } }