cvs: php4 /pear/Cache/Container dbx.php
| From: | Christian Stocker | Date: | Thu, 22 Mar 2001 14:29:02 +0000 |
| Subject: | cvs: php4 /pear/Cache/Container dbx.php | ||
| Groups: | php.cvs | ||
| Request: | Send a blank email to php-cvs+get-4777@lists.php.net to get a copy of this message | ||
chregu Thu Mar 22 06:29:02 2001 EDT
Added files:
/php4/pear/Cache/Container dbx.php
Log:
a new container, which uses the new dbx extension of php as db-abstraction
Index: php4/pear/Cache/Container/dbx.php
+++ php4/pear/Cache/Container/dbx.php
<?php
// +----------------------------------------------------------------------+
// | PHP version 4.0 |
// +----------------------------------------------------------------------+
// | Copyright (c) 1997, 1998, 1999, 2000, 2001 The PHP Group |
// +----------------------------------------------------------------------+
// | This source file is subject to version 2.0 of the PHP license, |
// | that is bundled with this package in the file LICENSE, and is |
// | available at through the world-wide-web at |
// | http://www.php.net/license/2_02.txt.
|
// | If you did not receive a copy of the PHP license and are unable to |
// | obtain it through the world-wide-web, please send a note to |
// | license@php.net so we can mail you a copy immediately. |
// +----------------------------------------------------------------------+
// | Authors: Christian Stocker <chregu@nomad.ch> |
// +----------------------------------------------------------------------+
//
// $Id: dbx.php,v 1.1 2001/03/22 14:29:01 chregu Exp $
require_once 'Cache/Container.php';
/**
* ext/dbx Cache Container.
*
* WARNING: Other systems might or might not support certain datatypes of
* the tables shown. As far as I know there's no large binary
* type in SQL-92 or SQL-99. Postgres seems to lack any
* BLOB or TEXT type, for MS-SQL you could use IMAGE, don't know
* about other databases. Please add sugestions for other databases to
* the inline docs.
*
* The field 'changed' has no meaning for the Cache itself. It's just there
* because it's a good idea to have an automatically updated timestamp
* field for debugging in all of your tables.
*
* For _MySQL_ you need this DB table:
*
* CREATE TABLE cache (
* id CHAR(32) NOT NULL DEFAULT '',
* cachegroup VARCHAR(127) NOT NULL DEFAULT '',
* cachedata BLOB NOT NULL DEFAULT '',
* userdata VARCHAR(255) NOT NULL DEFAULT '',
* expires INT(9) NOT NULL DEFAULT 0,
*
* changed TIMESTAMP(14) NOT NULL,
*
* INDEX (expires),
* PRIMARY KEY (id, cachegroup)
* )
*
* @author Christian Stocker <chregu@nomad.ch>
* @version $Id: dbx.php,v 1.1 2001/03/22 14:29:01 chregu Exp $
* @package Cache
*/
class Cache_Container_dbx extends Cache_Container {
/**
* Name of the DB table to store caching data
*
* @see Cache_Container_file::$filename_prefix
*/
var $cache_table = '';
/**
* DBx module to use
*
* at the moment only mysql or odbc
*
* @var string
*/
var $module = '';
/**
* DB host to use
*
* @var string
*/
var $host = '';
/**
* DB database to use
*
* @var string
*/
var $db = '';
/**
* DB username to use
*
* @var string
*/
var $username = '';
/**
* DB password to use
*
* @var string
*/
var $password = '';
/**
* PEAR DB object
*
* @var object PEAR_DB
*/
var $db;
function Cache_Container_dbx($options)
{
if (!is_array($options) ) {
return new Cache_Error('No options specified!', __FILE__, __LINE__);
}
$this->setOptions($options,
array('module','host','db','username','password',
'cache_table'));
if (!$this->module)
return new Cache_Error('No module specified!', __FILE__, __LINE__);
$this->db =
dbx_connect($this->module,$thos->host,$this->db,$this->username,$this->password);
if (dbx_error($this->db)) {
return new Cache_Error('DBx connect failed: ' . dbx_error($this->db),
__FILE__, __LINE__);
} else {
//not implemented yet in dbx
//$this->db->setFetchMode(DB_FETCHMODE_ASSOC);
}
}
function fetch($id, $group)
{
$query = sprintf("SELECT cachedata, userdata, expires FROM %s WHERE id = '%s'
AND cachegroup = '%s'",
$this->cache_table,
addslashes($id),
addslashes($group)
);
$res = dbx_query($this->db,$query);
if (dbx_error($this->db))
return new Cache_Error('DBx query failed: ' . dbx_error($this->db),
__FILE__, __LINE__);
$row = $res->data[0];
if (is_array($row))
return array($row['expires'], $this->decode($row['cachedata']),
$row['userdata']);
}
/**
* Stores a dataset.
*
* WARNING: we use the SQL command REPLACE INTO this might be
* MySQL specific. As MySQL is very popular the method should
* work fine for 95% of you.
*/
function save($id, $data, $expires, $group, $userdata)
{
$this->flushPreload($id, $group);
$query = sprintf("REPLACE INTO %s (userdata, cachedata, expires, id, cachegroup) VALUES
('%s', '%s', %d, '%s', '%s')",
$this->cache_table,
addslashes($userdata),
addslashes($this->encode($data)),
$this->getExpiresAbsolute($expires) ,
addslashes($id),
addslashes($group)
);
$res = dbx_query($this->db,$query);
if (dbx_error($this->db)) {
return new Cache_Error('DBx query failed: ' . dbx_error($this->db) ,
__FILE__, __LINE__);
}
}
function delete($id, $group)
{
$this->flushPreload($id, $group);
$query = sprintf("DELETE FROM %s WHERE id = '%s' and cachegroup =
'%s'",
$this->cache_table,
addslashes($id),
addslashes($group)
);
$res = dbx_query($this->db,$query);
if (dbx_error($this->db))
return new Cache_Error('DBx query failed: ' . dbx_error($this->db),
__FILE__, __LINE__);
}
function flush($group = "")
{
$this->flushPreload();
if ($group) {
$query = sprintf("DELETE FROM %s WHERE cachegroup = '%s'",
$this->cache_table, addslashes($group));
} else {
$query = sprintf("DELETE FROM %s", $this->cache_table);
}
$res = dbx_query($this->db,$query);
if (dbx_error($this->db))
return new Cache_Error('DBx query failed: ' . dbx_error($this->db),
__FILE__, __LINE__);
}
function idExists($id, $group)
{
$query = sprintf("SELECT id FROM %s WHERE ID = '%s' AND cachegroup =
'%s'",
$this->cache_table,
addslashes($id),
addslashes($group)
);
$res = dbx_query($this->db,$query);
if (dbx_error($this->db))
return new Cache_Error('DBx query failed: ' . dbx_error($this->db),
__FILE__, __LINE__);
$row = $res[0];
if (is_array($row)) {
return true;
} else {
return false;
}
}
function garbageCollection()
{
$query = sprintf('DELETE FROM %s WHERE expires <= %d AND expires > 0',
$this->cache_table,
time());
$res = dbx_query($this->db,$query);
if (dbx_error($this->db))
return new Cache_Error('DBx query failed: ' . dbx_error($this->db),
__FILE__, __LINE__);
}
}
?>