MySQL数据库操作类

<?php
/* 数据库配置
return array(
'DB_CONFIG' => array(
//数据库配置
'DB_HOST'=>'127.0.0.1', //服务器地址
'DB_NAME' => 'tmp', // 数据库名
'DB_USER' => 'root', // 用户名
'DB_PWD' => '', // 密码
'DB_ENCODE'=>'utf8',//编码
'DB_PREFIX' => 'dmtx_' // 数据库表前缀
)
);
*/
classM
{

private$link; //数据库连接
private$table; //表名
private$prefix; //表前缀
private$db_config; //数据库配置
/**
* 参数:表名 数据库配置数组 或 数据库配置文件路径
* @param $table
* @param string $db_config_arr_path
*/
function__construct($table, $db_config_arr_path= 'config.php')
{
if(is_array($db_config_arr_path)) {
$this->db_config = $db_config_arr_path;
} else{
$this->db_config = require($db_config_arr_path);
}
$this->conn();
$this->table = $this->prefix . $table;
}

/**
* 连接数据库
*/
privatefunctionconn()
{
$db_config= $this->db_config;
$host= $db_config["DB_CONFIG"]["DB_HOST"];
$user= $db_config["DB_CONFIG"]["DB_USER"];
$pwd= $db_config["DB_CONFIG"]["DB_PWD"];
$db_name= $db_config["DB_CONFIG"]["DB_NAME"];
$db_encode= $db_config["DB_CONFIG"]["DB_ENCODE"];
$this->prefix = $db_config["DB_CONFIG"]["DB_PREFIX"];

$this->link = mysql_connect($host, $user, $pwd) ordie('数据库服务器连接错误:'. mysql_error());
mysql_select_db($db_name) ordie('数据库连接错误:'. mysql_error());
mysql_query("set names '$db_encode'");
}

/**
* 数据查询
* 参数:sql条件 查询字段 使用的sql函数名
* @param string $where
* @param string $field
* @param string $fun
* @return array
* 返回值:结果集 或 结果(出错返回空字符串)
*/
publicfunctionselect($where= '1', $field= "*", $fun= '')
{
$rarr= array();
if(emptyempty($fun)) {
$sqlStr= "select $field from $this->table where $where";
$rt= mysql_query($sqlStr, $this->link);
while($rt&& $arr= mysql_fetch_assoc($rt)) {
array_push($rarr, $arr);
}
} else{
$sqlStr= "select $fun($field) as rt from $this->table where $where";
$rt= mysql_query($sqlStr, $this->link);
if($rt) {
$arr= mysql_fetch_assoc($rt);
$rarr= $arr['rt'];
} else{
$rarr= '';
}
}
return$rarr;
}

/**
* 数据更新
* 参数:sql条件 要更新的数据(字符串 或 关联数组)
* @param $where
* @param $data
* @return bool
* 返回值:语句执行成功或失败,执行成功并不意味着对数据库做出了影响
*/
publicfunctionupdate($where, $data)
{
$ddata= '';
if(is_array($data)) {
while(list($k, $v) = each($data)) {
if(emptyempty($ddata)) {
$ddata= "$k='$v'";

} else{
$ddata.= ",$k='$v'";
}
}
} else{
$ddata= $data;
}
$sqlStr= "update $this->table set $ddata where $where";
returnmysql_query($sqlStr);
}

/**
* 数据添加
* 参数:数据(数组 或 关联数组 或 字符串)
* @param $data
* @return int
* 返回值:插入的数据的ID 或者 0
*/
publicfunctioninsert($data)
{
$field= '';
$idata= '';
if(is_array($data) && array_keys($data) != range(0, count($data) - 1)) {
//关联数组
while(list($k, $v) = each($data)) {
if(emptyempty($field)) {
$field= "$k";
$idata= "'$v'";
} else{
$field.= ",$k";
$idata.= ",'$v'";
}
}
$sqlStr= "insert into $this->table($field) values ($idata)";
} else{
//非关联数组 或字符串
if(is_array($data)) {
while(list($k, $v) = each($data)) {
if(emptyempty($idata)) {
$idata= "'$v'";
} else{
$idata.= ",'$v'";
}
}

} else{
//为字符串
$idata= $data;
}
$sqlStr= "insert into $this->table values ($idata)";
}
if(mysql_query($sqlStr,$this->link))
{
returnmysql_insert_id($this->link);
}
return0;
}

/**
* 数据删除
* 参数:sql条件
* @param $where
* @return bool
*/
publicfunctiondelete($where)
{
$sqlStr= "delete from $this->table where $where";
returnmysql_query($sqlStr);
}

/**
* 关闭MySQL连接
* @return bool
*/
publicfunctionclose()
{
returnmysql_close($this->link);
}

}

<?php

require'Query/M.class.php';

$hj= newM("user");
//增
echo$hj->insert(array("NULL","1@qq.com","xxx"));
echo$hj->insert(array("email"=>"12@qq.com","password"=>"cccc"));
echo$hj->insert("NULL,'123@qq.com','cde'");

//查
//查看所有数据
$arr= $hj->select();
print_r($arr);
//查看id大于3且id小于6 的id 和email 字段 的所有数据
$arr= $hj->select("id>3 and id<6","id,email");
print_r($arr);
//获取数据库中一共有多少条记录
$rt= $hj->select("1","*","count");
echo$rt;

// 改
$b= $hj->update("id=1","email = '1234@qq.com'");
echo$b;
$b= $hj->update("id>3 and id<6",array("email"=>"1234@qq.com"));
echo$b;

// 删
$b= $hj->delete("id>3");
echo$b;

//关闭
$hj->close();