php数据库连接类封装 php封装数据库操作

php中怎么把数据库连接写成一个接口

我自己封装的一个

成都网络公司-成都网站建设公司成都创新互联十载经验成就非凡，专业从事成都网站制作、成都网站设计，成都网页设计，成都网页制作，软文推广，广告投放平台等。十载来已成功提供全面的成都网站建设方案，打造行业特色的成都网站建设案例，建站热线：18980820575，我们期待您的来电！

?php

class AppConfig{

public static $dbParam = array(

'dbHost' = 'localhost',

'dbUser' = 'root',

'dbPassword' ='',

'dbName' = '数据库名',

'dbCharset' = 'utf8',

'dbPort' = 3306,

'dbPrefix' = 'test_',

'dbPconnect' = 0,

'dbDebug' = true,

);

}

class Model {

private $version = ''; //mysql版本

private $config = array(); //数据库配置数组

private $class; //当前类名

public $tablepre = 'ts_'; //表前缀

public $db = ''; //库名

public $table = ''; //表名

private static $link; //数据库链接句柄

private $data = array(); //中间数据容器

private $condition = ''; //查询条件

private $fields = array(); //字段信息

private $sql = array(); //sql集合，调试用

public $primaryKey = 'id'; //表主键

//构造函数初始化

public function __construct($dbParam = array()) {

$this-config = (is_array($dbParam) !empty($dbParam)) ? $dbParam : AppConfig::$dbParam;

$this-connect();

$this-init();

}

//链接数据库

private function connect() {

if($this-config['dbPconnect']) {

self::$link = @mysql_pconnect($this-config['dbHost'], $this-config['dbUser'], $this-config['dbPassword']);

}else{

self::$link = @mysql_connect($this-config['dbHost'], $this-config['dbUser'], $this-config['dbPassword'], true);

}

mysql_errno(self::$link) != 0 $this-errdie('Could not connect Mysql: ');

$this-db= !empty($this-db) ? $this-db : $this-config['dbName'];

$serverinfo = $this-version();

if ($serverinfo '4.1' $this-config['dbCharset']) {

mysql_query("SET character_set_connection=".$this-config['dbCharset'].",character_set_results=".$this-config['dbCharset'].",character_set_client=binary", self::$link);

}

if ($serverinfo '5.0') {

mysql_query("SET sql_mode=''", self::$link);

}

@mysql_select_db($this-db, self::$link) or $this-errdie('Cannot use database');

return self::$link;

}

//表基本信息初始化

protected function init() {

$this-class = get_class($this);

$this-table = !empty($this-table) ? $this-table : strtolower($this-class);

$this-table = $this-tablepre . $this-table;

return $this;

}

//设置属性值

public function __set($name, $value) {

//exit($value);

$this-data['fields'][$name] = $value;

}

//获取属性值

public function __get($name) {

if(isset($this-data['fields'][$name])) {

return($this-data['fields'][$name]);

}else {

return NULL;

}

}

//字段信息处理

private function implodefields($data) {

if (!is_array($data)) {

$data = array();

}

$this-fields = !empty($this-data['fields']) ? array_merge($this-data['fields'], $data) : $data;

foreach($this-fields as $key = $value) {

$fieldsNameValueStr[] = "`$key`='$value'";

$fieldsNameStr[] = "`$key`";

$fieldsValueStr[] = "'$value'";

}

return array($fieldsNameValueStr, $fieldsNameStr, $fieldsValueStr);

}

//条件判断组装

private function condition($where = NULL) {

if (is_numeric($where)) {

$where = "WHERE `{$this-primaryKey}`='{$where}' LIMIT 1";

}elseif (is_array($where)){

$where = "WHERE `{$this-primaryKey}` in (".implode(',',$where).")";

}elseif(!empty($this-data['condition'])){

//'预留WHERE', 'order', 'group', 'limit' …………等条件关键词处理接口

$where = $where ? "WHERE {$where}" : "WHERE 1";

isset($this-data['condition']['where']) $where .= ' AND '.$this-data['condition']['where'];

isset($this-data['condition']['group']) $where .= ' GROUP BY '.$this-data['condition']['group'];

isset($this-data['condition']['order']) $where .= ' ORDER BY '.$this-data['condition']['order'];

isset($this-data['condition']['limit']) $where .= ' LIMIT '.$this-data['condition']['limit'];

}else{

$where = "WHERE {$where}";

}

$this-condition = $where;

return $this;

}

//插入数据

public function insert($data = array(), $replace = false) {

$fields = $this-implodefields($data);

$insert = $replace ? 'REPLACE' : 'INSERT';

$sql = "{$insert} INTO `{$this-db}`.`{$this-table}` (".implode(', ',$fields[1]).") values (".implode(', ',$fields[2]).")";

$this-query($sql);

return $this-getInsertId();

}

//更新数据

public function update($data = array() ,$where = '') {

$numargs = func_num_args();

if ($numargs == 1) {

$where = $data;

$data = array();

}

$fields = $this-implodefields($data);

$this-condition($where);

$sql = "UPDATE `{$this-db}`.`{$this-table}` SET ".implode(', ',$fields[0])." {$this-condition}";

$this-query($sql);

return $this-getAffectedRows();

}

//删除数据

public function delete($where = NULL) {

if(!is_array($where) strtolower(substr(trim($where), 0, 6)) == 'delete'){

$sql = $where;

}else{

$this-condition($where);

$sql = "DELETE FROM `{$this-db}`.`{$this-table}` {$this-condition}";

}

$this-query($sql);

return $this-getAffectedRows();

}

//查询数据

public function select($where = NULL, $fields = '*') {

if(!is_array($where) strtolower(substr(trim($where), 0, 6)) == 'select'){

$sql = $where;

}else{

$this-condition($where);

$sql = "SELECT {$fields} FROM `{$this-db}`.`{$this-table}` {$this-condition}";

}

return $this-fetch($this-query($sql));

}

//查询一条数据

public function getOne($where, $fields = '*') {

$data = $this-select($where, $fields = '*');

if($data) {

return $data[0];

}

return array();

}

//查询多条数据

public function getAll($where, $fields = '*') {

$data = $this-select($where, $fields = '*');

return $data;

}

//结果数量

public function getCount($where = '', $fields = '*') {

$this-condition($where);

$sql = "SELECT count({$fields}) as count FROM `{$this-db}`.`{$this-table}` {$this-condition}";

$data = $this-query($sql);

if($data){

return @mysql_result($data,0);

}

return 0;

}

//执行sql语句（flag为0返回mysql_query查询后的结果，为1返回lastid，其他返回影响行数，默认为2返回影响行数）

public function query($sql, $flag = '0', $type = '') {

if ($this-config['dbDebug']) {

$startime = $this-microtime_float();

}

//查询

if ($type == 'UNBUFFERED' function_exists('mysql_unbuffered_query')) {

$result = @mysql_unbuffered_query($sql, self::$link);

} else {

//exit($sql);

$result = @mysql_query($sql, self::$link);

}

//重试

if (in_array(mysql_errno(self::$link), array(2006,2013)) empty($result) $this-config['dbPconnect']==0 !defined('RETRY')) {

define('RETRY',true); @mysql_close(self::$link); sleep(2);

$this-connect();

$result = $this-query($sql);

}

if ($result === false) {

$this-errdie($sql);

}

if ($this-config['dbDebug']) {

$endtime = $this-microtime_float();

$this-sql[] = array($sql,$endtime-$startime);

}

//清空操作数据

$this-data = array();

return $flag == '0' ? $result : ($flag == '1' ? $this-getInsertId() : $this-getAffectedRows());

}

//返回结果$onlyone为true返回一条否则返回所有,$type有MYSQL_ASSOC,MYSQL_NUM,MYSQL_BOTH

public function fetch($result, $onlyone = false, $type = MYSQL_ASSOC) {

if($result){

if ($onlyone) {

$row = @mysql_fetch_array($result, $type);

return $row;

}else{

$rowsRs = array();

while($row=@mysql_fetch_array($result, $type)) {

$rowsRs[] = $row;

}

return $rowsRs;

}

}

return array();

}

//可以运行SELECT，SHOW，EXPLAIN 或 DESCRIBE 等返回一个资源标识符的语句得到返回结果数组

public function show($sql, $onlyone = false) {

return $this-fetch($this-query($sql), $onlyone);

}

// 使用call函数处理同类型函数

private function __call($name, $arguments) {

$callArr = array('on', 'where', 'order', 'between', 'group', 'limit');

if (in_array($name, $callArr)) {

$this-data['condition'][$name] = $arguments[0];

}else{

$this-errdie("function error: function {$name} is not in ($this-class) class exist");

}

return $this;

}

//返回最后一次插入ID

public function getInsertId() {

return @mysql_insert_id(self::$link);

}

//返回受影响行数

public function getAffectedRows() {

return @mysql_affected_rows(self::$link);

}

//获取错误信息

private function error() {

return ((self::$link) ? @mysql_error(self::$link) : @mysql_error());

}

//获取错误信息ID

private function errno() {

return ((self::$link) ? @mysql_errno(self::$link) : @mysql_errno());

}

//获取版本信息

function version() {

if(empty($this-version)) {

$this-version = mysql_get_server_info(self::$link);

}

return $this-version;

}

//打印错误信息

private function errdie($sql = '') {

if ($this-config['dbDebug']) {

die('/BRBMySQL ERROR/B/BR

SQL:'.$sql.'/BR

ERRNO:'.$this-errno().'/BR

ERROR:'.$this-error().'/BR');

}

die('DB ERROR！！！');

}

//获取时间微妙数

private function microtime_float()

{

list($usec, $sec) = explode(" ", microtime());

return ((float)$usec + (float)$sec);

}

//析构函数

public function __destruct() {

echo 'hr';

$this-config['dbDebug'] print_r($this-sql);

//unset($this-result);

//unset($this-condition);

//unset($this-data);

}

}

class user extends Model {

//public $db = 'qsf_mvc';

//public $table = 'user';

public $primaryKey = 'uid';

}

$userObj = new user();

//---------------------------------------插入数据方法一-----------------------------------------

//模拟ActiveRecord模式 插入数据

$userObj-username = 'hoho';

$userObj-passwd = '1478522';

$userObj-email = 'qsf.z11@163.com';

$userObj-sex = 1;

$userObj-desc = '清洁工';

$insetId = $userObj-insert();

if ($insetId 0) {

echo "插入ID为:{$insetId}BR";

}

//---------------------------------------插入数据方法二-----------------------------------------

//直接数组做参数插入数据

$userArr = array(

'username' = 'hoho',

'passwd' = '1478522',

'email' = 'qsf.z2121ia@163.com',

'sex' = '1',

'desc' = '厨师',

);

$insetId = $userObj-insert($userArr);

if ($insetId 0) {

echo "插入ID为:{$insetId}BR";

}

//---------------------------------------更新数据方法一----------------------------------------

$userObj-username = 'h111oho';

$userObj-passwd = '1478511122';

$userObj-email = 'qsf111ia@163.com';

$userObj-sex = 1;

$userObj-desc = '清洁工';

$affectedRows1 = $userObj-update(89);

if ($affectedRows1 0) {

echo "影响行数为:{$affectedRows1}BR";

}

//---------------------------------------更新数据方法二----------------------------------------

//更新记录（传递参数的方式和insert操作一样）

$userArr = array(

'username' = 'hohoho',

'passwd' = '1474rr4448522',

'email' = 'qsf.rrza@165.com',

'sex' = '0',

'desc' = '厨师qq',

);

$affectedRows = $userObj-update($userArr, $insetId);

if ($affectedRows 0) {

echo "影响行数为:{$affectedRows}BR";

}

//----------------------------------------查询数据----------------------------------------------

$userRs0 = $userObj-select(8); //单个主键值

//print_r($userRs0);

$userRs1 = $userObj-select(array(1,5,8)); //多个主键值的数组

//print_r($userRs1);

$userRs2 = $userObj-select('select count(*) as count from user where uid 20'); //直接完整sql语句

//print_r($userRs2);

$userRs3 = $userObj-select("`uid` 0"); //where条件

//print_r($userRs3);

$userRs4 = $userObj-getOne("`uid` 0"); //获取单条记录

//print_r($userRs4);

$usersRs5 = $userObj-getAll("`uid` 0"); ////获取所有记录

//print_r($usersRs5);

$usersRs6 = $userObj-limit('0,10')-where('uid 100')-order('uid DESC')-group('username')-select();

//print_r($usersRs6);

//----------------------------------------删除数据-----------------------------------------------

//删除操作传递参数的方式和select操作一样

$userObj-delete(60); //单个主键值

$userObj-delete(array(1,5,8)); //多个主键值的数组

$userObj-delete('delete from user where uid 100'); //直接完整sql语句

$userObj-delete("`uid` 100"); //where条件

$userObj-limit('5')-where('uid 80')-delete();

//----------------------------------------特殊查询-----------------------------------------------

$userShowRs = $userObj-show('show create table user', true); //获取特殊查询的结果,第二个参数代表返回一条结果还是所有的结果

php封装一个class类实现mysql数据库的增删该查

?php

class db{

private $db;

const MYSQL_OPT_READ_TIMEOUT = 11;

const MYSQL_OPT_WRITE_TIMEOUT = 12;

private $tbl_name;

private $where;

private $sort;

private $fields;

private $limit;

public static $_instance = null;

function __construct(){

$cfg = loadConfig('db');

$db = mysqli_init();

$db-options(self::MYSQL_OPT_READ_TIMEOUT, 3);

$db-options(self::MYSQL_OPT_WRITE_TIMEOUT, 1);

@$db-real_connect($cfg['host'],$cfg['user'],$cfg['pwd'],$cfg['db']);

if ($db-connect_error) {

$this-crash($db-errno,$db-error);

}

$db-set_charset("utf8");

$this-db = $db;

//echo $this-db-stat;

}

public static function getInstance(){

if(!(self::$_instance instanceof self)){

self::$_instance = new self();

}

return self::$_instance;

}

private function __clone() {} //覆盖__clone()方法，禁止克隆

public function find($conditions = null){

if($conditions) $this-where($conditions);

return $this-getArray($this-buildSql(),1);

}

public function findAll($conditions = null){

if($conditions) $this-where($conditions);

return $this-getArray($this-buildSql());

}

//表

public function t($table){ $this-tbl_name = $table; return $this;}

//条件

public function where($conditions){

$where = '';

if(is_array($conditions)){

$join = array();

foreach( $conditions as $key = $condition ){

$condition = $this-db-real_escape_string($condition);

$join[] = "`{$key}` = '{$condition}'";

}

$where = "WHERE ".join(" AND ",$join);

}else{

if(null != $conditions) $where = "WHERE ".$conditions;

}

$this-where = $where;

return $this;

}

//排序

public function sort($sort){

if(null != $sort) $sort = "ORDER BY {$sort}";

$this-sort = $sort;

return $this;

}

//字段

public function fields($fields){ $this-fields = $fields; return $this; }

public function limit($limit){$this-limit = $limit; return $this;}

private function buildSql(){

$this-fields = empty($this-fields) ? "*" : $this-fields;

$sql = "SELECT {$this-fields} FROM {$this-tbl_name} {$this-where} {$this-sort}";

accessLog('db_access',$sql);

if(null != $this-limit)$sql .= " limit {$this-limit}";

return $sql;

}

/**

* 返回查询数据

* @param $sql

* @param bool $hasOne

* @return array|bool|mixed

*/

private function getArray($sql,$hasOne = false){

if($this-db-real_query($sql) ){

if ($result = $this-db-use_result()) {

$row = array();

if($hasOne){

$row = $result-fetch_assoc();

}else{

while($d = $result-fetch_assoc()) $row[] = $d;

}

$result-close();

$this-fields = "*";

return $row;

}else{

return false;

}

}else{

if($this-db-error){

$this-crash($this-db-errno,$this-db-error,$sql);

}

}

}

public function findSql($sql,$hasOne = false){

accessLog('db_access',$sql);

if($this-db-real_query($sql) ){

if ($result = $this-db-use_result()) {

$row = array();

if($hasOne){

$row = $result-fetch_assoc();

}else{

while($d = $result-fetch_assoc()) $row[] = $d;

}

$result-close();

$this-fields = "*";

return $row;

}else{

return false;

}

}else{

if($this-db-error){

$this-crash($this-db-errno,$this-db-error,$sql);

}

}

}

public function create($row){

if(!is_array($row))return FALSE;

$row = $this-prepera_format($row);

if(empty($row))return FALSE;

foreach($row as $key = $value){

$cols[] = '`'.$key.'`';

$vals[] = "'".$this-db-real_escape_string($value)."'";

}

$col = implode(',', $cols);

$val = implode(',', $vals);

$sql = "INSERT INTO `{$this-tbl_name}` ({$col}) VALUES ({$val})";

accessLog('db_access',$sql);

if( FALSE != $this-db-query($sql) ){ // 获取当前新增的ID

if($this-db-insert_id){

return $this-db-insert_id;

}

if($this-db-affected_rows){

return true;

}

}

return FALSE;

}

//直接执行sql

public function runSql($sql){

accessLog('db_access',$sql);

if( FALSE != $this-db-query($sql) ){ // 获取当前新增的ID

return true;

}else{

return false;

}

}

public function update($row){

$where = "";

$row = $this-prepera_format($row);

if(empty($row))return FALSE;

foreach($row as $key = $value){

$value = $this-db-real_escape_string($value);

$vals[] = "`{$key}` = '{$value}'";

}

$values = join(", ",$vals);

$sql = "UPDATE {$this-tbl_name} SET {$values} {$this-where}";

accessLog('db_access',$sql);

if( FALSE != $this-db-query($sql) ){ // 获取当前新增的ID

if( $this-db-affected_rows){

return true;

}

}

return false;

}

function delete(){

$sql = "DELETE FROM {$this-tbl_name} {$this-where}";

if( FALSE != $this-db-query($sql) ){ // 获取当前新增的ID

if( $this-db-affected_rows){

return true;

}

}

return FALSE;

}

private function prepera_format($rows){

$columns = $this-getArray("DESCRIBE {$this-tbl_name}");

$newcol = array();

foreach( $columns as $col ){

$newcol[$col['Field']] = $col['Field'];

}

return array_intersect_key($rows,$newcol);

}

//崩溃信息

private function crash($number,$message,$sql=''){

$msg = 'Db Error '.$number.':'.$message ;

if(empty($sql)){

echo t('db_crash');

}else{

$msg .= " SQL:".$sql;

echo t('db_query_err');

}

accessLog('db_error',$msg);

exit;

}

}

PHP中对数据库操作的封装，有什么好的例子吗

类文件mysql.class.php：

?php

class Mysql{

//数据库连接返回值

private $conn;

/**

* [构造函数，返回值给$conn]

* @param [string] $hostname [主机名]

* @param [string] $username[用户名]

* @param [string] $password[密码]

* @param [string] $dbname[数据库名]

* @param [string] $charset[字符集]

* @return [null]

*/

function __construct($hostname,$username,$password,$dbname,$charset='utf8'){

$config = @mysql_connect($hostname,$username,$password);

if(!$config){

echo '连接失败，请联系管理员';

exit;

}

$this-conn = $config;

$res = mysql_select_db($dbname);

if(!$res){

echo '连接失败，请联系管理员';

exit;

}

mysql_set_charset($charset);

}

function __destruct(){

mysql_close();

}

/**

* [getAll 获取所有信息]

* @param [string] $sql [sql语句]

* @return [array] [返回二维数组]

*/

function getAll($sql){

$result = mysql_query($sql,$this-conn);

$data = array();

if($result  mysql_num_rows($result)0){

while($row = mysql_fetch_assoc($result)){

$data[] = $row;

}

}

return $data;

}

/**

* [getOne 获取单条数据]

* @param [string] $sql [sql语句]

* @return [array] [返回一维数组]

*/

function getOne($sql){

$result = mysql_query($sql,$this-conn);

$data = array();

if($result  mysql_num_rows($result)0){

$data = mysql_fetch_assoc($result);

}

return $data;

}

/**

* [getOne 获取单条数据]

* @param [string] $table [表名]

* @param [string] $data [由字段名当键，属性当键值的一维数组]

* @return [type] [返回false或者插入数据的id]

*/

function insert($table,$data){

$str = '';

$str .="INSERT INTO `$table` ";

$str .="(`".implode("`,`",array_keys($data))."`) ";

$str .=" VALUES ";

$str .= "('".implode("','",$data)."')";

$res = mysql_query($str,$this-conn);

if($res  mysql_affected_rows()0){

return mysql_insert_id();

}else{

return false;

}

}

/**

* [update 更新数据库]

* @param [string] $table [表名]

* @param [array] $data [更新的数据，由字段名当键，属性当键值的一维数组]

* @param [string] $where [条件，‘字段名’=‘字段属性’]

* @return [type] [更新成功返回影响的行数，更新失败返回false]

*/

function update($table,$data,$where){

$sql = 'UPDATE '.$table.' SET ';

foreach($data as $key = $value){

$sql .= "`{$key}`='{$value}',";

}

$sql = rtrim($sql,',');

$sql .= " WHERE $where";

$res = mysql_query($sql,$this-conn);

if($res  mysql_affected_rows()){

return mysql_affected_rows();

}else{

return false;

}

}

/**

* [delete 删除数据]

* @param [string] $table [表名]

* @param [string] $where [条件，‘字段名’=‘字段属性’]

* @return [type] [成功返回影响的行数，失败返回false]

*/

function del($table,$where){

$sql = "DELETE FROM `{$table}` WHERE {$where}";

$res = mysql_query($sql,$this-conn);

if($res  mysql_affected_rows()){

return mysql_affected_rows();

}else{

return false;

}

}

}

?

使用案例:

?php

//包含数据库操作类文件

include 'mysql.class.php';

//设置传入参数

$hostname='localhost';

$username='root';

$password='123456';

$dbname='aisi';

$charset = 'utf8';

//实例化对象

$db = new Mysql($hostname,$username,$password,$dbname);

//获取一条数据

$sql = "SELECT count(as_article_id) as count FROM as_article where as_article_type_id=1";

$count = $db-getOne($sql);

//获取多条数据

$sql = "SELECT * FROM as_article where as_article_type_id=1 order by as_article_addtime desc limit $start,$limit";

$service = $db-getAll($sql);

//插入数据

$arr = array(

'as_article_title'='数据库操作类',

'as_article_author'='rex',

);

$res = $db-insert('as_article',$arr);

//更新数据

$arr = array(

'as_article_title'='实例化对象',

'as_article_author'='Lee',

);

$where = "as_article_id=1";

$res = $db-update('as_article',$arr,$where);

//删除数据

$where = "as_article_id=1";

$res = $db-del('as_article',$where);

?

求PHP数据库封装类操作代码

?php

class MySQL{

private $host; //服务器地址

private $name; //登录账号

private $pwd; //登录密码

private $dBase; //数据库名称

private $conn; //数据库链接资源

private $result; //结果集

private $msg; //返回结果

private $fields; //返回字段

private $fieldsNum; //返回字段数

private $rowsNum; //返回结果数

private $rowsRst; //返回单条记录的字段数组

private $filesArray = array(); //返回字段数组

private $rowsArray = array(); //返回结果数组

private $charset='utf8'; //设置操作的字符集

private $query_count=0; //查询结果次数

static private $_instance; //存储对象

//初始化类

private function __construct($host='',$name='',$pwd='',$dBase=''){

if($host != '') $this-host = $host;

if($name != '') $this-name = $name;

if($pwd != '') $this-pwd = $pwd;

if($dBase != '') $this-dBase = $dBase;

$this-init_conn();

}

//防止被克隆

private function __clone(){}

public static function getInstance($host='',$name='',$pwd='',$dBase=''){

if(FALSE == (self::$_instance instanceof self)){

self::$_instance = new self($host,$name,$pwd,$dBase);

}

return self::$_instance;

}

public function __set($name,$value){

$this-$name=$value;

}

public function __get($name){

return $this-$name;

}

//链接数据库

function init_conn(){

$this-conn=@mysql_connect($this-host,$this-name,$this-pwd) or die('connect db fail !');

@mysql_select_db($this-dBase,$this-conn) or die('select db fail !');

mysql_query("set names ".$this-charset);

}

//查询结果

function mysql_query_rst($sql){

if($this-conn == '') $this-init_conn();

$this-result = @mysql_query($sql,$this-conn);

$this-query_count++;

}

//取得字段数

function getFieldsNum($sql){

$this-mysql_query_rst($sql);

$this-fieldsNum = @mysql_num_fields($this-result);

}

//取得查询结果数

function getRowsNum($sql){

$this-mysql_query_rst($sql);

if(mysql_errno() == 0){

return @mysql_num_rows($this-result);

}else{

return '';

}

}

//取得记录数组（单条记录）

function getRowsRst($sql,$type=MYSQL_BOTH){

$this-mysql_query_rst($sql);

if(empty($this-result)) return '';

if(mysql_error() == 0){

$this-rowsRst = mysql_fetch_array($this-result,$type);

return $this-rowsRst;

}else{

return '';

}

}

//取得记录数组（多条记录）

function getRowsArray($sql,$type=MYSQL_BOTH){

!empty($this-rowsArray) ? $this-rowsArray=array() : '';

$this-mysql_query_rst($sql);

if(mysql_errno() == 0){

while($row = mysql_fetch_array($this-result,$type)) {

$this-rowsArray[] = $row;

}

return $this-rowsArray;

}else{

return '';

}

}

//更新、删除、添加记录数

function uidRst($sql){

if($this-conn == ''){

$this-init_conn();

}

@mysql_query($sql);

$this-rowsNum = @mysql_affected_rows();

if(mysql_errno() == 0){

return $this-rowsNum;

}else{

return '';

}

}

//返回最近插入的一条数据库的id值

function returnRstId($sql){

if($this-conn == ''){

$this-init_conn();

}

@mysql_query($sql);

if(mysql_errno() == 0){

return mysql_insert_id();

}else{

return '';

}

}

//获取对应的字段值

function getFields($sql,$fields){

$this-mysql_query_rst($sql);

if(mysql_errno() == 0){

if(mysql_num_rows($this-result) 0){

$tmpfld = @mysql_fetch_row($this-result);

$this-fields = $tmpfld[$fields];

}

return $this-fields;

}else{

return '';

}

}

//错误信息

function msg_error(){

if(mysql_errno() != 0) {

$this-msg = mysql_error();

}

return $this-msg;

}

//释放结果集

function close_rst(){

mysql_free_result($this-result);

$this-msg = '';

$this-fieldsNum = 0;

$this-rowsNum = 0;

$this-filesArray = '';

$this-rowsArray = '';

}

//关闭数据库

function close_conn(){

$this-close_rst();

mysql_close($this-conn);

$this-conn = '';

}

//取得数据库版本

function db_version() {

return mysql_get_server_info();

}

}

PHP访问MYSQL数据库封装类(附函数说明)

复制代码

代码如下:

?php

/*

MYSQL

数据库访问封装类

MYSQL

数据访问方式，php4支持以mysql_开头的过程访问方式，php5开始支持以mysqli_开头的过程和mysqli面向对象

访问方式，本封装类以mysql_封装

数据访问的一般流程：

1,连接数据库

mysql_connect

or

mysql_pconnect

2,选择数据库

mysql_select_db

3,执行SQL查询

mysql_query

4,处理返回的数据

mysql_fetch_array

mysql_num_rows

mysql_fetch_assoc

mysql_fetch_row

etc

*/

class

db_mysql

{

var

$querynum

=

;

//当前页面进程查询数据库的次数

var

$dblink

;

//数据库连接资源

//链接数据库

function

connect($dbhost,$dbuser,$dbpw,$dbname='',$dbcharset='utf-8',$pconnect=0

,

$halt=true)

{

$func

=

empty($pconnect)

?

'mysql_connect'

:

'mysql_pconnect'

;

$this-dblink

=

@$func($dbhost,$dbuser,$dbpw)

;

if

($halt

!$this-dblink)

{

$this-halt("无法链接数据库！");

}

//设置查询字符集

mysql_query("SET

character_set_connection={$dbcharset},character_set_results={$dbcharset},character_set_client=binary",$this-dblink)

;

//选择数据库

$dbname

@mysql_select_db($dbname,$this-dblink)

;

}

//选择数据库

function

select_db($dbname)

{

return

mysql_select_db($dbname,$this-dblink);

}

//执行SQL查询

function

query($sql)

{

$this-querynum++

;

return

mysql_query($sql,$this-dblink)

;

}

//返回最近一次与连接句柄关联的INSERT，UPDATE

或DELETE

查询所影响的记录行数

function

affected_rows()

{

return

mysql_affected_rows($this-dblink)

;

}

//取得结果集中行的数目,只对select查询的结果集有效

function

num_rows($result)

{

return

mysql_num_rows($result)

;

}

//获得单格的查询结果

function

result($result,$row=0)

{

return

mysql_result($result,$row)

;

}

//取得上一步

INSERT

操作产生的

ID,只对表有AUTO_INCREMENT

ID的操作有效

function

insert_id()

{

return

($id

=

mysql_insert_id($this-dblink))

=

?

$id

:

$this-result($this-query("SELECT

last_insert_id()"),

0);

}

//从结果集提取当前行，以数字为key表示的关联数组形式返回

function

fetch_row($result)

{

return

mysql_fetch_row($result)

;

}

//从结果集提取当前行，以字段名为key表示的关联数组形式返回

function

fetch_assoc($result)

{

return

mysql_fetch_assoc($result);

}

//从结果集提取当前行，以字段名和数字为key表示的关联数组形式返回

function

fetch_array($result)

{

return

mysql_fetch_array($result);

}

//关闭链接

function

close()

{

return

mysql_close($this-dblink)

;

}

//输出简单的错误html提示信息并终止程序

function

halt($msg)

{

$message

=

"html\nhead\n"

;

$message

.=

"meta

content='text/html;charset=gb2312'\n"

;

$message

.=

"/head\n"

;

$message

.=

"body\n"

;

$message

.=

"数据库出错：".htmlspecialchars($msg)."\n"

;

$message

.=

"/body\n"

;

$message

.=

"/html"

;

echo

$message

;

exit

;

}

}

?