php实现可用于mysql,mssql,pg数据库操作类

<?PHP 
/********************************************************************************** 
此类将数据库操作封装，具有良好的可移植性,针对数据库：mysql,mssql,pg 
************************************************************************************ 
// -函数清单 索引： 
// - Open: 打开数据库连接 Line:71 
// - Close: 关闭数据库连接 Line:107 
// - SelectDB: 选择数据库 Line:129 
// - Query: 创建查询 Line:151 
// - DataSeek: 移动记录指针 Line:175 
// - FieldName: 获取字段名称 Line:198 
// - FieldType: 获取字段类型 Line:220 
// - FieldLenght: 获取字段长度 Line:242 
// - FetchRow: 获取数据并保存到数组（数字索引） Line:264 
// - FetchArray: 获取数据并保存进数组（数字和关联） Line:289 
// - FetchObject: 获取数据并保存到对象（对象方式） Line:315 
// - Result: 获取结果数据 Line:341 
// - FreeResult: 刷新记录集 Line:363 
// - RowsNumber: 获取记录数量 Line:385 
// - FieldsNumber: 获取字段数量 Line:407 
// - CurRecNumber: 获取当前记录号（从0开始） Line:429 
// - RecordNumber: 获取当前行号（从1开始） Line:438 
// - MoveFirstRec: 移动到第一条记录 Line:447 
// - MoveLastRec: 移动到最后一条记录 Line:469 
// - MovePreviousRec: 移动到前一条记录 Line:495 
// - MoveNextRec: 移动到下一条记录 Line:521 
// - MoveToRec: 移动到一个特定的记录（从1开始） Line:548 
************************************************************************************ 
//Inputs: 
// - dbType: databases type: mssql, mysql, pg 
// - connectType: connection type: c - common connection, 
// p - open persistent connection 
// - connect: for MS SQL Server - server name, 
// for MySQL - hostname [:port] [:/path/to/socket] , 
// for PostgreSQL - host, port, tty, options, 
// dbname (without username and password) 
// - username 
// - password 
// - dbName: database name 
// - query: SQL query 
// - result: result set identifier 
// - RowNumber: 
// - offset: field identifier 
// - ResultType: a constant and can take the following values: PGSQL_ASSOC, PGSQL_NUM, and PGSQL_BOTH 
// - FieldName 
// 
//Returns: 
// - result: result set identifier 
// - connect link identifier 
// - record number (starting at 0: CurrRecNumber or starting at 1: RecordNumber) 
// - number of fields in the specified result set 
// - number of rows in the specified result set 
*************************************************************************************/ 
Class mDatabase 
{ 
/***********************************成员变量定义***************************************/ 
var $dbType; // 数据库类型: mssql, mysql, pg 
var $connectType; // 连接类型: c - common connection, p - open persistent connection 
var $idCon; // 连接号 
var $curRow; // current row number of data from the result 
// associated with the specified result identifier array 
var $seek; // current row number of data from DataSeek function array 
 
/***********************************成员方法实现***************************************/ 
/************************************************************************************ 
*连接数据库的函数 
*************************************************************************************/ 
Function Open($dbType, $c, $connect, $username = "", $password = "") 
{ 
$this->dbType = $dbType; 
Switch ($dbType) { 
Case "mssql": 
If ($connectType == "c") { 
$idCon = mssql_connect($connect, $username, $password); 
} Else { 
$idCon = mssql_pconnect($connect, $username, $password); 
} 
Break; 
Case "mysql": 
If ($connectType == "c") { 
$idCon = mysql_connect($connect, $username, $password); 
} Else { 
$idCon = mysql_pconnect($connect, $username, $password); 
} 
Break; 
Case "pg": 
If ($connectType == "c") { 
$idCon = pg_connect($connect . " user=" . $username . " password=" . $password); 
} Else { 
$idCon = pg_pconnect($connect . " user=" . $username . " password=" . $password); 
} 
Break; 
Default: 
$idCon = 0; 
Break; 
} 
$this->idCon = $idCon; 
Return $idCon; 
} 
/************************************************************************************ 
*关闭数据库连接 
*************************************************************************************/ 
Function Close() 
{ 
Switch ($this->dbType) { 
Case "mssql": 
$r = mssql_close($this->idCon); 
Break; 
Case "mysql": 
$r = mysql_close($this->idCon); 
Break; 
Case "pg": 
$r = pg_close($this->idCon); 
Break; 
Default: 
$r = False; 
Break; 
} 
Return $r; 
} 
/************************************************************************************ 
*选择数据库 
*************************************************************************************/ 
Function SelectDb($dbName) 
{ 
Switch ($this->dbType) { 
Case "mssql": 
$r = mssql_select_db($dbName); 
Break; 
Case "mysql": 
$r = mysql_select_db($dbName); 
Break; 
Case "pg": 
$r = False; 
Break; 
Default: 
$r = False; 
Break; 
} 
Return $r; 
} 
/************************************************************************************ 
*创建查询 
*************************************************************************************/ 
Function Query($query) 
{ 
Switch ($this->dbType) { 
Case "mssql": 
$r = mssql_query($query, $this->idCon); 
Break; 
Case "mysql": 
$r = mysql_query($query, $this->idCon); 
Break; 
Case "pg": 
$r = pg_exec($this->idCon, $query); 
Break; 
Default: 
$r = False; 
Break; 
} 
$this->curRow[$r] = 0; 
$this->seek[$r] = 0; 
Return $r; 
} 
/************************************************************************************ 
*移动记录指针 
*************************************************************************************/ 
Function DataSeek($result, $RowNumber) 
{ 
Switch ($this->dbType) { 
Case "mssql": 
$r = mssql_data_seek($result, $RowNumber); 
Break; 
Case "mysql": 
$r = mysql_data_seek($result, $RowNumber); 
Break; 
Case "pg": 
$r = False; 
Break; 
Default: 
$r = False; 
Break; 
} 
$this->seek[$result] = (int) $RowNumber; 
Return $r; 
} 
/************************************************************************************ 
*获取字段名 
*************************************************************************************/ 
Function FieldName($result, $offset) 
{ 
Switch ($this->dbType) { 
Case "mssql": 
$r = mssql_field_name($result, $offset); 
Break; 
Case "mysql": 
$r = mysql_field_name($result, $offset); 
Break; 
Case "pg": 
$r = pg_fieldname($result, $offset); 
Break; 
Default: 
$r = False; 
Break; 
} 
Return $r; 
} 
/************************************************************************************ 
*获取字段类型 
*************************************************************************************/ 
Function FieldType($result, $offset) 
{ 
Switch ($this->dbType) { 
Case "mssql": 
$r = mssql_field_type($result, $offset); 
Break; 
Case "mysql": 
$r = mysql_field_type($result, $offset); 
Break; 
Case "pg": 
$r = pg_fieldtype($result, $offset); 
Break; 
Default: 
$r = False; 
Break; 
} 
Return $r; 
} 
/************************************************************************************ 
*获取字段长度 
*************************************************************************************/ 
Function FieldLength($result, $offset) 
{ 
Switch ($this->dbType) { 
Case "mssql": 
$r = mssql_field_length($result, $offset); 
Break; 
Case "mysql": 
$r = mysql_field_len($result, $offset); 
Break; 
Case "pg": 
$r = pg_fieldsize($result, $offset); 
Break; 
Default: 
$r = False; 
Break; 
} 
Return $r; 
} 
/************************************************************************************ 
*获取数据并保存到数组，可以用数字索引方式访问数组 
*************************************************************************************/ 
Function FetchRow($result, $RowNumber = 0) 
{ 
Switch ($this->dbType) { 
Case "mssql": 
$r = mssql_fetch_row($result); 
Break; 
Case "mysql": 
$r = mysql_fetch_row($result); 
Break; 
Case "pg": 
$r = pg_fetch_row($result, $RowNumber); 
If ($r) { 
$this->curRow[$result] = $RowNumber; 
$this->seek[$result] = $RowNumber; 
} 
Break; 
Default: 
$r = False; 
Break; 
} 
Return $r; 
} 
 
/************************************************************************************ 
*获取数据并保存到数组，可以用数字索引和关联索引的方式访问 
*************************************************************************************/ 
Function FetchArray($result, $RowNumber = 0, $ResultType = 2) 
{ 
Switch ($this->dbType) { 
Case "mssql": 
$r = mssql_fetch_array($result); 
Break; 
Case "mysql": 
$r = mysql_fetch_array($result); 
Break; 
Case "pg": 
$r = pg_fetch_array($result, $RowNumber, $ResultType); 
If ($r) { 
$this->curRow[$result] = $RowNumber; 
$this->seek[$result] = $RowNumber; 
} 
Break; 
Default: 
$r = False; 
Break; 
} 
Return $r; 
} 
/************************************************************************************ 
*获取数据并保存到对象 
*************************************************************************************/ 
Function FetchObject($result, $RowNumber = 0, $ResultType = 2) 
{ 
Switch ($this->dbType) { 
Case "mssql": 
$r = mssql_fetch_object($result); 
Break; 
Case "mysql": 
$r = mysql_fetch_object($result); 
Break; 
Case "pg": 
$r = pg_fetch_object($result, $RowNumber, $ResultType); 
If ($r) { 
$this->curRow[$result] = $RowNumber; 
$this->seek[$result] = $RowNumber; 
} 
Break; 
Default: 
$r = False; 
Break; 
} 
Return $r; 
} 
/************************************************************************************ 
*获取结果数据 
*************************************************************************************/ 
Function Result($result, $RowNumber, $FieldName) 
{ 
Switch ($this->dbType) { 
Case "mssql": 
$r = mssql_result($result, $RowNumber, $FieldName); 
Break; 
Case "mysql": 
$r = mysql_result($result, $RowNumber, $FieldName); 
Break; 
Case "pg": 
$r = pg_result($result, $RowNumber, $FieldName); 
Break; 
Default: 
$r = False; 
Break; 
} 
Return $r; 
} 
/************************************************************************************ 
*释放结果数据 
*************************************************************************************/ 
Function FreeResult($result) 
{ 
Switch ($this->dbType) { 
Case "mssql": 
$r = mssql_free_result($result); 
Break; 
Case "mysql": 
$r = mysql_free_result($result); 
Break; 
Case "pg": 
$r = pg_freeresult($result); 
Break; 
Default: 
$r = False; 
Break; 
} 
Return $r; 
} 
/************************************************************************************ 
*获取记录数量 
*************************************************************************************/ 
Function RowsNumber($result) 
{ 
Switch ($this->dbType) { 
Case "mssql": 
$r = mssql_num_rows($result); 
Break; 
Case "mysql": 
$r = mysql_num_rows($result); 
Break; 
Case "pg": 
$r = pg_numrows($result); 
Break; 
Default: 
$r = False; 
Break; 
} 
Return $r; 
} 
/************************************************************************************ 
*获取字段数量 
*************************************************************************************/ 
Function FieldsNumber($result) 
{ 
Switch ($this->dbType) { 
Case "mssql": 
$r = mssql_num_fields($result); 
Break; 
Case "mysql": 
$r = mysql_num_fields($result); 
Break; 
Case "pg": 
$r = pg_numfields($result); 
Break; 
Default: 
$r = False; 
Break; 
} 
Return $r; 
} 
/************************************************************************************ 
*获取当前记录号（从0开始） 
*************************************************************************************/ 
Function CurRecNumber($result) 
{ 
$r = $this->curRow[$result]; 
Return $r; 
} 
/************************************************************************************ 
*获取当前行号（从1开始） 
*************************************************************************************/ 
Function RecordNumber($result) 
{ 
$cr = $this->CurRecNumber($result) + 1; 
Return $cr; 
} 
/************************************************************************************ 
*移动到第一条记录 
*************************************************************************************/ 
Function MoveFirstRec($result) 
{ 
Switch ($this->dbType) { 
Case "pg": 
$r = $this->FetchRow($result, 0); 
Break; 
Default: 
$rn = $this->DataSeek($result, 0); 
If ($rn) { 
$r = $this->FetchRow($result); 
If ($r) $this->curRow[$result] = $this->seek[$result]; 
} Else { 
$r = False; 
} 
Break; 
} 
Return $r; 
} 
/************************************************************************************ 
*移动到最后一条记录 
*************************************************************************************/ 
Function MoveLastRec($result) 
{ 
$rs = $this->RowsNumber($result); 
If ($rs) { 
$rs--; 
Switch ($this->dbType) { 
Case "pg": 
$r = $this->FetchRow($result, $rs); 
Break; 
Default: 
$rn = $this->DataSeek($result, $rs); 
If ($rn) { 
$r = $this->FetchRow($result); 
If ($r) $this->curRow[$result] = $this->seek[$result]; 
} Else { 
$r = False; 
} 
Break; 
} 
} 
Return $r; 
} 
/************************************************************************************ 
*移动到前一条记录 
*************************************************************************************/ 
Function MovePreviousRec($result) 
{ 
$rs = $this->CurRecNumber($result); 
If ($rs) { 
$rs--; 
Switch ($this->dbType) { 
Case "pg": 
$r = $this->FetchRow($result, $rs); 
Break; 
Default: 
$rn = $this->DataSeek($result, $rs); 
If ($rn) { 
$r = $this->FetchRow($result); 
If ($r) $this->curRow[$result] = $this->seek[$result]; 
} Else { 
$r = False; 
} 
Break; 
} 
} 
Return $r; 
} 
/************************************************************************************ 
*移动到下一条记录 
*************************************************************************************/ 
Function MoveNextRec($result) 
{ 
$rs = $this->CurRecNumber($result); 
$rn = $this->RowsNumber($result); 
$rs++; 
If ($rs != $rn) { 
Switch ($this->dbType) { 
Case "pg": 
$r = $this->FetchRow($result, $rs); 
Break; 
Default: 
$re = $this->FetchRow($result); 
If ($re) { 
$r = $re; 
$this->curRow[$result]++; 
$this->seek[$result] = $this->curRow[$result]; 
} Else { 
$r = False; 
} 
Break; 
} 
} 
Return $r; 
} 
/************************************************************************************ 
*移动到指定记录（编号从0开始） 
*************************************************************************************/ 
Function MoveToRec($result, $RowNumber) 
{ 
$rn = $this->RowsNumber($result); 
If ($RowNumber > 0 And $RowNumber < $rn) { 
$RowNumber--; 
Switch ($this->dbType) { 
Case "pg": 
$r = $this->FetchRow($result, $RowNumber); 
Break; 
Default: 
$rn = $this->DataSeek($result, $RowNumber); 
If ($rn) { 
$r = $this->FetchRow($result); 
If ($r) $this->curRow[$result] = $this->seek[$result]; 
} Else { 
$r = False; 
} 
Break; 
} 
} 
Return $r; 
} 
} 
//********************************方法实现完毕****************************************// 
?>