首页 手机软件 手机游戏 单机游戏 资讯文章 专题下载 游戏合集 文章合集 php下载 php教程 电脑软件
+ -
当前位置：首页 → 问答吧 → 一个数据库操作类（跨MYSQL，MSSQL，PG）

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

时间：2006-12-29

来源：互联网

类不是我写的，很多注释和索引都是我自己添加的，还蛮好用的。。
有需要的可以自己留着。。
复制PHP内容到剪贴板
PHP代码:

<?PHP
/**********************************************************************************
            此类将数据库操作封装，具有良好的可移植性,针对数据库：mysql,mssql,pg  
*原作者：Andrzej Manczyk 整理：玉面修罗  E-mail/msn:[email protected] 时间：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;
}

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

作者: 玉面修罗   发布时间: 2006-12-28

复制PHP内容到剪贴板
PHP代码:

<?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;
}
}
//********************************方法实现完毕****************************************// 
?>

作者: 玉面修罗   发布时间: 2006-12-28

抄代码也不容易啊！:) 顶一个！

作者: achievocrane   发布时间: 2006-12-28

呼呼！PHP开源万岁！

作者: 野草   发布时间: 2006-12-29

好东西大家一起分享...
我上面标明了原作者...

作者: 玉面修罗   发布时间: 2006-12-29

不错啊...:lol

作者: greenskys   发布时间: 2007-01-09

学习了。

作者: 特蓝克斯   发布时间: 2007-01-10

还不如写三个类,省的选择,要不open ,seek ,close每次都要选择，感觉麻烦

作者: yustar   发布时间: 2007-01-13

超强呀！

作者: huanghaibo   发布时间: 2007-01-17

引用:
原帖由 achievocrane 于 2006-12-28 23:59 发表
抄代码也不容易啊！:) 顶一个！
不管如何，现回复了

作者: 阳垭   发布时间: 2007-01-18

不错

作者: dzjzmj   发布时间: 2007-01-18

:):) 谢谢。。。。

作者: betterp   发布时间: 2007-01-31

引用:
原帖由 yustar 于 2007-1-13 23:49 发表
还不如写三个类,省的选择,要不open ,seek ,close每次都要选择，感觉麻烦
同意，这样的封装没意义
虽然我自己也这样写过  :P

作者: ysixin   发布时间: 2007-02-01

代码不错？但是我们新手怎么用呢？

作者: executive   发布时间: 2007-02-02

不错。学习ING~~~

作者: 绿竹居   发布时间: 2007-02-07

抄了,谢谢

作者: daihui   发布时间: 2007-03-14

顶

作者: heixiake   发布时间: 2007-03-15

晕，不用PDO代理，又在重复发明轮子的说:L :L
也不用抽象，继承实现，好像作者不知道PHP5，
但不管怎么样，作者还是一个比较善于总结的人，
而且胸怀宽广，支持开元事业

作者: godswlin   发布时间: 2007-03-29

好像没有防错措施哎,不知道运行会不会出现异常?

作者: linuxroot   发布时间: 2007-03-29

刚接触PHP的时候,觉得这个类写的很叼,一直都在想自己什么时候才能写出来这样的类,现在看着,觉得很垃圾..
我相信自己现在能写出比这个优秀得多的类..

作者: 玉面修罗   发布时间: 2007-03-29

php4的OO

作者: cymple   发布时间: 2007-03-30

引用:
原帖由 godswlin 于 2007-3-29 14:52 发表
晕，不用PDO代理，又在重复发明轮子的说:L :L
也不用抽象，继承实现，好像作者不知道PHP5，
但不管怎么样，作者还是一个比较善于总结的人，
而且胸怀宽广，支持开元事业
同意:要求用PDO代理

作者: aaxron   发布时间: 2007-03-30

是不是有错误呀Function Open($dbType, $c,:@  $connect, $username = "", $password = "")
If ($connectType:@  == "c") {

作者: heixiake   发布时间: 2007-04-03

作者这个类写的非常的早，那个时候肯定还没有PHP5，所以很难实现抽象化，多态等高级特性
在PHP4里面用对象编程真的是一件非常痛苦的事情。。

作者: 玉面修罗   发布时间: 2007-04-03

顶一下

作者: tianshenyi   发布时间: 2007-04-13

这个自己写

作者: h058   发布时间: 2007-04-16

引用:
原帖由 heixiake 于 2007-4-3 11:47 发表
是不是有错误呀Function Open($dbType, $c,:@  $connect, $username = "", $password = "")
If ($connectType:@  == "c") {
您真细心

作者: h058   发布时间: 2007-04-16

支持一下

作者: h058   发布时间: 2007-04-16

very good

作者: fyp83   发布时间: 2007-04-20

:D :D :D :D 爱上了mysqli!呵呵,没有没有封闭这个的

作者: goshawk   发布时间: 2007-04-28

太多的switch类型判断，完全浪费了多态的特性

至少这一个类可以拆成四个。
php4也可以继承啊。

作者: 书生   发布时间: 2007-04-29

作者: eoe2005   发布时间: 2007-04-30

中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!中国的程序员才能壮大!!

作者: silinwang   发布时间: 2007-04-30

支持下。收藏了！

作者: xiaoqiang527   发布时间: 2007-05-04

只连接mysal

作者: silinwang   发布时间: 2007-05-08

好东西 要顶

作者: blue5tar   发布时间: 2007-05-13

学习了~

作者: fly1983   发布时间: 2007-05-14

太过于复杂了`不用CLASS似乎更简单`

作者: jojobb313   发布时间: 2007-05-14

好像，好久前，顶过此帖。

再顶了！

作者: xiaoqiang527   发布时间: 2007-05-16

精神可嘉。。不过有一句话不得不说，“你根本不懂面向对象”。
建议楼主好好学学面向对象理论，再回过头来看看这些代码，呵呵。

作者: diogin   发布时间: 2007-05-17

太全了吧，其实用几个简单的就可以了，太全面反而觉得忙烦滴、

作者: leesunny   发布时间: 2007-11-04

鼓励原创精品！

作者: luzhou   发布时间: 2007-11-05

没有错误处理

作者: yuanjing_119   发布时间: 2008-03-19

yours?
really?

作者: lindatech   发布时间: 2008-03-19

慢慢看看

作者: tz66066   发布时间: 2008-03-19

刚接触PHP的时候弄的。菜鸟级作品。

作者: 玉面修罗   发布时间: 2008-03-20

顶

作者: tz66066   发布时间: 2008-03-22

顶！！！！！！

作者: sinan62   发布时间: 2008-03-28

作者: 七月十五   发布时间: 2008-03-29

相关阅读 更多

热门阅读

热门下载

更多
关于本站 免责申明 联系我们

Copyright 2006-2020 php爱好者(phpfans.net) All Rights Reserved.备案号：湘ICP备2023016114号-2

本站为非盈利性网站，不接受任何广告。本站所有资源均由网友上传，如有侵权，请发邮件至 [email protected] phpfans.net