<?php
/**
* Created by PhpStorm.
* User: Sudo
* Date: 2017/7/11
* Time: 20:22
*/
//设置编码格式(防止乱码)
header("Content-type: text/html; charset=utf-8");
// 1 同壹个类,方法和变量必须加$this->变量/方法,但参数不需要
// 2 变量定义必须加上权限修饰符(封装)
// 3 常量定义 const 不需要加权限修饰符和$
// 4 类中的构造函数只能有一个
class Tools {
private $link = null;
function __construct(){
$this->connectDB();
}
function connectDB(){
$this ->link = mysqli_connect("localhost","root","root")
or die($this -> link = null);
if(!mysqli_select_db($this->link,"queen")){
$this ->link = null;
}
}
//查询数据库
// @param $tableNmae 要求传string类型的值 表名
// @param $col 默认为* 要求传array类型的值 列名
// @param $where 默认为"" 要求传array类型的值 条件
function selectDB($tableName,$col = "*",$where = ""){
//若数据库连接标识符为空则尝试继续连接数据库
if($this ->link == null){
$this -> connectDB();
//return "error";
}
//根据传递的数组元素拼接查询的字段
$cols = "";
if($col == "*"){
$cols = "*";
}else{
for($i = 0,$ilen = count($col);$i<$ilen;$i++){
//最后一个数组元素不拼接逗号
if($i < $ilen -1){
$cols = $cols.$col[$i].",";
continue;
}
$cols = $cols.$col[$i];
}
}
//根据传递的数组元素拼接查询的条件
$whereTemp == "";
if($where == ""){
$whereTemp == "";
}else{
for($i = 0,$ilen = count($where);$i<$ilen;$i++){
if($i < $ilen -1){
$whereTemp = $whereTemp.$where[$i].",";
continue;
}
$whereTemp = $whereTemp.$where[$i];
}
}
//构建sql语句
$sql = "";
if($whereTemp == ""){
//如果查询条件为空则不加条件
$sql = "select ".$cols." from ".$tableName;
}else{
//有查询条件时加上查询条件
$sql = "select ".$cols." from ".$tableName." where ".$whereTemp;
}
//执行查询语句返回结果集
$result = mysqli_query($this->link,$sql);
//关闭数据库
mysqli_close($this->link);
//如果刚才查询语句执行错误则返回error,否则返回查询的结果
if(mysqli_affected_rows($this->link) < 0){
return "error";
}else{
$arr = array();
//将查询结果存入数组$row中,再将$row添加到$arr数组中并返回
while($row = mysqli_fetch_row($result)){
array_push($arr, $row);
}
return $arr;
}
}
//插入数据到数据库表中
//参数一:表名$tableName,字符串
//参数二:字段名$arrCols,数组
//参数三:字段值$arrValues,数组
function insertDB($tableName,$arrCols,$arrValues){
if($this ->link == null){
$this -> connectDB();
}
//根据数组元素拼接要插入的字段名
$tempCols = "(";
for($i = 0,$ilen = count($arrCols);$i<$ilen;$i++){
if($i < $ilen -1){
$tempCols = $tempCols.$arrCols[$i].",";
continue;
}
$tempCols = $tempCols.$arrCols[$i];
}
$tempCols = $tempCols.")";
//根据数组元素拼接要插入的字段值
$tempValues = "(";
for($i = 0,$ilen = count($arrValues);$i<$ilen;$i++){
if($i < $ilen -1){
//如果插入表中的字段值是字符串则直接插入相应字段,否则转换成字符串再插入,最后一个字段值不拼接逗号
if(is_string($arrValues[$i])){
$tempValues = $tempValues."'".$arrValues[$i]."'".",";
}else{
$tempValues = $tempValues.$arrValues[$i].",";
}
continue;
}
if(is_string($arrValues[$i])){
$tempValues = $tempValues."'".$arrValues[$i]."'";
}else{
$tempValues = $tempValues.$arrValues[$i];
}
}
$tempValues = $tempValues.")";
//构建sql插入语句并执行该语句
$sql = "insert into ".$tableName. $tempCols." values".$tempValues;
mysqli_query($this->link,$sql);
//如果刚才的插入语句影响的纪录行数大于零,说明插入成功,关闭数据库并返回true,否则返回false
if(mysqli_affected_rows($this->link) > 0){
mysqli_close($this->link);
return true;
}else{
mysqli_close($this->link);
return false;
}
}
//更新数据库纪录
//参数一:表名$tableName,字符串
//参数二:字段名$colrows,数组
//参数三:字段值$values,数组
//参数四:作为更新依据的某一个特定字段名和字段值$where,字符串
function updateDB($tableName,$colrows,$values,$where){
if($this->link == null){
$this ->connectDB();
}
$str = "";
for($i = 0,$ilen = count($colrows);$i<$ilen;$i++){
if($i < $ilen -1){
//根据传递的数组元素拼接将要更新的“字段名=‘新值’”,用逗号分隔;
if(is_string($values[$i])){
//如果新的字段值$values[$i]是字符串,则加上单引号,否则不加
$str = $str.$colrows[$i]."="."'".$values[$i]."'".",";
}else{
$str = $str.$colrows[$i]."=".$values[$i].",";
}
}else{
//最后壹个数组元素(即最后一个字段名=‘新值’)结束后不再拼接逗号
if(is_string($values[$i])){
$str = $str.$colrows[$i]."="."'".$values[$i]."'";
}else{
$str = $str.$colrows[$i]."=".$values[$i];
}
}
}
//构建更新纪录的sql语句,若执行成功并且该更新操作确实影响到数据库表中纪录则返回true,否则返回false
$sql = "update ".$tableName." set ".$str." where ".$where;
mysqli_query($this->link,$sql);
if(mysqli_affected_rows($this->link) >= 0){
return true;
}else{
return false;
}
}
//删除数据库纪录
function deleteDB($tableName,$where){
if($this->link == null){
$this ->connectDB();
}
//根据给定字段的键值组合删除表中相关纪录内容,成功返回true,失败返回false
$sql = "delete from ".$tableName." where ".$where;
mysqli_query($this->link,$sql);
if(mysqli_affected_rows($this->link) >= 0){
return true;
}else{
return false;
}
}
//封装一个上传文件后将对应的服务器临时副本拷贝到指定目录的类,文件名为“原始文件名+服务器当前日期时间”格式
function moveFile($name,$username){
move_uploaded_file($_FILES[$name]["tmp_name"], "upload/".$username.$_FILES[$name]["name"].date("Y-m-d-h-i-s"));
}
//获取客户端通过Ajax提交Form表单的数据类,返回数组
function getClientData($arr){
$arrTemp = array();
for($i = 0,$ilen = count($arr);$i<$ilen;$i++){
array_push($arrTemp, $_REQUEST[$arr[$i]]);
}
return $arrTemp;
}
}
?>
PHP封装MySQLi数据库操作类
最后编辑于 :
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
- 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
推荐阅读更多精彩内容
- 自编PHP框架之数据库PDO层封装和模型类部分方法的编写 如果你是喷子,问我造轮子花这么多精力有什么用的话,那就走...
- 应用程序配置文件存放数据库连接字符串的信息 对SQL Server数据库操作方法的封装 对SQLite数据库操作方...
- EasyDB 基于ORMLite封装的数据库操作工具类——致力于最简洁的数据库操作API 功能点 支持自定义数据库...
- [引言] 我们在学习Java编程时,连接数据库技术(JDBC)是一项必备技能,我们经常需要读取或操作持久性存储的结...