adulau/cakephp2-php8
1
0
Fork 0
mirror of https://github.com/kamilwylegala/cakephp2-php8.git synced 2025-03-18 07:29:51 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Implementing basic connection to postgres using PDO

Browse source
This commit is contained in:
José Lorenzo Rodríguez 2010-10-17 23:36:34 -04:30
parent 28685dc234
commit f3d3ee92f2
1 changed files with 21 additions and 40 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

61
cake/libs/model/datasources/dbo/dbo_postgres.php
View file

@ -112,23 +112,30 @@ class DboPostgres extends DboSource {
*/ */
function connect() { function connect() {
$config = $this->config; $config = $this->config;
$conn = "host='{$config['host']}' port='{$config['port']}' dbname='{$config['database']}' ";
$conn .= "user='{$config['login']}' password='{$config['password']}'";
if (!$config['persistent']) {
$this->connection = pg_connect($conn, PGSQL_CONNECT_FORCE_NEW);
} else {
$this->connection = pg_pconnect($conn);
}
$this->connected = false; $this->connected = false;
try {
$flags = array(
PDO::ATTR_PERSISTENT => $config['persistent']
);
if (!empty($config['encoding'])) {
$flags[PDO::MYSQL_ATTR_INIT_COMMAND] = 'SET search_path TO ' . $config['schema'];
}
$this->_connection = new PDO(
"pgsql:host={$config['host']};port={$config['port']};dbname={$config['database']}",
$config['login'],
$config['password'],
$flags
);
if (!empty($config['encoding'])) {
$this->setEncoding($config['encoding']);
}
if ($this->connection) {
$this->connected = true; $this->connected = true;
$this->_execute("SET search_path TO " . $config['schema']); } catch (PDOException $e) {
} $this->errors[] = $e->getMessage();
if (!empty($config['encoding'])) {
$this->setEncoding($config['encoding']);
} }
return $this->connected; return $this->connected;
} }
@ -138,33 +145,7 @@ class DboPostgres extends DboSource {
* @return boolean * @return boolean
*/ */
function enabled() { function enabled() {
return extension_loaded('pgsql'); return in_array('pgsql', PDO::getAvailableDrivers());
}
/**
* Disconnects from database.
*
* @return boolean True if the database could be disconnected, else false
*/
function disconnect() {
if ($this->hasResult()) {
pg_free_result($this->_result);
}
if (is_resource($this->connection)) {
$this->connected = !pg_close($this->connection);
} else {
$this->connected = false;
}
return !$this->connected;
}
/**
* Executes given SQL statement.
*
* @param string $sql SQL statement
* @return resource Result resource identifier
*/
function _execute($sql) {
return pg_query($this->connection, $sql);
} }
/** /**