mysql存储过程fetch

Ⅰ mysql 存储过程

你应该在做统计吧,估计你不会的就是mysql存储过程的语法 我之前也写过 很是郁闷 我给你一段代码 是我用mysql写过的一个存储过程 你看看 主要是了解里面的语法 看懂了 你所说的需求并不难
有看不懂的地方一起讨论 :
begin

declare tikk datetime ;
declare done int default 0;
declare userid int default 0;
declare moleid int default 0;
declare couid int default 0;
declare mname varchar(255) ;
declare opsid int default 0;

declare c1 cursor for Select I_userID,I_operationID from space_operation_record where status<>0 group by I_userID,I_operationID order by createtime desc;
declare continue handler for sqlstate '02000' set done =1;
set tikk = now();
open c1;
repeat
fetch c1 into userid, opsid;
if not done then
select I_moleID from space_operation where status<>0 and ID=opsid into moleid;
if moleid <> '' then
select Nvc_identification from space_operation where status<>0 and ID=opsid into @identiftion;
if moleid > 0 then
Select Nvc_ename from space_mole where status<>0 and ID=moleid into mname;
else
set mname = 'space';
end if;

create temporary table if not exists sp_tab1(id bigint(20),Nvc_content MEDIUMTEXT,I_obyuID bigint(20),I_tID bigint(20),createtime datetime);
INSERT INTO sp_tab1 Select ID,Nvc_content,I_objectID,I_tmID,createtime from space_operation_record where status<>0 and I_operationID=opsid and I_userID=userid ;
select count(*) from sp_tab1 into couid;

set @ihod = 0;
set @listp = '';
set @listpp = '';
set @content0p = '';
set @content0 = '';
while couid > 0 do
select ID,Nvc_content,I_obyuID,createtime,I_tID into @iok,@conuiy,@objiplk,@crtimhr,@tmids from sp_tab1 where ID > @ihod order by ID asc limit 0,1;
if @iok <> '' then
if mname = 'blog' then
INSERT INTO space_operation_stat(I_operationID,I_userID,Nvc_content,D_stattime,createtime) VALUES (@iok,userid,@conuiy,@crtimhr,tikk);
elseif mname = 'team' then
if(@identiftion = 'addblog' || @identiftion = 'mdyblog') then
INSERT INTO space_operation_stat(I_operationID,I_userID,Nvc_content,D_stattime,I_tmID,createtime) VALUES (@iok,userid,@conuiy,@crtimhr,@tmids,tikk);
else
set @listpp = CONCAT(@listpp,CONCAT(@objiplk,','));
set @operarry1p = substring_index(@conuiy,'|',1);
set @operarry2p = substring_index(@conuiy,'|',-1);
set @content0p = CONCAT(@content0p,CONCAT(@operarry2p,SPACE(1)));
set @objlistp = substring(@listpp,1,length(@listpp)-1);
end if;
elseif mname = 'space' then
if(@identiftion = 'headphoto' || @identiftion = 'status') then
INSERT INTO space_operation_stat(I_operationID,I_userID,Nvc_content,D_stattime,I_tmID,createtime) VALUES (@iok,userid,@conuiy,@crtimhr,@tmids,tikk);
else
set @listppr = CONCAT(@listppr,CONCAT(@objiplk,','));
set @operarry1pr = substring_index(@conuiy,'|',1);
set @operarry2pr = substring_index(@conuiy,'|',-1);
set @content0pr = CONCAT(@content0pr,CONCAT(@operarry2pr,SPACE(1)));
set @objlistpr = substring(@listppr,1,length(@listppr)-1);
end if;
else
set @listp = CONCAT(@listp,CONCAT(@objiplk,','));
set @operarry1 = substring_index(@conuiy,'|',1);
set @operarry2 = substring_index(@conuiy,'|',-1);
set @content0 = CONCAT(@content0,CONCAT(@operarry2,SPACE(1)));
set @objlist = substring(@listp,1,length(@listp)-1);
end if;
set @ihod = @iok;
end if;
set couid = couid -1;
end while;

if @content0 <> '' then
set @contentp = CONCAT(@operarry1,concat('|',@content0));
Select createtime,ID into @uitimej,@IDjok from space_operation_record where status<>0 and I_operationID=opsid order by createtime desc limit 0,1;
if @uitimej <> '' then
INSERT INTO space_operation_stat(I_operationID,I_userID,Nvc_content,D_stattime,createtime,Nvc_objlist) VALUES(@iok,userid,@contentp,@crtimhr,tikk,@objlist);
end if;
end if;
if @content0p <> '' then
if @identiftion = 'addphoto' then
set @contentp = CONCAT(@operarry1p,CONCAT('|',@content0p));
else
set @contentp = CONCAT(@operarry1p,CONCAT(@content0p,'|'));
end if;

Select createtime,ID into @uitimej,@IDjok from space_operation_record where status<>0 and I_operationID=opsid order by createtime desc limit 0,1;
if @uitimej <> '' then
INSERT INTO space_operation_stat(I_operationID,I_userID,Nvc_content,D_stattime,createtime,Nvc_objlist,I_tmID) VALUES(@iok,userid,@contentp,@crtimhr,tikk,@objlistp,@tmids);
end if;
end if;
if @content0pr <> '' then
set @contentp = CONCAT(@operarry1p,concat('|',@content0pr));
Select createtime,ID into @uitimej,@IDjok from space_operation_record where status<>0 and I_operationID=opsid order by createtime desc limit 0,1;
if @uitimej <> '' then
INSERT INTO space_operation_stat(I_operationID,I_userID,Nvc_content,D_stattime,createtime,Nvc_objlist,I_tmID) VALUES(@iok,userid,@contentp,@crtimhr,tikk,@objlistp,@tmids);
end if;
end if;
delete from sp_tab1;
end if;
end if;

until done end repeat;
close c1;
drop temporary table if exists sp_tab1 ;

UPDATE space_operation_play SET status=0;
UPDATE space_operation_display SET status=0;
Select createtime into @ptimes from space_operation_stat where status<>0 order by createtime desc limit 0,1;
if @ptimes <>'' then
create temporary table if not exists sp_tab2(id bigint(20),Nvc_content MEDIUMTEXT,I_userID bigint(20),I_lyuID bigint(20),D_stattime datetime);
INSERT INTO sp_tab2 Select ID,Nvc_content,I_userID,I_tmID,D_stattime from space_operation_stat where status<>0 and createtime=@ptimes order by D_stattime desc limit 0,30;
select count(*) from sp_tab2 into @cou1id;
set @uoj = 0;
while @cou1id > 0 do
select ID,Nvc_content,I_userID,D_stattime,I_lyuID into @io1k,@conui1y,@objipl1k,@crtimh1r,@unlpa from sp_tab2 where ID > @uoj order by ID asc limit 0,1;
if @io1k <> '' then
INSERT INTO space_operation_play(I_statID,Nvc_content,D_stattime,I_userID,Createtime,I_tmID) VALUES (@io1k,@conui1y,@crtimh1r,@objipl1k,now(),@unlpa);
set @uoj = @io1k;
end if;
set @cou1id = @cou1id -1;
end while;
drop temporary table if exists sp_tab2 ;
end if;

end

Ⅱ 怎么写mysql存储过程，并用php调用它

mysql创建的存储，在mysql里执行就可以

create procere pr_user_get(
p_user_id int -- 传入的参数

)
proc_start:begin
select b.*
from table1 as a,table2 as b
where a.userid = p_user_id

and a.username = b.username;

end proc_start

php调用
$sql = "call pr_user_get('$userid')";
$result = mysql_query($sql);
$row = mysql_fetch_array($result);

$row 就是了

Ⅲ php调用mysql存储过程，如何实现。 我的代码如下：

mysql存储过程返回2个资源，第一个是执行信息，第二个是存储过程返回结果。

mysql_*系列函数无法获取超过1个资源，需使用mysqli或PDO代替。

PDO：

$stmt=$db->prepare("CALLpro_rb_save(?,?,@return_msg);");
$stmt->bindParam(1,$a);
$stmt->bindParam(2,$b);
$stmt->execute();
$outputArray=$db->query("select@return_msg")->fetch(PDO::FETCH_ASSOC);

var_export($return_msg);

Ⅳ mysql中的存储过程、触发器、视图的用法

建立存储过程

Create procere、Create function

下面是它们的格式：
Create proceresp_Name ([proc_parameter ])
routine_body

这里的参数类型可以是 IN OUT INOUTT ，意思和单词的意思是一样的，IN 表示是传进来的参数，
OUT 是表示传出去的参数，INOUT 是表示传进来但最终传回的参数。
Create functionsp_Name ([func_parameter ])
Returns type

Routine_body
Returns type 指定了返回的类型，这里给定的类型与返回值的类型要是一样的，否则会报错。

下面给出两个简单的例子来说明：

1、 显示 Mysql 当前版本

执行结果
mysql> use welefen;
Database changed
mysql> delimiter // #定义//作为结束标记符号
mysql> create procere getversion(out param1 varchar(50)) #param1为传出参数
-> begin
-> select version() into param1; #将版本的信息赋值给 param1
-> end
-> //
Query OK, 0 rows affected (0.00 sec)

mysql> call getversion(@a); #调用getversion()这个存储过程
-> //
Query OK, 0 rows affected (0.00 sec)

mysql> select @a;
-> //
+--------------------------+
| @a |
+--------------------------+
| 5.1.14-beta-community-nt |
+--------------------------+
1 row in set (0.00 sec)

2、 显示”hello world”

执行结果
mysql> delimiter //
mysql> create function display(w varchar(20)) returns varchar(50)
-> begin
-> return concat('hello ‘,w);
-> end
-> //
Query OK, 0 rows affected (0.05 sec)

mysql> select display("world");
-> //
+------------------+
| display("world") |
+------------------+
| hello world |
+------------------+
1 row in set (0.02 sec)

其他操作存储过程的语句

前面我们已经知道了怎么创建存储过程，下面看看其他常用的用于操作存储过程的语句。

Alter {procere | function} sp_Name []

Alter 语法是用来改变一个过程或函数的特征,当你想改变存储过程或者函数的结构时可以使
用它。当然你也可以先 drop 它再 create。

Drop {procere | function} [if exists] sp_Name

Drop 语法即用来删除一个存储程序或者函数，当你创建的一个存储过程或者函数的名字已经存
在时，你想把以前的给覆盖掉，那么此时你就可以使用 drop ,然后在创建。

Show create {procere | function } sp_Name

Show 语法用来显示创建的存储过程或者函数的信息。这里的 show 用法跟数据表中的 show 用
法是很相似的。

Show {procere | function} status [like 'partten']

它返回子程序的特征，如数据库，名字，类型，创建者及创建和修改日期。如果没有指定样式，
根据你使用的语句，所有存储程序和存储函数的信息都被列出。

看了以上的几个语法，你是不是感觉跟对表的操作很相象，那你就想对了，他们确实是很相似
的。带着一份激动心情我们继续往下看，你会发现很简单。

Begin ... End 语句

通过 begin end 可以来包含多个语句，每个语句以“;”结尾。

Declare

用Declare 来声明局部变量
Declarevar_Name type defaulevaule

Delare 条件

Declarecondition_Name CONDITION FOR condition_value

调用存储过程

Call

格式：
Callsp_Name [parameter ]

这里的 sp_Name 必须是由 create procere 创建的名称。它可以通过声明的参数来传回值，
它也返回受影响的行数，在 MySQL 中可以通过 mysql_affected_rows() 来获得。

流程控制语句

IF 语句

IFsearch_condition THENstatement_list
[ELSEIFsearch_condition THENstatement_list]
[ELSEstatement_list]
END IF

CASE 语句

CASE case_value
WHEN when_value THENstatement_list
WHEN when_value THENstatement_list]
ELSEstatement_list]
END CASE

LOOP 语句

[begin_label:] LOOP
statement_list
END LOOP [end_label]
LOOP 实现了一个简单的循环，通过 LEAVE 来退出

LEAVE 语句

LEAVE lable
退出语句，一般可以用在循环中。

ITERATE 语句

ITERATE lable
ITERATE 一般出现在 LOOP、REPEATE、WHILE 里，意思是再次循环。

REPEATE 语句

[begin_label:] REPEAT
statement_list
UNTILsearch_condition
END REPEAT [end_label]
REPEAT 语句内的语句或语句群被重复，直至 search_condition 为真。

WHILE 语句

[begin_label:] WHILEsearch_condition DO
statement_list
END WHILE [end_label]
WHILE 语句内的语句或语句群被重复，直至 search_condition 为真。
运用实例

下面通过几个例子来讲述他们的应用：

对网站用户的操作

为了简单,用户表只有用户名和密码的信息.在服务端，我们建立如下的表：

代码片段
Drop table if exists user;
Create table user(
Id int unsigned not null auto_increment,
Name varchar(20) not null,
Pwd char(32) not null,
Primary key(Id)
);

添加用户的存储过程：

代码片段
Delimiter //
Create procere insertuser(in username varchar(20),in userpwd varchar(32))
Begin
Insert into welefen.user(Name,Pwd) values (username,md5(userpwd));
End
//

验证用户的存储过程：

代码片段
Delimiter //
Create procere validateuser(in username varchar(20),out param1)
Begin
Select Pwd into param1 from welefen.user where Name=username;
End
//

修改密码的存储过程：

代码片段
Delimiter //
Create procere modifyPwd(in username varchar(20),in userpwd varchar(32))
Begin
Update welefen.user set Pwd=md5(userpwd) where Name=username;
End
//

删除用户的存储过程：

代码片段
Delimiter //
Create procere deleteuser(in username varchar(20))
Begin
delete from welefen.user where Name=username;
End
//

在客户端，我们给出如下的程序：

代码片段
文件名：ProcereUser.php
<?php

if (!mysql_connect("localhost","root","welefen")){
echo "连接数据库失败";
}
if (!mysql_select_db("welefen")){
echo "选择数据库表失败<br>";
}

$insert_user=array("welefen","welefen");//这里的welefen分别为用户名、密码
if (mysql_query("call insertuser('$insert_user[0]','$insert_user[1]')")){
echo "添加用户$insert_user[0]成功<br>";
}else {
echo "添加用户$insert_user[0]失败<br>";
}

$validate_user=array("welefen","welefen");//这里的welefen分别为用户名、密码
mysql_query("call validateuser('$validate_user[0]',@a)");
$Pwd=mysql_query("select @a");
$result=mysql_fetch_array($Pwd);
if ($result[0]==md5($validate_user[1])){
echo "用户$validate_user[0]验证正确<br>";
}else {
echo "用户$validate_user[0]验证错误<br>";
}

$modify_Pwd=array("welefen","weilefeng"); //welefen为用户名weilefeng为新密码
if (mysql_query("call modifyPwd('$modify_Pwd[0]','$modify_Pwd[1]')")){
echo "用户$modigy_Pwd[0]的密码修改成功<br>";
}else {
echo "用户$modigy_Pwd[0]的密码修改失败<br>";
}

$delete_user=array("welefen"); //welefen为用户名
if (mysql_query("call deleteuser('$delete_user[0]')")){
echo "用户$delete_user[0]删除成功<br>";
}else {
echo "用户$delete_user[0]删除失败<br>";
}
?

程序运行的结果：

执行结果
添加用户welefen 成功
用户welefen 验证正确
用户welefen 的密码修改成功
用户welefen 删除成功

以上的这个程序简单的说明了Mysql 中的存储过程结合PHP 的应用，当然在实际应用要比这个
复杂的多。

验证角谷猜想

角谷猜想：给定一个整数x,若x%2=1，则x=3*x+1，否则x=x/2，如此循环下去，经过有限步骤必
能得到1。
例 如 ： 初 始 整 数 为 9 ， 则
9->28->14->7->22->11->34->17->52->26->13->40->20->10->5->16->8->4->2->1

为了说明存储过程中一些语法的应用，我们通过存储过程来实现它:

执行结果
mysql> delimiter //
mysql> create procere jgguess(in number int)
-> begin
-> declare param1 int default 1;
-> set @a=concat(number);
-> jiaogu:loop #循环开始
-> set param1=number%2;
-> if param1=1 then set number=number*3+1; #number 为奇数，将它乘3加 1
-> else set number=number/2;
-> end if;
-> set @a=concat(@a,'->',number);
-> if number>1 then iterate jiaogu; #number 不为 1，继续循环
-> end if;
-> leave jiaogu; #退出循环
-> end loop jiaogu;
-> end
-> //
Query OK, 0 rows affected (0.00 sec)

mysql> call jgguess(11);
-> //
Query OK, 0 rows affected (0.00 sec)

mysql> select @a//
+-------------------------------------------------------+
| @a |
+-------------------------------------------------------+
| 11->34->17->52->26->13->40->20->10->5->16->8->4->2->1 |
+-------------------------------------------------------+
1 row in set (0.02 sec)

在这个存储过程中，你传入的参数不能超过int 型数据的范围，否则就会报错。

触发器

触发器是与表有关的命名数据库对象，当表上出现特定事件时，将激活该对象。例如当我们向
某个表插入一行数据时发生一个事件或者删除某个记录时触发某个事件。
语法：
CREATE TRIGGER trigger_Name trigger_time trigger_event
ON tbl_Name FOR EACHROW trigger_stmt
trigger_time 是触发器的动作时间。它可以是 BEFORE 或 AFTER ，以指明触发器是在激活它的
语句之前或之后触发。
trigger_event 指明了激活触发器的语句的类型。trigger_event 可以是下述值之一：
INSERT：将新行插入表时激活触发器，例如，通过 INSERT、LOADDATA 和 REPLACE 语句；
UPDATE：更改某一行时激活触发器，例如，通过UPDATE语句；
DELETE：从表中删除某一行时激活触发器，例如，通过 DELETE 和 REPLACE 语句。

例如当我们向上面的user 表中增加一个用户名为“welefen ”时，我们把记录用户数的表的值增
加 1;

代码片段
Create table numuser(
Num int not null default 0
);

Delimiter //
Create trigger testnum after insert on welefen.user for each row
Begin
Update welefen.numuser set Num=Num+1;
End
//

视图

当我们想得到数据表中某些字段的信息，并想把他们保存时我们就可以用视图。

语法：
CREATE [OR REPLACE] [ALGORITHM = {UNDEFINED | MERGE | TEMPTABLE}]
VIEW view_Name [(column_list)]
AS select_statement
[WITH [CASCADED | LOCAL] CHECK OPTION]

例如我们想对上面的用户表使用视图，可以这样：
Create viewwelefen.userview as select * fromwelefen.user;
查看视图的信息可以使用:
Select * fromwelfen.userview;

Ⅳ MySQL中创建存储过程中命令号客户机的分隔符

第一步，双击打开MySQL Workbench客户端，连接数据库book，创建数据库存储过程，如下图所示：
如何利用MySQL Workbench中的光标创建存储过程

第二步，编写存储过程命令，声明变量和光标，打开光标，fetch和关闭光标，如下图所示：
如何利用MySQL Workbench中的光标创建存储过程

第三步，然后运行存储过程，“Apply SQL Script to Database”，如下图所示：
如何利用MySQL Workbench中的光标创建存储过程

第四步，点击“Apply”进行执行存储过程，如下图所示：
如何利用MySQL Workbench中的光标创建存储过程

第五步，勾选执行SQL语句，接着单击“Finish”，完成SQL语句执行，如下图所示：
如何利用MySQL Workbench中的光标创建存储过程

第六步，调用存储过程，并查看执行存储过程的结果，如下图所示：
如何利用MySQL Workbench中的光标创建存储过程

Ⅵ Mysql里如何使用存储过程

CREATE DEFINER 存储过程名
@变量1 类型 ----这里个就是传进来的
@变量2 类型 output ----这个是定义输出变量
as
declared @变量 类型,@变量 类型 --这里是定义内部变量 只能这是过程用
if 条件
begin
#￥%……&*
end
else
begin
#￥%……&
end
-----不知道你要什么
execute 数据库名.dbo.过程名 -----这个是 在这个过程里 调用别的过程

Ⅶ mysql 存储过程怎么调用

php调用mysql存储过程和函数的方法
存储过程和函数是MySql5.0刚刚引入的。关于这方面的操作在PHP里面没有直接的支持。但是由于Mysql PHP API的设计，使得我们可以在以前的PHP版本中的mysql php api中支持存储过程和函数的调用。

在php中调用存储过程和函数。

1。调用存储过程的方法。

a。如果存储过程有 IN/INOUT参数，声明一个变量，输入参数给存储过程，该变量是一对，

一个php变量（也可以不必，只是没有php变量时，没有办法进行动态输入），一个Mysql

变量。

b。如果存储过程有OUT变量，声明一个Mysql变量。

mysql变量的声明比较特殊，必须让mysql服务器知道此变量的存在，其实也就是执行一条mysql语句。

入set @mysqlvar=$phpvar ;

c。使用mysql_query()/mysql_db_query()执行mysql 变量声明语句。

mysql_query("set @mysqlvar=$pbpvar");

这样，在mysql服务器里面就有一个变量，@mysqlar。如果是IN参数，那么其值可以由phpar传入。

d。 如果是存储过程。

1。执行 call procere（）语句。

也就是mysql_query("call proceer([var1]...)");

2. 如果有返回值，执行select @ar，返回执行结果。

mysql_query("select @var)"

接下来的操作就和php执行一般的mysql语句一样了。可以通过mydql_fetch_row()等函数获得结果。

如果时函数。 直接执行 select function（） 就可以了。
$host="localhost";
$user="root";
$password="11212";
$db="samp_db";
$dblink=mysql_connect($host,$user,$password)
or die("can't connect to mysql");
mysql_select_db($db,$dblink)
or die("can't select samp_db");
$res=mysql_query("set @a=$password",$dblink);
$res=mysql_query("call aa(@a)",$dblink);
$res=mysql_query("select @a",$dblink);
$row=mysql_fetch_row($res);
echo $row[0];

Ⅷ 调用存储过程返回集出错Warning: mysql_fetch_array(): supplied argument is not a valid MySQL result

说明$rs为空，所以用mysql_fetch_array没有得到数据，所以会报错

Ⅸ MySQL存储过程创建，我错在哪里了

你这个要取输入的ROWS以后的学生学号?
open cur;
FETCH cur into sno; 这里要用for循环啊。
不然你游标里面的数据很多，不可能都保存到sno里面的。
LOOP
FETCH cur into sno;
while FOUND DO
set ROWS=ROWS+1;
END LOOP
这样你的ROWS才会实现不停＋1功能

Ⅹ 怎么写mysql存储过程，并用php调用它

• 实现原理
  

1. 首先，需要知道怎么写mysql存储过程，了解mysq存储过程语言，
   

2. 其次，使用mysql工具创建存储过程。

3. 最后，通过mysql_query()函数执行mysql变量的设置和mysql存储过程及返回值。
   
   

• 具体代码如下：

1. mysql存储过程代码

createprocerepro_name(user_idint)
begin
.........
end

2. PHP代码

$host="localhost";
$user="root";
$password="232412";
$db="user_db";
$dblink=mysql_connect($host,$user,$password)ordie("can'tconnecttomysql");
mysql_select_db($db,$dblink)ordie("can'tselectuser_db");
$user_id=1;
$res=mysql_query("set@a=$user_id",$dblink);
$res=mysql_query("callpro_name(@a)",$dblink);