mysql存储过程学习及java调用存储过程

时间:2021-08-22 04:24:42

      首先在mysql中练习下存储过程的小例子:   

mysql存储过程学习及java调用存储过程mysql> delimiter //
mysql存储过程学习及java调用存储过程mysql
> create procedure hello()
mysql存储过程学习及java调用存储过程    
-> begin
mysql存储过程学习及java调用存储过程    
-> select 'It is not a HelloWorld';
mysql存储过程学习及java调用存储过程    
-> end
mysql存储过程学习及java调用存储过程    
-> //
mysql存储过程学习及java调用存储过程Query OK, 
0 rows affected (0.01 sec)

其中“delimiter //”的意思是定义结束符号为“//”,以此来替换mysql中的“;”
在mysql中查询上面的过程hello():

mysql存储过程学习及java调用存储过程mysql> call hello()//
mysql存储过程学习及java调用存储过程
+------------------------+
mysql存储过程学习及java调用存储过程
| It is not a HelloWorld |
mysql存储过程学习及java调用存储过程
+------------------------+
mysql存储过程学习及java调用存储过程
| It is not a HelloWorld |
mysql存储过程学习及java调用存储过程
+------------------------+
mysql存储过程学习及java调用存储过程
1 row in set (0.00 sec)

建立一个简单的测试用表:

mysql存储过程学习及java调用存储过程mysql> DROP TABLE IF EXISTS `userinfo`.`mapping`;
mysql存储过程学习及java调用存储过程    
-> CREATE TABLE  `userinfo`.`mapping` (
mysql存储过程学习及java调用存储过程    
->   `cFieldID` smallint(5) unsigned NOT NULL,
mysql存储过程学习及java调用存储过程    
->   `cFieldName` varchar(30NOT NULL,
mysql存储过程学习及java调用存储过程    
->   PRIMARY KEY  (`cFieldID`)
mysql存储过程学习及java调用存储过程    
-> ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
mysql存储过程学习及java调用存储过程    
-> //
mysql存储过程学习及java调用存储过程Query OK, 
0 rows affected (0.14 sec)

向table mapping中插入一些初始化的数据:

mysql存储过程学习及java调用存储过程mysql> load data infile 'd://userInfo//field.txt' into table mapping
mysql存储过程学习及java调用存储过程    
-> fields terminated by ',' lines terminated by '/r/n' //
mysql存储过程学习及java调用存储过程Query OK, 
5 rows affected (0.02 sec)
mysql存储过程学习及java调用存储过程Records: 
5  Deleted: 0  Skipped: 0  Warnings: 0
mysql存储过程学习及java调用存储过程mysql
> select *from mapping//
mysql存储过程学习及java调用存储过程
+----------+-------------+
mysql存储过程学习及java调用存储过程
| cFieldID | cFieldName  |
mysql存储过程学习及java调用存储过程
+----------+-------------+
mysql存储过程学习及java调用存储过程
|        1 | MarketValue |
mysql存储过程学习及java调用存储过程
|        2 | P/L         |
mysql存储过程学习及java调用存储过程
|        3 | EName       |
mysql存储过程学习及java调用存储过程
|        4 | Nominal     |
mysql存储过程学习及java调用存储过程
|        5 | Chg         |
mysql存储过程学习及java调用存储过程
+----------+-------------+
mysql存储过程学习及java调用存储过程
5 rows in set (0.02 sec)

现在简历一个向mapping中插入一条记录并返回记录的总和

mysql存储过程学习及java调用存储过程mysql> drop procedure if exists mappingProc;
mysql存储过程学习及java调用存储过程    
->  create procedure mappingProc(out cnt int)
mysql存储过程学习及java调用存储过程    
->  begin
mysql存储过程学习及java调用存储过程    
->  declare maxid int;
mysql存储过程学习及java调用存储过程    
->  select max(cFieldID)+1 into maxid from mapping;
mysql存储过程学习及java调用存储过程    
->  insert into mapping(cFieldID,cFieldName) values(maxid,'hello');
mysql存储过程学习及java调用存储过程    
->  select count(cFieldID) into cnt from mapping;
mysql存储过程学习及java调用存储过程    
->  end
mysql存储过程学习及java调用存储过程    
->  //

查找mappingProc():

mysql存储过程学习及java调用存储过程mysql> call mappingProc(@a)//
mysql存储过程学习及java调用存储过程mysql
> select @a//
mysql存储过程学习及java调用存储过程
+------+
mysql存储过程学习及java调用存储过程
| @a   |
mysql存储过程学习及java调用存储过程
+------+
mysql存储过程学习及java调用存储过程
| 6    |
mysql存储过程学习及java调用存储过程
+------+
mysql存储过程学习及java调用存储过程
mysql> select * from mapping//
mysql存储过程学习及java调用存储过程
+----------+-------------+
mysql存储过程学习及java调用存储过程
| cFieldID | cFieldName  |
mysql存储过程学习及java调用存储过程
+----------+-------------+
mysql存储过程学习及java调用存储过程
|        1 | MarketValue |
mysql存储过程学习及java调用存储过程
|        2 | P/L                 |
mysql存储过程学习及java调用存储过程
|        3 | EName          |
mysql存储过程学习及java调用存储过程
|        4 | Nominal     |
mysql存储过程学习及java调用存储过程
|        5 | Chg         |
mysql存储过程学习及java调用存储过程
|        6 | hello       |
mysql存储过程学习及java调用存储过程
+----------+-------------+

下面是java代码用来调用MySQL的存储过程:

mysql存储过程学习及java调用存储过程package kissJava.sql;
mysql存储过程学习及java调用存储过程
import java.sql.CallableStatement;
mysql存储过程学习及java调用存储过程
import java.sql.Connection;
mysql存储过程学习及java调用存储过程
import java.sql.DriverManager;
mysql存储过程学习及java调用存储过程
import java.sql.SQLException;
mysql存储过程学习及java调用存储过程
import java.sql.Types;
mysql存储过程学习及java调用存储过程mysql存储过程学习及java调用存储过程
public class SQLUtils {
mysql存储过程学习及java调用存储过程    String url 
= "jdbc:mysql://127.0.0.1:3306/userInfo"
mysql存储过程学习及java调用存储过程    String userName 
= "root";
mysql存储过程学习及java调用存储过程    String password 
= "zhui007";
mysql存储过程学习及java调用存储过程mysql存储过程学习及java调用存储过程    
public Connection getConnection() {
mysql存储过程学习及java调用存储过程        Connection con
=null;
mysql存储过程学习及java调用存储过程mysql存储过程学习及java调用存储过程        
try{
mysql存储过程学习及java调用存储过程            DriverManager.registerDriver(
new com.mysql.jdbc.Driver());
mysql存储过程学习及java调用存储过程            con 
= DriverManager.getConnection(url, this.userName, this.password);
mysql存储过程学习及java调用存储过程mysql存储过程学习及java调用存储过程        }
catch(SQLException sw)
mysql存储过程学习及java调用存储过程         }

mysql存储过程学习及java调用存储过程        
return con;
mysql存储过程学习及java调用存储过程    }

mysql存储过程学习及java调用存储过程mysql存储过程学习及java调用存储过程    
public void testProc(){
mysql存储过程学习及java调用存储过程        Connection conn 
= getConnection();
mysql存储过程学习及java调用存储过程        CallableStatement stmt 
= null;
mysql存储过程学习及java调用存储过程mysql存储过程学习及java调用存储过程        
try{
mysql存储过程学习及java调用存储过程            stmt 
= conn.prepareCall("{call mappingProc(?)}");    
mysql存储过程学习及java调用存储过程            stmt.registerOutParameter(
1, Types.INTEGER);
mysql存储过程学习及java调用存储过程            stmt.execute();
mysql存储过程学习及java调用存储过程            
int i= stmt.getInt(1);
mysql存储过程学习及java调用存储过程            System.out.println(
"count = " + i);
mysql存储过程学习及java调用存储过程mysql存储过程学习及java调用存储过程        }
catch(Exception e){
mysql存储过程学习及java调用存储过程            System.out.println(
"hahad = "+e.toString());
mysql存储过程学习及java调用存储过程mysql存储过程学习及java调用存储过程        }
finally{
mysql存储过程学习及java调用存储过程mysql存储过程学习及java调用存储过程            
try {
mysql存储过程学习及java调用存储过程                stmt.close();
mysql存储过程学习及java调用存储过程                conn.close();
mysql存储过程学习及java调用存储过程mysql存储过程学习及java调用存储过程            }
catch (Exception ex) {
mysql存储过程学习及java调用存储过程                System.out.println(
"ex : "+ ex.getMessage());
mysql存储过程学习及java调用存储过程            }

mysql存储过程学习及java调用存储过程        }

mysql存储过程学习及java调用存储过程    }

mysql存储过程学习及java调用存储过程mysql存储过程学习及java调用存储过程    
public static void main(String[] args) {
mysql存储过程学习及java调用存储过程        
new SQLUtils().testProc();
mysql存储过程学习及java调用存储过程    }

mysql存储过程学习及java调用存储过程}

在到MySQL中查询可看到插入一条新的记录