三．編碼與測試
在准備工作完成後，進入編碼與測試階段，本例演示了在hibernate3.0中調用mysql的存儲過程的方法。
1、hibernate的配置文件
在hibernate的配置文件中包含數據庫的連接信息，以及加入OR mapping的xml格式的映射文件，該文件如下（部分內容略）：
……
<property name="connection.url">jdbc:mysql://localhost:3306/test</property>
<property name="connection.username">root</property>
<property name="connection.password">root</property>
<property name="connection.driver_class">com.mysql.jdbc.Driver</property>
<property name="dialect">org.hibernate.dialect.MySQLDialect</property>
<property name="show_sql">true</property>
<mapping resource="com/amigo/proc/model/User.hbm.xml"/>
……
2、OR Mapping文件
產生的OR Mapping文件有User.java以及其對應的hibernate映射文件User.hbm.xml。其中User.java的內容如下：
public class User implements java.io.Serializable {
private static final long serialVersionUID = 1L;
/** 用戶id*/
private String userid;
/** 用戶姓名*/
private String name;
/** 用戶blog*/
private String blog;
//省略get/set方法
}
User.hbm.xml文件的內容如下：
<?xml version="1.0"?>
<!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
<hibernate-mapping package="com.amigo.proc.model">
<class name="User" table="tbl_user">
<id name="userid" column="userid">
<generator class="assigned"/>
</id>
<property name="name" column="name" type="string" />
<property name="blog" column="blog" type="string" />
</class>
<sql-query name="getUserList" callable="true">
<return alias="user" class="User">
<return-property name="userid" column="userid"/>
<return-property name="name" column="name"/>
<return-property name="blog" column="blog" />
</return>
{call getUserList()}
</sql-query>
</hibernate-mapping>
在該文件中需注意<sql-query…></sql-query>中的這段代碼，調用的存儲過程在其中定義，並定義了調用存儲過程後將記錄組裝成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對象的相應方法來實現存儲過程的調用。
五．總結
本例提出了在hibernate3中調用mysql的存儲過程的實現方案，從本例可以看出，hibernate提供了在*.hbm.xml中配置調用存儲過程，並通過向用戶提供session.getNamedQuery("…")方法來調用配置的調用查詢相關的存儲過程的方法，另外，hibernate還提供了取得sql的connection的方法，從而能夠通過connection中存儲過程調用相關的方法來實現存儲過程的調用。
