loading...

一个数据库操作类（跨MYSQL，MSSQL，PG）

发布时间：December 23, 2006 分类：PHP

《很强的PHP图片处理类》

《Phpwind被黑事件》

// -函数清单 索引：
// - 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

< ?PHP

/**********************************************************************************

            此类将数据库操作封装，具有良好的可移植性,针对数据库：mysql,mssql,pg  

*原作者：Andrzej Manczyk 整理：玉面修罗  E-mail/msn:xiuluo-999@163.com 时间：2006-12-20*        

************************************************************************************

// -函数清单                                                    索引：

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

}

}

//********************************方法实现完毕****************************************// 

?>

Tags: MySQL, PHP类, 数据库操作, MsSQL, PostgreSQL

版权声明：原创作品，欢迎转载，转载时请务必以超链接形式标明文章原始地址、作者信息和本声明。

已有 3 条评论 »

  1. John John

    顶一个~~

    回复
  2. french french

    为何不用工厂模式。。
    每一类数据库写一个CLASS。。然后用一个来配置文件来配置使用的数据库。再写一个工厂函数。读取配置文件中的数据库格式。再new一个数据库CLASS。。再调用其它的方法。。比用switch要好一点吧（个人愚见）

    回复
  3. yum1a0 yum1a0

    french胸说的是EZ么?

    回复

添加新评论 »

captcha
请输入验证码