AI 助理
文档备案控制台
开发者社区 数据库 文章 正文

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

2023-07-26 402
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 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 版
PHP
SQL
关系型数据库
MySQL
API
数据库
缓存
数据库连接
相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发，帮助IT从业者们通过“阿里云Web应用上云解决方案”，了解一个企业级Web应用上云的常见架构，了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。 &nbsp; 相关的阿里云产品：云数据库RDS MySQL 版 阿里云关系型数据库RDS（Relational Database Service）是一种稳定可靠、可弹性伸缩的在线数据库服务，提供容灾、备份、恢复、迁移等方面的全套解决方案，彻底解决数据库运维的烦恼。 了解产品详情:&nbsp;https://www.aliyun.com/product/rds/mysql&nbsp;
漏刻有时
目录
相关文章
蓝易云
|
10月前
|
设计模式 安全 PHP
PHP 5与PHP 7的主要区别分析
综上所述，PHP 7相比于PHP 5，不仅在性能上有显著提升，还增加了许多新特性和改进，使得PHP语言更加强大和现代化。同时，弃用了一些过时的特性和函数，更加注重代码的健壯性和安全性。然而，这些改变也意味着从PHP 5迁移到PHP 7可能需要一些代码的调整和优化。
蓝易云
324 10
varin
|
11月前
|
关系型数据库 MySQL PHP
PHP和Mysql前后端交互效果实现
本文介绍了使用PHP连接MySQL数据库的基本函数及其实现案例。内容涵盖数据库连接、选择数据库、执行查询、获取结果等常用操作，并通过用户登录和修改密码的功能实例，展示了PHP与MySQL的交互过程及代码实现。
varin
533 0
PHP和Mysql前后端交互效果实现
蓝易云
|
关系型数据库 MySQL Linux
查看Linux、Apache、MySQL、PHP版本的技巧
以上就是查看Linux、Apache、MySQL、PHP版本信息的方法。希望这些信息能帮助你更好地理解和使用你的LAMP技术栈。
蓝易云
695 17
蓝易云
|
关系型数据库 MySQL PHP
源码编译安装LAMP（HTTP服务，MYSQL ,PHP，以及bbs论坛）
通过以上步骤，你可以成功地在一台Linux服务器上从源码编译并安装LAMP环境，并配置一个BBS论坛（Discuz!）。这些步骤涵盖了从安装依赖、下载源代码、配置编译到安装完成的所有细节。每个命令的解释确保了过程的透明度，使即使是非专业人士也能够理解整个流程。
蓝易云
548 18
蓝易云
|
关系型数据库 MySQL 网络安全
如何排查和解决PHP连接数据库MYSQL失败写锁的问题
通过本文的介绍，您可以系统地了解如何排查和解决PHP连接MySQL数据库失败及写锁问题。通过检查配置、确保服务启动、调整防火墙设置和用户权限，以及识别和解决长时间运行的事务和死锁问题，可以有效地保障应用的稳定运行。
蓝易云
581 25
疯狂的猿
|
搜索推荐 PHP SEO
SEO化在线检测分析PHP源码
SEO化在线检测分析PHP源码，有助于确定您的 SEO 错误并优化您的互联网网页内容以获得更高的搜索引擎评级 还提供与您的竞争对手的逐个方面的 SEO 比较。分析报告甚至可以下载为 PDF 文件以供离线使用 上传服务器后解压安装
疯狂的猿
440 18
萝卜带泥
|
前端开发 关系型数据库 MySQL
PHP与MySQL动态网站开发实战指南####
【10月更文挑战第21天】 本文将深入浅出地探讨如何使用PHP与MySQL构建一个动态网站，从环境搭建到项目部署，全程实战演示。无论你是编程新手还是希望巩固Web开发技能的老手，都能在这篇文章中找到实用的技巧和启发。我们将一起探索如何通过PHP处理用户请求，利用MySQL存储数据，并最终呈现动态内容给用户，打造属于自己的在线平台。 ####
萝卜带泥
816 0
xibeijing
|
SQL 关系型数据库 MySQL
PHP与MySQL的高效交互：从基础到实践####
本文深入探讨了PHP与MySQL数据库之间的高效交互技术，涵盖了从基础连接到高级查询优化的全过程。不同于传统的摘要概述，这里我们直接以一段精简代码示例作为引子，展示如何在PHP中实现与MySQL的快速连接与简单查询，随后文章将围绕这一核心，逐步展开详细讲解，旨在为读者提供一个从入门到精通的实战指南。 ```php <?php // 数据库配置信息 $servername = "localhost"; $username = "root"; $password = "password"; $dbname = "test_db"; // 创建连接 $conn = new mysqli($se
xibeijing
503 31
zhanbao
|
关系型数据库 MySQL PHP
PHP与MySQL的深度整合：构建高效动态网站####
在当今这个数据驱动的时代，掌握如何高效地从数据库中检索和操作数据是至关重要的。本文将深入探讨PHP与MySQL的深度整合方法，揭示它们如何协同工作以优化数据处理流程，提升网站性能和用户体验。我们将通过实例分析、技巧分享和最佳实践指导，帮助你构建出既高效又可靠的动态网站。无论你是初学者还是有经验的开发者，都能从中获得宝贵的见解和实用的技能。 ####
zhanbao
330 27
游客762btuqu5wybw666
|
安全 关系型数据库 MySQL
PHP与MySQL动态网站开发实战指南####
——深入探索LAMP栈下的高效数据交互与处理技巧 ####
游客762btuqu5wybw666
337 9

热门文章

最新文章

  • 1
    php代码审计之——phpstorm动态调试
  • 2
    使用消息服务(MNS)订阅阿里云物联网平台设备消息PHP示例参考
  • 3
    PHP对大小写敏感问题的处理比较乱，写代码时可能偶尔出问题，所以这里总结一下。以便用到的出现错误
  • 4
    安装php问题集合
  • 5
    disuz 7.2文字常量定义文件messages.lang.php
  • 6
    40个迹象表明你还是PHP菜鸟
  • 7
    php调用webservice报错Class &#39;SoapClient&#39; not found
  • 8
    Ubuntu14.04 64bit 编译安装nginx1.7+php5.4+mysql5.6
  • 9
    PHP系列（二）PHP函数的声明与应用
  • 10
    FirePHP——Ajax与php开发帮手
  • 1
    【紧急救援】MySQL CPU 100%！一套组合拳教你快速定位并解决！
    1182
  • 2
    MySQL中日期和时间函数的使用指南
    527
  • 3
    MySQL 与 Redis 如何保证双写一致性？
    1004
  • 4
    【赵渝强老师】MySQL的事务隔离级别
    503
  • 5
    【Docker】（3）学习Docker中 镜像与容器数据卷、映射关系！手把手带你安装 MySql主从同步 和 Redis三主三从集群！并且进行主从切换与扩容操作，还有分析 哈希分区 等知识点！
    968
  • 6
    MySQL源码编译安装
    2402
  • 7
    MySQL二进制包安装
    1746
  • 8
    MySQL包安装 -- SUSE系列（离线RPM包安装MySQL）
    940
  • 9
    MySQL包安装 -- SUSE系列（SUSE资源库安装MySQL）
    932
  • 10
    MySQL包安装 -- Debian系列（离线DEB包安装MySQL）
    3848

    • 相关课程

    更多
  • MySQL数据库入门学习
  • MySQL企业常见架构与调优经验分享
  • 云数据库MySQL版快速上手教程
  • 阿里云云原生数据仓库AnalyticDB MySQL版 使用教程
  • MySQL实战进阶
  • 阿里云数据库产品家族及特性

    • 相关电子书

    更多
  • 阿里云栖开发者沙龙PHP技术专场-深入浅出网络编程与swoole内核-吴镇宇
  • PHP安全开发:从白帽角度做安全
  • PHP 2017.北京 全球开发者大会——高可用的PHP

    • 推荐镜像

    更多
  • mysql
    • 下一篇
    一条命令迁移，帮你实现 OpenClaw 与 Hermes Agent 记忆互通！