我们的数据模型分为两个数据库上的架构。这些模式是隔离使用的,除了在两者之间桥接的一些单键关系。没有跨两个数据库的写事务。
与这个问题类似,我们要使用Hibernate在不同数据库中的2个表上进行联接,我们想使用Hibernate来处理实体的联接。我们不能使用数据库解决方案(DB2上的联合视图)。
我们为Hibernate设置了两个单独的数据库配置(“医生”和“病人”),当使用DAO显式访问特定会话时,它们可以完美工作。
我们希望使用Hibernate来自动检索该实体,方法是调用DoctorBO.getExam().getPatient()其中检查包含指向另一个数据库上的Patient表的ID。
DoctorBO.getExam().getPatient()
我尝试执行此操作的一种方法是使用自定义UserType:
public class DistributedUserType implements UserType, ParameterizedType { public static final String CLASS = "CLASS"; public static final String SESSION = "SESSION"; private Class<? extends DistributedEntity> returnedClass; private String session; /** {@inheritDoc} */ @Override public int[] sqlTypes() { // The column will only be the id return new int[] { java.sql.Types.BIGINT }; } /** {@inheritDoc} */ @Override public Class<? extends DistributedEntity> returnedClass() { // Set by typedef parameter return returnedClass; } /** {@inheritDoc} */ @Override public boolean equals(Object x, Object y) throws HibernateException { if (x == y) { return true; } if ((x == null) || (y == null)) { return false; } Long xId = ((DistributedEntity) x).getId(); Long yId = ((DistributedEntity) y).getId(); if (xId.equals(yId)) { return true; } else { return false; } } /** {@inheritDoc} */ @Override public int hashCode(Object x) throws HibernateException { assert (x != null); return x.hashCode(); } /** {@inheritDoc} */ @Override public Object nullSafeGet(ResultSet rs, String[] names, Object owner) throws HibernateException, SQLException { Long id = rs.getLong(names[0]); return HibernateUtils.getSession(session).get(returnedClass, id); } /** {@inheritDoc} */ @Override public void nullSafeSet(PreparedStatement st, Object value, int index) throws HibernateException, SQLException { DistributedEntity de = (DistributedEntity) value; st.setLong(index, de.getId()); } /** {@inheritDoc} */ @Override public Object deepCopy(Object value) throws HibernateException { return value; } /** {@inheritDoc} */ @Override public boolean isMutable() { return false; } /** {@inheritDoc} */ @Override public Serializable disassemble(Object value) throws HibernateException { return (Serializable) value; } /** {@inheritDoc} */ @Override public Object assemble(Serializable cached, Object owner) throws HibernateException { return cached; } /** {@inheritDoc} */ @Override public Object replace(Object original, Object target, Object owner) throws HibernateException { return original; } /** {@inheritDoc} */ @Override public void setParameterValues(Properties parameters) { String clazz = (String) parameters.get(CLASS); try { returnedClass = ReflectHelper.classForName(clazz); } catch (ClassNotFoundException e) { throw new IllegalArgumentException("Class: " + clazz + " is not a known class type."); } session = (String) parameters.get(SESSION); } }
然后将使用:
@TypeDef(name = "testUserType", typeClass = DistributedUserType.class, parameters = { @Parameter(name = DistributedUserType.CLASS, value = PatientBO.CLASSNAME), @Parameter(name = DistributedUserType.SESSION, value = HibernateUtils.PATIENT_SESS) }) @Type(type = "testUserType") @Column(name = "PATIENT_ID") private PatientBO patient;
UserType有效-正确加载数据,并且仅将字段的ID持久保存到数据库中。我已经测试了非常简单的示例,doctor.getExam().getPatient()并且doctor.getExam().setPatient()似乎都很好用,但是我认为这是一个糟糕的技巧,并且我对Hibernate没有足够的了解,无法知道它是否可以安全使用。
doctor.getExam().getPatient()
doctor.getExam().setPatient()
有没有更好的方法来实现我们想要的?我在这里描述的方式是否足够,还是将来会造成困难?
我认为这不是一个好主意。您试图使所有内容都“好像”在一个数据库中,但事实并非如此。并且您“好像” toOne在检查和患者之间存在真正的联系,尽管这不是真正的联系。
toOne
尽管您意识到了这一事实,但其他或将来的开发人员不一定如此,并且会想知道为什么不可能进行如下查询:
select e from Exam e left join fetch e.patient
要么
select e from Exam e where e.patient.name like 'Smith%'
简而言之,您的伪协会仅履行常规协会提供的合同的一小部分,这将给IMO带来更多的混乱,而不是安慰。
没有什么能阻止您使用诸如
Patient getExamPatient(Exam e)
这样做的目的是相同的,但是要明确两个实体之间没有真正的关联。