使用 hibernate SQLQuery 实现动态表操作

迷南。 2022-08-24 04:22 132阅读 0赞

<table style="BORDER-COLLAPSE: collapse; WORD-WRAP: break-word"> 
 <tbody> 
 <tr> 
 <td align="middle">使用 hibernate SQLQuery 实现动态表 操作 </td> 
 </tr> 
 <tr> 
 <td></td> 
 </tr> 
 <tr> 
 <td></td> 
 </tr> 
 <tr> 
 <td align="middle"> 
 <table style="BORDER-COLLAPSE: collapse; WORD-WRAP: break-word"> 
 <tbody> 
 <tr> 
 <td> 
 <div style="MARGIN: 15px"> 
 <div>
 先说一个题外话，我对 hibernate 的学习，主要都是通过阅读它提供的文档，如果你有下载过 hibernate，在这个目录下可以找到 doc 
 </div> 
 <div>
 hibernate-3.2/doc/reference/en/html_single/index.html 
 </div> 
 <div>
 &nbsp; 
 </div> 
 <div>
 我在实际的项目应用中，有时会设计出这样的一种数据表，每个时间段产生一个新表，例如是按年或月或日。相同类型的表中，所有的字段结构都是一样的。而 hibernate 提供的类与表的映射，是只能映射到一个具体表的，在程序的运行过程中，很难去动态修改一个 hbm 对应的表名。我在网上也有看到一实现，但是很复杂，并且不符合我的要求。 
 </div> 
 <div>
 &nbsp; 
 </div> 
 <div>
 因此我就想到直接用 jdbc 去操作数据库，这样的做法是绕过 hibernate 了。方法是从 hibernate 的 session 中，直接取得数据库 connection ，然后就直接 jdbc 了。 
 </div> 
 <div>
 &nbsp; 
 </div> 
 <div>
 后来在升级了 proxool 到 9.0RC3 后，发现居然出现了数据库连接无法释放的问题。为了解决这个问题，我查阅了 hibernate doc。我发现原来用 SQLQuery 可以更好的解决，并且可以重新用于 hibernate hbm 机制。以下举例说明。 
 </div> 
 <div>
 &nbsp; 
 </div> 
 <div>
 例如我有一个 pojo 是 ReadInfo，用来记录阅读信息的。由于数据量宠大，所以我的思路是按月划分，每个月一张表。所以只是表名不同，而字段是完全相同的。 
 </div> 
 <div>
 &nbsp; 
 </div> 
 <div>
 ReadInfo.java 是这样的，其中 userId, year, month, day 是联合主键： 
 </div> 
 <div>
 &nbsp; 
 </div> 
 <table style="BORDER-COLLAPSE: collapse"> 
 <tbody> 
 <tr> 
 <td> <code>&nbsp;&nbsp;&nbsp;&nbsp;private Integer userId; &nbsp;&nbsp;&nbsp;&nbsp;private Integer year; &nbsp;&nbsp;&nbsp;&nbsp;private Integer month; &nbsp;&nbsp;&nbsp;&nbsp;private Integer day; &nbsp;&nbsp;&nbsp;&nbsp;private Integer point;</code></td> 
 </tr> 
 </tbody> 
 </table> 
 那么相应的 ReadInfo.hbm.xml 的片段是 
 <table style="BORDER-COLLAPSE: collapse"> 
 <tbody> 
 <tr> 
 <td> <code>&nbsp;&nbsp;&nbsp;&nbsp;&lt;class name="ReadInfo" table="tblReadInfo" mutable="false"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;composite-id&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;key-property name="userId" column="userId" type="integer"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;key-property name="year" column="year" type="integer"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;key-property name="month" column="month" type="integer"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;key-property name="day" column="day" type="integer"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/composite-id&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="point" column="point" type="integer"/&gt; &nbsp;&nbsp;&nbsp;&nbsp;&lt;/class&gt;</code></td> 
 </tr> 
 </tbody> 
 </table> 
 上面的xml，注意 2 个细节 
 1. pojo 所映射的 table tblReadInfo 实际上是不存在的。实际的表是 tblRead200710 之类的； 
 2. mutable 要设置为&nbsp;false，即是说，关闭 hibernate 对这个 pojo 的任何持久化操作，以避免 hibernate 把数据写到 tblReadInfo 中（这个表是不存在的嘛）。因此，所有的持久化操作，都是需要自己通过 SQLQuery 来处理。 
 现在可以看一下 ado 中的操作了，先看一个 select 操作 
 <div></div> 
 <table style="BORDER-COLLAPSE: collapse"> 
 <tbody> 
 <tr> 
 <td> <code>public ReadInfo selectReadInfo(Integer userId, Integer year, &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Integer month, Integer day) throws HibernateException &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ReadInfo readInfo = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Session session = getSession(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Transaction tx = session.beginTransaction(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;try &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String sql = "select * from tblRead" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;+ Misc.formatMoon(year, month) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;+ " where userId=? and day=?"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;SQLQuery query = session.createSQLQuery(sql); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;query.addEntity(ReadInfo.class); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;query.setLong(0, userId); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;query.setInteger(1, day); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;readInfo = (ReadInfo) query.uniqueResult(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;tx.commit(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;catch (HibernateException e) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;log.error("catch exception:", e); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if (tx != null) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;tx.rollback(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;throw e; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return readInfo; &nbsp;&nbsp;&nbsp;&nbsp;}</code></td> 
 </tr> 
 </tbody> 
 </table> 
 上面的代码，关键是以下几点： 
 1. 通过函数参数的 year, month 来确定要操作的表名，我自己写了一个 Misc.formatMoon(year, month) 来生成 "yyyyMM" 格式的字串； 
 2. 使用了 SQLQuery ，再通过 query.addEntity(ReadInfo.class); 建立与 ReadInfo 的映射关系； 
 3. query.setXxx() 与 PreparedStatement 的类似，不过索引是从 0 开始； 
 4. 其它的就跟一般的 Query 操作类似的了。 
 再看一个 insert 操作 
 <table style="BORDER-COLLAPSE: collapse"> 
 <tbody> 
 <tr> 
 <td> <code>&nbsp;&nbsp;&nbsp;&nbsp;public void insertReadInfo(ReadInfo readInfo) throws HibernateException &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Session session = getSession(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Transaction tx = session.beginTransaction(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;try &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String sql = "insert into tblRead" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;+ Misc.formatMoon(readInfo.getYear(), readInfo.getMonth()) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;+ " (userId, year, month, day, point) values (?, ?, ?, ?, ?)"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;SQLQuery query = session.createSQLQuery(sql); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;query.setLong(0, readInfo.getUserId()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;query.setInteger(1, readInfo.getYear()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;query.setInteger(2, readInfo.getMonth()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;query.setInteger(3, readInfo.getDay()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;query.setInteger(4, readInfo.getPoint()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;query.executeUpdate(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;tx.commit(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;catch (HibernateException e) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;log.error("catch exception:", e); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if (tx != null) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;tx.rollback(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;throw e; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;}</code></td> 
 </tr> 
 </tbody> 
 </table> 
 同理，update, delete 等操作也是这样实现的。 
 hmm.. 这种处理方式的麻烦的地方是需要手工写 sql ，因此要尽量写通用的标准 sql，不然在数据库兼容方面会有问题。当然，有时是会出现无法兼容的情况，那么可以考虑把 sql 写到配置文件中，根据不同的数据库，装载相应的配置文件咯。 
 </div></td> 
 </tr> 
 </tbody> 
 </table></td> 
 </tr> 
 </tbody> 
</table>

转自:http://blog.chinaunix.net/u1/50766/showart\_400410.html