java挪用mysql存儲進程實例剖析

java挪用mysql存儲進程實例剖析。本站提示廣大學習愛好者：（java挪用mysql存儲進程實例剖析）文章只能為提供參考，不一定能成為您想要的結果。以下是java挪用mysql存儲進程實例剖析正文

本文實例講述了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法式設計有所贊助。