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流与文件