在查詢時(shí)報(bào)下面的錯(cuò)誤，使用的是hibernate，oracle數(shù)據(jù)庫，并做了集群
WARN - SQL Error: 17002, SQLState: null
ERROR - Io 異常：Software caused connection abort: recv failed
請(qǐng)問是什么原因造成的，謝謝！

???參考hibernate對(duì)hql語句的解析，寫了對(duì)SQL語句的解析，并生成相應(yīng)的對(duì)象。主要為了自定義查詢條件進(jìn)行查詢和對(duì)查詢結(jié)果進(jìn)行二次查詢使用。目前只支持簡單的sql語句的解析，不支持子查詢的解析。在壓縮包中只給出了解析程序，沒有包括對(duì)應(yīng)的查詢對(duì)象。鏈接:程序源碼。 項(xiàng)目要求能獲得CONNECTION便于對(duì)數(shù)據(jù)庫的操作，并要求能與spring中的事務(wù)處于同一事務(wù)中。實(shí)現(xiàn)：
1.定義SanHibernateTransactionManager類，繼承spring中的 HibernateTransactionManager，便于獲得HibernateTransactionObject。把這個(gè)類注入到spring容器中。

< bean? id ="transactionManager"
????????class ="com.san.tools.hibernate.SanHibernateTransactionManager" >
???????? < property? name ="sessionFactory" >
???????????? < ref? bean ="sessionFactory" />
???????? </ property >
???? </ bean >

?

public?class?SanHibernateTransactionManager?extends?HibernateTransactionManager{

????public?Object?getTransactionObj(){
????????return?super.doGetTransaction();
????}
????????????
????public?boolean?existsTransaction(Object?transaction){
????????return?super.isExistingTransaction(transaction);
????}
????
????public?Session?getSession(){
????????return?SessionFactoryUtils.getSession(this.getSessionFactory(),?true);
????}
????
????public?Session?getCurrentSession(){
????????HibernateTransactionObject?obj?=?(HibernateTransactionObject)this.getTransactionObj();
????????return?obj.getSessionHolder().getSession();
????}
}

2.開始事務(wù)。

public ? void ?beginTransaction()? throws ?SQLException {
???????? // TransactionDefinition.PROPAGATION_REQUIRED:支持當(dāng)前的事務(wù)，如果不存在就創(chuàng)建一個(gè)新的。
????????DefaultTransactionDefinition?transactionDef? = ? new ?DefaultTransactionDefinition(TransactionDefinition.PROPAGATION_REQUIRED);
???????? // 創(chuàng)建一個(gè)TransactionStatus
????????TransactionStatus?transactionStatus? = ?transactionManager.getTransaction(transactionDef);
???????? // 取得綁定到當(dāng)前線程上的session。從HibernateTransactionObject中獲得，這里修改了spring中HibernateTransactionManager.java文件，
???????? // 將private?HibernateTransactionObject改為protected?HibernateTransactionObject
????????Session?session? = ?transactionManager.getCurrentSession();
?????? if (session? != ? this .session) {
????????????System.err.println( " session不是同一對(duì)象 " );
????????}
???????? // 將transactionStatus保存到集合中
???????? this .transactionStatuss.add(transactionStatus);
???????? this .beginTransaction? = ? true ;
????}

3.提交事務(wù) 4.回滾事務(wù)

public?void?rollBack(){
????????for(int?i?=?transactionStatuss.size()?-?1;i?>=?0;i--){
????????????DefaultTransactionStatus?transactionStatus?=?(DefaultTransactionStatus)transactionStatuss.get(i);
????????????transactionManager.rollback(transactionStatus);
????????}
????????transactionStatuss.clear();
????}

???????貼出這段代碼一是為了共享一點(diǎn)所得，二是希望能指出中間有什么不正確的地方(心里不是很有底)

 

 

     摘要:   閱讀全文