上海做手机网站建设,商丘在线商城,互联网装修公司品牌,wordpress管理页面密码忘记EntityManager
在使用持久化工具的时候#xff0c;一般都有一个对象来操作数据库#xff0c;在原生的Hibernate中叫做Session#xff0c;在 JPA 中叫做EntityManager#xff0c;在MyBatis中叫做SqlSession#xff0c;通过这个对象来操作数据库。
EntityManager是 JPA 中…EntityManager
在使用持久化工具的时候一般都有一个对象来操作数据库在原生的Hibernate中叫做Session在 JPA 中叫做EntityManager在MyBatis中叫做SqlSession通过这个对象来操作数据库。
EntityManager是 JPA 中用于增删改查的接口连接内存中的 java 对象和数据库的数据存储。Hibernate EntityManager是围绕提供JPA编程接口实现的Hibernate Core的一个包装支持JPA实体实例的生命周期并允许用标准的Java Persistence查询语言编写查询。
EntityManager称为实体管理器它由EntityManagerFactory所创建。EntityManagerFactory作为EntityManager的工厂包含有当前O-R映射的元数据信息每个EntityManagerFactory可称为一个持久化单元PersistenceUnit每个持久化单元可认为是一个数据源的映射所谓数据源可理解为一个数据库可以在应用服务器中配置多个数据源同时使用不同的PersistenceUnit来映射这些数据源从而能够很方便的实现跨越多个数据库之间的事务操作
PersistenceContext称为持久化上下文它一般包含有当前事务范围内的被管理的实体对象(Entity)的数据。每个EntityManager都会跟一个PersistenceContext相关联。PersistenceContext中存储的是实体对象的数据而关系数据库中存储的是记录EntityManager正是维护这种OR映射的中间者它可以把数据从数据库中加载到PersistenceContext中也可以把数据从PersistenceContext中持久化到数据库EntityManager通过Persist、merge、remove、refresh、flush等操作来操纵PersistenceContext与数据库数据之间的同步
EntityManager是应用程序操纵持久化数据的接口。它的作用与hibernate session类似。为了能够在一个请求周期中使用同一个session对象在hibernate的解决方案中提出了currentSession的概念hibernate中的current session可以跟JTA事务绑定也可以跟当前线程绑定。在hibernate中session管理着所有的持久化对象的数据。而在EJB3中EntityManager管理着PersistenceContextPersistenceContext正是被管理的持久化对象的集合。 以下是基于项目中使用来说的 依赖
spring-boot.version2.5.6/spring-boot.version
hibernate-types-52.version2.14.0/hibernate-types-52.version
dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-data-jpa/artifactId
/dependency
!-- hibernate支持配置 --
dependencygroupIdorg.hibernate/groupIdartifactIdhibernate-core/artifactId
/dependency
dependencygroupIdorg.hibernate/groupIdartifactIdhibernate-entitymanager/artifactId
/dependency
dependencygroupIdorg.hibernate/groupIdartifactIdhibernate-ehcache/artifactId
/dependency
dependencygroupIdcom.vladmihalcea/groupIdartifactIdhibernate-types-52/artifactIdversion${hibernate-types-52.version}/version
/dependency
!-- hibernate支持配置 --配置
spring.datasource.urljdbc:postgresql://localhost:5432/demo
spring.datasource.usernamedemo
spring.datasource.passworddemo
spring.datasource.driver-class-nameorg.postgresql.Driver
#该选项用来验证数据库连接的有效性。如果您的驱动程序支持JDBC4我们强烈建议您不要设置此属性
spring.datasource.hikari.connection-test-querySELECT 1
#池中最大连接数包括闲置和使用中的连接
spring.datasource.hikari.maximum-pool-size100
#自动提交从池中返回的连接
spring.datasource.hikari.auto-committrue
#池中维护的最小空闲连接数
spring.datasource.hikari.minimum-idle10
#连接允许在池中闲置的最长时间
spring.datasource.hikari.idle-timeout30000
#连接池的用户定义名称主要出现在日志记录和JMX管理控制台中以识别池和池配置
spring.datasource.hikari.pool-nameDatebookHikariCP
#池中连接最长生命周期
spring.datasource.hikari.max-lifetime1800000
#等待来自池的连接的最大毫秒数
spring.datasource.hikari.connection-timeout30000spring.jpa.databasePOSTGRESQL
spring.jpa.properties.hibernate.current_session_context_classorg.springframework.orm.hibernate5.SpringSessionContext
#spring.jpa.properties.hibernate.current_session_context_classthread
spring.jpa.properties.hibernate.hbm2ddl.autoupdate//自动创建表
#spring.jpa.properties.hibernate.default_schemamss
spring.jpa.properties.hibernate.dialectcom.xysd.common.utils.AdvancedPostgreSQLDialect
spring.jpa.properties.hibernate.show_sqlfalse
spring.jpa.properties.hibernate.format_sqlfalse
spring.jpa.properties.hibernate.use_sql_commentsfalse
spring.jpa.properties.hibernate.jdbc.batch_size500
spring.jpa.properties.hibernate.default_batch_fetch_size160
spring.jpa.properties.hibernate.max_fetch_depth3
spring.jpa.properties.hibernate.batch_fetch_styleDYNAMIC
spring.jpa.properties.hibernate.jdbc.fetch_size500
spring.jpa.properties.hibernate.cache.use_second_level_cachefalse
spring.jpa.properties.hibernate.cache.region.factory_classorg.hibernate.cache.ehcache.EhCacheRegionFactory
spring.jpa.properties.hibernate.cache.use_query_cachefalse
spring.jpa.properties.hibernate.order_updatestrue
spring.jpa.properties.hibernate.query.substitutionstrue 1,false 0
#避免KingBase报createClob 错误
spring.jpa.properties.hibernate.jdbc.lob.non_contextual_creationtrueSpringSessionContext AdvancedPostgreSQLDialect
public class AdvancedPostgreSQLDialect extends PostgreSQL10Dialect {public AdvancedPostgreSQLDialect(){super();this.registerColumnType(Types.CLOB, text);this.registerColumnType(Types.BOOLEAN, bit);this.registerHibernateType(Types.ARRAY, StandardBasicTypes.CHARACTER_ARRAY.getName());//支持jsonb extAttr属性this.registerColumnType(Types.OTHER, jsonb );}}支持JPALocalContainerEntityManagerFactoryBean—得到EntityManager—得到session 不支持JPALocalSessionFactoryBean—得到session LocalContainerEntityManagerFactoryBean与LocalSessionFactoryBean
封装JPA操作
SuppressWarnings(rawtypes)
public class JpaQueryBuilder{static boolean isMonitorPerformance() {return false;}/*** 创建query* 通过params设置query查询参数* param hql* param params*/static Query createHQLQueryByParams(Session session, String hql, Object... params){Query query session.createQuery(hql);setParamsWithQuery(query, params);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(Query.class, hql,query);}return query;}/*** 创建query* 通过params设置query查询参数* param T* param hql* param params*/static T QueryT createHQLQueryByParams(Session session, ClassT resultType, String hql,Object... params){QueryT query session.createQuery(hql,resultType);setParamsWithQuery(query, params);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(Query.class, hql,query);}return query;}/*** 创建query* 通过params设置query查询参数* param hql* param params*/static Query createHQLQueryByMapParams(Session session, String hql, MapString,Object params){Query query session.createQuery(hql);setNamedParamsWithQuery(query, params);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(Query.class, hql,query);}return query;}/*** 创建query* 通过params设置query查询参数* param T* param hql* param params*/static T QueryT createHQLQueryByMapParams(Session session, ClassT resultType, String hql,MapString,Object params){QueryT query session.createQuery(hql,resultType);setNamedParamsWithQuery(query, params);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(Query.class, hql,query);}return query;}/*** 创建query 带分页* 通过params设置query查询参数* param hql* param params*/static Query createPageHQLQueryByMapParams(Session session, String hql, int pageNo, int pageSize,MapString,Object params){Query query session.createQuery(hql);setNamedParamsWithQuery(query, params);int startIndex(pageNo-1)*pageSize;query.setFirstResult(startIndex).setMaxResults(pageSize);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(Query.class, hql,query);}return query;}/*** 创建query 带分页* 通过params设置query查询参数* param T* param hql* param params*/static T QueryT createPageHQLQueryByMapParams(Session session, ClassT resultType, String hql,int pageNo, int pageSize, MapString,Object params){QueryT query session.createQuery(hql,resultType);setNamedParamsWithQuery(query, params);int startIndex(pageNo-1)*pageSize;query.setFirstResult(startIndex).setMaxResults(pageSize);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(Query.class, hql,query);}return query;}/*** 创建NativeQuery* param sql* param params 参数为数组*/static NativeQuery createSQLQueryByParams(Session session, String sql, Object... params){NativeQuery query session.createNativeQuery(sql);setParamsWithQuery(query, params);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(NativeQuery.class, sql,query);}return query;}/*** 创建NativeQuery* param T* param sql* param params 参数为数组*/static T NativeQueryT createSQLQueryByParams(Session session, ClassT resultType, String sql,Object... params){NativeQueryT query session.createNativeQuery(sql,resultType);setParamsWithQuery(query, params);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(NativeQuery.class, sql,query);}return query;}/*** 创建NativeQuery* param sql* param params*/static NativeQuery createSQLQueryByMapParams(Session session, String sql, MapString,Object params){NativeQuery query session.createNativeQuery(sql);setNamedParamsWithQuery(query, params);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(NativeQuery.class, sql,query);}return query;}/*** 创建NativeQuery* param T* param sql* param params*/static T NativeQueryT createSQLQueryByMapParams(Session session, ClassT resultType, String sql,MapString,Object params){NativeQueryT query session.createNativeQuery(sql,resultType);setNamedParamsWithQuery(query, params);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(NativeQuery.class, sql,query);}return query;}/*** 创建NativeQuery 带分页* param pageNo* param params*/static NativeQuery createPageSQLQueryByMapParams(Session session, String sql, int pageNo, int pageSize,MapString,Object params){NativeQuery query session.createNativeQuery(sql);setNamedParamsWithQuery(query, params);int startIndex(pageNo-1)*pageSize;query.setFirstResult(startIndex).setMaxResults(pageSize);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(NativeQuery.class, sql,query);}return query;}/*** 创建NativeQuery 带分页* param T* param sql* param params*/static T NativeQueryT createPageSQLQueryByMapParams(Session session, ClassT resultType, String sql,int pageNo, int pageSize, MapString,Object params){NativeQueryT query session.createNativeQuery(sql,resultType);setNamedParamsWithQuery(query, params);int startIndex(pageNo-1)*pageSize;query.setFirstResult(startIndex).setMaxResults(pageSize);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(NativeQuery.class, sql,query);}return query;}//设置参数private static void setParamsWithQuery(Query query, Object... params) {if (paramsnull||params.length0) {return;}for(int i0;iparams.length;i){query.setParameter(i,params[i]);}}//设置参数private static void setNamedParamsWithQuery(Query query, MapString, Object params) {if (paramsnull||params.size()0) {return;}for(Map.EntryString,Object entry:params.entrySet()){Object paramKey entry.getKey();Object paramValue entry.getValue();if(paramValue instanceof List){query.setParameterList((String)paramKey, (List)paramValue);}else if(paramValue instanceof String[]){query.setParameterList((String)paramKey, (String[])paramValue);}else if(paramValue instanceof Object[]){query.setParameterList((String)paramKey, (Object[])paramValue);}else if(paramValue instanceof Collection){query.setParameterList((String)paramKey, (Collection)paramValue);}else{query.setParameter((String)paramKey, paramValue);}}}}对外提供的服务
SuppressWarnings({rawtypes,unchecked})
public abstract class JpaHibernateRepository{protected Logger logger LogManager.getLogger(this.getClass());AutowiredPersistenceContextprivate EntityManager em;protected EntityManager getEm(){return em;}/*** 根据jpa EntityManager 获取hibernate session* return*/protected Session getSession(){return (Session) getEm().getDelegate();}private boolean isMonitorPerformance() {return true;}/*** 创建query* 通过params设置query查询参数* param hql* param params*/protected Query createHQLQueryByParams(String hql,Object... params){Query query JpaQueryBuilder.createHQLQueryByParams(getSession(), hql, params);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(Query.class, hql,query);}return query;}/*** 创建query* 通过params设置query查询参数* param T* param hql* param params*/protected T QueryT createHQLQueryByParams(ClassT resultType,String hql,Object... params){QueryT query JpaQueryBuilder.createHQLQueryByParams(getSession(), resultType, hql, params);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(Query.class,hql, query);}return query;}/*** 创建query* 通过params设置query查询参数* param hql* param params*/protected Query createHQLQueryByMapParams(String hql,MapString,Object params){Query query JpaQueryBuilder.createHQLQueryByMapParams(getSession(), hql, params);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(Query.class, hql,query);}return query;} /*** 创建query* 通过params设置query查询参数* param T* param hql* param params*/protected T QueryT createHQLQueryByMapParams(ClassT resultType,String hql,MapString,Object params){QueryT query JpaQueryBuilder.createHQLQueryByMapParams(getSession(), resultType, hql, params);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(Query.class, hql,query);}return query;}/*** 创建query 带分页* 通过params设置query查询参数* param hql* param params*/protected Query createPageHQLQueryByMapParams(String hql,int pageNo,int pageSize,MapString,Object params){Query query JpaQueryBuilder.createPageHQLQueryByMapParams(getSession(), hql, pageNo, pageSize, params);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(Query.class, hql,query);}return query;}/*** 创建query 带分页* 通过params设置query查询参数* param T* param hql* param params*/protected T QueryT createPageHQLQueryByMapParams(ClassT resultType,String hql,int pageNo,int pageSize,MapString,Object params){QueryT query JpaQueryBuilder.createPageHQLQueryByMapParams(getSession(), resultType, hql, pageNo, pageSize, params);if(isMonitorPerformance()) {return QueryProxy.newProxyQuery(Query.class, hql,query);}return query;}//批量执行sql更新protected int batchUpdateSql(final String sql,final ListObject[] batchParams){long start System.currentTimeMillis();final BatchUpdatedResult updateResult new BatchUpdatedResult();this.getSession().doWork(new Work() {Overridepublic void execute(Connection conn) throws SQLException {PreparedStatement ps null ;try{ps conn.prepareStatement(sql);for(Object[] params : batchParams){if(params null){continue;}for(int i0;iparams.length;i){Object p params[i];if(p null){ps.setNull(i1,Types.VARCHAR);}else if( p instanceof String){String pstr (String)p;ps.setString(i1, pstr);}else if(p instanceof Integer){int n (Integer)p;ps.setInt(i1, n);}else if(p instanceof Date){Date d (Date)p;ps.setTimestamp(i1, new Timestamp(d.getTime()));}else if(p instanceof Long){Long d (Long)p;ps.setLong(i1, d);}else if(p instanceof Byte){Byte d (Byte)p;ps.setByte(i1, d);}else if(p instanceof Boolean){Boolean d (Boolean)p;ps.setBoolean(i1, d);}else if(p instanceof Double){Double d (Double)p;ps.setDouble(i1, d);}else if(p instanceof BigDecimal){BigDecimal d (BigDecimal)p;ps.setBigDecimal(i1, d);}else if(p instanceof Float){Float d (Float)p;ps.setFloat(i1, d);}else{throw new RuntimeException(未识别的参数类型:p.getClass());}}ps.addBatch();}int[] updateds ps.executeBatch();for(int update:updateds) {updateResult.addUpdated(update);}}finally{if(ps!null){ps.close();}}}});logger.info(耗时[(System.currentTimeMillis()-start)]毫秒批量执行SQL:sql);return updateResult.updated;}//批量执行sql更新protected int batchUpdateSql(final String sql,final ListObject[] batchParams,int[] sqlTypes){long start System.currentTimeMillis();final BatchUpdatedResult updateResult new BatchUpdatedResult();this.getSession().doWork(new Work() {Overridepublic void execute(Connection conn) throws SQLException {PreparedStatement ps null ;try{ps conn.prepareStatement(sql);for(Object[] params : batchParams){if(params null){continue;}if(sqlTypesnull || sqlTypes.length!params.length){throw new IllegalArgumentException(sqlTypes.length must be equal to params.length);}for(int i0;iparams.length;i){Object p params[i];if(p null){ps.setNull(i1,sqlTypes[i]);}else if( p instanceof String){String pstr (String)p;ps.setString(i1, pstr);}else if(p instanceof Integer){int n (Integer)p;ps.setInt(i1, n);}else if(p instanceof Date){Date d (Date)p;ps.setTimestamp(i1, new Timestamp(d.getTime()));}else if(p instanceof Long){Long d (Long)p;ps.setLong(i1, d);}else if(p instanceof Byte){Byte d (Byte)p;ps.setByte(i1, d);}else if(p instanceof Boolean){Boolean d (Boolean)p;ps.setBoolean(i1, d);}else if(p instanceof Double){Double d (Double)p;ps.setDouble(i1, d);}else if(p instanceof BigDecimal){BigDecimal d (BigDecimal)p;ps.setBigDecimal(i1, d);}else if(p instanceof Float){Float d (Float)p;ps.setFloat(i1, d);}else{throw new RuntimeException(未识别的参数类型:p.getClass());}}ps.addBatch();}int[] updateds ps.executeBatch();for(int update:updateds) {updateResult.addUpdated(update);}}finally{if(ps!null){ps.close();}}}});logger.info(耗时[(System.currentTimeMillis()-start)]毫秒批量执行SQL:sql);return updateResult.updated;}/*** 安全获取实体* param T* param entityClass* param id* return*/public T T safeGet(ClassT entityClass, Serializable id) {if(idnull) return null;if((id instanceof String)StringUtils.isBlank((String)id)) {return null;}return this.getSession().get(entityClass, id);}/*** 根据Ids查找entity列表* param entityClass* param orderedIds* return*/public T ListT findByOrderedIds(ClassT entityClass,CollectionString orderedIds,String... loadFetchs){ListT result new ArrayListT();if(orderedIds null || orderedIds.size() 0 ){return result;}ListListString splittedIdsList Utils.splitToFixedList(orderedIds, 800);MapString, T entityMap new HashMapString, T();String hqlselect o from entityClass.getName() o ;if(loadFetchs!null) {for (int i0;iloadFetchs.length;i) {hqlhqlleft join fetch o.loadFetchs[i] oi ;}}hqlhqlwhere o.id in (:ids);for(ListString ids : splittedIdsList){ListT entities this.createHQLQueryByMapParams(entityClass, hql,Utils.buildMap(ids,ids)).list();for(T t : entities){String id ((IEntity)t).getId();entityMap.put(id, t);}}for(String id : orderedIds){if(entityMap.containsKey(id)){result.add(entityMap.get(id));}}return result;}
} 使用
//更多使用自行参考
Repository
public class CommonRepositoryHibernate extends JpaHibernateRepository {//构建当前年获取数据public ListDateRec getHolidayByYear(Date year) {String hql select d from DateRec.class.getName() d where d.valid 1 and dateTime :dateTime ;ListDateRec holidays this.createHQLQueryByMapParams(DateRec.class, hql, Utils.buildMap(dateTime, year)).list();if (holidays null) holidays new ArrayList();return holidays;}//根据主键获取实体对象public DateRec getDateRecById(String id) {DateRec dateRec this.safeGet(DateRec.class, id);return dateRec;}//根据前端参数构建sqlpublic ListDateRec getDateRecBy(MapString, Object params) {StringBuffer sql new StringBuffer();sql.append( select id from t_date_rec d where d.valid 1 );if (params.get(ids) ! null) {sql.append( and d.id in (:ids) );}if (params.get(dateTypes) ! null) {sql.append( and d.date_type in (:dateTypes) );}ListString ids this.createSQLQueryByMapParams(sql.toString(), params).list();if (CollectionUtils.isEmpty(ids)) return new ArrayList();ListDateRec recs this.findByOrderedIds(DateRec.class, ids);if (recs null) recs new ArrayList();return recs;}}
