Dorado7 MultiHibernateDao.java McfBaseDAO 多数据源支持(单Hibernate双数据库)

本文主要是介绍Dorado7 MultiHibernateDao.java McfBaseDAO 多数据源支持(单Hibernate双数据库),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

单Hibernate双数据库

MultiHibernateDao.java

package com.gs.oms.dao;import java.sql.Connection;
import java.sql.DriverManager;
import java.util.List;
import java.util.Map;
import java.util.Properties;import org.apache.commons.lang.StringUtils;
import org.hibernate.Query;
import org.hibernate.Session;
import org.springframework.stereotype.Repository;import com.bstek.dorado.data.provider.Page;
import com.gs.mcf.common.McfBaseDAO;/**** MultiHibernateDao 多数据源支持(单Hibernate双数据库)* 创建日期: 20151125* @author like12* @param <T>* */
@SuppressWarnings("rawtypes")
@Repository
public class MultiHibernateDao<T> extends McfBaseDAO {//like12 add,20151224,全局Sessionprivate static Session sessionGlobal = null;/*** 保存* @param entity*/public void saveMulti(T entity) {String entityName = this.getEntityName(entity);Session session = this.getSessionMulti();session.saveOrUpdate(entityName, entity);session.flush();session.clear();}/*** 修改* * @param hql* @param params*/public void excuteUpdate(final String hql, Object[] params) {Query query = this.getSessionMulti().createQuery(hql);if (params != null) {int i = 0;for (Object o : params) {query.setParameter(i, o);i++;}}query.executeUpdate();}/*** 单个查询* @param hql* @param parameters* @return*/@SuppressWarnings("unchecked")public <X> X findUniqueMulti(String hql, Map<String, ?> parameters) {return (X) createQueryMulti(hql, parameters).uniqueResult();}/*** like12 add,20160127* 全部查询* @param hql* @param parameters* @return*/@SuppressWarnings("unchecked")public <X> List<X> findMulti(String hql, Map<String, ?> parameters) {return createQueryMulti(hql, parameters).list();}/*** 分页查询* @param page* @param hql* @param parameters* @return*/@SuppressWarnings("unchecked")public Page<T> findMulti(Page<T> page, String hql, Map<String, ?> parameters) {notNull(page, "page");Query q = this.createQueryMulti(hql, parameters);long totalCount = countHqlResultMulti(hql, parameters);page.setEntityCount((int) totalCount);setPageParameterToQuery(q, page);page.setEntities(q.list());return page;}public Query createQueryMulti(String queryString, Map<String, ?> parameters) {Query query = this.getSessionMulti().createQuery(queryString);if (parameters != null) {query.setProperties(parameters);}return query;}protected long countHqlResultMulti(String hql, Map<String, ?> parameters) {String countHql = generateCountHqlMulti(hql);return ((Number) findUniqueMulti(countHql, parameters)).longValue();}private String generateCountHqlMulti(String hql) {hql = "from " + StringUtils.substringAfter(hql, "from");hql = StringUtils.substringBefore(hql, "order by");String countHql = "select count(*) " + hql;return countHql;}/*** 获取多数据源Session* @return*/public Session getSessionMulti() {//like12 modofied,20151224,每一次 增删改查 都要产生一次新的Session 数据库会很快死掉if(sessionGlobal == null){Properties prop = new Properties();String driver = null;String url = null;String username = null;String password = null;Connection connection = null;try{//读配置文件prop.load(this.getClass().getClassLoader().getResourceAsStream("DBConfigCygl.properties"));driver = prop.getProperty("driver");url = prop.getProperty("url");username = prop.getProperty("username");password = prop.getProperty("password");Class.forName(driver);//1.加载驱动connection = DriverManager.getConnection(url,username,password);//2.得到连接}catch (Exception e){e.printStackTrace();}//中途拦截,正规默认为:this.sessionFactory.openSession()sessionGlobal = this.sessionFactory.openSession(connection);}//like12 add,20151228,bug,需清除上一次操作的遗留信息,否则编辑不了sessionGlobal.clear();return sessionGlobal;}/*** like12 add,20160127,关闭Session*/public void closeSessionMulti() {if(sessionGlobal != null){sessionGlobal.close();//like12 add,20160302,bug,session被关闭后不是null 而是‘SessionImpl(<closed>)’,下次将报错sessionGlobal = null;}}
}

这篇关于Dorado7 MultiHibernateDao.java McfBaseDAO 多数据源支持(单Hibernate双数据库)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/816497

相关文章

Spring Security基于数据库的ABAC属性权限模型实战开发教程

《SpringSecurity基于数据库的ABAC属性权限模型实战开发教程》:本文主要介绍SpringSecurity基于数据库的ABAC属性权限模型实战开发教程,本文给大家介绍的非常详细,对大... 目录1. 前言2. 权限决策依据RBACABAC综合对比3. 数据库表结构说明4. 实战开始5. MyBA

Spring Security方法级安全控制@PreAuthorize注解的灵活运用小结

《SpringSecurity方法级安全控制@PreAuthorize注解的灵活运用小结》本文将带着大家讲解@PreAuthorize注解的核心原理、SpEL表达式机制,并通过的示例代码演示如... 目录1. 前言2. @PreAuthorize 注解简介3. @PreAuthorize 核心原理解析拦截与

一文详解JavaScript中的fetch方法

《一文详解JavaScript中的fetch方法》fetch函数是一个用于在JavaScript中执行HTTP请求的现代API,它提供了一种更简洁、更强大的方式来处理网络请求,:本文主要介绍Jav... 目录前言什么是 fetch 方法基本语法简单的 GET 请求示例代码解释发送 POST 请求示例代码解释

Java图片压缩三种高效压缩方案详细解析

《Java图片压缩三种高效压缩方案详细解析》图片压缩通常涉及减少图片的尺寸缩放、调整图片的质量(针对JPEG、PNG等)、使用特定的算法来减少图片的数据量等,:本文主要介绍Java图片压缩三种高效... 目录一、基于OpenCV的智能尺寸压缩技术亮点:适用场景:二、JPEG质量参数压缩关键技术:压缩效果对比

Java调用C++动态库超详细步骤讲解(附源码)

《Java调用C++动态库超详细步骤讲解(附源码)》C语言因其高效和接近硬件的特性,时常会被用在性能要求较高或者需要直接操作硬件的场合,:本文主要介绍Java调用C++动态库的相关资料,文中通过代... 目录一、直接调用C++库第一步:动态库生成(vs2017+qt5.12.10)第二步:Java调用C++

springboot+dubbo实现时间轮算法

《springboot+dubbo实现时间轮算法》时间轮是一种高效利用线程资源进行批量化调度的算法,本文主要介绍了springboot+dubbo实现时间轮算法,文中通过示例代码介绍的非常详细,对大家... 目录前言一、参数说明二、具体实现1、HashedwheelTimer2、createWheel3、n

Java利用docx4j+Freemarker生成word文档

《Java利用docx4j+Freemarker生成word文档》这篇文章主要为大家详细介绍了Java如何利用docx4j+Freemarker生成word文档,文中的示例代码讲解详细,感兴趣的小伙伴... 目录技术方案maven依赖创建模板文件实现代码技术方案Java 1.8 + docx4j + Fr

SpringBoot首笔交易慢问题排查与优化方案

《SpringBoot首笔交易慢问题排查与优化方案》在我们的微服务项目中,遇到这样的问题:应用启动后,第一笔交易响应耗时高达4、5秒,而后续请求均能在毫秒级完成,这不仅触发监控告警,也极大影响了用户体... 目录问题背景排查步骤1. 日志分析2. 性能工具定位优化方案:提前预热各种资源1. Flowable

Ubuntu中远程连接Mysql数据库的详细图文教程

《Ubuntu中远程连接Mysql数据库的详细图文教程》Ubuntu是一个以桌面应用为主的Linux发行版操作系统,这篇文章主要为大家详细介绍了Ubuntu中远程连接Mysql数据库的详细图文教程,有... 目录1、版本2、检查有没有mysql2.1 查询是否安装了Mysql包2.2 查看Mysql版本2.

Oracle数据库常见字段类型大全以及超详细解析

《Oracle数据库常见字段类型大全以及超详细解析》在Oracle数据库中查询特定表的字段个数通常需要使用SQL语句来完成,:本文主要介绍Oracle数据库常见字段类型大全以及超详细解析,文中通过... 目录前言一、字符类型(Character)1、CHAR:定长字符数据类型2、VARCHAR2:变长字符数