原文出处:http://tech.it168.com/j/d/
2007-05-14/200705141007843.shtml
摘要:
本文以详尽的实例展示了hibernate3.x
中调用存储过程各步骤,从建立测试表、存储过程的建立、工程的建立以及类的编写和测试一步一步引导用户学习hibernate3.x
中调用存储过程的方法.
如果底层数据库(eg.
Oracle
、mysql
、sqlserver
)等支持存储过程,可通过存储过程执行批量删除、更新等操作。本文以实例说明在hibernate3.x
中如何调用存储过程。
说明:本例hibernate
所用版本为3.0
,mysql
所用版本为5.0
,所用数据库驱动为mysql-connector-java-5.0.4-bin.jar
。
一.
建表与初始化数据
在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;
建表成功后,在该表中插入如下4
条初始数据,对应的sql
语句如下:
INSERT INTO `tbl_user` (`userid`,`name`,`blog`) VALUES
('ant', '
蚂蚁',
'http://www.blogjava.net/qixiangnj');
INSERT INTO `tbl_user` (`userid`,`name`,`blog`) VALUES
('beansoft', 'bean',
'http://www.blogjava.net/beansoft');
INSERT INTO `tbl_user` (`userid`,`name`,`blog`) VALUES
('sterning', '
似水流年',
'http://www.blogjava.net/sterning');
INSERT INTO `tbl_user` (`userid`,`name`,`blog`) VALUES
('tom', 'tom' , 'http://www.blogjava.net/tom');
二.
建立存储过程
为测试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;
end;
三.
编程前准备工作
1.
建立工程
在进入代码编写前,建立新的java
工程proc
,
目录结构如下:
proc
-lib
-bin
-src
-com
-amigo
-proc
-model
2.
引入所需包
将hibernate3.0
的包以及其相关包放入编译路径中,另注意:还需将mysql
的数据库驱动jar
包mysql-connector-java-5.0.4-bin.jar
放入编译路径中。
四.
编码与测试
在准备工作完成后,进入编码与测试阶段,本例演示了在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
的内容如下:
package
com.amigo.proc.model;
public
class
User
implements
java.io.Serializable
{
private
static
final
long
serialVersionUID
=
1L
;
private
String userid;
private
String name;
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
的session
以及事务的类HibernateSessionFactory
该类包括打开session
等方法,主要用于管理hibernate
的session
和事务。该类的内容如下(部分内容略):
package
com.amigo.proc;
import
java.io.ByteArrayOutputStream;
import
java.io.OutputStreamWriter;
import
org.hibernate.HibernateException;
import
org.hibernate.Session;
import
org.hibernate.SessionFactory;
import
org.hibernate.Transaction;
import
org.hibernate.cfg.Configuration;
public
class
HibernateSessionFactory
{
private
static
String CONFIG_FILE_LOCATION
=
"
/hibernate.cfg.xml
"
;
private
static
final
ThreadLocal threadLocal
=
new
ThreadLocal();
private
static
Configuration configuration
=
null
;
private
static
SessionFactory sessionFactory;
private
static
String charSet;
private
static
final
String encoding
=
(
new
OutputStreamWriter(
new
ByteArrayOutputStream())).getEncoding();
public
HibernateSessionFactory()
{
}
public
static
final
synchronized
void
open()
{
if
(sessionFactory
!=
null
)
return
;
try
{
sessionFactory
=
getConfiguration().buildSessionFactory();
charSet
=
configuration.getProperty(
"
hibernate.connection.charSet
"
);
if
(charSet
==
null
)
charSet
=
encoding;
return
;
}
catch
(Throwable throwable)
{
throw
new
ExceptionInInitializerError(throwable);
}
}
private
static
synchronized
void
configure()
throws
HibernateException
{
if
(sessionFactory
==
null
)
{
if
(configuration
==
null
)
{
getConfiguration().configure(CONFIG_FILE_LOCATION);
}
open();
}
}
public
static
synchronized
final
Configuration getConfiguration()
{
if
(configuration
==
null
)
{
configuration
=
new
Configuration();
}
return
configuration;
}
public
static
final
SessionFactory getSessionFactory()
{
return
sessionFactory;
}
public
static
final
Session getSession()
throws
HibernateException
{
configure();
Session session
=
null
;
if
(threadLocal.get()
==
null
)
{
session
=
getSessionFactory().openSession();
threadLocal.set(session);
}
else
{
try
{
session
=
(Session)threadLocal.get();
}
catch
(Exception ex)
{
session
=
getSessionFactory().openSession();
threadLocal.set(session);
}
}
return
session;
}
//
其余方法略
}
4
.
hibernate
调用存储过程的测试类
本类是该例的核心类,在本类中,以实例清楚地说明了在hibernate
中如何调用存储过程,例示了hibernate
调用查询、更新、插入和删除这四类存储过程的方法,该类的内容如下:
package
com.amigo.proc;
import
java.sql.CallableStatement;
import
java.sql.Connection;
import
java.sql.PreparedStatement;
import
java.util.List;
import
com.amigo.proc.model.User;
import
org.hibernate.Session;
import
org.hibernate.Transaction;
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());
}
}
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
对象的相应方法来实现存储过程的调用。
该类的执行结果如下:
Hibernate: {call getUserList()}
序号: 1, userid: ant, name:
蚂蚁, blog: http://www.blogjava.net/qixiangnj
序号: 2, userid: beansoft, name: bean,
blog: http://www.blogjava.net/beansoft
序号: 3, userid: sterning, name:
似水流年, blog:
http://www.blogjava.net/sterning
序号: 4, userid: tom, name: tom, blog:
http://www.blogjava.net/tom
update successfully
insert successfully
delete successfully
五.总结
本例提出了在hibernate3
中调用mysql
的存储过程的实现方案,从本例可以看出,hibernate
提供了在*.hbm.xml
中配置调用存储过程,并通过向用户提供
session.getNamedQuery(“…”)
方法来调用配置的调用查询相关的存储过程的方法,另外,
hibernate
还提供了取得
sql
的
connection
的方法,从而能够通过
connection
中存储过程调用相关的方法来实现存储过程的调用。
分享到:
相关推荐
【hibernate3.6.X】是一个流行的Java持久化框架,它实现了ORM(对象关系映射)技术,使得开发者可以通过面向对象的方式处理数据库操作,从而降低了数据库编程的复杂性。在传统的三层架构中,hibernate常被用作数据...
本文将详细介绍如何使用Hibernate 3.x版本调用存储过程,涵盖调用方法、配置及示例代码。 #### Hibernate调用存储过程的重要性 Hibernate调用存储过程的优势主要体现在以下几点: 1. **性能提升**:存储过程在...
Struts1.3、Spring4.x和Hibernate4.x是经典的Java Web开发框架组合,被称为SSH。这个项目展示了如何将这三个框架整合起来,实现一个完整的书籍管理应用,包括书籍的增加、删除、修改和查询功能,并且包含了分页展示...
3. **Hibernate 4.x**:Hibernate是一个流行的Java ORM(对象关系映射)框架,它简化了与数据库的交互。在本例中,Hibernate用于持久化学生信息到SQL Server 2005数据库。我们需要配置Hibernate的SessionFactory,...
这篇文章详细介绍了如何在Hibernate 3.x版本中调用存储过程。 首先,我们需要理解存储过程的概念。存储过程是预编译的SQL语句集合,存储在数据库服务器中,可以接受输入参数,并返回结果。它们可以提高性能,减少...
而较早的版本如`hibernate3.jar`和`hibernate-3.1.jar`则对应Hibernate 3.x系列,其功能可能没有最新版本全面。 `hibernate-jpa-2.1-api-1.0.0.Final.jar`是Java Persistence API (JPA) 2.1的实现,JPA是Java EE...
通常,Struts1.x 的 Action 类会调用 Hibernate 的 Session 对象来处理数据库操作。在登录注册场景中,用户输入的数据首先会被封装到 ActionForm 对象,然后由 Action 处理这些数据,通过 Hibernate 连接数据库进行...
这样,Struts1.x处理用户界面和业务流程,而Hibernate则专注于数据存储,两者结合提供了灵活且高效的开发解决方案。 **常见应用场景:** 这两个框架常用于构建企业级Web应用,如电商平台、CRM系统、内容管理系统等...
综上所述,这个"Struts1.x 在线购物车系统,Hibernate,Mysql"项目是一个综合性的Web开发实践,涵盖了前端交互、后端业务处理和数据存储等多个层面,对于提升开发者在Java Web开发领域的技能有很大帮助。
MyBatisCodeHelper-Pro是一款专为IntelliJ IDEA 2020.3.X版本设计的高效Mybatis代码生成插件。这款插件极大地提升了开发人员在使用Mybatis框架时的生产力,通过自动生成常见的Mapper接口、XML配置文件、Service以及...
2. 支持JPA 2.1:4.3.x版本开始全面支持Java Persistence API 2.1,提供了更多的规范特性,如存储过程调用、新查询构造器等。 3. 更强大的Criteria API:提供了更灵活的动态查询方式,使得开发者可以更加方便地构建...
【标题】"Flex4.X+BlazeDS+Spring3实战开发在线书店四"涉及的核心技术栈是Adobe Flex 4.6、BlazeDS、Spring 3框架以及Java相关的JPA和Hibernate,配合MySQL数据库实现一个在线书店的完整系统。下面将详细阐述这些...
11.2.6 调用存储过程 11.3 BLOB/CLOB类型数据的操作 11.3.1 如何获取本地数据连接 11.3.2 相关的操作接口 11.3.3 插入Lob类型的数据 11.3.4 以块数据方式读取Lob数据 11.3.5 以流数据方式读取Lob数据 11.4 自增键和...
3. **JPA 2.1支持**:支持最新的JPA规范,如实体图形化、存储过程调用等。 4. **更强大的查询构建器**:Querydsl和JPQL的集成,提供了更强大的静态类型查询构建能力。 5. **并发和多线程优化**:提升了在多线程环境...
11.2.6 调用存储过程 11.3 BLOB/CLOB类型数据的操作 11.3.1 如何获取本地数据连接 11.3.2 相关的操作接口 11.3.3 插入Lob类型的数据 11.3.4 以块数据方式读取Lob数据 11.3.5 以流数据方式读取Lob数据 11.4 自增键和...
4.1.7还强化了对JPA 2.1规范的实现,包括JSON-B支持和对存储过程的增强调用。最重要的是,它引入了“黑盒”测试工具,帮助开发者更好地测试和调试Hibernate应用。 在这些版本中,每个都对性能、API的易用性和数据库...
- 使用命令行工具:`java -jar hibernate-tools-X.Y.Z.jar hbm2ddl -db hsqldb -dialect org.hibernate.dialect.HSQLDialect -input hibernate-mapping.hbm.xml` - 通过编程方式调用。 #### 四、事务和并发控制 ...
Hibernate是一款强大的Java持久化框架,它为Java开发者提供了一种对象关系映射工具,使得在Java应用程序中管理和存储数据变得更加简单。"hibernate-entitymanager-3.4.0.GA"是Hibernate的一个特定版本,它包含了...