Revision: 50728
Updated Code
at August 31, 2011 09:27 by Jotape
Updated Code
<?php define('VM_FETCH_ARRAY' , 'array'); define('VM_FETCH_ASSOC' , 'assoc'); define('VM_FETCH_OBJECT', 'object'); define('VM_FETCH_ROW' , 'row'); class Conexao { private $host = DB_SERVER; private $dbname = DB_NAME; private $user = DB_USER; private $pswd = DB_PASS; private $port = DB_PORT; var $_query_id; private $con; public function __construct() { $this->con = pg_connect("host=$this->host dbname=$this->dbname user=$this->user password=$this->pswd port=$this->port"); if (!$this->con) { die('Não foi possÃÂvel conectar-se com o servidor: ' . pg_last_error()); } } //método construtor public function fecha(){ # fecha cpnexão pg_close($this->con); } public function execute($sql) { $sql = trim($sql); $retorno = false; # executa a query $result = pg_query($sql); //print_r($sql); # no caso de select, os dados são colocados em um array if (is_bool($result)) $retorno = $result; else { while ($row = $this->fetch_assoc($result)) { # codifica resultado para utf8 array_walk($row, 'toUtf8'); $retorno[] = $row; } } return (is_bool($retorno) && !$retorno)?true:$retorno; } /** * Metodo que irá criar um Array com os dados da consulta. * @param {string} $result: Resultado da Consulta. * @return {array} $rows: Array com os dados da Consulta. **/ function criarArray($result = ''){ $result = !$result ? $this->_queryId : $result; $rows = array(); // LOOP que irá criar o Array com os dados. while ($row = $this->fetch_object()) { # codifica resultado para utf8 array_walk($row, 'toUtf8'); $rows[] = $row; } return $rows; } public function sqlQuery($sql) { $this->_query_id = pg_query($sql) or die(pg_last_error()); return $this->_query_id ? $this->_query_id : false; } public function insert_id() { return pg_insert($this->con); } public function fetch_array($query_id = '') { $query_id = (!$query_id) ? $this->_query_id : $query_id; return pg_fetch_array($query_id, PGSQL_ASSOC); } public function fetch_row($query_id = '') { $query_id = (!$query_id) ? $this->_query_id : $query_id; return pg_fetch_row($query_id); } public function fetch_object($query_id = '') { $query_id = (!$query_id) ? $this->_query_id : $query_id; return pg_fetch_object($query_id); } public function fetch_assoc($query_id = '') { $query_id = (!$query_id) ? $this->_query_id : $query_id; return pg_fetch_assoc($query_id); } public function num_rows($query_id = '') { $query_id = (!$query_id) ? $this->_query_id : $query_id; return pg_num_rows($query_id); } public function result($result = '', $row = 0, $cols = 0) { $result = !$result ? $this->_query_id : $result; return pg_fetch_result($result, $row, $cols); } public function num_fields($result = '') { $result = !$result ? $this->_query_id : $result; return pg_num_fields($result); } public function affected_rows() { return pg_affected_rows($this->con); } public function field_name($result = '', $i = 0) { $result = !$result ? $this->_query_id : $result; return pg_field_name($result, $i); } public function field_type($result = '', $i = 0) { $result = !$result ? $this->_query_id : $result; return pg_field_type($result, $i); } function start_transaction() { pg_query("START TRANSACTION"); } function commit() { pg_query("COMMIT"); } function rollback() { pg_query("ROLLBACK"); } } ?>
Revision: 50727
Initial Code
Initial URL
Initial Description
Initial Title
Initial Tags
Initial Language
at August 31, 2011 09:27 by Jotape
Initial Code
<?php define('VM_FETCH_ARRAY' , 'array'); define('VM_FETCH_ASSOC' , 'assoc'); define('VM_FETCH_OBJECT', 'object'); define('VM_FETCH_ROW' , 'row'); class Conexao { private $host = DB_SERVER; private $dbname = DB_NAME; private $user = DB_USER; private $pswd = DB_PASS; private $port = DB_PORT; var $_query_id; private $con; public function __construct() { $this->con = pg_connect("host=$this->host dbname=$this->dbname user=$this->user password=$this->pswd port=$this->port"); if (!$this->con) { die('Não foi possÃvel conectar-se com o servidor: ' . pg_last_error()); } } //método construtor public function fecha(){ # fecha cpnexão pg_close($this->con); } public function execute($sql) { $sql = trim($sql); $retorno = false; # executa a query $result = pg_query($sql); //print_r($sql); # no caso de select, os dados são colocados em um array if (is_bool($result)) $retorno = $result; else { while ($row = $this->fetch_assoc($result)) { # codifica resultado para utf8 array_walk($row, 'toUtf8'); $retorno[] = $row; } } return (is_bool($retorno) && !$retorno)?true:$retorno; } /** * Metodo que irá criar um Array com os dados da consulta. * @param {string} $result: Resultado da Consulta. * @return {array} $rows: Array com os dados da Consulta. **/ function criarArray($result = ''){ $result = !$result ? $this->_queryId : $result; $rows = array(); // LOOP que irá criar o Array com os dados. while ($row = $this->fetch_object()) { # codifica resultado para utf8 array_walk($row, 'toUtf8'); $rows[] = $row; } return $rows; } public function sqlQuery($sql) { $this->_query_id = pg_query($sql) or die(pg_last_error()); return $this->_query_id ? $this->_query_id : false; } public function insert_id() { return pg_insert($this->con); } public function fetch_array($query_id = '') { $query_id = (!$query_id) ? $this->_query_id : $query_id; return pg_fetch_array($query_id, PGSQL_ASSOC); } public function fetch_row($query_id = '') { $query_id = (!$query_id) ? $this->_query_id : $query_id; return pg_fetch_row($query_id); } public function fetch_object($query_id = '') { $query_id = (!$query_id) ? $this->_query_id : $query_id; return pg_fetch_object($query_id); } public function fetch_assoc($query_id = '') { $query_id = (!$query_id) ? $this->_query_id : $query_id; return pg_fetch_assoc($query_id); } public function num_rows($query_id = '') { $query_id = (!$query_id) ? $this->_query_id : $query_id; return pg_num_rows($query_id); } public function result($result = '', $row = 0, $cols = 0) { $result = !$result ? $this->_query_id : $result; return pg_fetch_result($result, $row, $cols); } public function num_fields($result = '') { $result = !$result ? $this->_query_id : $result; return pg_num_fields($result); } public function affected_rows() { return pg_affected_rows($this->con); } public function field_name($result = '', $i = 0) { $result = !$result ? $this->_query_id : $result; return pg_field_name($result, $i); } public function field_type($result = '', $i = 0) { $result = !$result ? $this->_query_id : $result; return pg_field_type($result, $i); } function start_transaction() { pg_query("START TRANSACTION"); } function commit() { pg_query("COMMIT"); } function rollback() { pg_query("ROLLBACK"); } } ?>
Initial URL
Initial Description
Initial Title
Postgre Connect class
Initial Tags
php
Initial Language
PHP