php教程分享

  1. php教程首页
  2. php图像处理

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

•php图像处理•阅读 8696

一个数据库操作类（跨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

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

}

}

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

?>

赞 (0)
上一篇10-24
下一篇 2-27

相关推荐

  • 快速掌握 Mysql数据库对文件操作的封装

    快速掌握Mysql数据库对文件操作的封装快速掌握Mysql数据库对文件操作的封装在查看Mysql对文件的操作中，它在不同的操作系统上对文件的操作，除了使用标准C运行库函数，包括open、close、seek等，在Win32下的文件和目录操作…
    •Mysql
    2015-04-2820161

  • MSSQL清空日志删除日志文件

    MSSQL清空日志删除日志文件最近的项目主要做数据的归档，把数据从一个数据库拉到另一个数据库，造成新数据库的日志文件非常大;或者数据库在使用过程中会使日志文件不断增加，使得数据库的性能下降，并且占用大量的磁盘空间。于是想把日志文件删除。最简…
    •Mysql
    2015-05-274683

  • php操作mysql数据库的基本类

    php操作mysql数据库的基本类代码如下<?php$dbhost='localhost';$dbuser='root';$dbpass='123456';$dbname='products';$connect=mysql_conne…
    •php会话
    2015-06-0713363

  • mssql_data_seek()

    mssql_data_seek()mssql_data_seek移动列指针。语法:booleanmssql_data_seek(intresult_identifier,introw_number);返回值:布尔值函数种类:数据库功能内容说…
    •php上传下载
    2015-09-2819989

  • CI框架连接数据库配置操作以及多数据库操作

    CI框架连接数据库配置操作以及多数据库操作数据库快速入门例子代码下面的内容将简单说明怎样使用数据库。更详细的信息请阅读各个函数的单独介绍页面。初始化数据库类下面的代码将依据你的数据库配置载入并初始化数据库类:$this->load-&…
    •php面向对象
    2015-12-057829

  • MySQL数据库类的定义

    MySQL数据库类的定义俗话说“好的开始是成功的一半”，而PHP+MySQL项目中数据库的操作是重点之一，能否简化数据库操作程序的编写，就成了影响工作效率的关键之一。所以小阳并不是一开始就做页面，而是先建立一个“dbclass.php”文件…
    •Mysql
    2016-01-1117611

  • thinkphp3查询mssql数据库乱码解决方法

    thinkphp3查询mssql数据库乱码解决方法这篇文章主要介绍了thinkphp3查询mssql数据库乱码解决方法,需要的朋友可以参考下thinkphp查询mssql数据库出现乱码的原因是ThinkPHP默认为UTF-8，而msmsql…
    •php数组
    2016-02-0111938

  • codeigniter自带数据库类使用方法说明

    codeigniter自带数据库类使用方法说明在CodeIgniter中，使用数据库是非常频繁的事情。你可以使用框架自带的数据库类，就能便捷地进行数据库操作初始化数据库类依据你的数据库配置载入并初始化数据库类：代码如下:this->l…
    •Php 与 Smarty
    2016-05-016297