MySQL 5.0以后的版本开始支持存储过程，存储过程具有一致性、高效性、安全性和体系结构等特点，本节将通过具体的实例讲解PHP是如何操纵MySQL存储过程的。
实例261：存储过程的创建
这是一个创建存储过程的实例
录像位置：光盘\mingrisoft\09\261
实例说明
为了保证数据的完整性、一致性，提高应用的性能，常采用存储过程技术。MySQL 5.0之前的版本并不支持存储过程，随着MySQL技术的日趋完善，存储过程将在以后的项目中得到广泛的应用。本实例将介绍在MySQL 5.0以后的版本中创建存储过程。
技术要点
一个存储过程包括名字、参数列表，以及可以包括很多SQL语句的SQL语句集。下面为一个存储过程的定义过程：
create procedure proc_name (in parameter integer)
begin
declare variable varchar(20);
if parameter=1 then
set variable='MySQL';
else
set variable='PHP';
end if;
insert into tb (name) values (variable);
end;
MySQL中存储过程的建立以关键字create procedure开始，后面紧跟存储过程的名称和参数。MySQL的存储过程名称不区分大小写，例如PROCE1()和proce1()代表同一个存储过程名。存储过程名不能与MySQL数据库中的内建函数重名。 存储过程的参数一般由3部分组成。第一部分可以是in、out或inout。in表示向存储过程中传入参数；out表示向外传出参数；inout表示定义的参数可传入存储过程，并可以被存储过程修改后传出存储过程，存储过程默认为传入参数，所以参数in可以省略。第二部分为参数名。第三部分为参数的类型，该类型为MySQL数据库中所有可用的字段类型，如果有多个参数，参数之间可以用逗号进行分割。
MySQL存储过程的语句块以begin开始，以end结束。语句体中可以包含变量的声明、控制语句、SQL查询语句等。由于存储过程内部语句要以分号结束，所以在定义存储过程前应将语句结束标志“;”更改为其他字符，并且该字符在存储过程中出现的几率也应该较低，可以用关键字delimiter更改。例如：
mysql>delimiter //
存储过程创建之后，可用如下语句进行删除，参数proc_name指存储过程名。 drop procedure proc_name
实现过程 （1）MySQL存储过程是在“命令提示符”下创建的，所以首先应该打开“命令提示符”窗口。
（2）进入“命令提示符”窗口后，首先应该登录MySQL数据库服务器，在“命令提示符”下输入如下命令：
mysql –u用户名 –p用户密码
（3）更改语句结束符号，本实例将语句结束符更改为“//”。代码如下：
delimiter //
（4）创建存储过程前应首先选择某个数据库。代码如下：
use 数据库名
（5）创建存储过程。
（6）通过call语句调用存储过程。
MySql> call proc_name(@para)-->对应存储过程定义中out的输出到一个变量函数para中
MySql>select @para -------->显示出来
--------------------------------------------------
MySql> call proc_name(5)-->对应存储过程定义中 in 定义,传入值5到存储过程中
（7）列出MYSQL库中所有已存在的存储过程文件
MySql> show procedure status;
（8）查看存在的存储过程文件内容:
MySql>show create procedure proc_name;
（9）程序代码示例:
view plaincopy to clipboardprint?
package service; import java.sql.CallableStatement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Types; public class TestMysqlProcedure { String url = "jdbc:mysql://127.0.0.1:3306/mydate"; String userName = "root"; String password = "root"; public Connection getConnection() { Connection con=null; try{ DriverManager.registerDriver(new com.mysql.jdbc.Driver()); con = DriverManager.getConnection(url, this.userName, this.password); }catch(SQLException sw){ } return con; } //读取OUT型的存储过程(计算记录总数) public void testProc_Out(){ Connection conn = getConnection(); CallableStatement stmt = null; try{ //调取OUT型的存储过程P(计算记录总数) stmt = conn.prepareCall("{call p(?)}"); //读取所有OUT型的存储过程的返回参数数据 stmt.registerOutParameter(1, Types.INTEGER); stmt.execute(); int i= stmt.getInt(1); System.out.println("count = " + i); }catch(Exception e){ System.out.println("hahad = "+e.toString()); }finally{ try { stmt.close(); conn.close(); }catch (Exception ex) { System.out.println("ex : "+ ex.getMessage()); } } } //读取IN型的存储过程(条件查询) public void testProc_In(){ Connection conn = getConnection(); CallableStatement stmt = null; ResultSet rs=null; try{ //调取IN型的存储过程P2,(条件查询) stmt = conn.prepareCall("{call p2(?)}"); //设置IN型的存储过程参数值 stmt.setInt(1, 3); //执行语句,并返回值 rs=stmt.executeQuery(); if(rs.next()){ System.out.println("rs ---------- " + rs.getInt(1)); System.out.println("rs ---------- " + rs.getString(2)); } }catch(Exception e){ System.out.println("hahad --------- "+e.toString()); }finally{ try { rs.close(); stmt.close(); conn.close(); }catch (Exception ex) { System.out.println("ex ----------: "+ ex.getMessage()); } } } public static void main(String[] args) { TestMysqlProcedure tmp=new TestMysqlProcedure(); tmp.testProc_Out(); tmp.testProc_In(); } } package service;import java.sql.CallableStatement;import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Types;public class TestMysqlProcedure { String url = "jdbc:mysql://127.0.0.1:3306/mydate"; String userName = "root"; String password = "root"; public Connection getConnection() { Connection con=null; try{ DriverManager.registerDriver(new com.mysql.jdbc.Driver()); con = DriverManager.getConnection(url, this.userName, this.password); }catch(SQLException sw){ } return con; } //读取OUT型的存储过程(计算记录总数) public void testProc_Out(){ Connection conn = getConnection(); CallableStatement stmt = null; try{ //调取OUT型的存储过程P(计算记录总数) stmt = conn.prepareCall("{call p(?)}"); //读取所有OUT型的存储过程的返回参数数据 stmt.registerOutParameter(1, Types.INTEGER); stmt.execute(); int i= stmt.getInt(1); System.out.println("count = " + i); }catch(Exception e){ System.out.println("hahad = "+e.toString()); }finally{ try { stmt.close(); conn.close(); }catch (Exception ex) { System.out.println("ex : "+ ex.getMessage()); } } } //读取IN型的存储过程(条件查询) public void testProc_In(){ Connection conn = getConnection(); CallableStatement stmt = null; ResultSet rs=null; try{ //调取IN型的存储过程P2,(条件查询) stmt = conn.prepareCall("{call p2(?)}"); //设置IN型的存储过程参数值 stmt.setInt(1, 3); //执行语句,并返回值 rs=stmt.executeQuery(); if(rs.next()){ System.out.println("rs ---------- " + rs.getInt(1)); System.out.println("rs ---------- " + rs.getString(2)); } }catch(Exception e){ System.out.println("hahad --------- "+e.toString()); }finally{ try { rs.close(); stmt.close(); conn.close(); }catch (Exception ex) { System.out.println("ex ----------: "+ ex.getMessage()); } } } public static void main(String[] args) { TestMysqlProcedure tmp=new TestMysqlProcedure(); tmp.testProc_Out(); tmp.testProc_In(); } } 举一反三
根据本实例，读者可以：
利用存储过程实现多表查询。
利用存储过程对商品信息进行降序输出。
原文：http://blog.csdn.net/to_cm/archive/2009/02/25/3932576.aspx
最新评论