php开发实战分析(7):mysql类库操作的高级使用

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: php开发实战分析(7):mysql类库操作的高级使用

前言:MySQL 类库

MySQL 类库是用于在 PHP 中与 MySQL 数据库进行交互的工具集合。PHP 提供了多个可用的 MySQL 类库,其中最常用的是官方提供的 MySQLi(MySQL improved)和 PDO(PHP Data Objects)。


1.MySQLi(MySQL improved):

MySQLi 是 PHP 官方提供的 MySQL 扩展,提供了面向对象和面向过程两种 API 风格。它支持 MySQL 5.0 版本及以上,并提供了更多的功能和性能改进。

使用 MySQLi 类库,你可以使用面向对象或面向过程的方式连接 MySQL 数据库、执行查询和事务、处理结果集等。下面是使用面向对象风格的示例:


<?php
$mysqli = new mysqli("localhost", "username", "password", "database");
if ($mysqli->connect_errno) {
    echo "连接 MySQL 失败: " . $mysqli->connect_error;
    exit;
}
$query = "SELECT * FROM users";
$result = $mysqli->query($query);
while ($row = $result->fetch_assoc()) {
    echo $row['username'] . "<br>";
}
$mysqli->close();


可以参考 PHP 官方文档了解更多 MySQLi 的用法和功能。


2.PDO(PHP Data Objects):

PDO 是一个通用的、可扩展的数据库访问抽象层,可以用于连接多种类型的数据库,包括 MySQL。使用 PDO,你可以使用统一的 API 风格来连接数据库、执行查询和事务,并处理结果集。

下面是 PDO 的示例:

<?php
$dsn = "mysql:host=localhost;dbname=database";
$username = "username";
$password = "password";
try {
    $pdo = new PDO($dsn, $username, $password);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    $query = "SELECT * FROM users";
    $stmt = $pdo->query($query);
    while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
        echo $row['username'] . "<br>";
    }
} catch (PDOException $e) {
    echo "连接数据库失败: " . $e->getMessage();
}
  1. 参考 PHP 官方文档了解更多 PDO 的用法和功能。

无论选择使用 MySQLi 还是 PDO,都可以根据具体需求和个人喜好选择合适的类库来进行 MySQL 数据库操作。它们都提供了丰富的功能和可靠的性能,可以满足大多数的 PHP 数据库开发需求。


一、自行封装 MySQL 类库

1.MySQL 类库进行自行封装的优点


  1. 代码复用和可维护性:封装 MySQL 类库可以将数据库操作逻辑封装到一个独立的类中,提供统一的接口和方法,使代码更加模块化。这样可以减少重复的代码编写,提高代码的复用性和可维护性。如果需要修改数据库连接或操作方式,只需要修改封装类的实现,而不需要在代码的多个地方进行修改。
  2. 隐藏细节和增加安全性:封装类库能够隐藏底层数据库细节,使系统的其他部分不直接和数据库进行交互。这样可以提高代码的安全性,避免直接执行原始的 SQL 语句等潜在风险。
  3. 错误处理和异常管理:自行封装 MySQL 类库可以对数据库操作过程中的错误进行处理和管理。可以自定义异常处理机制,捕获并处理数据库操作中可能出现的异常,从而更好地控制错误流程,提供更友好的错误信息,以及记录和处理数据库错误信息。
  4. 注重性能和优化:通过自行封装 MySQL 类库,可以在底层处理一些性能优化的细节。例如,可以使用查询预处理等方式提高数据库操作的效率,减少数据库访问的网络开销。还可以根据具体应用需求进行数据库连接池、查询缓存等优化,提升系统的性能和响应速度。
  5. 适应多个数据库类型:自行封装的类库可以以抽象的方式连接和操作多种类型的数据库,而不仅限于 MySQL。这样,如果未来需要切换到其他类型的数据库,只需修改封装类库的实现,而不会对应用其他部分产生影响。


综上所述,自行封装 MySQL 类库能够提供更好的代码复用性、可维护性、安全性、错误处理和性能优化等优势,使开发过程更加高效、可靠和可扩展。封装类库可以根据项目需求和团队要求进行定制化,满足特定的开发需求,并提供更好的抽象层,使代码更加可读、可靠和易于维护。


2.单记录查询

    public function query($sql)
    {
        $this->connect(); //logs($sql);//print $sql.'<br>';
        $result = $this->db->query($sql);
        $this->error(); ///var_dump($result);
        $result->setFetchMode(PDO::FETCH_ASSOC);
        $this->querynum++;
        return $result->fetch();
    }
    public function fetch($table, $field, $condition = '', $sort = '')
    {
        $condition = $this->format_condition($condition);
        $sort && $sort = ' ORDER BY ' . $sort;
        $sql = 'SELECT ' . $field . ' FROM ' . $this->table($table) . $condition . $sort . ' LIMIT 1'; //print $sql.'<br>';
        return $this->query($sql);
    }


3.多记录查询

    public function queryall($sql)
    {
        $this->connect();
        $result = $this->db->query($sql); //print $sql.'<br>';die();//logs($sql);
        $this->error();
        $result->setFetchMode(PDO::FETCH_ASSOC);
        $this->querynum++;
        return $result->fetchall();
    }
    public function fetchall($table, $field, $condition = '', $sort = '', $limit = '')
    {
        $condition = $this->format_condition($condition);
        $sort && $sort = ' ORDER BY ' . $sort;
        $limit && $limit = ' LIMIT ' . $limit;
        $sql = 'SELECT ' . $field . ' FROM ' . $this->table($table) . $condition . $sort . $limit;
        return $this->queryall($sql);
    }


4.获取插入的id

    public function lastinsertid()
    {
        return $this->db->lastInsertId();
    }


5.插入数据

   public function insert($table, $array)
    {
        if (!is_array($array)) {
            return false;
        }
        foreach ($array as $key => $value) {
            $cols[] = $key;
            $vals[] = '\'' . $this->strescape($value) . '\'';
        }
        $col = join(',', $cols);
        $val = join(',', $vals);
        $sql = 'INSERT INTO ' . $this->table($table) . ' (' . $col . ') VALUES (' . $val . ')'; //print $sql;//logs($sql);
        return $this->exec($sql);
    }


6.更新数据

    public function update($table, $array, $condition)
    {
        if (!is_array($array)) {
            return false;
        }
        $condition = $this->format_condition($condition);
        foreach ($array as $key => $value) {
            $vals[] = $key . ' = \'' . $this->strescape($value) . '\'';
        }
        $values = join(',', $vals);
        $sql = 'UPDATE ' . $this->table($table) . ' SET ' . $values . $condition;
        return $this->exec($sql);
    }


7.删除数据

    public function delete($table, $condition)
    {
        $condition = $this->format_condition($condition);
        $sql = 'DELETE FROM ' . $this->table($table) . $condition;
        return $this->exec($sql);
    }


8.统计数量

   public function rowcount($table, $condition = '')
    {
        $condition = $this->format_condition($condition);
        $sql = 'SELECT COUNT(*) FROM ' . $this->table($table) . $condition; 
        $result = $this->query($sql);
        return $result['COUNT(*)'];
    }
    public function get_count($sql = '')
    {
        $result = $this->query('SELECT COUNT(*) FROM ' . $sql);
        return $result['COUNT(*)'];
    }

二、MySQL 类库的实战使用

1.文章系统上一篇和下一篇

function get_prev_news($news_id)
{
    global $db;
    $row = $db->query("select news_id,name,code from " . $db->table('news') . " where news_id<" . intval($news_id) . " order by news_id desc limit 1");
    $row['url'] = get_url($row['code']);
    return $row;
}


//下一篇
function get_next_news($news_id)
{
    global $db;
    $row = $db->query("select news_id,name,code from " . $db->table('news') . " where news_id>" . intval($news_id) . " order by news_id asc limit 1");
    $row['url'] = get_url($row['code']);
    return $row;
}

2.条件判断查询的拼接语句

function get_brand($id = 0, $name = '', $recommend = 0, $startI = 0, $num = null)
{
    global $db;
    $where = '';
    global $db;
    $where = '';
    if ($id != 0) {
        $where .= ' and id=' . intval($id);
    }
    if ($name != 0) {
        $where .= " and name like '%" . trim(addslashes($name)) . "%'";
    }
    if ($recommend != 0) {
        $where .= " and recommend=" . intval($recommend);
    }
    if ($num != null) {
        $where .= ' limit ' . intval($startI) . "," . intval($num);
    }
    return $db->queryall("select * from " . $db->table('brand') . " where status=1 " . $where);
}

3.获取收藏数

//获取收藏数
function get_fav_count($uid = 0)
{
    global $db;
    return $db->get_count($db->table('member_fav') . " where uid=" . intval($uid));
}


4.数量统计

$robot_count = $db->rowcount("member", array("is_robot" => 1));


5.添加字段

    public function install()
    {
        global $db;
        $sql = "alter table " . $db->table("member") . " add is_robot tinyint(1) default '0'  COMMENT '是否机器人'; ";
        $db->query($sql);
        return true;
    }


6.删除字段

   public function uninst()
    {
        global $db;
        $sql = "alter table " . $db->table("member") . " drop column is_robot; ";
        $db->query($sql);
        return true;
    }

7.跨表查询

$where='';
$row = $db->queryall("SELECT g.goods_id,g.name,g.subname,g.code,g.thumb,g.unit,g.virtype,g.status goods_status,ifnull(g.point*i.num, 0) point,g.uptime,ifnull(s.weight, g.weight) weight,ifnull(s.attr_ids,'') as spec_ids,ifnull(s.`values`,'')as spec_name, ifnull(s.price, g.price) price,ifnull(s.number, g.number) number,(ifnull(s.price, g.price)*i.num) amount,(ifnull(s.weight, g.weight)*i.num) total_weight, c.uid,ifnull(f.id,0) as favid,i.* from " . $db->table('cart') . " c join " . 
$db->table('cart_item') . " i on c.id = i.cid join " .
$db->table('goods') . " g on i.gid=g.goods_id left join " . 
$db->table('goods_spec') . " s on i.gid=s.goods_id and s.values =i.spec left join " . 
$db->table('member_fav') . " f on f.goods_id=i.gid and f.spec=i.spec and f.uid=c.uid where 1 " . $where);


8.类型限制

$db->insert('banner', array('c_id' => intval($login_id), 'c_width' => intval($c_width), 'c_height' => intval($c_height), 'c_title' => ptitle($c_title), 'c_name' => ptitle($c_name), 'c_time' => time(), 'c_code' => ''));


9.记录格式转换

function get_delivery($order_sn)
{
    global $db;
    $row = $db->queryall("select d.*,ifnull(e.name,'商家配送') exp_name,e.code exp_code,e.code2 exp_code2 from " . $db->table('delivery') . " d left join " . $db->table('express_common') . " e on d.exp_id=e.id where order_sn=" . $order_sn);
    foreach ($row as $k => $v) {
        $row[$k]['exp_time'] = date('Y-m-d H:i:s', $v['addtime']);
    }
    return $row;
}


function get_not_delivery($order_sn)
{
    global $db;
    $goods = $db->queryall("SELECT g.thumb,g.code,og.* FROM " . $db->table('order') . " o join " . $db->table('order_goods') . " og on o.id=og.order_id left join " . $db->table('goods') . " g on g.goods_id=og.goods_id left join (select order_sn,concat(goods_id,spec)goods from " . $db->table('delivery') . " d join " . $db->table('delivery_goods') . " dg on d.id=dg.delivery_id WHERE order_sn=" . $order_sn . ") de on de.order_sn=o.order_sn and de.goods=concat(og.goods_id,og.spec) where concat(og.goods_id,og.spec)<>ifnull(goods,'') and o.order_sn=" . $order_sn);
    foreach ($goods as $k => $v) {
        $goods[$k]['price'] = format_price($v['price']);
        $goods[$k]['amount'] = format_price($v['price'] * $v['num']);
        $goods[$k]['url'] = $v['code'] . '-g.html';
    }
    return $goods;
}


11.获取订单数

function order_count($uid = 0, $status = 0, $where = '')
{
    global $db;
    if ($uid != 0) {
        $where .= " and uid=" . $uid;
    }
    if ($status != 0) {
        $where .= " and status=" . $status;
    }
    return $db->rowcount('order', "1 " . $where);
}



@漏刻有时

相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
9天前
|
SQL 关系型数据库 MySQL
MySQL 窗口函数详解:分析性查询的强大工具
MySQL 窗口函数从 8.0 版本开始支持,提供了一种灵活的方式处理 SQL 查询中的数据。无需分组即可对行集进行分析,常用于计算排名、累计和、移动平均值等。基本语法包括 `function_name([arguments]) OVER ([PARTITION BY columns] [ORDER BY columns] [frame_clause])`,常见函数有 `ROW_NUMBER()`, `RANK()`, `DENSE_RANK()`, `SUM()`, `AVG()` 等。窗口框架定义了计算聚合值时应包含的行。适用于复杂数据操作和分析报告。
50 11
|
24天前
|
存储 关系型数据库 MySQL
PHP与MySQL动态网站开发:从基础到实践####
本文将深入探讨PHP与MySQL的结合使用,展示如何构建一个动态网站。通过一系列实例和代码片段,我们将逐步了解数据库连接、数据操作、用户输入处理及安全防护等关键技术点。无论您是初学者还是有经验的开发者,都能从中获益匪浅。 ####
|
27天前
|
安全 关系型数据库 MySQL
PHP与MySQL动态网站开发实战指南####
——深入探索LAMP栈下的高效数据交互与处理技巧 ####
|
25天前
|
关系型数据库 MySQL PHP
php实现一个简单的MySQL分页
通过本文的详细步骤和代码示例,我们实现了一个简单的PHP MySQL分页功能。主要步骤包括计算总记录数、设置分页参数、查询当前页的数据以及生成分页链接。这种分页方式适用于大多数Web应用,能够有效提升用户体验和页面响应速度。
26 4
|
27天前
|
SQL 关系型数据库 MySQL
PHP与MySQL的高效协同开发策略####
本文深入探讨了PHP与MySQL在Web开发中的协同工作机制,通过优化配置、最佳实践和高级技巧,展示了如何提升数据库交互性能,确保数据安全,并促进代码可维护性。我们将从环境搭建讲起,逐步深入到查询优化、事务管理、安全防护及性能调优等核心环节,为开发者提供一套实战驱动的解决方案框架。 ####
|
20天前
|
SQL 关系型数据库 MySQL
PHP与MySQL的高效交互:从基础到实践####
本文深入探讨了PHP与MySQL数据库之间的高效交互技术,涵盖了从基础连接到高级查询优化的全过程。不同于传统的摘要概述,这里我们直接以一段精简代码示例作为引子,展示如何在PHP中实现与MySQL的快速连接与简单查询,随后文章将围绕这一核心,逐步展开详细讲解,旨在为读者提供一个从入门到精通的实战指南。 ```php <?php // 数据库配置信息 $servername = "localhost"; $username = "root"; $password = "password"; $dbname = "test_db"; // 创建连接 $conn = new mysqli($se
23 0
|
27天前
|
关系型数据库 MySQL PHP
PHP与MySQL的深度整合:构建高效动态网站####
在当今这个数据驱动的时代,掌握如何高效地从数据库中检索和操作数据是至关重要的。本文将深入探讨PHP与MySQL的深度整合方法,揭示它们如何协同工作以优化数据处理流程,提升网站性能和用户体验。我们将通过实例分析、技巧分享和最佳实践指导,帮助你构建出既高效又可靠的动态网站。无论你是初学者还是有经验的开发者,都能从中获得宝贵的见解和实用的技能。 ####
21 0
|
测试技术 PHP 数据库
20个非常有用的PHP类库
下面是一些非常有用的PHP类库,相信一定可以为你的WEB开发提供更好和更为快速的方法。 图表库 下面的类库可以让你很简的创建复杂的图表和图片。当然,它们需要GD库的支持。 pChart - 一个可以创建统计图的库。
880 0
|
3月前
|
安全 关系型数据库 MySQL
PHP与MySQL交互:从入门到实践
【9月更文挑战第20天】在数字时代的浪潮中,掌握PHP与MySQL的互动成为了开发动态网站和应用程序的关键。本文将通过简明的语言和实例,引导你理解PHP如何与MySQL数据库进行对话,开启你的编程之旅。我们将从连接数据库开始,逐步深入到执行查询、处理结果,以及应对常见的挑战。无论你是初学者还是希望提升技能的开发者,这篇文章都将为你提供实用的知识和技巧。让我们一起探索PHP与MySQL交互的世界,解锁数据的力量!
|
1月前
|
前端开发 关系型数据库 MySQL
PHP与MySQL动态网站开发实战指南####
【10月更文挑战第21天】 本文将深入浅出地探讨如何使用PHP与MySQL构建一个动态网站,从环境搭建到项目部署,全程实战演示。无论你是编程新手还是希望巩固Web开发技能的老手,都能在这篇文章中找到实用的技巧和启发。我们将一起探索如何通过PHP处理用户请求,利用MySQL存储数据,并最终呈现动态内容给用户,打造属于自己的在线平台。 ####
42 0