一． 建表與初始化數據

在mysql的test數據庫中建立一張新表：tbl_user,建表語句如下：

DROP TABLE IF EXISTS `user`;

CREATE TABLE `tbl_user` (

`userid` varchar(50) NOT NULL,

`name` varchar(50) default '',

`blog` varchar(50) default '',

PRIMARY KEY? (`userid`)

) ENGINE=InnoDB DEFAULT CHARSET=gb2312;

建表成功后，在該表中任意插入幾條數據。

二． 建立存儲過程

為測試hibernate3.x中存儲過程的調用，我們在user表中建立getUserList、createUser、updateUser和deleteUser這四個存儲過程，在mysql中建立存儲過程的語句如下：

1. 獲得用戶信息列表的存儲過程--getUserList

DROP PROCEDURE IF EXISTS `getUserList`;

CREATE PROCEDURE `getUserList`()

begin

select * from? tbl_user;

end;

2. 通過傳入的參數創建用戶的存儲過程--createUser

DROP PROCEDURE IF EXISTS `createUser`;

CREATE PROCEDURE `createUser`(IN userid varchar(50), IN name varchar(50), IN blog varchar(50))

begin

insert into tbl_user values(userid, name, blog);

end;

3. 通過傳入的參數更新用戶信息的存儲過程--updateUser

DROP PROCEDURE IF EXISTS `updateUser`;

CREATE PROCEDURE `updateUser`(IN nameValue varchar(50), IN blogValue varchar(50), IN useidValue varchar(50))

begin

update tbl_user set name = nameValue, blog = blogValue where userid = useridValue;

end;

4. 刪除用戶信息的存儲過程--deleteUser

DROP PROCEDURE IF EXISTS `deleteUser`;

CREATE PROCEDURE `deleteUser`(IN useridValue int(11))

begin

delete from tbl_user where userid = useridValue;

private String userid;

/** 用戶姓名*/

private String name;

/** 用戶blog*/

private String blog;

//省略get/set方法

}

User.hbm.xml文件的內容如下：

{call getUserList()}

在該文件中需注意中的這段代碼，調用的存儲過程在其中定義，并定義了調用存儲過程后將記錄組裝成User對象，同時對記錄的字段與對象的屬性進行相關映射。

3． hibernate調用存儲過程的測試類

本類是該例的核心類，在本類中，以實例清楚地說明了在hibernate中如何調用存儲過程，例示了hibernate調用查詢、更新、插入和刪除這四類存儲過程的方法，該類的內容如下：

// hibernate調用存儲過程

public class ProcTest ...{

public static void main(String[] args) throws Exception ...{

ProcTest proc = new ProcTest();

Session session = HibernateSessionFactory.getSession();

proc.testProcQuery(session);

proc.testProcUpdate(session);

System.out.println("update successfully");

proc.testProcInsert(session);

System.out.println("insert successfully");

proc.testProcDelete(session);

System.out.println("delete successfully");

session.close();

}

// 測試實現查詢的存儲過程

private void testProcQuery(Session session) throws Exception ...{

//查詢用戶列表

List list = session.getNamedQuery("getUserList").list();

for (int i = 0; i < list.size(); i++) ...{

User user = (User) list.get(i);

System.out.print("序號: " + (i+1));

System.out.print(", userid: " + user.getUserid());

System.out.print(", name: " + user.getName());

System.out.println(", blog: " + user.getBlog());

}

}

/**//**

* 測試實現更新的存儲過程

* @throws Exception

*/

private void testProcUpdate(Session session) throws Exception ...{

//更新用戶信息

Transaction tx = session.beginTransaction();

Connection con = session.connection();

String procedure = "{call updateUser(?, ?, ?)}";

CallableStatement cstmt = con.prepareCall(procedure);

cstmt.setString(1, "陳xx");

cstmt.setString(2, "http://www.blogjava.net/sterningChen");

cstmt.setString(3, "sterning");

cstmt.executeUpdate();

tx.commit();

}

// 測試實現插入的存儲過程

private void testProcInsert(Session session) throws Exception ...{

//創建用戶信息

session.beginTransaction();

PreparedStatement st = session.connection().prepareStatement("{call

createUser(?, ?, ?)}");

st.setString(1, "amigo");

st.setString(2, "阿蜜果");

st.setString(3, "http://www.wblogjava.net/amigoxie");

st.execute();

session.getTransaction().commit();

}

// 測試實現刪除的存儲過程

private void testProcDelete(Session session) throws Exception ...{

//刪除用戶信息

session.beginTransaction();

PreparedStatement st = session.connection().prepareStatement("{call deleteUser

(?)}");

st.setString(1, "amigo");

st.execute();

session.getTransaction().commit();

}

}

在本類中，調用查詢類存儲過程時，調用session.getNamedQuery("…")方法來獲得User.hbm.xml中配置的查詢存儲過程。在其余的存儲過程調用的測試中，首先通過hibernate的session獲得connection，然后調用connection對象的相應方法來實現存儲過程的調用。

總結

以上是生活随笔為你收集整理的hibernate4调用mysql存储过程_hibernate调用存储过程的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。