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

布满荆棘的人生 2022-04-21 16:26 207阅读 0赞

一、总体说明

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

二、环境

1.上文的项目RestDemo

2.MySQL5.6下载[http://dev.mysql.com/get/Downloads/MySQL-5.6/mysql-5.6.16-win32.zip][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][http_dev.mysql.com_get_Downloads_MySQL-5.6_mysql-5.6.16-win32.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][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;

![2e2eb9389b504fc2df5cfca4e7dde71190ef6d0b.jpg_referer_c6811510820a19d89214b135cb09_x_.jpg][]

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

四、引入Hibernate

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

![a8ec8a13632762d04648e81ea2ec08fa513dc619.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，内容如下：

<?xml version='1.0' encoding='utf-8'?>
    <!DOCTYPE hibernate-configuration PUBLIC
            "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
            "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">
    
    <hibernate-configuration>
       <session-factory>
       
            <property name="connection.driver_class">com.mysql.jdbc.Driver</property>
            <property name="connection.url">jdbc:mysql://127.0.0.1:3306/RestDemo</property>
            <property name="connection.username">root</property>
            <property name="connection.password"></property>
    
            
            <property name="connection.pool_size">1</property>
    
            
            <property name="dialect">org.hibernate.dialect.MySQLDialect</property>
    
            
            <property name="current_session_context_class">thread</property>
    
            
            <property name="cache.provider_class">org.hibernate.cache.internal.NoCacheProvider</property>
     
            
            <property name="show_sql">true</property>
    
            
            <property name="hbm2ddl.auto">update</property>
    
    
            <mapping resource="com/waylau/rest/bean/User.hbm.xml"/>
     
        </session-factory>
    </hibernate-configuration>

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

<?xml version="1.0"?>
    <!DOCTYPE hibernate-mapping PUBLIC
            "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
            "http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd">
    
     
    <hibernate-mapping package="com.waylau.rest.bean">
    
        <class name="User" table="T_USER">
            <id name="userId" column="USERID"  type="string" >
                <generator class="assigned"/>
            </id>
            <property name="userName" type="string" />
            <property name="age" type="string" />
        </class>
     
    </hibernate-mapping>

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 List<User> getAllUsers();
    }

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 List<User> getAllUsers() {
            SessionFactory sessionFactory = HibernateUtil.getSessionFactory(); 
    		Session s = null;
    		Transaction t = null;
    		List<User> uesrs = 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 List<User> getAllUsers(){     
        	List<User> users = new ArrayList<User>();   
        	users = userDaoImpl.getAllUsers();
            return users;
        }
        
        
    }

五、运行

1.将服务端运行后

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

完整项目架构如下：

![42166d224f4a20a4f4a58f6692529822730ed0dc.jpg_referer_5bd6b3bbc45c10387d69faf210b2_x_.jpg][]

=====================完整项目代码已经上传===================

https://github.com/waylau/Restdemo

[http_dev.mysql.com_get_Downloads_MySQL-5.6_mysql-5.6.16-win32.zip]: http://sourceforge.net/projects/hibernate/files/hibernate4/4.3.4.Final/hibernate-release-4.3.4.Final.zip
[http_dev.mysql.com_get_Downloads_Connector-J_mysql-connector-java-5.1.29.zip]: http://dev.mysql.com/get/Downloads/Connector-J/mysql-connector-java-5.1.29.zip
[2e2eb9389b504fc2df5cfca4e7dde71190ef6d0b.jpg_referer_c6811510820a19d89214b135cb09_x_.jpg]: /images/20220414/18453f64fab241ff9bdc37ff3cf0d230.png
[a8ec8a13632762d04648e81ea2ec08fa513dc619.jpg_referer_d1125cbcd62a28341ab1023b22f7_x_.jpg]: /images/20220414/bdbb79f2cef746349f0b4064e8bbd572.png
[42166d224f4a20a4f4a58f6692529822730ed0dc.jpg_referer_5bd6b3bbc45c10387d69faf210b2_x_.jpg]: /images/20220414/c46dd2d5823540439b2f6f71838e70cf.png