« PHP格式化输出文本区

PHP操作access实例 »

mysql mssql pq的数据库操作类

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;
}

//........................下面接
?>




<?php
//.........接上面
/
*获取数据并保存到数组，可以用数字索引和关联索引的方式访问
*/
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;
}
}
?>

加入收藏 PHP中文手册 PHP论坛 查看全部回复 关闭此页