hibernate mysql5.6_用Jersey构建RESTful服务5-Jersey+MySQL5.6+Hibernate4.3

╰+哭是因爲堅強的太久メ 2023-01-11 14:26 81阅读 0赞

用Jersey构建RESTful服务5--Jersey+MySQL5.6+Hibernate4.3 一、总体说明 本例运行演示了用Jersey构建RESTful服务中，如何同过Hibernate将数据持久化进MySQL的过程 二、环境 1.上文的项目RestDemo 2.MySQL5.6下载http://dev.mysql.com/get/Downloads/MySQL-5.6

用Jersey构建RESTful服务5--Jersey+MySQL5.6+Hibernate4.3

一、总体说明

本例运行演示了用Jersey构建RESTful服务中，如何同过Hibernate将数据持久化进MySQL的过程

二、环境

1.上文的项目RestDemo

2.MySQL5.6下载http://dev.mysql.com/get/Downloads/MySQL-5.6/mysql-5.6.16-win32.zip

3.Hibernate4.3.4下载http://sourceforge.net/projects/hibernate/files/hibernate4/4.3.4.Final/hibernate-release-4.3.4.Final.zip

4.Java程序连接MySQL的驱动mysql-connector-java-5.1.29-bin.jar下载

http://dev.mysql.com/get/Downloads/Connector-J/mysql-connector-java-5.1.29.zip

三、数据库准备

1.搭建MySQL数据库

2.创建数据库RestDemo ,及数据表t\_user,结构如下

DROP TABLE IF EXISTS \`t\_user\`;

CREATE TABLE \`t\_user\` (

\`userId\` varchar(50) NOT NULL,

\`userName\` varchar(50) NOT NULL,

\`age\` varchar(50) NOT NULL,

PRIMARY KEY (\`userId\`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

![1455241T0-0.jpg?referer=c6811510820a19d89214b135cb09&x=.jpg][1455241T0-0.jpg_referer_c6811510820a19d89214b135cb09_x_.jpg]

ps: userId 非自增长类型，需要在业务添加

四、引入Hibernate

1.解压Hibernate的包，在lib\\required文件夹下所有jar引入进项目

![1455246031-1.jpg?referer=d1125cbcd62a28341ab1023b22f7&x=.jpg][1455246031-1.jpg_referer_d1125cbcd62a28341ab1023b22f7_x_.jpg]

2.解压mysql-connector-java-5.1.29.zip，将mysql-connector-java-5.1.29-bin.jar引入进项目

3.在项目的根目录创建hibernate的配置文件hibernate.cfg.xml，内容如下：

com.mysql.jdbc.Driver

jdbc:mysql://127.0.0.1:3306/RestDemo

root

org.hibernate.dialect.MySQLDialect

thread

org.hibernate.cache.internal.NoCacheProvider

true

update

4.在项目User.java 的同个目录下，创建该类的映射文件User.hbm.xml

5.创建包com.waylau.rest.util，在该包下创建HibernateUtil.java

package com.waylau.rest.util;

import org.hibernate.SessionFactory;

import org.hibernate.boot.registry.StandardServiceRegistry;

import org.hibernate.boot.registry.StandardServiceRegistryBuilder;

import org.hibernate.cfg.Configuration;

/\*\*

\* Hibernate 初始化配置工具类

\* @author waylau.com

\* 2014-3-23

\*/

public class HibernateUtil \{

private static Configuration configuration;

private static SessionFactory sessionFactory;

private static StandardServiceRegistry standardServiceRegistry;

static \{

try \{

//第一步:读取Hibernate的配置文件 hibernamte.cfg.xml文件

configuration = new Configuration().configure("hibernate.cfg.xml");

//第二步:创建服务注册构建器对象，通过配置对象中加载所有的配置信息

StandardServiceRegistryBuilder sb = new StandardServiceRegistryBuilder();

sb.applySettings(configuration.getProperties());

//创建注册服务

standardServiceRegistry = sb.build();

//第三步:创建会话工厂

sessionFactory = configuration.buildSessionFactory(standardServiceRegistry);

\} catch (Throwable ex) \{

// Make sure you log the exception, as it might be swallowed

System.err.println("Initial SessionFactory creation failed." + ex);

throw new ExceptionInInitializerError(ex);

public static SessionFactory getSessionFactory() \{

return sessionFactory;

6.在项目中建com.waylau.rest.dao包，在该包下建立User操作的接口UserDao.java

package com.waylau.rest.dao;

import java.util.List;

import com.waylau.rest.bean.User;

/\*\*

\* User Dao 接口

\* @author waylau.com

\* 2014-3-18

\*/

public interface UserDao \{

public User getUserById(String id);

public boolean deleteUserById(String id);

public boolean createUser(User user);

public boolean updateUser(User user);

public ListgetAllUsers();

7.在项目中建com.waylau.rest.dao.impl包，在该包下建立User操作接口的实现UserDaoImpl.java

package com.waylau.rest.dao.impl;

import java.util.List;

import org.hibernate.Query;

import org.hibernate.Session;

import org.hibernate.SessionFactory;

import org.hibernate.Transaction;

import com.waylau.rest.bean.User;

import com.waylau.rest.dao.UserDao;

import com.waylau.rest.util.HibernateUtil;

/\*\*

\* 用户DAO实现

\* @author waylau.com

\* 2014-3-23

\*/

public class UserDaoImpl implements UserDao \{

@Override

public User getUserById(String id) \{

SessionFactory sessionFactory = HibernateUtil.getSessionFactory();

Session s = null;

Transaction t = null;

User user = null;

try\{

s = sessionFactory.openSession();

t = s.beginTransaction();

String hql = "from User where userId="+id;

Query query = s.createQuery(hql);

user = (User) query.uniqueResult();

t.commit();

\}catch(Exception err)\{

t.rollback();

err.printStackTrace();

\}finally\{

s.close();

return user;

@Override

public boolean deleteUserById(String id) \{

SessionFactory sessionFactory = HibernateUtil.getSessionFactory();

Session s = null;

Transaction t = null;

boolean flag = false;

try\{

s = sessionFactory.openSession();

t = s.beginTransaction();

User user = new User();

user.setUserId(id);

s.delete(user);

t.commit();

flag = true;

\}catch(Exception err)\{

t.rollback();

err.printStackTrace();

\}finally\{

s.close();

return flag;

@Override

public boolean createUser(User user) \{

SessionFactory sessionFactory = HibernateUtil.getSessionFactory();

Session s = null;

Transaction t = null;

boolean flag = false;

try\{

s = sessionFactory.openSession();

t = s.beginTransaction();

s.save(user);

t.commit();

flag = true;

\}catch(Exception err)\{

t.rollback();

err.printStackTrace();

\}finally\{

s.close();

return flag;

@Override

public boolean updateUser(User user) \{

SessionFactory sessionFactory = HibernateUtil.getSessionFactory();

Session s = null;

Transaction t = null;

boolean flag = false;

try\{

s = sessionFactory.openSession();

t = s.beginTransaction();

s.update(user);

t.commit();

flag = true;

\}catch(Exception err)\{

t.rollback();

err.printStackTrace();

\}finally\{

s.close();

return flag;

@Override

public ListgetAllUsers() \{

SessionFactory sessionFactory = HibernateUtil.getSessionFactory();

Session s = null;

Transaction t = null;

Listuesrs = null;

try\{

s = sessionFactory.openSession();

t = s.beginTransaction();

String hql = "select \* from t\_user";

Query query = s.createSQLQuery(hql).addEntity(User.class);

query.setCacheable(true); // 设置缓存

uesrs = query.list();

t.commit();

\}catch(Exception err)\{

t.rollback();

err.printStackTrace();

\}finally\{

s.close();

return uesrs;

8.修改项目中 com.waylau.rest.resources包下的UserResource.java，使之前在内存中模拟CURD转为在数据库中实现

package com.waylau.rest.resources;

import java.util.ArrayList;

import java.util.List;

import javax.ws.rs.Path;

import javax.ws.rs.Produces;

import javax.ws.rs.Consumes;

import javax.ws.rs.PathParam;

import javax.ws.rs.core.MediaType;

import javax.ws.rs.DELETE;

import javax.ws.rs.GET;

import javax.ws.rs.POST;

import javax.ws.rs.PUT;

import com.waylau.rest.bean.User;

import com.waylau.rest.dao.impl.UserDaoImpl;

/\*\*

\* 用户资源

\* @author waylau.com

\* 2014-3-19

\*/

@Path("/users")

public class UserResource \{

private UserDaoImpl userDaoImpl = new UserDaoImpl();

/\*\*

\* 增加

\* @param user

\*/

@POST

@Consumes(\{MediaType.APPLICATION\_XML, MediaType.APPLICATION\_JSON\})

public void createUser(User user)

userDaoImpl.createUser(user);

/\*\*

\* 删除

\* @param id

\*/

@DELETE

@Path("\{id\}")

public void deleteUser(@PathParam("id")String id)\{

userDaoImpl.deleteUserById(id);

/\*\*

\* 修改

\* @param user

\*/

@PUT

@Consumes(MediaType.APPLICATION\_XML)

public void updateUser(User user)\{

userDaoImpl.updateUser(user);

/\*\*

\* 根据id查询

\* @param id

\* @return

\*/

@GET

@Path("\{id\}")

@Produces(\{MediaType.APPLICATION\_XML, MediaType.APPLICATION\_JSON\})

public User getUserById(@PathParam("id") String id)\{

User u = userDaoImpl.getUserById(id);

return u;

/\*\*

\* 查询所有

\* @return

\*/

@GET

@Produces(\{MediaType.APPLICATION\_XML, MediaType.APPLICATION\_JSON\})

public ListgetAllUsers()\{

Listusers = new ArrayList();

users = userDaoImpl.getAllUsers();

return users;

五、运行

1.将服务端运行后

2.运行UserClient客户端，可以看到数据库已经实现增删改查

完整项目架构如下：

![14552422J-2.jpg?referer=5bd6b3bbc45c10387d69faf210b2&x=.jpg][14552422J-2.jpg_referer_5bd6b3bbc45c10387d69faf210b2_x_.jpg]

![f68f2add0b68e4f9810432fce46917b7.png][]

本文原创发布php中文网，转载请注明出处，感谢您的尊重！

[1455241T0-0.jpg_referer_c6811510820a19d89214b135cb09_x_.jpg]: https://www.php.cn/uploads/allimg/140403/1455241T0-0.jpg?referer=c6811510820a19d89214b135cb09&x=.jpg
[1455246031-1.jpg_referer_d1125cbcd62a28341ab1023b22f7_x_.jpg]: https://www.php.cn/uploads/allimg/140403/1455246031-1.jpg?referer=d1125cbcd62a28341ab1023b22f7&x=.jpg
[14552422J-2.jpg_referer_5bd6b3bbc45c10387d69faf210b2_x_.jpg]: https://www.php.cn/uploads/allimg/140403/14552422J-2.jpg?referer=5bd6b3bbc45c10387d69faf210b2&x=.jpg
[f68f2add0b68e4f9810432fce46917b7.png]: https://img-blog.csdnimg.cn/img_convert/f68f2add0b68e4f9810432fce46917b7.png