php开发实战分析(8):mysql类库的操作高级使用API开发(字段操作、权限分配、日期格式、跨表查询,数据分表)

简介: php开发实战分析(8):mysql类库的操作高级使用API开发(字段操作、权限分配、日期格式、跨表查询,数据分表)

前言

在使用mysql类库时,需要封装 PHP 的 MySQL 开发 API 接口,为了设计出更加可靠、安全和易于使用的接口,以下是一些常见的注意事项:

  1. 参数验证和过滤:确保对传入 API 接口的参数进行严格的验证和过滤,以防止 SQL 注入攻击和其他安全漏洞。可以使用 PHP 的过滤器函数(如filter_var)或者利用预定义的过滤器(如FILTER_SANITIZE_STRING)来验证和过滤参数。
  2. 错误处理与异常管理:编写健壮的错误处理和异常管理机制,检查每个数据库操作的返回值或抛出相应的异常。在处理异常时,提供有用的错误信息,以便于追踪和调试问题。
  3. SQL 查询安全性:对于动态构建的 SQL 查询,尽量使用参数化查询(prepared statements)来防止 SQL 注入攻击。参数化查询能够在发送给数据库服务器之前对参数进行处理和转义,从而有效地阻止恶意用户对数据库进行攻击。
  4. 数据库连接管理:保证数据库连接的有效管理,避免频繁的连接和断开操作对性能造成的负面影响。可以使用连接池、持久连接等技术来优化数据库连接的性能和资源利用。
  5. 错误日志记录:将数据库操作过程中的错误信息进行记录和追踪,以便能够快速定位问题并进行处理。可以使用 PHP 的错误日志记录函数(如error_log)将错误信息写入日志文件或发送到指定的日志系统。
  6. 安全性考虑:避免在 API 接口中直接暴露敏感信息,如数据库用户名、密码等。尽量采用配置文件等安全方式进行敏感信息的存储和引用。
  7. 跨库和跨表兼容性:尽量编写通用的 API 接口,能够适应不同的数据库和表结构。考虑到不同数据库之间的差异,使用标准化的 SQL 语法和数据类型,以确保 API 在不同环境中的兼容性。
  8. 性能优化:对数据库操作进行性能优化,避免频繁的查询或更新操作。可以使用缓存技术、索引优化、批量操作等方法来提高数据库的性能和响应速度。
  9. API 接口设计规范:按照良好的 API 设计规范,使用符合 RESTful 风格的 URL、清晰的接口命名和语义化的 HTTP 方法。提供一致性的接口返回格式,如 JSON 或 XML,以方便客户端的调用和解析。
  10. 单元测试和文档化:通过编写单元测试案例来验证 API 接口的正确性和稳定性。并且提供清晰、详细的文档,描述 API 接口的使用方法、参数说明、返回值等,以方便其他开发者使用。

一、新增字段

  • checkAdminAuth($_COOKIE['admin_roles'], '0', 1); 权限限制
public function upAlter()
    {
        checkAdminAuth($_COOKIE['admin_roles'], '0', 1);//超管权限
        global $db;
        dbc();
        $sql = "ALTER TABLE " . $db->table('bank_record') . " ADD `inv_add_tel` varchar(255) DEFAULT NULL COMMENT '地址电话';";
        $sql .= "ALTER TABLE " . $db->table('bank_record') . " ADD `inv_bank_account` VARCHAR(255) DEFAULT NULL COMMENT '银行账户';";
        $sql .= "ALTER TABLE " . $db->table('bank_record') . " ADD `bank_source` INT(2) DEFAULT 0 COMMENT '客户端来源0手机1PC';";
        $db->query($sql);
        $res["data"] = '新增自动,Status:OK';
        die(json_encode_lockdata($res));
    }


二、新增数据表

public function creatTable()
     {
         checkAdminAuth($_COOKIE['admin_roles'], '0', 1);//超管权限
         global $db, $res;
         dbc();
         //读取管理员信息
         $sql = "CREATE TABLE IF NOT EXISTS `po_certificate` (
         `cert_id` int(11) NOT NULL AUTO_INCREMENT,
         `cert_name` varchar(32) DEFAULT NULL COMMENT '姓名',
         `cert_user_no` varchar(32) DEFAULT NULL COMMENT '身份证号',
         `cert_no` varchar(64) DEFAULT NULL COMMENT '证书编号',
         `cert_time` varchar(64) DEFAULT NULL COMMENT '获取时间',
         `course_name1` varchar(255) DEFAULT NULL COMMENT '技术目录1',
         `course_name2` varchar(255) DEFAULT NULL COMMENT '技术目录2',
         `course_name3` varchar(255) DEFAULT NULL COMMENT '技术目录3',
         `course_name4` varchar(255) DEFAULT NULL COMMENT '技术目录4',
         `cert_user_phone` varchar(32) DEFAULT NULL COMMENT '手机号码',
         PRIMARY KEY (`cert_id`)
         ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='电子证书';";
         $db->query($sql);
         $res["data"] = '创建成功';
         die(json_encode_lockdata($res));
     }


三、删除指定记录

  • get_param('sign_id');传递参数,安全过滤;
 public function delSign()
      {
          checkAdminAuth($_COOKIE['admin_roles'], '0', 1);//超管权限
          global $db;
          dbc();
          @$sign_id = get_param('sign_id');
          if ($sign_id == "") {
              die("参数错误");
          }
          $db->delete('sign_2023', 'sign_id in (' . $sign_id . ')');
          $res["data"] = '更新成功';
          die(json_encode_lockdata($res));
      }


三、批量同步交易信息

 public function synsBank()
        {
            checkAdminAuth($_COOKIE['admin_roles'], '0', 1);//超管权限
            global $db, $res;
            dbc();
            //读取管理员信息
            $sql = "select record_id,from_user_id,from_user_name FROM " . $db->table('bank_record') . " WHERE user_card = '' OR user_card IS NULL";
            $sql .= " AND course_id = 14 ORDER BY record_id DESC LIMIT 200";
            $row = $db->queryall($sql);
            //更新入库;
            for ($i = 0; $i < count($row); $i++) {
                $row_user = $db->fetch('user', 'user_card', array('user_id' => $row[$i]['from_user_id']), ' user_id DESC');
                $db->update('bank_record', array('user_card' => $row_user['user_card']), array('record_id' => $row[$i]['record_id']));
            }
            $res["data"] = '更新成功';
            die(json_encode_lockdata($res));
        }


四、修改用户密码

  public function updatePwd()
    {
        global $db, $res;
        dbc();
        @$user_pwd = get_param("user_pwd");
        $new_pwd = md5(rand(111111, 999999) . "/@W12");
        $db->update('user', array('user_pwd' => $new_pwd), array("user_pwd" => $user_pwd));
        $res['msg'] = "OK";
        $res["data"] = "密码更新成功.";
        die(json_encode_lockdata($res));
    }


五、获取用户信息

    public function getPwd()
    {
        global $db, $res;
        dbc();
        @$user_id = get_param("user_id");
        $sql = "select user_pwd FROM " . $db->table('user');
        if ($user_id != "") {
            $sql .= " WHERE user_id =" . $user_id;
        }
        $sql .= " ORDER BY user_id DESC";
        $row = $db->query($sql);
        $res['msg'] = "OK";
        $res["data"] = $row;
        die(json_encode_lockdata($res));
    }


六、更新多个用户表

    /*07.更新城市列表-1*/
    public function updateCity()
    {
        global $db, $res;
        dbc();
        @$user_area = get_param("user_area");
        @$old_user_area = get_param("old_user_area");
        $db->update('project', array('user_area' => $user_area), array("user_area" => $old_user_area));
        $db->update('user', array('user_area' => $user_area), array("user_area" => $old_user_area));
        $db->update('verify', array('user_area' => $user_area), array("user_area" => $old_user_area));
        $db->update('expert', array('user_area' => $user_area), array("user_area" => $old_user_area));
        $res['msg'] = "OK";
        $res["data"] = $user_area . "-信息更新成功.";
        die(json_encode_lockdata($res));
    }



@漏刻有时

相关实践学习
每个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月前
|
缓存 监控 前端开发
顺企网 API 开发实战:搜索 / 详情接口从 0 到 1 落地(附 Elasticsearch 优化 + 错误速查)
企业API开发常陷参数、缓存、错误处理三大坑?本指南拆解顺企网双接口全流程,涵盖搜索优化、签名验证、限流应对,附可复用代码与错误速查表,助你2小时高效搞定开发,提升响应速度与稳定性。
|
10月前
|
API 开发者 数据采集
高效获取淘宝商品详情:API 开发实现链接解析的完整技术方案
2025反向海淘新机遇:依托代购系统,聚焦小众垂直品类,结合Pandabay数据选品,降本增效。系统实现智能翻译、支付风控、物流优化,助力中式养生茶等品类利润翻倍,新手也能快速入局全球市场。
高效获取淘宝商品详情:API 开发实现链接解析的完整技术方案
|
10月前
|
存储 缓存 算法
淘宝买家秀 API 深度开发:多模态内容解析与合规推荐技术拆解
本文详解淘宝买家秀接口(taobao.reviews.get)的合规调用、数据标准化与智能推荐全链路方案。涵盖权限申请、多模态数据清洗、情感分析、混合推荐模型及缓存优化,助力开发者提升审核效率60%、商品转化率增长28%,实现UGC数据高效变现。
|
10月前
|
存储 缓存 算法
亚马逊 SP-API 深度开发:关键字搜索接口的购物意图挖掘与合规竞品分析
本文深度解析亚马逊SP-API关键字搜索接口的合规调用与商业应用,涵盖意图识别、竞品分析、性能优化全链路。通过COSMO算法解析用户购物意图,结合合规技术方案提升关键词转化率,助力卖家实现数据驱动决策,安全高效优化运营。
|
12月前
|
JSON API 数据安全/隐私保护
深度分析淘宝卖家订单详情API接口,用json返回数据
淘宝卖家订单详情API(taobao.trade.fullinfo.get)是淘宝开放平台提供的重要接口,用于获取单个订单的完整信息,包括订单状态、买家信息、商品明细、支付与物流信息等,支撑订单管理、ERP对接及售后处理。需通过appkey、appsecret和session认证,并遵守调用频率与数据权限限制。本文详解其使用方法并附Python调用示例。
|
11月前
|
数据可视化 测试技术 API
从接口性能到稳定性:这些API调试工具,让你的开发过程事半功倍
在软件开发中,接口调试与测试对接口性能、稳定性、准确性及团队协作至关重要。随着开发节奏加快,传统方式已难满足需求,专业API工具成为首选。本文介绍了Apifox、Postman、YApi、SoapUI、JMeter、Swagger等主流工具,对比其功能与适用场景,并推荐Apifox作为集成度高、支持中文、可视化强的一体化解决方案,助力提升API开发与测试效率。
|
10月前
|
JSON 算法 API
Python采集淘宝商品评论API接口及JSON数据返回全程指南
Python采集淘宝商品评论API接口及JSON数据返回全程指南
|
10月前
|
JSON API 数据安全/隐私保护
Python采集淘宝拍立淘按图搜索API接口及JSON数据返回全流程指南
通过以上流程,可实现淘宝拍立淘按图搜索的完整调用链路,并获取结构化的JSON商品数据,支撑电商比价、智能推荐等业务场景。
|
11月前
|
JSON 前端开发 API
如何调用体育数据足篮接口API
本文介绍如何调用体育数据API:首先选择可靠服务商并注册获取密钥,接着阅读文档了解基础URL、端点、参数及请求头,然后使用Python等语言发送请求、解析JSON数据,最后将数据应用于Web、App或分析场景,同时注意密钥安全、速率限制与错误处理。
1148 152
|
12月前
|
JSON 算法 安全
淘宝商品详情API接口系列,json数据返回
淘宝开放平台提供了多种API接口用于获取商品详情信息,主要通过 淘宝开放平台(Taobao Open Platform, TOP) 的 taobao.tbk.item.info.get(淘宝客商品详情)或 taobao.item.get(标准商品API)等接口实现。以下是关键信息及JSON返回示例:

推荐镜像

更多