使用过ThinkPHP框架的同学可能会对于其中数据库模型操作特别有好感,ThinkPHP提供了数据库操作的简单的操作,对于连接数据库,数据库的增删改查等数据操作都非常的nice,同时支持连贯操作,对于那些不习惯写sql语句的同学真是大大的便利。(注:sql还是很重要的,不要因为用了框架就把原先的忘了)。
而在笔者使用php操作redis实现后台任务的过程中,也想要借助这种便利,但无奈redis操作单独的类,直接访问其中的controller文件的话,总是会提示M方法失败,导致此模型方法不能使用。万般无奈之下,只能自己来实现一下了。
借助PHP的mysqli相关函数,进行MySQL数据库操作类的实现。此程序中提供数据库的操作包括:数据库的连接,数据库的选择,数据库用户的选择,相应数据库中所有数据表名的查看;数据表的操作包括:相应的数据表中字段全部属性的查看,数据表的增删改查操作,数据表查询、插入的连贯操作等
/**
* Author: helen
* CreateTime: 2016/4/12 20:14
* description: 数据库操作类(仅对接MySQL数据库,主要利用MySQLi函数)
*/classDatabase{//MySQL主机地址private$_host;
//MySQL用户名private$_user;
//MySQL用户密码private$_password;
//指定数据库名称private$_database;
//MySQL数据库端口号private$_port;
private$_socket;
//当前数据库对象private$_dbObj;
//数据库表private$_table;
//数据库表对象private$_tableObj;
// 最近错误信息protected$error = '';
// 数据信息protected$data = array();
// 查询表达式参数protected$options = array();
protected$_validate = array(); // 自动验证定义protected$_auto = array(); // 自动完成定义protected$_map = array(); // 字段映射定义protected$_scope = array(); // 命名范围定义// 链操作方法列表protected$methods = array('strict','order','alias','having','group','lock','distinct','auto','filter','validate','result','token','index','force');
/**
* Database类初始化函数
* 取得DB类的实例对象 字段检查
* @access public
* @param string $host MySQL数据库主机名
* @param string $user MySQL数据库用户名
* @param string $password MySQL数据库密码
* @param string $database 指定操作的数据库
* @return mixed 数据库连接信息、错误信息
*/publicfunction__construct($host,$user,$passowrd,$database,$port=3306){$this->_initialize();
if(!isset($host)||!isset($user)||!isset($passowrd)||!isset($database)){
returnfalse;
}else{
$this->_host = $host;
$this->_user = $user;
$this->_password = $passowrd;
$this->_database = $database;
$this->_port = $port;
$_dbObj = new mysqli($host,$user,$passowrd,$database,$port);
if($_dbObj->connect_errno){
$this->error = $_dbObj->connect_error;
returnfalse;
}else{
$this->_dbObj = $_dbObj;
return$this;
}
}
}
/**
* 错误信息函数
* 返回数据库操作过程中最后一次执行时的错误信息
* @access public
* @return mixed 数据库连接错误信息(正常返回'')
*/publicfunctionerror(){return$this->error;
}
// 回调方法 初始化模型protectedfunction_initialize() {}
/**
* 设置数据对象的值
* @access public
* @param string $name 名称
* @param mixed $value 值
* @return void
*/publicfunction__set($name,$value) {// 设置数据对象属性$this->data[$name] = $value;
}
/**
* 获取数据对象的值
* @access public
* @param string $name 名称
* @return mixed
*/publicfunction__get($name) {returnisset($this->data[$name])?$this->data[$name]:null;
}
/**
* 检测数据对象的值
* @access public
* @param string $name 名称
* @return boolean
*/publicfunction__isset($name) {returnisset($this->data[$name]);
}
/**
* 销毁数据对象的值
* @access public
* @param string $name 名称
* @return void
*/publicfunction__unset($name) {unset($this->data[$name]);
}
/**
* 利用__call方法实现一些特殊的方法(对于调用类中不存在方法的解决方案)
* @access public
* @param string $method 方法名称
* @param array $args 调用参数
* @return mixed
*/publicfunction__call($method,$args) {/*if(in_array(strtolower($method),$this->methods,true)) {
// 连贯操作的实现
$this->options[strtolower($method)] = $args[0];
return $this;
}elseif(in_array(strtolower($method),array('count','sum','min','max','avg'),true)){
// 统计查询的实现
$field = isset($args[0])?$args[0]:'*';
return ;
}elseif(strtolower(substr($method,0,5))=='getby') {
// 根据某个字段获取记录
$field = parse_name(substr($method,5));
$where[$field] = $args[0];
return ;
}elseif(strtolower(substr($method,0,10))=='getfieldby') {
// 根据某个字段获取记录的某个值
$name = parse_name(substr($method,10));
$where[$name] =$args[0];
return ;
}elseif(isset($this->_scope[$method])){// 命名范围的单独调用支持
return ;
}else{
}*/
}
/*
* 选择数据库
* @access public
* @param string $database 选择的数据库名称
* @return mixed 数据库连接信息
* */publicfunctionselect_db($database){$select_db = mysqli_select_db($this->_dbObj,$database);
if($select_db){
$this->_database = $database;
$_dbObj = new mysqli($this->_host,$this->_user,$this->_password,$database,$this->_port);
$this->_dbObj = $_dbObj;
return$this;
}else{
$this->error = mysqli_error($this->_dbObj);
returnfalse;
}
}
/*
* 数据库用户更换
* @access public
* @param string $user 数据库用户名称
* @param string $password 数据库用户密码
* @return mixed 数据库连接信息
* */publicfunctionchange_user($user,$password){$change_user = mysqli_change_user($this->_dbObj,$user,$password,$this->_database);
if($change_user){
$this->_user = $user;
$this->_password = $password;
$_dbObj = new mysqli($this->_host,$this->_user,$this->_password,$this->_database,$this->_port);
$this->_dbObj = $_dbObj;
return$this;
}else{
$this->error = mysqli_error($this->_dbObj);
returnfalse;
}
}
/*
* 查询数据库中所有的表名
* @access public
* @return array 数据表的数量和表名
* */publicfunctiontables(){$sql = 'show tables';
$search_res = mysqli_query($this->_dbObj,$sql);
if($search_res){
$num_rows = $search_res->num_rows;
$tables_msg = array(
'count'=>$num_rows,
'tables'=>array()
);
for($i=0;$i$num_rows;$i++){
$row = $search_res->fetch_assoc();
$key = 'Tables_in_'.$this->_database;
array_push($tables_msg['tables'],$row[$key]);
}
mysqli_free_result($search_res);
return$tables_msg;
}else{
mysqli_free_result($search_res);
returnfalse;
}
}
/*
* 获取指定表中所有信息
* @access public
* @param string $table 数据表名称
* @return array 数据表的详细信息
* */publicfunctionselect_table($table){$sql = 'select * from '.$table;
$search_res = mysqli_query($this->_dbObj,$sql);
if($search_res){
$this->_table = $table;
$table_msg = self::query_handle($search_res);
$this->_tableObj = $table_msg;
mysqli_free_result($search_res);
return$table_msg;
}else{
mysqli_free_result($search_res);
returnfalse;
}
}
/*
* 获取指定表的字段详细信息
* @access public
* @param string $table 数据表名称
* @return array 数据表的字段详细信息
* */publicfunctionselect_table_fields($table){$sql = 'show fields from '.$table;
$search_res = mysqli_query($this->_dbObj,$sql);
if($search_res){
$this->_table = $table;
$fields_msg = self::query_handle($search_res);
mysqli_free_result($search_res);
return$fields_msg;
}else{
mysqli_free_result($search_res);
returnfalse;
}
}
/*
* 获取数据表中指定字段信息(允许多字段同时查询)
* @access public
* @param mixed $field 指定字段(字符串传入使用,间隔)
* @return array 数据表中指定字段信息
* */publicfunctiongetField($field){$fields = self::param_handle($field);
$count = count($fields);
for($i=0;$i$count;$i++){
$index = $fields[$i];
$sql = 'select '.$index.' from '.$this->_table;
$res = mysqli_query($this->_dbObj,$sql);
$field_msg[$index] = self::query_handle($res);
}
return$field_msg;
}
/*
* mysqli_query函数结果处理函数
* @access protected
* @param object $obj mysqli_query函数结果
* @return array 数据表中指定字段信息
* */protectedfunctionquery_handle($obj){$res = array();
for($i=0;$i$obj->num_rows;$i++){
$row = $obj->fetch_assoc();
array_push($res,$row);
}
return$res;
}
/*
* 传入参数处理函数
* @access protected
* @param mixed $param 传入参数
* @return array 处理后数组数据
* */publicfunctionparam_handle($param){if(is_string($param)&&!empty($param)){
$params = explode(',',$param);
}elseif(is_array($param)&&!empty($param)){
$params = $param;
}else{
returnfalse;
}
return$params;
}
/*
* 查询表达式参数处理函数
* @access protected
* @param mixed $param 传入参数(where limit order)
* @return string 处理后字符串数据
* */publicfunctionoptions_handle($param){if(is_numeric($param)){
$option = $param;
}elseif(is_string($param)&&!empty($param)&&!is_numeric($param)){
$params = explode(',',$param);
$count = count($params);
$option = implode(' and ',$params);
}elseif(is_array($param)&&!empty($param)){
$params = $param;
$count = count($params);
$arr = array();
foreach($paramas$key=>$value){
$tip = "$key=$value ";
array_push($arr,$tip);
}
$option = implode(' and ',$arr);
}else{
returnfalse;
}
return$option;
}
/*
* 查询表达式$options处理函数
* @access protected
* @return string 处理后字符串数据
* */protectedfunctionoption(){$options = $this->options;
$option = '';
if(isset($options['where'])){
$option .= 'where '.$options['where'].' ';
}
if(isset($options['order'])){
$option .= 'order by '.$options['order'].' '.$options['order_type'].' ';
}
if(isset($options['limit'])){
$option .= 'limit '.$options['limit'];
}
return$option;
}
/*
* 根据查询表达式查询数据(符合条件的所有记录)
* @access public
* @return array 满足查询表达式的特定数据
* */publicfunctionfind(){$option = self::option();
$sql = 'select * from '.$this->_table.' '.$option;
$search_res = mysqli_query($this->_dbObj,$sql);
$msg = self::query_handle($search_res);
return$msg;
}
/*
* 查询表达式 where处理函数
* @access public
* @param mixed $where where查询条件
* @return object $this
* */publicfunctionwhere($where){$this->options['where'] = self::options_handle($where);
return$this;
}
/*
* 查询表达式 limit处理函数
* @access public
* @param mixed $limit limit查询条件(数字)
* @return object $this
* */publicfunctionlimit($limit){$this->options['limit'] = self::options_handle($limit);
return$this;
}
/*
* 查询表达式 order处理函数
* @access public
* @param string $order order查询条件
* @param string $type order查询条件的顺序(默认降序)
* @return object $this
* */publicfunctionorder($order,$type='desc'){$this->options['order'] = $order;
$this->options['order_type'] = $type;
return$this;
}
/*
* 数据处理函数(最多处理二维数据)
* @access public
* @param array $data 需要插入的数据
* @return object $this
* */publicfunctiondata(array $data){$values = array();
$fields = array();
if(is_array($data)){
foreach($dataas$key=>$value){
if(is_array($value)){ //二维数组$tip = 1;
array_push($values,'('.implode(',',array_values($value)).')');
array_push($fields,'('.implode(',',array_keys($value)).')');
}else{ //一维数组$tip = 0;
}
}
}else{
returnfalse;
}
if(!$tip){
array_push($values,'('.implode(',',array_values($data)).')');
array_push($fields,'('.implode(',',array_keys($data)).')');
}
$this->data['fields'] = $fields[0];
$this->data['values'] = implode(',',$values);
return$this;
}
/*
* 数据新增函数
* @access public
* @return mixed 数据库新增信息
* */publicfunctionadd(){$fields = $this->data['fields'];
$values = $this->data['values'];
$sql = 'INSERT INTO '.$this->_table.$fields.'VALUES'.$values;
$res = mysqli_query($this->_dbObj,$sql);
return$res;
}
/*
* 数据更新函数(一维数组)
* @access public
* @param array $data 需要更新的数据
* @return mixed 数据库新增信息
* */functionsave(array $data){$tip = array();
if(is_array($data)){
foreach($dataas$key=>$value){
array_push($tip,"$key=$value");
}
}else{
returnfalse;
}
$set_msg = implode(',',$tip);
$sql = 'UPDATE '.$this->_table.' SET '.$set_msg.' WHERE '.$this->options['where'];
$res = mysqli_query($this->_dbObj,$sql);
return$res;
}
/*
* 数据删除函数
* @access public
* @return mixed 数据库删除信息
* */publicfunctiondelete(){$sql = 'DELETE FROM '.$this->_table.' WHERE '.$this->options['where'];
$res = mysqli_query($this->_dbObj,$sql);
return$res;
}
/*
* SQL语句查询
* */publicfunctionquery($sql){$search_res = mysqli_query($this->_dbObj,$sql);
return$search_res;
}
/*
* mysql中查询语句
* */protectedfunctionsql(){/*
* 基本SQL语句
* 插入数据:INSERT INTO tb_name(id,name,score)VALUES(NULL,'张三',140),(NULL,'张四',178),(NULL,'张五',134);
* 更新语句:UPDATE tb_name SET score=189 WHERE id=2;
* 删除数据:DELETE FROM tb_name WHERE id=3;
* WHERE语句:SELECT * FROM tb_name WHERE id=3;
* HAVING 语句:SELECT * FROM tb_name GROUP BY score HAVING count(*)>2
* 相关条件控制符:=、>、、IN(1,2,3......)、BETWEEN a AND b、NOT AND 、OR Linke()用法中 % 为匹配任意、 _ 匹配一个字符(可以是汉字)IS NULL 空值检测
* MySQL的正则表达式:SELECT * FROM tb_name WHERE name REGEXP '^[A-D]' //找出以A-D 为开头的name
* */
}
/*
* 关闭连接
* */publicfunctionclose(){$close = mysqli_close($this->_dbObj);
if($close){
returntrue;
}else{
returnfalse;
}
}
function__destruct(){
mysqli_close($this->_dbObj);
}
}
操作示例:
首先实例化此类,其中需要输入host(数据库地址)、user(数据库用户)、password(数据库用户密码)、database(数据库名称)此四种信息,进行数据库的连接,然后即可调用select_table()方法,其中传入数据表名,从而设置对指定表的操作,从而即可利用连贯操作进行相应数据的增删改查。 其中参数基本均支持字符串和数组两种形式。
include '/classes/db.php';
$db = new \Database('localhost', 'root', '901230', 'weixin');
//$db = new \mysqli('localhost','root','901230','weixin');
//$db->select_db('visitor');
//dump($db->error());
//$db->change_user('helen','901230');
$table = 'zyd_fuweng_user';
//dump($db->select_table_fields($table));
//dump($db->error());
$db->select_table($table);
$param1 = '123';
$param2 = 'id>1,record>100';
$param3 = array(
/*array('count'=>1,'openid'=>'123','record'=>'100'),
array('count'=>2,'openid'=>'234','record'=>'200'),*/
array('count' => 4, 'openid' => '456', 'record' => '500')
);
$param4 = array('count' => 4, 'openid' => '456', 'record' => '500');
//dump($db->where('id=4')->save($param4));
dump($db->where('count=4')->delete());
die;
dump($db->data($param3)->add());
dump(array_keys($param3));
dump(array_values($param3));
dump(implode(',', array_values($param3)));
dump(implode(',', array_keys($param3)));
dump($db->where($param2)->order('id')->limit(2)->find());
dump($db->options_handle($param1));
dump($db->options_handle($param2));
dump($db->options_handle($param3));
$array = array('id', 'count');
$num = '123';
if (is_string($num)) {
echo'true';
}
dump($db->getField($array));
dump($db->select_table_fields($table));
/*$array = array('a','b');
$array1 = array();
dump($db->getField('a,b'));
dump($db->getField($array));
dump($db->getField($array1));
dump($db->getField(''));*/
/*$str = '';
if(empty($str)){
echo'true';
}*/
/*$model = M('zyd_fuweng_user');
$res = $model->getField('create_time,count');
dump($res);*/
die;
//
$table = 'zyd_fuweng_user';
//选择指定的数据库,并返回其中全部信息
$table_msg = $db->select_table($table);
//选择指定数据库,返回数据库的字段信息
$table_field_msg = $db->select_table_fields($table);
//条件搜索,传入条件均为数据
$where = array(
'id' => 1
);
$data = array(
'headimgurl' => 'helen.jpg'
);
dump($db->where($where)->field('field'));
dump($table);
/*$dbObj = new \mysqli('localhost','helen','901230','weixin','3306');
//$query = 'select * from zyd_fuweng_user';
$query = 'show fields from zyd_fuweng_user';
$tables = mysqli_query($dbObj,$query);
//dump($tables);
$count = $tables->num_rows;
$arr = array();
for($i=0;$i$count;$i++){
$row = $tables->fetch_assoc();
//dump($row);
array_push($arr,$row);
}
mysqli_free_result($tables);
dump($arr);
die;
$query1 = 'select * from zyd_fuweng_user';
$table_msg = mysqli_query($dbObj,$query1);
//输出查询结果
$num = $table_msg->num_rows;
for($i=0;$i$num;$i++){
$row = $table_msg->fetch_assoc();
dump($row);
}
dump($dbObj);
dump($tables);
dump($table_msg);
$res = mysqli_close($dbObj);
dump($res);*/
').addClass('pre-numbering').hide();
$(this).addClass('has-numbering').parent().append($numbering);
for (i = 1; i ').text(i));
};
$numbering.fadeIn(1700);
});
});
以上就介绍了MySQL数据库操作类PHP实现,支持连贯操作,包括了Mysql数据库方面的内容,希望对PHP教程有兴趣的朋友有所帮助。
已抢140827个
抢已抢4598个
抢已抢7182个
抢已抢12260个
抢