hibernate4调用mysql存储过程_hibernate调用存储过程
一． 建表與初始化數據
在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调用存储过程的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： mysql select查询语句_mys
- 下一篇： linux cmake编译源码,linu