- 浏览: 1974708 次
- 性别:
- 来自: 深圳
文章分类
- 全部博客 (509)
- JavaEE (122)
- Oracle数据库 (29)
- JavaScript (37)
- SAP (5)
- MySql数据库 (7)
- JavaSE (4)
- Ajax (1)
- jQuery (13)
- SSH框架 (36)
- Web Service (10)
- JSF框架 (2)
- JBPM (0)
- ireport报表 (2)
- ibatis (5)
- Hibernate (31)
- JSP (11)
- Tomcat 服务器 (20)
- Other (19)
- JavaWeb (4)
- Maven (11)
- OSWorkFlow (10)
- HTML (13)
- Exception汇总 (7)
- SVN (2)
- 笑话 (1)
- JSTL (1)
- WebSphere Message Broker (13)
- ANT命令 (3)
- Liunx (12)
- Struts2 (26)
- Eclipse (6)
- DOS (3)
- Flex (11)
- WebSphere (1)
- 开发常用工具 (3)
- Junit (2)
- EJB (4)
- Struts1.2 (2)
- Jboss (1)
- Android (2)
- Java框架源码解析 (1)
- Spring (4)
- MyBatis (6)
- SpringMVC (4)
- Jetty (2)
- 数据库表设计 (1)
- SSO (4)
最新评论
-
贝塔ZQ:
也可以试试PageOffice插件,觉得更简单点
Jxl操作Excel设置背景、字体颜色、对齐方式、列的宽度 -
jia1208:
...
Could not publish server configuration for Tomcat v6.0 Server at localhost. -
u011274527:
赞
java.io.EOFException java.io.ObjectInputStream$PeekInputStream.readFully 错误 -
旭旭小牛啦:
怎么没哟了,继续赛
jQuery 选择器 -
wzw3919:
100行会报空指针
Java 解压缩zip文件
今天开会讨论的时候. 项目中要用到通过Hibernate访问多个数据库..以为系统集成了其他子系统,所以几个不同数据库进行数据访问和存取..
在有限的时间内,做一个比较简单的例子..便于以后参考:有些地方,未考虑,请大家拍砖..
Hibernate访问多个数据库的设计思路:其实就是利用 Hibernate中config = new
Configuration().configure(configFile);
可以加载不同数据库配置信息的原理,编写一个通过的 数据库操作类,再编写一个数据库管理程序[map],
将加载的数据库连接实例put早数据库管
理程序中,
具体实现见下面:
在做测试之前,需要在oracle和mysql中建立表Student;
见表语句:
oracle:
Create table Student( id varchar2(10) not null, name varchar2(10)not null, sex varchar2(4) not null, age number ) commit;
mySql:
create table `student` ( `id` varchar (30), `name` varchar (30), `sex` varchar (12), `age` int (4) ); commit;
这里针对于两个不同数据库..一个文件是对oracle数据库操作,取名叫oracle.cfg.xml
另外一个针对于MySql数据库操作..取名叫做mySql.cfg.xml
oracle.cfg.xml配置如下:
<?xml version='1.0' encoding='UTF-8'?> <!DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD 3.0//EN" "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd"> <!-- Generated by MyEclipse Hibernate Tools. --> <hibernate-configuration> <session-factory> <property name="connection.url"> jdbc:oracle:thin:@localhost:1521:ORCL </property> <property name="dialect"> org.hibernate.dialect.Oracle9Dialect </property> <property name="connection.username">scott</property> <property name="connection.password">tiger</property> <property name="connection.driver_class">oracle.jdbc.driver.OracleDriver</property> <property name="show_sql">true</property> <property name="format_sql">true</property> <mapping resource = "pack/java/model/Student.hbm.xml"/> </session-factory> </hibernate-configuration>
mySql.cfg.xml配置如下:'
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD 3.0//EN" "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd"> <!-- Generated by MyEclipse Hibernate Tools. --> <hibernate-configuration> <session-factory name=""> <property name="connection.url">jdbc:mysql://127.0.0.1/mysql</property> <property name="dialect">org.hibernate.dialect.MySQLDialect</property> <property name="connection.username">root</property> <property name="connection.password">password</property> <property name="connection.driver_class">com.mysql.jdbc.Driver</property> <property name="show_sql">true</property> <property name="format_sql">true</property> <mapping resource = "pack/java/model/Student.hbm.xml"/> </session-factory> </hibernate-configuration>
之后,建立一个Student VO对象.
package pack.java.model; import java.io.Serializable; /** * Student VO * @author Administrator * */ public class Student implements Serializable{ private static final long serialVersionUID = 1034231412171686357L; private String id; private String name; private String sex; private long age; public String getId() { return id; } public void setId(String id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public String getSex() { return sex; } public void setSex(String sex) { this.sex = sex; } public long getAge() { return age; } public void setAge(long age) { this.age = age; } public Student() { super(); // TODO Auto-generated constructor stub } public Student(String id, String name, String sex, long age) { super(); this.id = id; this.name = name; this.sex = sex; this.age = age; } }
、建立 一个DataBaseManager 管理SessionManager;
package pack.java.basedao; import java.util.HashMap; /** * 建立 一个DataBaseManager 管理SessionManager; * 用于存放多个SessionFactory; * @author Administrator * */ public class DataBaseManager extends HashMap{ private static final long serialVersionUID = 2939313139367007154L; private static DataBaseManager dbinstance = new DataBaseManager(); public static DataBaseManager getDbinstance() { return dbinstance; } public static void setDbinstance(DataBaseManager dataBaseManager){ DataBaseManager.dbinstance = dataBaseManager; } public SessionManager get(Object key){ return (SessionManager) super.get(key); } @SuppressWarnings("unchecked") @Override public Object put(Object key, Object value) { // TODO Auto-generated method stub return super.put(key, value); } }
、 建立一个SessionManager;从SessionFactory中获取Session,以及定义一些,基本的CRUD的操作;
package pack.java.basedao; import java.io.Serializable; import java.util.List; import org.hibernate.Criteria; import org.hibernate.Query; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.Transaction; import org.hibernate.cfg.Configuration; /** * 建立一个SessionManager;从SessionFactory中 * 获取Session,以及定义一些,基本的CRUD的操作; * @author Administrator * */ public class SessionManager{ private Configuration configuration = null; private SessionFactory sessionFactory = null; private Session session = null; public Criteria createCriteria(Class clazz){ return session.createCriteria(clazz); } public void buildSession(){ sessionFactory = configuration.buildSessionFactory(); session = sessionFactory.openSession(); } public SessionManager(String configFile){ configuration = new Configuration().configure(configFile); buildSession(); } public Session getSession(){ return session; } public void save(Object obj){ Transaction transaction = session.beginTransaction(); session.save(obj); transaction.commit(); } public void update(Object obj){ Transaction transaction = session.beginTransaction(); session.update(obj); transaction.commit(); } @SuppressWarnings("unchecked") public <T>List<T> queryAll(Class clazz){ return session.createQuery("from "+clazz.getName()).list(); } @SuppressWarnings("unchecked") public Object queryObjectById(Class clazz,Serializable id){ return session.load(clazz, id); } public void delete(Object obj){ Transaction transaction = session.beginTransaction(); session.delete(obj); transaction.commit(); } @SuppressWarnings("unchecked") public void delete(Class clazz,Serializable id){ Transaction transaction = session.beginTransaction(); this.delete(this.queryObjectById(clazz, id)); transaction.commit(); } @SuppressWarnings("unchecked") public <T>List<T> queryObjectsByHql(String hql,Object...objects){ Query query = session.createQuery(hql); if(objects!= null && objects.length>0){ for(int i = 0;i<objects.length;i++){ query.setParameter(i, objects[i]); } } return query.list(); } }
最后,就是测试针对多个数据库进行操作了,
具体代码如下:
package pack.java.test; import pack.java.basedao.DataBaseManager; import pack.java.basedao.SessionManager; import pack.java.model.Student; /** * 测试多个数据源; * @author ZhouHaiTao * */ public class TestHibernateDataSource { DataBaseManager baseManager = null; public void testDataSource(){ setDatabase(); SessionManager mysqlSessionManager = baseManager.get("mysql"); //Session mysqlSession = mysqlSessionManager.getSession(); Student student1 = new Student(); student1.setId("100"); student1.setName("周海涛"); student1.setAge(22); student1.setSex("男"); mysqlSessionManager.save(student1); System.out.println("成功添加到MySql数据库中!"); SessionManager oracleSessionManager = baseManager.get("oracle"); //Session oracleSession = oracleSessionManager.getSession(); Student student2 = new Student(); student2.setId("101"); student2.setName("张三"); student2.setAge(20); student2.setSex("女"); oracleSessionManager.save(student2); System.out.println("成功添加到Oracle数据库中!"); } public void setDatabase(){ SessionManager oracleSessionManager = new SessionManager("oracle.cfg.xml"); SessionManager mysqlSessionManager = new SessionManager("mysql.cfg.xml"); baseManager = DataBaseManager.getDbinstance(); baseManager.put("mysql", mysqlSessionManager); baseManager.put("oracle", oracleSessionManager); } public static void main(String[] args) { new TestHibernateDataSource().testDataSource(); } }
运行之后,生成两条插入的sql语句..
Hibernate:
insert
into
STUDENT
(NAME, SEX, AGE, ID)
values
(?, ?, ?, ?)
成功添加到MySql数据库中!
Hibernate:
insert
into
STUDENT
(NAME, SEX, AGE, ID)
values
(?, ?, ?, ?)
成功添加到Oracle数据库中!
分别查询oracle和Mysql数据库,
发现数据都已经插入进来了,操作成功!
发表评论
-
大型互联网服务集成平台:springmvc+mybatis+restfull+JMS+webservice+bootstrap
2015-04-12 23:36 22SpringMVC + Mybatis + SpringS ... -
Spring中二级缓存的配置
2011-12-18 20:40 22121.首先,在spring的hibernate配置里(app ... -
Hibernate 配置文件提示
2011-12-11 16:03 10081.这个则是hibernate.cfg.xml文件的头信息.. ... -
Hibernate中二级缓存的配置
2011-10-18 00:26 1237我们知道 hibernate的session提供了一级缓存, ... -
Hibernate 生成策略属性
2011-10-17 14:01 987"assigned" 主键由外部程序负责生 ... -
Exception in thread "main" java.lang.NoClassDefFoundError: javax/transaction/Syn
2011-10-16 18:37 2432Exception in thread "main& ... -
Hibernate缓存的分类
2011-10-16 11:25 1005Hibernate缓存分类: Session ... -
在Hibernate中使用日期函数获取数据库时间
2011-10-04 20:13 1645在Hibernate中使用日期函数获取数据库时间 ... -
Hibernate关联映射-one to one主键双向关联
2011-09-23 01:11 1294这次,继续上一次的实例。 记录1对1 主键双向关联. ... -
Exception in thread "main" org.hibernate.id.IdentifierGenerationException: attem
2011-09-23 00:46 2039今天在做Hibernate中1多1双向关联映射的实例时, ... -
Hibernate关联映射-one to one 外键双向关联.
2011-09-22 00:28 1151说明:双向一对一,是一对多的特例,只需要在多的一方设置成 ... -
Hibernate关联映射-many to many 外键单向关联.
2011-09-20 01:18 1429多对多的实例很多,这里说一个比较简单的例子,而且还是单向 ... -
Hibernate关联映射-many to one 外键单向关联
2011-09-18 00:25 1931多个人可以对应一个地址,也就是所谓的多对一关系,many to ... -
Hibernate关联映射-one to to 主键单向关联
2011-09-17 23:23 1026这次介绍 还是以Person 和 Address 为例. ... -
Hibernate关联映射-one to many外键单向关联
2011-09-15 01:14 4567以下是说明,1对多 单向外键关联 的实例.同样以person ... -
Hibernate关联映射-one to one单向外键关联
2011-09-13 22:00 1608Hibernate的关联关系很多,也非常的复杂. 常见的有 ... -
org.hibernate.TransientObjectException: object references an unsaved transient i
2011-09-12 19:02 1464org.hibernate.TransientObjectEx ... -
org.hibernate.PropertyAccessException: Exception occurred inside getter of pack.
2011-09-12 18:54 6105报如下,异常是因为,在Person对象中.设置的属性类型 ... -
org.hibernate.MappingException: could not instantiate id generator
2011-09-10 14:32 2444在搭建Hibernate的环境时, ... -
配置hibernate.properties 或 hibernate.cfg.xml 文件时,在配置JDBC连接参数时,要配置数据库方言
2011-09-10 13:04 1911各数据库的方言 (配置 hibernate.cfg.xml 时 ...
相关推荐
这个数据库访问控制框架工程名为dbmanager,目前的版本是1.1.8,只支持MYSQL数据库,在未来的两周时间内我会发布后续扩展版本,加入对SQLSERVER, ORACLE,SYBASE,DB2数据库的支持。 之所以想写这个框架,最主要的一个...
16.1.4. 返回多个实体(Returning multiple entities) 16.1.5. 返回非受管实体(Returning non-managed entities) 16.1.6. 处理继承(Handling inheritance) 16.1.7. 参数(Parameters) 16.2. 命名SQL查询 ...
这个数据库访问控制框架工程dbmanager的文档,目前的版本是1.5.6,在原版本1.1.8对MYSQL的支持上加入了对SQLSERVER, ORACLE,SYBASE,DB2数据库的支持。 之所以想写这个框架,最主要的一个原因是,目前在JAVA开发中...
Hibernate Reactive来访问数据库, 编写Java代码以数据模型, 编写React式数据访问代码,以及 程序。 我们建议您从这里开始! 范例程序 目录中有一个非常简单的示例程序。 Gradle构建 该项目是建立与Gradle,但...
(1)Configuration:用于解析hibernate.cfg.xml文件和XXXXX.hbm.xml文件...如果应用同时访问多个DB,怎需要为每个数据库创建一个单独的SessionFactory实例。 (3)Session:也被称为持久化管理器,对象级数据库操作。
现在每个方法都自己开启和关闭事务,暂时还不支持在一个事务中做多个操作然后统一提交事务. * (三)作者寄语: * 昔日有JavaScript借Java发展,今日也希望AHibernate借Hibernate之名发展. * 希望这个项目...
BeetSql是一个全功能DAO工具,同时具有Hibernate 优点 & Mybatis优点功能,适用于承认以SQL为中心,同时又需求工具能自动能生成大量常用的SQL的应用。 在开发效率上,无需注解,自动使用大量内置SQL,轻易完成增删...
这个数据库访问控制框架工程名为dbmanager,目前的版本是1.5.6,已在上一次发布的1.1.8版本的基础上加入了对SQLSERVER, ORACLE,SYBASE,DB2数据库的支持。 之所以想写这个框架,最主要的一个原因是,目前在JAVA开发中...
1.Hibernate 对 JDBC 访问数据库的代码进行了轻量级封装,大大简化了数据访问层繁琐的重复性代码,并且减少了内存消耗,加快了运行效率。 2.Hibernate 使用 Java 的反射机制,而不是使用字节码增强程序类,并实现了...
等通配符号),多关键字,模糊查询,排序等6,支持Clustering7,支持直接访问Lucene API8,对Lucene索引,API的高效管理Hibernate Search运行的环境如下:1、JDK或JRE 5.0以上2、Hibernate-Search以及相应的依赖包3...
Hibernate框架是一个对象关系映射(ORM)框架,它能够将Java对象与数据库表进行映射,实现Java对象与数据库之间的自动转换。在网上书城系统中,Hibernate框架负责处理与MySQL数据库的交互操作,如查询书籍信息、添加...
1.2. 第一部分 - 第一个Hibernate应用程序 首先我们将创建一个简单的基于控制台的(console-based)Hibernate应用程序。由于我们使用Java数据库(HSQL DB),所以不必安装任何数据库服务器。 假设我们希望有一个小...
BeetlSQL的目标是提供开发高效,维护高效,运行高效的数据库访问框架,在一个系统多个库的情况下,提供一致的编写代码方式。支持如下数据平台。传统数据库:MySQL(国内兼容MySQL协议的各种大数据库),MariaDB,Oracle,...
5.1.2 Hibernate访问持久化类属性的策略 5.1.3 在持久化类的访问方法中加入程序逻辑 5.1.4 设置派生属性 5.1.5 控制insert和update语句 5.2 处理SQL引用标识符 5.3 创建命名策略 5.4 设置数据库Schema...
16.1.4. 返回多个实体(Returning multiple entities) 16.1.5. 返回非受管实体(Returning non-managed entities) 16.1.6. 处理继承(Handling inheritance) 16.1.7. 参数(Parameters) 16.2. 命名SQL查询 ...
第一部分 从Hibernate和EJB 3.0开始 第1章 理解对象/关系持久化 1.1 什么是持久化 1.1.1 关系数据库 1.1.2 理解SQL 1.1.3 在Java中使用SQL 1.1.4 面向对象应用程序中的持久化 1.2 范式不...
(假若您希望使用其它用户名如root,您需要修改hibernate的数据库配置中的连接参数——位于hibernate.cfg.xml中,以及创建数据库表时的连接参数——位于build.xml中。) 7, 确认ant安装正确. ant可以在此下载: ...