File Source for OCSP_CURSOR

<?php
/**
* Class file OCSP_CURSOR_mySQL.phpclass
*
* @project Open CSP-Management
* @package dbms
* @category mysql
*
* @author Peter Krebs (pk) <pitlinz@users.sourceforge.net>
* @license http://opensource.org/licenses/gpl-license.php GNU Public License
*
***/
require_once dirname(__FILE__)."/OCSP_CURSOR.phpclass"; // <pk-06-07-26 />
/**
* handels mySQL database cursor
*
* @project Open CSP-Management
* @package dbms
* @category mysql
*
* @author Peter Krebs (pk) <pitlinz@users.sourceforge.net>
* @license http://opensource.org/licenses/gpl-license.php GNU Public License
*
*
* @todo currently most function only work with select rights for public
* to any table if different db users are used table rights
* has to be set manualy
*
* @version pk-06-07-26 parent object DB_CURSOR added
* @version pk-07-06-15 renamed from mySQL_CURSOR to OCSP_CURSOR_mySQL
*
***/
class OCSP_CURSOR_mySQL extends OCSP_CURSOR {
/**
* @var mysqlcursor $myCursor
***/
var $myCursor=FALSE;
/**
* @var mysqlconection $myConnId
***/
var $myConnId=FALSE;
/**
* @var bool $bufferd use mysql_query instead of mysql_unbuffered_query
***/
var $buffered=TRUE;
/**
* calls mysql_query or mysql_unbufferd_query to get a resultset
*
* @param mysqlconection $aConnId
* @param string $aQuery
* @param bool $autoClose close cursor ofter the last row fetch
* @param bool $useBuffer use mysql_query ?
* @param debug since pk-05-01-12
*
* @return bool if we get a valid mySQL cursor
*
***/
function OCSP_CURSOR_mySQL($aConnId,$aQuery,$autoClose=TRUE,$useBuffer=TRUE,$debug=FALSE) {
if ($debug) echo "<p><b>OCSP_CURSOR_mySQL::OCSP_CURSOR_mySQL(... $aQuery ,\$autoClose=$autoClose, ...)</b> (".get_class($this).")</p>";
if ((empty($aQuery))) {
return FALSE;
}
if (!$aConnId) {
$ERR="NO_CONNECTION";
include $GLOBALS['PROJECT']['PHPINCPAHT']."io/errors.phpinc";
die();
}
$this->myQuery =$aQuery;
$this->myConnId =$aConnId;
$this->myAutoClose =$autoClose;
$this->rowNr =0;
$this->buffered =$useBuffer;
if ($useBuffer)
return ($this->myCursor=@mysql_query($this->myQuery,$this->myConnId));
else
return ($this->myCursor=@mysql_unbuffered_query($this->myQuery,$this->myConnId));
}
##############################################
/**
* @param int $pos
* @param boolean $debug
*
* @return mixed (array) on success boolean on failure
*
*/
function fetchArrayNum($pos=-1,$debug=FALSE) {
if ($debug) echoDebugMethod(__FILE__,get_class($this),"OCSP_CURSOR_mySQL::fetchArrayNum()");
if ($this->myCursor)
{
if (!($arr_ret=mysql_fetch_array($this->myCursor)))
{
if ($this->myAutoClose)
{
$this->free();
}
return False;
} else {
$this->rowNr++;
if (OCSP_CONF::getInstance()->getValue('OUTPUT_ENCODING_CHECK') && ($str_encoding = OCSP_CONF::getInstance()->getValue('OUTPUT_ENCODING')))
{
foreach($arr_ret as $str_key => $mix_val)
{
if (!empty($mix_val))
{
switch($str_encoding)
{
case "UTF-8":
if (!OCSP_OBJ::isMultiByteStr($mix_val))
{
$arr_ret[$str_key] = utf8_encode($mix_val);
}
break;
}
}
}
}
if ($pos > -1) return $arr_ret[$pos];
else return $arr_ret;
}
} else {
if ($debug) ocsp_logError(__FILE__,__LINE__,"no cursor",E_WARNING);
return FALSE;
}
}
##############################################
/**
* returns an array of a database row
*
* @param boolean $ucase make column names uppercase
* @param boolean $debug
*
* @return array
*
* @global $OCSP_CONF
*
* @version pk-07-08-28
*
*/
function fetchArrayFld($ucase=FALSE)
{
if ($this->myCursor)
{
if (!($arr_row=@mysql_fetch_assoc($this->myCursor)))
{
if ($this->myAutoClose) $this->free();
return FALSE;
} else {
$this->rowNr++;
if ($ucase || OCSP_CONF::getInstance()->getValue('OUTPUT_ENCODING_CHECK'))
{
$arr_ret=array();
if (OCSP_CONF::getInstance()->getValue('OUTPUT_ENCODING_CHECK'))
{
$str_encoding = OCSP_CONF::getInstance()->getValue('OUTPUT_ENCODING');
} else {
$str_encoding = "";
}
foreach($arr_row as $key => $val) {
if ($ucase) $key=strtoupper($key);
if (!empty($val) && !empty($str_encoding))
{
switch($str_encoding)
{
case "UTF-8":
if (!OCSP_OBJ::isMultiByteStr($val))
{
$val = utf8_encode($val);
}
break;
}
}
$arr_ret[$key]=$val;
}
return $arr_ret;
} else {
return $arr_row;
}
}
} else {
return FALSE;
}
}
##############################################
function fetchArray() {
if ($this->myCursor)
{
$arr_ret=@mysql_fetch_array($this->myCursor);
if (!$arr_ret)
{
if ($this->myAutoClose) $this->free();
return False;
} else {
$this->rowNr++;
if (OCSP_CONF::getInstance()->getValue('OUTPUT_ENCODING_CHECK') && ($str_encoding = OCSP_CONF::getInstance()->getValue('OUTPUT_ENCODING')))
{
foreach($arr_ret as $str_key => $mix_val)
{
if (!empty($mix_val))
{
switch($str_encoding)
{
case "UTF-8":
if (!OCSP_OBJ::isMultiByteStr($mix_val))
{
$arr_ret[$str_key] = utf8_encode($mix_val);
}
break;
}
}
}
}
return $arr_ret;
}
} else {
return False;
}
}
/**
* free the cursor with @mysql_free_result
**/
function free() {
if ($this->myCursor) {
@mysql_free_result($this->myCursor);
}
$this->myCursor=FALSE;
}
##############################################
function numOfRows() {
if ($this->myCursor) {
if ($this->buffered) {
return @mysql_num_rows($this->myCursor);
} else {
return $this->rowNr * (-1);
}
} else {
return $this->rowNr * (-1);
}
}
}
?>

Source for file OCSP_CURSOR_mySQL.phpclass