[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Phpgroupware-cvs] phpgwapi/inc/class.db.inc.php, 1.10
|
From: |
nomail |
|
Subject: |
[Phpgroupware-cvs] phpgwapi/inc/class.db.inc.php, 1.10 |
|
Date: |
Thu, 30 Dec 2004 07:47:30 +0100 |
Update of /phpgwapi/inc
Added Files:
Branch:
class.db.inc.php
date: 2004/12/30 06:47:30; author: skwashd; state: Exp; lines: +180 -119
Log Message:
new HEAD
=====================================================================
<?php
/**
* Database abstraction class
* @author NetUSE AG Boris Erdmann, Kristian Koehntopp
* @author Dan Kuykendall, Dave Hall and others
* @copyright Copyright (C) 1998-2000 NetUSE AG Boris Erdmann, Kristian
Koehntopp
* @copyright Portions Copyright (C) 2001-2004 Free Software Foundation,
Inc. http://www.fsf.org/
* @license http://www.fsf.org/licenses/lgpl.html GNU Lesser General
Public License
* @link http://www.sanisoft.com/phplib/manual/DB_sql.php
* @package phpgwapi
* @subpackage database
* @version $Id: class.db.inc.php,v 1.10 2004/12/30 06:47:30 skwashd Exp
$
*/
if (empty($GLOBALS['phpgw_info']['server']['db_type']))
{
$GLOBALS['phpgw_info']['server']['db_type'] = 'mysql';
}
/**
* Include concrete database implementation
*/
include(PHPGW_API_INC.'/adodb/adodb.inc.php');
/**
* Database abstraction class to allow phpGroupWare to use multiple
database backends
*
* @package phpgwapi
* @subpackage database
* @abstract
*/
class db
{
var $Host;
var $Type;
var $Database;
var $User;
var $Password;
var $debug = 0;
var $Halt_On_Error = 'yes'; // should be true or false
/**
* Constructor
* @param string $query query to be executed (optional)
*/
function db($query = '')
{
$this->adodb =
NewADOConnection($GLOBALS['phpgw_info']['server']['db_type']);
if($query != '')
{
echo "wtf: db";
$this->query($query);
}
}
/**
* Get current connection id
* @return int current connection id
*/
function link_id()
{
//echo "link_id: depricated";
if(!$this->adodb->isConnected())
{
$this->connect();
}
return $this->adodb->_connectionID;
}
/**
* Get current query id
* @return int id of current query
*/
function query_id()
{
echo "query_id: depricated";
die('you really need this method?');
return $this->Query_ID;
}
/**
* Open a connection to a database
*
* @param string $Database name of database to use (optional)
* @param string $Host database host to connect to (optional)
* @param string $User name of database user (optional)
* @param string $Password password for database user (optional)
*/
function connect($Database = '', $Host = '', $User = '',
$Password = '')
{
if($debug) /* $GLOBALS['phpgw']->log */ echo
"depricated: connect";
$this->Database = $Database != '' ? $Database :
$this->Database;
$this->Host = $Host != '' ? $Host : $this->Host;
$this->User = $User != '' ? $User : $this->User;
$this->Password = $Password != '' ? $Password :
$this->Password;
return $this->adodb->connect($this->Host, $this->User,
$this->Password, $this->Database);
}
/**
* Close a connection to a database - only needed for persistent
connections
*/
function disconnect()
{
if($debug) /* $GLOBALS['phpgw']->log */ echo
"disconnect: depricated";
$this->adodb->close();
}
/**
* Escape strings before sending them to the database
*
* @param string $str the string to be escaped
* @return string escaped sting
*/
function db_addslashes($str)
{
if($debug) /* $GLOBALS['phpgw']->log */ echo
"to_timestanp: db_addsl";
if(!$this->adodb) //workaround
{
return addslashes($str);
}
return substr($this->adodb->qstr($str,
get_magic_quotes_gpc()), 1, -1);
}
/**
* Convert a unix timestamp to a rdms specific timestamp
*
* @param int unix timestamp
* @return string rdms specific timestamp
*/
function to_timestamp($epoch)
{
if($debug) /* $GLOBALS['phpgw']->log */ echo
"to_timestanp: depricated";
return substr($this->adodb->DBTimeStamp($epoch), 1, -1);
}
/**
* Convert a rdms specific timestamp to a unix timestamp
*
* @param string rdms specific timestamp
* @return int unix timestamp
*/
function from_timestamp($timestamp)
{
if($debug) /* $GLOBALS['phpgw']->log */ echo
"from_timestanp: depricated";
return $this->adodb->UnixTimeStamp($timestamp);
}
/**
* Execute a query with limited result set
* @param integer $start Row to start from
* @deprecated
* @see limit_query()
*/
function limit($start)
{
if($debug) /* $GLOBALS['phpgw']->log */ echo
"depricated: limit";
die('where is the sql string?');
}
/**
* Discard the current query result
*/
function free()
{
if($this->debug) /* $GLOBALS['phpgw']->log */ echo
"depricated: limit";
unset($this->resultSet);
return true;
}
/**
* Execute a query
*
* @param string $Query_String the query to be executed
* @param mixed $line the line method was called from - use
__LINE__
* @param string $file the file method was called from - use
__FILE__
* @return integer current query id if sucesful and null if fails
*/
function query($Query_String, $line = '', $file = '')
{
if($this->debug) /* $GLOBALS['phpgw']->log */ echo
"query: depricated: $Query_String <br>";
if(!$this->adodb->isConnected())
{
$this->connect();
}
$this->resultSet = $this->adodb->Execute($Query_String);
if(!$this->resultSet && $this->Halt_On_Error == 'yes')
{
echo $Query_String.'<br>';
echo $this->adodb->ErrorMsg();
_debug_array(debug_backtrace());
die();
}
else
{
$this->delayPointer = true;
return true;
}
}
/**
* Execute a query with limited result set
*
* @param string $Query_String the query to be executed
* @param integer $offset row to start from
* @param integer $line the line method was called from - use
__LINE__
* @param string $file the file method was called from - use
__FILE__
* @param integer $num_rows number of rows to return (optional),
if unset will use
$GLOBALS['phpgw_info']['user']['preferences']['common']['maxmatchs']
* @return integer current query id if sucesful and null if fails
*/
function limit_query($Query_String, $offset = -1, $line = '',
$file = '', $num_rows = -1)
{
if($this->debug) /* $GLOBALS['phpgw']->log */ echo
"depricated: limit_query";
if(!$this->adodb->isConnected())
{
$this->connect();
}
$this->resultSet =
$this->adodb->SelectLimit($Query_String, $num_rows, $offset);
if(!$this->resultSet && $this->Halt_On_Error == 'yes')
{
echo "$Query_String<br>";
print $this->adodb->ErrorMsg();
_debug_array(debug_backtrace());
die();
}
else
{
$this->delayPointer = true;
return true;
}
}
/**
* Move to the next row in the results set
*
* @return bool was another row found?
*/
function next_record()
{
if($this->debug) /* $GLOBALS['phpgw']->log */ echo
"depricated: next_record<br>";
if($this->resultSet && $this->resultSet->RecordCount())
{
if($this->delayPointer)
{
$this->delayPointer = false;
return true;
}
if(!$this->resultSet->EOF)
{
return $this->resultSet->MoveNext();
}
}
return false;
}
/**
* Move to position in result set
*
* @param int $pos required row (optional), default first row
* @return int 1 if sucessful or 0 if not found
*/
function seek($pos = 0)
{
if($this->debug) /* $GLOBALS['phpgw']->log */ echo
"depricated: seek";
if($this->resultSet)
{
return $this->resultSet->Move($pos);
}
return false;
}
/**
* Begin transaction
*
* @return integer|boolean current transaction id
*/
function transaction_begin()
{
if($this->debug) /* $GLOBALS['phpgw']->log */ echo
'depricated';
return $this->adodb->BeginTrans();
}
/**
* Complete the transaction
*
* @return boolean True if sucessful, False if fails
*/
function transaction_commit()
{
if($this->debug) /* $GLOBALS['phpgw']->log */ echo
"depricated: transaction_commit";
return $this->adodb->CommitTrans();
}
/**
* Rollback the current transaction
*
* @return boolean True if sucessful, False if fails
*/
function transaction_abort()
{echo "depricated: transaction_abort";
return True;
}
/**
* Find the primary key of the last insertion on the current db
connection
*
* @param string $table name of table the insert was performed on
* @param string $field the autoincrement primary key of the
table
* @return integer the id, -1 if fails
*/
function get_last_insert_id($table, $field)
{
//echo "depricated: get_last_insert_id";
return $this->adodb->Insert_ID();
}
/**
* Lock a table
*
* @param string $table name of table to lock
* @param string $mode type of lock required (optional), default
write
* @return boolean True if sucessful, False if fails
*/
function lock($table, $mode='write')
{
//echo "depricated: lock";
//$this->adodb->BeginTrans();
}
/**
* Unlock a table
*
* @return boolean True if sucessful, False if fails
*/
function unlock()
{
//echo "depricated: unlock";
//$this->adodb->CommitTrans();
}
/**
* Get the number of rows affected by last update
*
* @return integer number of rows
*/
function affected_rows()
{
//echo "depricated: affected_rows";
return $this->adodb->Affected_Rows();
}
/**
* Number of rows in current result set
*
* @return integer number of rows
*/
function num_rows()
{
//echo "depricated: num_rows";
if($this->resultSet)
{
return $this->resultSet->RecordCount();
}
return 0;
}
/**
* Number of fields in current row
*
* @return integer number of fields
*/
function num_fields()
{echo "depricated: num_fields";}
/**
* Short hand for num_rows()
* @return integer Number of rows
* @see num_rows()
*/
function nf()
{echo "depricated: nf";
return $this->num_rows();
}
/**
* Short hand for print @see num_rows
*/
function np()
{echo "depricated: np";
print $this->num_rows();
}
/**
* Return the value of a filed
*
* @param string $String name of field
* @param boolean $strip_slashes string escape chars from
field(optional), default false
* @return string the field value
*/
function f($name, $strip_slashes = False)
{
if($this->resultSet && get_class($this->resultSet) !=
'adorecordset_empty')
{
//echo "depricated: f";
if ($strip_slashes || ($this->auto_stripslashes
&& ! $strip_slashes))
{
return
stripslashes($this->resultSet->Fields($name));
}
else
{
return $this->resultSet->Fields($name);
}
}
}
/**
* Print the value of a field
*
* @param string $Name name of field to print
* @param bool $strip_slashes string escape chars from
field(optional), default false
*/
function p($Name, $strip_slashes = True)
{
echo "depi: p";
print $this->f($Name, $strip_slashes);
}
/**
* Get the id for the next sequence - not implemented!
*
* @param string $seq_name name of the sequence
* @return integer sequence id
*/
function nextid($seq_name)
{ echo "depi: nextid";}
/**
* Get description of a table
*
* @param string $table name of table to describe
* @param boolean $full optional, default False summary
information, True full information
* @return array Table meta data
*/
function metadata($table = '',$full = false)
{
echo "depi: metadata";
/*
* Due to compatibility problems with Table we changed
the behavior
* of metadata();
* depending on $full, metadata returns the following
values:
*
* - full is false (default):
* $result[]:
* [0]["table"] table name
* [0]["name"] field name
* [0]["type"] field type
* [0]["len"] field length
* [0]["flags"] field flags
*
* - full is true
* $result[]:
* ["num_fields"] number of metadata records
* [0]["table"] table name
* [0]["name"] field name
* [0]["type"] field type
* [0]["len"] field length
* [0]["flags"] field flags
* ["meta"][field name] index of field named "field
name"
* The last one is used, if you have a field name,
but no index.
* Test: if (isset($result['meta']['myfield'])) { ...
*/
}
/**
* Error handler
*
* @param string $msg error message
* @param int $line line of calling method/function (optional)
* @param string $file file of calling method/function (optional)
*/
function halt($msg, $line = '', $file = '')
{ echo "depi: halt";}
/**
* Get a list of table names in the current database
*
* @return array list of the tables
*/
function table_names()
{
//echo "depi: table_names";
//_debug_array(debug_backtrace());
return $this->adodb->MetaTables('TABLES');
}
/**
* Return a list of indexes in current database
*
* @return array List of indexes
*/
function index_names()
{
echo "depi: index_names";
return array();
}
/**
* Create a new database
*
* @param string $adminname Name of database administrator user
(optional)
* @param string $adminpasswd Password for the database
administrator user (optional)
*/
function create_database($adminname = '', $adminpasswd = '')
{ echo "depi: create_database";}
/**
* Prepare SQL statement
*
* @param string $query SQL query
* @return integer|boolean Result identifier for
query_prepared_statement() or FALSE
* @see query_prepared_statement()
*/
function prepare_sql_statement($query)
{
echo "depi";
if (($query == '') || (!$this->connect()))
{
return(FALSE);
}
return(FALSE);
}
/**
* Execute prepared SQL statement
*
* @param resource $result_id Result identifier from
prepare_sql_statement()
* @param array $parameters_array Parameters for the prepared SQL
statement
* @return boolean TRUE on success or FALSE on failure
* @see prepare_sql_statement()
*/
function query_prepared_statement($result_id, $parameters_array)
{
if ((!$this->connect()) || (!$result_id))
{
return(FALSE);
}
return(FALSE);
}
}
?>
| [Prev in Thread] |
Current Thread |
[Next in Thread] |
- [Phpgroupware-cvs] phpgwapi/inc/class.db.inc.php, 1.10,
nomail <=