对于在Web容器中使用EntityManager对象,这里需要做一些改进,才能更安全。Servlet是非线程安全的,所以需要改变获得EntityManager对象的方式,这里使用ThreadLocal类。
ThreadLocal就是为每一个使用某变量的线程都提供一个该变量值的副本,使每一个线程都可以独立地改变自己的副本,而不会和其他线程的副本冲突。从线程的角度看,就好像每一个线程都完全拥有一个该变量,这就解决了Servlet非线程安全的问题。
以下EntityManager对象非容器EJB容器托管,手动控制事务处理。可用于JAVA SE环境。如果是EJB容器管理,或者WEB容器,可以直接注入@PersistenceContext,使用JTA、RESOURCE_LOCAL事务管理。
import java.io.Serializable;
import java.util.Collection;
import java.util.List;
/**
*
* <p>Title: 数据库操作接口</p>
* <p>Description:EasyJWeb Tools中的添删改查等业务引擎使用该DAO进行数据库操作 </p>
* <p>Copyright: Copyright (c) 2006</p>
* <p>Company: EasyJF开源团队</p>
* @author 大峡
* @version 0.1
*/
public interface IDAO<T> {
/**
* 把对象保存到持久层
*
* @param obj
* @return 若保存成功,则返回true,否则返回false
* @throws IdExistException
*/
boolean save(T obj);
/**
* 更新持久层中的对象
*
* @param obj
* @return 若修改成功,则返回true,否则返回false
*/
boolean update(T obj);
/**
* 删除持久层中的对象
*
* @param obj
* @return 若删除操作成功,则返回true,否则返回false
*/
boolean del(T obj);
/**
* 根据类及主键加载对象
*
* @param clz
* @param id
* @return 若查找到指定主键值的持久对象,则返回该对象,否则返回null
*/
T get(Class<T> clz, Serializable id);
/**
* 根据类、字段名及字段值加载对象,只加载一条符合条件的对象。
*
* @param clz
* @param fieldName
* @param value
* @return 若查询到指定属性及值的持久对象,则返回该对象,否则返回null
*/
T getBy(Class<T> clz, String fieldName, Serializable value);
/**
* 根据条件查询对象
*
* @param clz 类名
* @param scope 查询条件
* @return 返回查询的记录结果记录
*/
List<T> query(Class<T> clz, String scope);
/**
* 根据条件、条件参数查询对象
*
* @param clz 类名
* @param scope 查询条件
* @param paras 查询参数
* @return 返回查询的记录结果集
*/
List<T> query(Class<T> clz, String scope, Collection paras);
/**
* 查询符合条件的对象,从begin开始取max条记录
*
* @param clz Java类
* @param scope 查询条件
* @param paras 查询参数
* @param begin 返回有效结果开始记录数
* @param max 返回的最多记录数
* @return 返回查询的记录结果集
*/
List<T> query(Class<T> clz, String scope, Collection paras, int begin, int max);
/**
* 执行sql语句,并返回一个对象,如select count(*) from tableName等
* @param sql sql语句
* @return 返回查询结果,若没有结果则返回null
*/
Object uniqueResult(String sql);
/**
* 根据sql语句及查询参数执行查询,并返回一个唯一对象,如select count(*) from tableName where filed=?
* @param sql
* @param paras
* @return 返回单一的查询结果,若没有结果则返回null
*/
Object uniqueResult(String sql,Collection paras);
/**
* 执行任意sql语句,返回受影响的记录数
* @param sql sql语句
* @return 返回受影响的记录数
*/
int execute(String sql);
/**
* 根据sql语句及参数执行数据库操作,返回受影响的记录数
* @param sql sql语句
* @param paras 参数
* @return 返回受影响的记录数
*/
int execute(String sql,Collection paras);
}
import java.io.Serializable;
import java.util.Collection;
import java.util.List;
import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.Query;
public class EntityMangerDaoSurport<T> implements IDAO<T> {
private static EntityManagerFactory emf;
private static ThreadLocal<EntityManager> em;
public EntityManager getEntityManager() {
EntityManager manager = em.get();
if (manager == null) {
manager = emf.createEntityManager();
em.set(manager);
}
return manager;
}
public boolean del(Object obj) {
getEntityManager().getTransaction().begin();
if (!getEntityManager().contains(obj))
obj = getEntityManager().merge(obj);
getEntityManager().remove(obj);
getEntityManager().getTransaction().commit();
return true;
}
public int execute(String sql) {
return execute(sql, null);
}
public int execute(String sql, Collection paras) {
Query query = getEntityManager().createNativeQuery(sql);
int parameterIndex = 0;
if (paras != null && paras.size() > 0) {
for (Object obj : paras) {
query.setParameter(parameterIndex++, obj);
}
}
return query.executeUpdate();
}
public T get(Class<T> clz, Serializable id) {
return getEntityManager().find(clz, id);
}
public T getBy(Class<T> clz, String fieldName, Serializable value) {
Query query = getEntityManager().createQuery(
"from " + clz + " where fieldName=?");
query.setParameter(0, value);
return (T) query.getSingleResult();
}
public List query(Class clz, String scope) {
return query(clz, scope, null);
}
public List query(Class clz, String scope, Collection paras) {
return query(clz, scope, null, -1, -1);
}
public List query(Class clz, String scope, Collection paras, int begin,
int max) {
Query query = getEntityManager().createQuery(
"from " + clz + " where " + scope);
int parameterIndex = 0;
if (paras != null && paras.size() > 0) {
for (Object obj : paras) {
query.setParameter(parameterIndex++, obj);
}
}
if (begin >= 0 && max > 0) {
query.setFirstResult(begin);
query.setMaxResults(max);
}
return query.getResultList();
}
public boolean save(Object obj) {
getEntityManager().getTransaction().begin();
getEntityManager().persist(obj);
getEntityManager().getTransaction().commit();
return true;
}
public Object uniqueResult(String sql) {
return uniqueResult(sql, null);
}
public Object uniqueResult(String sql, Collection paras) {
Query query = getEntityManager().createQuery(sql);
int parameterIndex = 0;
if (paras != null && paras.size() > 0) {
for (Object obj : paras) {
query.setParameter(parameterIndex++, obj);
}
}
return query.getSingleResult();
}
public boolean update(Object obj) {
getEntityManager().getTransaction().begin();
getEntityManager().merge(obj);
getEntityManager().getTransaction().commit();
return true;
}
}
分享到:
相关推荐
通过将公共通用操作写进父类简化代码,提高代码的复用。 面向接口 使用继承 泛型 引入JPA API查询 以及 元数据 提高代码的安全性.
【标题】"Hibernate泛型Dao"是针对Java开发中的数据持久化框架Hibernate的一个高级应用,主要目的是为了提高代码的复用性和简洁性。在传统的Hibernate使用中,针对每个实体类,我们都需要创建一个对应的Dao(Data ...
本文将详细介绍泛型DAO模式在Java Web开发中的应用,包括泛型机制、JPA框架、Struts框架和Spring框架的使用。 一、泛型机制 Java 5.0版本引入了泛型机制,提供了一种解决方案,使用类型参数来代替Object类型的变量...
在实际的Java Web应用中,我们可以结合Spring框架的Hibernate或JPA支持,进一步简化泛型DAO的实现,利用Spring的模板类如JdbcTemplate、HibernateTemplate等,自动处理SQL执行和结果映射。 总的来说,泛型DAO在Java...
基于泛型的通用Dao接口是指使用泛型来实现数据访问对象(DAO)的接口,主要是在使用 Hibernate 或 JPA 时使用。泛型可以使得DAO接口更灵活、更通用。 泛型Dao接口的优点: 1. 耦合性低:泛型Dao接口可以与不同的...
在DAO(Data Access Object)层的封装中,JPA可以帮助我们创建一组通用的方法,如save、update、delete和findAll,以处理常见的CRUD(Create、Read、Update、Delete)操作。这些方法可以应用于任何实体类,大大提高...
1、基于SpringBoot+Thymeleaf+JPA的博客系统源码.zip 2、该资源包括项目的全部源码,下载可以直接使用! 3、本项目适合作为计算机、数学、电子信息等专业的课程设计、期末大作业和毕设项目,作为参考资料学习借鉴。 ...
本项目为基于Java平台的JPA查询封装设计源码,包含70个文件,主要由68个Java源文件、1个XML配置文件以及1个YAML配置文件组成,旨在提供高效的JPA查询封装方案。
目录 企业级应用的特点 JPA及JPA使用技巧 使用泛型DAO来简化DAO层的开发 IOC容器、AOP及Spring2 EasyJWeb如何实现快速开发 小结
Spring Data JPA是Spring框架的一个模块,它简化了Java应用程序对数据库的操作,通过提供自动的repository接口实现。在处理复杂的查询需求时,Spring Data JPA的`Specifications`接口提供了动态构建查询的能力,允许...
泛型DAO(Data Access Object)是一种设计模式,用于抽象数据访问层的操作,提供通用的CRUD(Create, Read, Update, Delete)方法。通过泛型,DAO可以适用于多种类型的实体,降低了代码重复。例如,一个BaseDAO接口...
自定义通用DAO实现基本的CRUD,比如: public interface BaseDao<T> { int insert(T obj) throws Exception; int update(T obj) throws Exception; int deleteByPrimaryKey(Object key) throws Exception; int ...
"hibernate不是泛型的通用DAo1"这个标题暗示了我们讨论的是一种非泛型化的DAO实现,可能是因为开发者想要避免强制继承和泛型模板。 在描述中提到,开发者在网上寻找的大多数DAO实现都是泛型的,需要继承来使用。...
spring data jpa 实例源码 spring data jpa 实例源码 spring data jpa 实例源码
`jpa_2.0-src.zip`包含的是JPA 2.0版本的源码,你可以从中看到各种接口和实现类的具体定义,以及它们如何协同工作来实现持久化功能。 **API文档** `api-javadoc.zip`则提供了JPA的API文档,这对于开发者来说是极其...
综上所述,`JPA(hibernate) Dao 和 DaoSupport`涉及到Java持久化技术,主要关注如何通过面向对象的方式操作数据库,以及如何设计和使用DAO层来封装数据访问逻辑。在实际项目中,我们还需要了解如何使用Spring Data ...
经典JAVA EE企业应用实战基于WEBLOGIC JBOSS的JSF+EJB 3+JPA整合开发——源码第9章 其他部分详见我的上传列表。 本书介绍了Java EE规范的三大主要规范JSF、EJB 3和JPA,其中JSF是Sun公司提供的JSF RI;EJB 3部分则...
**JPA整合Spring源码详解** 在现代Java开发中,对象关系映射(ORM)框架如Java Persistence API(JPA)和Spring框架的结合使用,极大地简化了数据库操作。本篇将深入探讨JPA与Spring整合的源码实现,帮助开发者理解...
JPA用于整合现有的ORM技术,可以简化现有Java EE和Java SE应用的对象持久化的开发工作,实现ORM的统一。JPA作为一项对象持久化的标准,不但可以获得Java EE应用服务器的支持,还可以直接在Java SE中使用。JPA必将...
Spring Data JPA通过提供一套高级的Repository接口,使得开发者无需编写大量的DAO层代码即可实现对数据库的基本操作。例如,`CrudRepository`接口提供了增删查改的基本方法,而`JpaRepository`则扩展了更多功能,如...