侯体宗的博客
  • 首页
  • Hyperf版
  • beego仿版
  • 人生(杂谈)
  • 技术
  • 关于我
  • 更多分类
    • 文件下载
    • 文字修仙
    • 中国象棋ai
    • 群聊
    • 九宫格抽奖
    • 拼图
    • 消消乐
    • 相册

实例解析MySQL中的存储过程及存储过程的调用方法

数据库  /  管理员 发布于 6年前   219

mysql在5.1之后增加了存储过程的功能, 存储过程运行在mysql内部,语句都已经编译好了,速度比sql更快. 存储过程与mysql相当于shell和linux系统。如果你是程序员的话,那我告诉你存储过程实际上是一个方法,你只要调用这个方法,并且输入它设置好的参数就可以获取或者执行你想要的操作了. 看了如下存储过程实例,你会发现mysql存储过程和shell很像.
下面存储过程内容为:调用存储过程,并且传入用户名,密码参数。存储过程会将这她们存储到process_test表里面.看实例

一,创建数据库

mysql>create database db_proc;

二,创建表

mysql>CREATE TABLE `proc_test` ( `id` tinyint(4) NOT NULL AUTO_INCREMENT, #ID,自动增长 `username` varchar(20) NOT NULL, #用户名 `password` varchar(20) NOT NULL, #密码 PRIMARY KEY (`id`) #主键 ) ENGINE=MyISAM AUTO_INCREMENT=50 DEFAULT CHARSET=utf8; #设置表引擎和字符集

三、创建存储过程

create procedure mytest(in name varchar(20),in pwd varchar(20))#定义传入的参数 begin insert into proc_test(username,password) values(name,pwd);#把传进来的参数name和pwd插入表中,别忘记分号 end; #注意这个分号别忘记了create procedure mytest(in name varchar(20),in pwd varchar(20))#定义传入的参数 begin insert into proc_test(username,password) values(name,pwd);#把传进来的参数name和pwd插入表中,别忘记分号 end; #注意这个分号别忘记了

四、测试调用存储过程
用法:call 存储过程名称(传入的参数)
call proc_test("绝心是凉白开","")
username为”绝心是凉白开“传入数据库中,密码”“

五、查看数据库中有无加入的数据

select * from proc_test where username=‘绝心是凉白开';#如果有内容说明成功了

六、删除存储过程

drop procdure 存储过程名;

七、通用分页存储过程代码及调用

DROP PROCEDURE IF EXISTS pr_pager; CREATE PROCEDURE pr_pager(   IN   p_table_name    VARCHAR(1024),    /*表名*/   IN   p_fields      VARCHAR(1024),    /*查询字段*/   IN   p_page_size     INT,         /*每页记录数*/   IN   p_page_now     INT,         /*当前页*/   IN   p_order_string   VARCHAR(128),     /*排序条件(包含ORDER关键字,可为空)*/    IN   p_where_string   VARCHAR(1024),    /*WHERE条件(包含WHERE关键字,可为空)*/     OUT  p_out_rows     INT          /*输出记录总数*/   ) NOT DETERMINISTIC SQL SECURITY DEFINER COMMENT '分页存储过程'    BEGIN    /*定义变量*/   DECLARE m_begin_row INT DEFAULT 0;   DECLARE m_limit_string CHAR(64);    /*构造语句*/     SET m_begin_row = (p_page_now - 1) * p_page_size;   SET m_limit_string = CONCAT(' LIMIT ', m_begin_row, ', ', p_page_size);      SET @COUNT_STRING = CONCAT('SELECT COUNT(*) INTO @ROWS_TOTAL FROM ', p_table_name, ' ', p_where_string);   SET @MAIN_STRING = CONCAT('SELECT ', p_fields, ' FROM ', p_table_name, ' ', p_where_string, ' ', p_order_string, m_limit_string);    /*预处理*/   PREPARE count_stmt FROM @COUNT_STRING;   EXECUTE count_stmt;   DEALLOCATE PREPARE count_stmt;   SET p_out_rows = @ROWS_TOTAL;    PREPARE main_stmt FROM @MAIN_STRING;   EXECUTE main_stmt;   DEALLOCATE PREPARE main_stmt;    END; 

1.取记录调用:

call pr_pager('表名', '*', 25, 1, '', '', @count_rows); call pr_pager('user', '*', 15, 2, '', 'where id>3', @count_rows); call pr_pager('user', '*', 15, 1, 'group by password order by id desc', '', @count_rows); 

2.调用1后再取条数调用:

select @count_rows;  select @MAIN_STRING //select sql select @COUNT_STRING //seelct count sql 

支持多表级联 ,分组 :

复制代码 代码如下:

call pr_pager('job j left join enter_job ej on j.job_no=ej.job_no','j.*,ej.*','25','1','group by ej.put_away_user order by ej.put_away_user desc','where j.job_table="enter"',@p_out_rows);

<?php function dump_single_form41report($sys_report_id) {   $this->dbConn->setFetchMode(DB_FETCHMODE_ASSOC);   //SET @a=1;CALL dbpi_report.simpleproc(@a);SELECT @a;   $sql = "CALL dbpi_temp.dumpSingleReportForm41($sys_report_id);";   $result = $this->dbConn->query($sql);   if (mysql_error()) {     die (mysql_error().'<b>:</b> dump_single_form41report(...)['.__LINE__.'];<br>'.$sql);   }   return $result; }  function initQueuePool($sys_report_id, $username){   $this->dbConn->setFetchMode(DB_FETCHMODE_ASSOC);   $this->checkPreviousThread($sys_report_id, $username);    $temptablename = "_".$username."_".$sys_report_id;   $sql = "SET @a=".$sys_report_id.";";   $this->dbConn->query($sql);   $sql = "SET @b='".DB_REPORT.".".$temptablename."';";   $this->dbConn->query($sql);   $sql = "SET @c='".DB_PREPRODUCT."';";   $this->dbConn->query($sql);   $sql = "CALL ".DB_REPORT.".fm41_simpleproc(@a,@b,@c);";   $this->dbConn->query($sql); }  

 
普通的查询,只返回一个结果集,而存储过程却返回至少两个结果集,其中一个就是存储过程的执行状态。我们必须要清除了这个执行状态以后,才可能再次调用另外一个存储过程 。

<?php $rs=mysql_query("call pr_pager('change_monitor','*',10,1,'','',@p_out_rows)"); while($rows=mysql_fetch_array($rs)){   echo $rows[Schedule]; } $query=mysql_query("select @p_out_rows"); $v=mysql_fetch_array($query);  can't return a result set in the given context

需要php调用存储过程,返回一个结果集,发现很困难,找了半天,终于在老外的论坛上找到解决方案,这里本地化一下。
关键就是两点:
1.

define('CLIENT_MULTI_RESULTS', 131072);

2.

$link = mysql_connect("127.0.0.1", "root", "",1,CLIENT_MULTI_RESULTS) or die("Could not connect: ".mysql_error());


  • 上一条:
    详解MySQL查询时区分字符串中字母大小写的方法
    下一条:
    mysql Sort aborted: Out of sort memory, consider increasing server sort buffer size的解决方法
  • 昵称:

    邮箱:

    0条评论 (评论内容有缓存机制,请悉知!)
    最新最热
    • 分类目录
    • 人生(杂谈)
    • 技术
    • linux
    • Java
    • php
    • 框架(架构)
    • 前端
    • ThinkPHP
    • 数据库
    • 微信(小程序)
    • Laravel
    • Redis
    • Docker
    • Go
    • swoole
    • Windows
    • Python
    • 苹果(mac/ios)
    • 相关文章
    • 分库分表的目的、优缺点及具体实现方式介绍(0个评论)
    • DevDB - 在 VS 代码中直接访问数据库(0个评论)
    • 在ubuntu系统中实现mysql数据存储目录迁移流程步骤(0个评论)
    • 在mysql中使用存储过程批量新增测试数据流程步骤(0个评论)
    • php+mysql数据库批量根据条件快速更新、连表更新sql实现(0个评论)
    • 近期文章
    • 在go语言中使用api.geonames.org接口实现根据国际邮政编码获取地址信息功能(1个评论)
    • 在go语言中使用github.com/signintech/gopdf实现生成pdf分页文件功能(0个评论)
    • gmail发邮件报错:534 5.7.9 Application-specific password required...解决方案(0个评论)
    • 欧盟关于强迫劳动的规定的官方举报渠道及官方举报网站(0个评论)
    • 在go语言中使用github.com/signintech/gopdf实现生成pdf文件功能(0个评论)
    • Laravel从Accel获得5700万美元A轮融资(0个评论)
    • 在go + gin中gorm实现指定搜索/区间搜索分页列表功能接口实例(0个评论)
    • 在go语言中实现IP/CIDR的ip和netmask互转及IP段形式互转及ip是否存在IP/CIDR(0个评论)
    • PHP 8.4 Alpha 1现已发布!(0个评论)
    • Laravel 11.15版本发布 - Eloquent Builder中添加的泛型(0个评论)
    • 近期评论
    • 122 在

      学历:一种延缓就业设计,生活需求下的权衡之选中评论 工作几年后,报名考研了,到现在还没认真学习备考,迷茫中。作为一名北漂互联网打工人..
    • 123 在

      Clash for Windows作者删库跑路了,github已404中评论 按理说只要你在国内,所有的流量进出都在监控范围内,不管你怎么隐藏也没用,想搞你分..
    • 原梓番博客 在

      在Laravel框架中使用模型Model分表最简单的方法中评论 好久好久都没看友情链接申请了,今天刚看,已经添加。..
    • 博主 在

      佛跳墙vpn软件不会用?上不了网?佛跳墙vpn常见问题以及解决办法中评论 @1111老铁这个不行了,可以看看近期评论的其他文章..
    • 1111 在

      佛跳墙vpn软件不会用?上不了网?佛跳墙vpn常见问题以及解决办法中评论 网站不能打开,博主百忙中能否发个APP下载链接,佛跳墙或极光..
    • 2017-06
    • 2017-08
    • 2017-09
    • 2017-10
    • 2017-11
    • 2018-01
    • 2018-05
    • 2018-10
    • 2018-11
    • 2020-02
    • 2020-03
    • 2020-04
    • 2020-05
    • 2020-06
    • 2020-07
    • 2020-08
    • 2020-09
    • 2021-02
    • 2021-04
    • 2021-07
    • 2021-08
    • 2021-11
    • 2021-12
    • 2022-02
    • 2022-03
    • 2022-05
    • 2022-06
    • 2022-07
    • 2022-08
    • 2022-09
    • 2022-10
    • 2022-11
    • 2022-12
    • 2023-01
    • 2023-03
    • 2023-04
    • 2023-05
    • 2023-07
    • 2023-08
    • 2023-10
    • 2023-11
    • 2023-12
    • 2024-01
    • 2024-03
    Top

    Copyright·© 2019 侯体宗版权所有· 粤ICP备20027696号 PHP交流群

    侯体宗的博客