欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

java调用mysql存储过程实例分析

程序员文章站 2024-03-03 20:26:28
本文实例讲述了java调用mysql存储过程的方法。分享给大家供大家参考。具体如下: 数据库的测试代码如下 : 1、新建表test create table...

本文实例讲述了java调用mysql存储过程的方法。分享给大家供大家参考。具体如下:

数据库的测试代码如下 :

1、新建表test

create table test(
field1 int not null
)
type=myisam ;
insert into test(field1) values(1);

2、删除已存在的存储过程:

-- 删除储存过程
delimiter // -- 定义结束符号
drop procedure p_test;

3、mysql存储过程定义:

create procedure p_test()
begin
declare temp int;
set temp = 0; 
update test set field1 = values(temp);
end

4、调用方法:

callablestatement cstmt = conn.preparecall("{call p_test()}");
cstmt.executeupdate();
import java.sql.*; 
/** 
igoder 
*/ 
public class proceduretest {
 /*
 表和存储过程定义如下:
 delimiter // 
drop table if exists test //
  create table test(
   id int(11) null
  ) //
 drop procedure if existssp1 //
  create procedure sp1(in p int)
  comment 'insert into a int value'
  begin
   declare v1 int;
   set v1 = p;
   insert into test(id) values(v1);
  end
  //
  drop procedure if exists sp2 //
  create procedure sp2(out p int)
  begin
   select max(id) into p from test;
  end
  //
 drop procedure if exists sp6 //
  create procedure sp6()
  begin
    select * from test;
  end//
 */ 
 public static void main(string[] args) {
 //callin(111);
 //callout();
 callresult();
 } 
 /**
 * 调用带有输入参数的存储过程
 * @param in   stored procedure input parametervalue 
 */
 public static void callin(int in){
 //获取连接
 connection conn = connectdb.getconnection();
 callablestatement cs = null;
 try {
  //可以直接传入参数
  //cs = conn.preparecall("{call sp1(1)}");
  //也可以用问号代替
  cs = conn.preparecall("{call sp1(?)}");
  //设置第一个输入参数的值为110
  cs.setint(1, in);
  cs.execute();
 } catch (exception e) {
  e.printstacktrace();
 } finally {
  try {
  if(cs != null){
   cs.close();
  }
  if(conn != null){
   conn.close();
  }
  } catch (exception ex) {
  ex.printstacktrace();
  }
 }
 }
 /**
 * 调用带有输出参数的存储过程
 * 
 */
 public static void callout() {
 connection conn = connectdb.getconnection();
 callablestatement cs = null;
 try {
  cs = conn.preparecall("{call sp2(?)}");
  //第一个参数的类型为int
  cs.registeroutparameter(1, types.integer);
  cs.execute();
  //得到第一个值
  int i = cs.getint(1);
  system.out.println(i);
 } catch (exception e) {
  e.printstacktrace();
 } finally {
  try {
  if(cs != null){
   cs.close();
  }
  if(conn != null){
   conn.close();
  }
  } catch (exception ex) {
  ex.printstacktrace();
  }
 }
 }
 /**
 * 调用输出结果集的存储过程
 */
 public static void callresult(){
 connection conn = connectdb.getconnection();
 callablestatement cs = null;
 resultset rs = null;
 try {
  cs = conn.preparecall("{call sp6()}");
  rs = cs.executequery();
  //循环输出结果
  while(rs.next()){
  system.out.println(rs.getstring(1));
  }
 } catch (exception e) {
  e.printstacktrace();
 } finally {
  try {
  if(rs != null){
   rs.close();
  }
  if(cs != null){
   cs.close();
  }
  if(conn != null){
   conn.close();
  }
  } catch (exception ex) {
  ex.printstacktrace();
  }
 }
 }
} 
/** 
*获取数据库连接的类 
*/
import java.sql.connection;
import java.sql.drivermanager;
import java.sql.preparedstatement;
import java.sql.resultset;
import java.sql.sqlexception;
import java.sql.statement; 
class connectdb {
 public static connection getconnection(){
 connection conn = null;
 preparedstatement preparedstatement = null;
 try {
  class.forname("org.gjt.mm.mysql.driver").newinstance(); 
  string dbname = "test";
  string url="jdbc:mysql://localhost/"+dbname+"?user=root&password=root&useunicode=true&characterencoding=8859_1";
  conn= drivermanager.getconnection(url);
 } catch (exception e) {
  e.printstacktrace();
 } 
 return conn;
 } 
}

希望本文所述对大家的java程序设计有所帮助。

上一篇: Java流与文件

下一篇: