PHP Classes

File: Zend/Db/Statement/Pgsql.php

Recommend this page to a friend!
  Classes of Viktor Jenei   Zend PostgreSQL Adapter (without pdo_pgsql)   Zend/Db/Statement/Pgsql.php   Download  
File: Zend/Db/Statement/Pgsql.php
Role: Class source
Content type: text/plain
Description: Zend PostgreSQL Statement
Class: Zend PostgreSQL Adapter (without pdo_pgsql)
Zend Framework DB Adapter to access PostgreSQL
Author: By
Last change:
Date: 14 years ago
Size: 6,528 bytes
 

Contents

Class file image Download
<?php
/**
 * Zend Framework PgSQL Statement
 *
 * @author Jenei Viktor Attila
 * @copyright 2010 Jenei Viktor Attila
 * @license http://framework.zend.com/license/new-bsd New BSD License
 */
 
/**
 * @see Zend_Db_Statement
 */
require_once 'Zend/Db/Statement.php';

/**
 * Extends for PgSQL
 *
 * @category Zend
 * @package Zend_Db
 * @subpackage Statement
 */
class Zend_Db_Statement_Pgsql extends Zend_Db_Statement {
    var
$_prepared_sql = '';
    var
$_sqlresult = null;
    var
$_columnCount = 0;
    var
$_rowCount = 0;
   
/**
     * @param string $sql
     * @return void
     * @throws Zend_Db_Statement_Exception
     */
   
public function _prepare( $sql ) {
       
$this->_prepared_sql = $sql;
    }

   
/**
     * Binds a parameter to the specified variable name.
     *
     * @param mixed $parameter Name the parameter, either integer or string.
     * @param mixed $variable Reference to PHP variable containing the value.
     * @param mixed $type OPTIONAL Datatype of SQL parameter.
     * @param mixed $length OPTIONAL Length of SQL parameter.
     * @param mixed $options OPTIONAL Other options.
     * @return bool
     * @throws Zend_Db_Statement_Exception
     */
   
protected function _bindParam( $parameter, &$variable, $type = null, $length = null, $options = null ) {
        return
true;
    }

   
/**
     * Closes the cursor and the statement.
     *
     * @return bool
     */
   
public function close() {
        if (
strlen( $this->_prepared_sql ) > 0 ) {
          
$this->_prepared_sql = '';
        }
        if (
$this->_sqlresult ) @pg_free_result( $this->_sqlresult );
        return
false;
    }

   
/**
     * Closes the cursor, allowing the statement to be executed again.
     *
     * @return bool
     */
   
public function closeCursor() {
        if (
$this->_sqlresult ) {
            return @
pg_free_result( $this->_sqlresult );
        }
        return
false;
    }

   
/**
     * Returns the number of columns in the result set.
     * Returns null if the statement has no result set metadata.
     *
     * @return int The number of columns.
     */
   
public function columnCount() {
            return
$this->_columnCount;
    }

   
/**
     * Retrieves the error code, if any, associated with the last operation on
     * the statement handle.
     *
     * @return string error code.
     */
   
public function errorCode() {
        return
false;
    }

   
/**
     * Retrieves an array of error information, if any, associated with the
     * last operation on the statement handle.
     *
     * @return array
     */
   
public function errorInfo() {
        if ( !
$this->_prepared_sql ) {
            return
false;
        }
        return array(
           
1,
           
pg_last_error( $this->_adapter->getConnection() )
        );
    }

   
/**
     * Executes a prepared statement.
     *
     * @param array $params OPTIONAL Values to bind to parameter placeholders.
     * @return bool
     * @throws Zend_Db_Statement_Exception
     */
   
public function _execute(array $params = null) {
        if ( !
$this->_prepared_sql ) {
            return
false;
        }

        if (
$params === null) {
           
$params = $this->_bindParam;
        }

       
$retval = true;
   
$sql_query = $this->_prepared_sql;

        if (
$params ) {
                foreach (
$params as &$v ) {
                       
$v = ( $v === null ) ? 'NULL' : "'" . pg_escape_string( $this->_adapter->getConnection(), $v ) . "'";
        }
       
$sql_query = vsprintf( str_replace( "?", "%s", $sql_query ), $params );
    } else {
       
$sql_query = $sql_query;
    }
   
$this->_sqlresult = @pg_query( $this->_adapter->getConnection(), $sql_query );

    if ( !
$this->_sqlresult ) {
       
$retval = false;
            require_once
'Zend/Db/Statement/Exception.php';
            throw new
Zend_Db_Statement_Exception(
                   
'PGSql statement execute error : ' . pg_result_error( $this->_sqlresult ),
                   
1 );
        }
       
$this->_columnCount = @pg_field_num( $this->_sqlresult );
       
$this->_rowCount = @pg_num_rows( $this->_sqlresult );
        return
$retval;
    }

   
/**
     * Fetches a row from the result set.
     *
     * @param int $style OPTIONAL Fetch mode for this fetch operation.
     * @param int $cursor OPTIONAL Absolute, relative, or other.
     * @param int $offset OPTIONAL Number for absolute or relative cursors.
     * @return mixed Array, object, or scalar depending on fetch mode.
     * @throws Zend_Db_Statement_Exception
     */
   
public function fetch( $style = null, $cursor = null, $offset = null ) {
        if ( !
$this->_sqlresult ) {
            return
false;
        }

        if (
$style === null ) {
           
$style = $this->_fetchMode;
        }

   
$row = null;
    switch (
$style ) {
        case
Zend_Db::FETCH_NUM:
       
$row = pg_fetch_row( $this->_sqlresult );
        break;
        case
Zend_Db::FETCH_ASSOC:
       
$row = pg_fetch_assoc( $this->_sqlresult );
        break;
        case
Zend_Db::FETCH_BOTH:
       
$row = pg_fetch_assoc( $this->_sqlresult );
        if (
$row !== false)
           
$row = array_merge( $this->_sqlresult, array_values( $row ) );
        break;
        case
Zend_Db::FETCH_OBJ:
       
$row = pg_fetch_object( $this->_sqlresult );
        break;
            case
Zend_Db::FETCH_BOUND:
               
$row = pg_fetch_assoc( $this->_sqlresult );
                if (
$row !== false ){
                   
$row = array_merge( $row, array_values( $row ) );
                   
$row = $this->_fetchBound( $row );
                }
                break;
        default:
        break;
    }
    return
$row;
    }

   
/**
     * Retrieves the next rowset (result set) for a SQL statement that has
     * multiple result sets. An example is a stored procedure that returns
     * the results of multiple queries.
     *
     * @return bool
     * @throws Zend_Db_Statement_Exception
     */
   
public function nextRowset()
    {
       
/**
         * @see Zend_Db_Statement_Exception
         */
       
require_once 'Zend/Db/Statement/Exception.php';
        throw new
Zend_Db_Statement_Exception( __FUNCTION__.'() is not implemented' );
    }

   
/**
     * Returns the number of rows affected by the execution of the
     * last INSERT, DELETE, or UPDATE statement executed by this
     * statement object.
     *
     * @return int The number of rows affected.
     */
   
public function rowCount() {
        if ( !
$this->_sqlresult ) {
            return
false;
        }
        return
$this->_rowCount;
    }

}