189 8069 5689
在PHP的面向过程中，我们可以通过封装函数来实现对数据库的操作，那么在面向过程中，我们同样可以通过类来实现对数据库的操作，整个过程和面向过程的思路大体差不多，但是代码量更多了一些，实现起来稍微困难。一共实现了十个功能。先定义成员属性，然后定义成员方法。一共分为连接数据库的config文件、具体实现对数据库操作的类文件、测试代码。所有的代码均是通过了测试，具体的测试结果由于篇幅问题没有附图。
成都创新互联服务项目包括阿里地区网站建设、阿里地区网站制作、阿里地区网页制作以及阿里地区网络营销策划等。多年来，我们专注于互联网行业，利用自身积累的技术优势、行业经验、深度合作伙伴关系等，向广大中小型企业、政府机构等提供互联网行业的解决方案，阿里地区网站推广取得了明显的社会效益与经济效益。目前，我们服务的客户以成都为中心已经辐射到阿里地区省份的部分城市，未来相信会继续扩大服务区域并继续获得客户的支持与信任！
具体实现功能：
1、连接数据库；
2、插入数据；
3、更新数据；
4、删除数据；
5、修改数据；
6、求最大值；
7、求最小值；
8、求平均数；
9、求和；
10、指定查询；
具体代码分为三个部分：
一、config文件：主要用于连接数据库
'127.0.0.1', //主机 'DB_USER' => 'root', //用户名 'DB_PWD' => '123456', //密码 'DB_NAME' => 'blog', //数据库名 'DB_CHARSET' => 'utf8', //字符集 'DB_PREFIX' => 'bbs_', //前缀 );
二、数据库操作类：
host = $config['DB_HOST'];
$this->user = $config['DB_USER'];
$this->pwd = $config['DB_PWD'];
$this->dbName = $config['DB_NAME'];
$this->charset = $config['DB_CHARSET'];
$this->prefix = $config['DB_PREFIX'];
//连接
$this->link = $this->connect();
//判断连接成功与否 失败处理
if (!$this->link) {
exit('数据库连接或者选择数据库失败。');
}
//表名 需要处理
$this->table = $this->getTable();
//字段 需要处理
$this->fields = $this->getFields();
}
//连接数据库成员方法
protected function connect()
{
$conn = MySQLi_connect($this->host,$this->user,$this->pwd);
//连接数据库失败处理
if (!$conn) {
return flase;
}
//选择数据失败处理
if (!mysqli_select_db($conn,$this->dbName)) {
return false ;
}
//设置字符集
mysqli_set_charset($conn,$this->charset);
//返回处理结果
return $conn;
}
//初始化表 【暂时出现报错，后面用命名空间解决】
protected function getTable()
{
//判断用户时候设置过？
if (isset($this->table)) {
//设置过就以用户的为准，先把用户前缀弃掉，然后拼接前缀，保证统一性
return $this->prefix . ltrim($this->table,$this->prefix);
} else {
//没有设置过就用 类名拼接前缀，组成一个全新的的表名
//get_class() 获取类名 等同于 __CLASS__
//获取类名后进行字串提取[substr( string,start,length )],并且全部转换为小写[strtolower()]
return $this->prefix . strtolower(substr(get_class($this),0,-5));
}
}
//初始化字段 需要把字段缓存到一个文件里面去
protected function getFields()
{
//如果有字段的文件说明以前缓存过这个文件，直接包含即可，但是需要知道文件路径的规则
//定义文件路径
$filePath = './caceh/' . $this->table . '.php';
//判断时候有缓存文件
if (file_exists($filePath)) {
//存在缓存文件直接包含即可
return include $filePath;
} else {
//没有的话就需要生成一个缓存文件
//首先需要查询字段
$fields = $this->queryFields();
//var_export() 输出或返回一个变量的字符串 true表示不打印 将其保存下来
$str = "';
//写入到缓存文件file_put_contents(文件保存路径，需要写进去的内容)
file_put_contents($filePath, $str);
}
return $fields;
}
//查询字段处理
protected function queryFields()
{
//打印字段的sql语句
$sql = 'desc ' . $this->table;
//var_dump($sql);
//执行sql语句 需要定义成员方法query
$data = $this->query($sql);
$fields = [];
//想要获取字段，需要对返回的数据进行遍历
foreach ($data as $key => $value) {
$fields[] = $value['Field'];
if ($value['Key'] == 'PRI') {
$fields['_pk'] = $value['Field'];
}
}
return $fields;
}
//系统级查询(定义为 public ),在外部调用的时候，想自定义SQL语句可以只是调用该成员方法
//查询相应的结果，这个仅供读取使用查询相应的结果
public function query($sql)
{
//执行一条SQL语句
$result = mysqli_query($this->link,$sql);
if ($result) {
$data = [];
//获取每行数据
while ($row = mysqli_fetch_assoc($result)) {
$data[] = $row;
}
return $data;
} else {
return false;
}
}
//查询成员方法
//准备好无需换的SQL语句
//用户调用询的时候，将call里面保存进去的参数，一一替换sql语句
//发送SQL语句
//返回查询的结果
public function select()
{
//拼接sql语句
$sql = "select %FIELDS% from %TABLE% %WHERE% %GROUP% %HAVING% %ORDER% %LIMIT%";
//将sql语句中的相应部分替换
$newsql = str_replace(
array(
'%FIELDS%',
'%TABLE%',
'%WHERE%',
'%GROUP%',
'%HAVING%',
'%ORDER%',
'%LIMIT%',
),
array(
$this->parseFields(),
$this->parseTable(),
$this->parseWhere(),
$this->parseGroup(),
$this->parseHaving(),
$this->parseOrder(),
$this->parseLimit(),
),
$sql
);
echo $newsql;
$this->sql = $newsql;
return $this->query($newsql);
}
//字段处理
protected function parseFields()
{
//因为我们对比字段的时不需要对比主键是谁，所以需要unset()
//将当前的字段赋值给一个变量
$fields = $this->fields;
unset($fields['_pk']);
//判断字段是什么形式（字符串、数组）
if (is_array($this->options['fields'][0])) {
//遍历取出键值
foreach ($this->options['fields'][0] as $key => $value) {
//判断传入的字段时候合法（属于表结构中的字段）
if (!in_array($value, $fields)) {
//如果不属于合法的字段就unset()
unset($this->options['fields'][0][$key]);
}
}
return join(',',$this->options['fields'][0]);
} else if (is_string($this->options['fields'][0])){
//如果是字符串就先变为数组进行处理
$this->options['fields'][0] = explode(',', $this->options['fields'][0]);
//遍历
foreach ($this->options['fields'][0] as $key => $value) {
//判断字段是否合法
if (!in_array($value,$fields)) {
unset($this->options['fields'][0][$key]);
}
return join(',',$this->options['fields'][0]);
}
} else {
return join(',',$fields);
}
}
//判断用户有没有手动指定过查询哪个用
//如果指定过，则以用户设定的options里面的表为准
//如果没有设定过，则以默认的为准
protected function parseTable()
{
if (isset($this->options['table'][0])) {
return $this->options['table'][0];
} else {
return $this->table;
}
}
//判断用户设置过where 如果设置过就以用户设置为准，没有设置就为空
protected function parseWhere()
{
if (isset($this->options['where'][0])) {
return 'WHERE ' .$this->options['where'][0];
} else {
return '';
}
}
//判断用户设置过group 如果设置过就以用户设置为准，没有设置就为空
protected function parseGroup()
{
if (isset($this->options['where'][0])) {
return 'GROUP BY ' .$this->options['group'][0];
} else {
return '';
}
}
//判断用户设置过having如果设置过就以用户设置为准，没有设置就为空
protected function parseHaving()
{
if (isset($this->options['having'][0])) {
return 'HAVING ' .$this->options['having'][0];
} else {
return '';
}
}
//判断用户设置过order如果设置过就以用户设置为准，没有设置就为空
protected function parseOrder()
{
if (isset($this->options['order'][0])) {
return 'ORDER BY ' .$this->options['order'][0];
} else {
return '';
}
}
//limit可以有以下几种传法
protected function parseLimit()
{
if (isset($this->options['limit'][0])) {
if (is_int($this->options['limit'][0])) {
//用户传进来的是一个整 数，就是查询指定的条数
return 'LIMIT ' . $this->options['limit'][0];
} else if (is_array($this->options['limit'][0])){
//用户传进来的是一个数组，则数组中的第一个元素为$offset,第二个元素为$num
return 'LIMIT ' . join(',',$this->options['limit'][0]);
} else {
//如果户传进来的是一个字符串，则以用户传的为准
return 'LIMIT ' . $this->options['limit'][0];
}
} else {
return '';
}
}
//插入的成员方法
public function insert($data)
{
//SQL语句
$sql = "insert into %TABLE%(%FIELDS%) values(%VALUES%) ";
//替换
$newsql = str_replace(
array(
'%TABLE%',
'%FIELDS%',
'%VALUES%'
),
array(
$this->parseTable(),
$this->parseInsertFieldes($data),
join (',',$this->parseValue($data)),
),
$sql
);
//重新赋值
$this->sql = $newsql;
echo $this->sql;
//调用exec并执行
return $this->exec($newsql,true);
}
//处理插入时候的字段
protected function parseInsertFieldes(&$data)
{
foreach ($data as $key => $value) {
if (!in_array($key,$this->fields)) {
unset($data[$key]);
}
}
return join(',',array_keys($data));
}
//处理插入时候的值
//分为字符串 数组 空的情况处理
protected function parseValue($data)
{
if (is_string($data)) {
$data = '\'' . $data . '\'';
} else if (is_array($data)){
$data = array_map(array($this, 'parseValue'),$data);
} else if (is_null($data)){
$data = 'null';
}
return $data;
}
//
public function exec($sql,$isInsertId = false)
{
$result = mysqli_query($this->link,$sql);
if ($result) {
if ($isInsertId) {
//insertfan返回自动增长的id
return mysqli_insert_id($this->link);
} else {
//update delete 返回受影响的行数
return mysqli_affected_rows($this->link);
}
} else {
return false;
}
}
//更新方法
public function update($data)
{
$sql = "update %TABLE% set %SETS% %WHERE% %ORDER% %LIMIT%";
$newsql = str_replace(
array(
'%TABLE%',
'%SETS%',
'%WHERE%',
'%ORDER%',
'%LIMIT%'
),
array(
$this->parseTable(),
$this->parseSets($data),
$this->parseWhere(),
$this->parseOrder(),
$this->parseLimit(),
),
$sql
);
$this->sql = $newsql;
//echo $newsql;
return $this->exec($newsql);
}
//更新内容设置
protected function parseSets($data)
{
$sets = [];
foreach ($data as $key => $value) {
if (in_array($key,$this->fields)) {
$sets[] = $key . '=' . $this->parseValue($value);
}
}
return join(',',$sets);
}
//删除方法
public function delete()
{
$sql = "delete from %TABLE% %WHERE% %ORDER% %LIMIT%";
$newsql = str_replace(
array(
'%TABLE%',
'%WHERE%',
'%ORDER%',
'%LIMIT%'
),
array(
$this->parseTable(),
$this->parseWhere(),
$this->parseOrder(),
$this->parseLimit(),
),
$sql
);
$this->sql = $newsql;
return $this->exec($newsql);
}
//求总数
public function sum($field = null )
{
if (is_null($field)) {
$field = $this->fields['_pk'];
}
$sql = "select count($field) as sum from %TABLE% %WHERE% ";
$newsql = str_replace(
array(
'%TABLE%',
'%WHERE%',
),
array(
$this->parseTable(),
$this->parseWhere(),
),
$sql
);
$this->sql = $newsql;
$data = $this->query($newsql);
return $data[0]['sum'];
}
//求最大数
public function max($field = null )
{
if (is_null($field)) {
$field = $this->fields['_pk'];
}
$sql = "select max($field) as max from %TABLE% %WHERE% ";
$newsql = str_replace(
array(
'%TABLE%',
'%WHERE%',
),
array(
$this->parseTable(),
$this->parseWhere(),
),
$sql
);
$this->sql = $newsql;
$data = $this->query($newsql);
return $data[0]['max'];
}
//求最小数
public function min($field = null )
{
if (is_null($field)) {
$field = $this->fields['_pk'];
}
$sql = "select min($field) as min from %TABLE% %WHERE% ";
$newsql = str_replace(
array(
'%TABLE%',
'%WHERE%',
),
array(
$this->parseTable(),
$this->parseWhere(),
),
$sql
);
$this->sql = $newsql;
$data = $this->query($newsql);
return $data[0]['min'];
}
//求平均数
public function avg($field = null )
{
if (is_null($field)) {
$field = $this->fields['_pk'];
}
$sql = "select avg($field) as avg from %TABLE% %WHERE% ";
$newsql = str_replace(
array(
'%TABLE%',
'%WHERE%',
),
array(
$this->parseTable(),
$this->parseWhere(),
),
$sql
);
$this->sql = $newsql;
$data = $this->query($newsql);
return $data[0]['avg'];
}
//自动的一个按照字段来查询的智能化查询方法
protected function getBy($field,$value)
{
$sql = "select %FIELDS% from %TABLE% %WHERE%";
$newsql = str_replace(
array(
'%FIELDS%',
'%TABLE%',
'%WHERE%'
),
array(
$this->parseFields(),
$this->parseTable(),
' WHERE '.$field . "='$value'",
),
$sql
);
$this->sql = $newsql;
echo $newsql;
return $this->query($newsql);
}
//__call方法，针对用户请求limit(), order(),group()等将其保存到options中， 判断其方法合法性;
//并且return $this 让其能够连贯操作，
public function __call($func,$args)
{
//合法的
$allow = ['where','table','fields','order','limit','group','having'];
//把传入的统一转化为小写
$func = strtolower($func);
if (in_array($func,$allow)) {
$this->options[$func] = $args;
return $this;
} else if(substr($func,0,5) == 'getby'){
$field = substr($func,5);
if (in_array($field,$this->fields)) {
return $this->getBy($field,$args[0]);
}
} else {
exit ('方法不合法！');
}
}
//析構方法 關閉頁面/對象消費時候調用
public function __destruct()
{
mysqli_close($this->link);
}
}三、测试（验证）代码：
//包含文件
$config = include 'config.php';
$blog = new UserModel($config);
//测试查询
$data = $blog->fields('uid,uesrname,password')->table('bbs_user')->limit([1,2])->order('uid desc ')->group('username')->select();
var_dump($data);
//插入测试
$_POST['uesrname'] = 'chen';
$_POST['password'] = 123456;
$_POST['creatime'] = 123423;
$_POST['senlin'] = '不存在的字段处理';
echo $blog->insert($_POST);
//更新测试
$_POST['uesrname'] = '1kkkkk12';
$_POST['password'] = 123456;
$_POST['createtime'] = 234567;
$_POST['haiyan'] = '你可长点心眼吧';
echo $blog->where('uid>0')->limit('1')->update($_POST);
//删除测试
echo $blog->where('uid>0 and uid<2')->delete();
//测试求和
echo $blog->sum('uid');
//测试求最大数
echo $blog->max('uid');
//测试求最小数
echo $blog->min();
//测试求平均數
echo $blog->avg();
//测试自动的一个按照字段来查询
$data = $blog->getByPassword('123456');
var_dump($data);