Vergleich inc/db_pdo.php - 1.8.19 - 1.8.37

  Keine Änderungen   Hinzugefügt   Modifiziert   Entfernt
Zeile 8Zeile 8
 *
*/


 *
*/


class dbpdoEngine {

/**

class dbpdoEngine
{
/**

	 * The database class to store PDO objects

	 * The database class to store PDO objects

	 *

	 *

	 * @var PDO

	 * @var PDO

	 */
public $db;








	 */
private $db;

/**
* The last query resource that ran
*
* @var PDOStatement
*/
public $last_query;


/**


/**

	 * The last query resource that ran

	 * Array used to seek through result sets. This is used when using the `fetch_field` method with a row specified.

	 *

	 *

	 * @var PDOStatement

	 * @var array Array keyed by object hashes for {@see PDOStatement} instances.

	 */

	 */

	public $last_query = "";

public $seek_array = array();

public $queries = 0;

	private $seek_array = array();






/**
* Connect to the database.


/**
* Connect to the database.

Zeile 35Zeile 38
	 * @param string $username The database username. (depends on DSN)
* @param string $password The database user's password. (depends on DSN)
* @param array $driver_options The databases driver options (optional)

	 * @param string $username The database username. (depends on DSN)
* @param string $password The database user's password. (depends on DSN)
* @param array $driver_options The databases driver options (optional)

 
	 *
* @throws Exception Thrown when failing to connect to the database.

	 */
function __construct($dsn, $username="", $password="", $driver_options=array())
{
try

	 */
function __construct($dsn, $username="", $password="", $driver_options=array())
{
try

		{









		{
$driver_options =
$driver_options +
array(
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
PDO::ATTR_EMULATE_PREPARES => false,
)
;


			$this->db = new PDO($dsn, $username, $password, $driver_options);

			$this->db = new PDO($dsn, $username, $password, $driver_options);

		}

		}

		catch(PDOException $exception)
{

		catch(PDOException $exception)
{

    		die('Connection failed: '.$exception->getMessage());

			throw new Exception('Unable to connect to database server');

		}

		}


$this->db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

 
	}

/**
* Query the database.
*
* @param string $string The query SQL.

	}

/**
* Query the database.
*
* @param string $string The query SQL.

 
	 *

	 * @return PDOStatement The query data.
*/

	 * @return PDOStatement The query data.
*/

	function query($string)

	public function query($string)

	{

	{

		++$this->queries;


 
		$query = $this->db->query($string, PDO::FETCH_BOTH);
$this->last_query = $query;

		$query = $this->db->query($string, PDO::FETCH_BOTH);
$this->last_query = $query;


$query->guid = $this->queries;

 

return $query;
}


return $query;
}

Zeile 75Zeile 83
	 * @param int $resulttype One of PDO's constants: FETCH_ASSOC, FETCH_BOUND, FETCH_CLASS, FETCH_INTO, FETCH_LAZY, FETCH_NAMED, FETCH_NUM, FETCH_OBJ or FETCH_BOTH
* @return array The array of results.
*/

	 * @param int $resulttype One of PDO's constants: FETCH_ASSOC, FETCH_BOUND, FETCH_CLASS, FETCH_INTO, FETCH_LAZY, FETCH_NAMED, FETCH_NUM, FETCH_OBJ or FETCH_BOTH
* @return array The array of results.
*/

	function fetch_array($query, $resulttype=PDO::FETCH_BOTH)

	public function fetch_array($query, $resulttype=PDO::FETCH_BOTH)

	{
switch($resulttype)
{

	{
switch($resulttype)
{

Zeile 91Zeile 99
			default:
$resulttype = PDO::FETCH_BOTH;
break;

			default:
$resulttype = PDO::FETCH_BOTH;
break;

		}

if($this->seek_array[$query->guid])



		}

$hash = spl_object_hash($query);

if(isset($this->seek_array[$hash]))

		{

		{

			$array = $query->fetch($resulttype, $this->seek_array[$query->guid]['offset'], $this->seek_array[$query->guid]['row']);

			$array = $query->fetch($resulttype, $this->seek_array[$hash]['offset'], $this->seek_array[$hash]['row']);

		}
else
{
$array = $query->fetch($resulttype);
}

		}
else
{
$array = $query->fetch($resulttype);
}





		return $array;
}


		return $array;
}


Zeile 110Zeile 120
	 *
* @param PDOStatement $query The query resource.
* @param int $row The pointer to move the row to.

	 *
* @param PDOStatement $query The query resource.
* @param int $row The pointer to move the row to.

	 */
function seek($query, $row)
{
$this->seek_array[$query->guid] = array('offset' => PDO::FETCH_ORI_ABS, 'row' => $row);
}



	 */
public function seek($query, $row)
{
$hash = spl_object_hash($query);

$this->seek_array[$hash] = array('offset' => PDO::FETCH_ORI_ABS, 'row' => $row);
}


/**
* Return the number of rows resulting from a query.


/**
* Return the number of rows resulting from a query.

Zeile 122Zeile 134
	 * @param PDOStatement $query The query resource.
* @return int The number of rows in the result.
*/

	 * @param PDOStatement $query The query resource.
* @return int The number of rows in the result.
*/

	function num_rows($query)

	public function num_rows($query)

	{
if(stripos($query->queryString, 'SELECT') !== false)

	{
if(stripos($query->queryString, 'SELECT') !== false)

		{

		{

			$query = $this->db->query($query->queryString);
$result = $query->fetchAll();
return count($result);

			$query = $this->db->query($query->queryString);
$result = $query->fetchAll();
return count($result);

Zeile 133Zeile 145
		else
{
return $query->rowCount();

		else
{
return $query->rowCount();

		}
}

		}
}


/**
* Return the last id number of inserted data.
*


/**
* Return the last id number of inserted data.
*

	 * @param string $name The name of the insert id to check. (Optional)

	 * @param string|null $name The name of the insert id to check. (Optional)

	 * @return int The id number.
*/

	 * @return int The id number.
*/

	function insert_id($name="")

	public function insert_id($name=null)

	{
return $this->db->lastInsertId($name);
}

	{
return $this->db->lastInsertId($name);
}

Zeile 153Zeile 165
	 * @param PDOStatement $query The query resource.
* @return int The error number of the current error.
*/

	 * @param PDOStatement $query The query resource.
* @return int The error number of the current error.
*/

	function error_number($query)

	public function error_number($query)

	{
if(!method_exists($query, "errorCode"))
{
return 0;
}


	{
if(!method_exists($query, "errorCode"))
{
return 0;
}


		$errorcode = $query->errorCode();

return $errorcode;

		return $query->errorCode();



	}

/**

	}

/**

Zeile 171Zeile 181
	 * @param PDOStatement $query The query resource.
* @return array The error string of the current error.
*/

	 * @param PDOStatement $query The query resource.
* @return array The error string of the current error.
*/

	function error_string($query)

	public function error_string($query)

	{
if(!method_exists($query, "errorInfo"))
{
return $this->db->errorInfo();
}

	{
if(!method_exists($query, "errorInfo"))
{
return $this->db->errorInfo();
}

 


		return $query->errorInfo();
}


		return $query->errorInfo();
}


Zeile 186Zeile 197
	 * @param PDOStatement $query
* @return int The number of affected rows.
*/

	 * @param PDOStatement $query
* @return int The number of affected rows.
*/

	function affected_rows($query)

	public function affected_rows($query)

	{
return $query->rowCount();
}

	{
return $query->rowCount();
}

Zeile 197Zeile 208
	 * @param PDOStatement $query The query resource.
* @return int The number of fields.
*/

	 * @param PDOStatement $query The query resource.
* @return int The number of fields.
*/

	function num_fields($query)

	public function num_fields($query)

	{
return $query->columnCount();
}

	{
return $query->columnCount();
}

Zeile 208Zeile 219
	 * @param string $string The string to be escaped.
* @return string The escaped string.
*/

	 * @param string $string The string to be escaped.
* @return string The escaped string.
*/

	function escape_string($string)

	public function escape_string($string)

	{
$string = $this->db->quote($string);


	{
$string = $this->db->quote($string);


		// Remove ' from the begginging of the string and at the end of the string, because we already use it in insert_query

		// Remove ' from the beginning of the string and at the end of the string, because we already use it in insert_query

		$string = substr($string, 1);
$string = substr($string, 0, -1);


		$string = substr($string, 1);
$string = substr($string, 0, -1);


Zeile 225Zeile 236
	 * @param string $attribute The attribute to check.
* @return string The value of the attribute.
*/

	 * @param string $attribute The attribute to check.
* @return string The value of the attribute.
*/

	function get_attribute($attribute)

	public function get_attribute($attribute)

	{

	{

		$attribute = $this->db->getAttribute(constant("PDO::".$attribute.""));

		$attribute = $this->db->getAttribute(constant("PDO::{$attribute}"));


return $attribute;
}


return $attribute;
}