溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

Hibernate Template類的使用方法

發(fā)布時(shí)間：2021-07-13 15:24:53 來源：億速云 閱讀：130 作者：chen 欄目：編程語言

這篇文章主要介紹“Hibernate Template類的使用方法”，在日常操作中，相信很多人在Hibernate Template類的使用方法問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對(duì)大家解答”Hibernate Template類的使用方法”的疑惑有所幫助！接下來，請(qǐng)跟著小編一起來學(xué)習(xí)吧！

目的：使用HibernateTemplate執(zhí)行execute（new HibernateCallback（））方法，從HibernateCallback中得到session，在此session中做多個(gè)操作，并希望這些操作位于同一個(gè)事務(wù)中。

如果你這樣寫（1）：

       public static void main(String ss[]) {
CtxUtil.getBaseManager().getHibernateTemplate().execute(new HibernateCallback() {
public Object doInHibernate(Session session) throws HibernateException, SQLException {
// 保存stu1
Student stu1 = new Student();
stu1.setName("aaaa");// 在數(shù)據(jù)庫中,name字段不允許為null
session.save(stu1);
session.flush();//實(shí)際上，如果不是程序員"手癢"來調(diào)用這個(gè)flush(),HibernateTemplate中session的事務(wù)處理還是很方便的
Student stu2 = new Student();
session.save(stu2);// 沒有設(shè)置name字段，預(yù)期會(huì)報(bào)出例外
session.flush();
return null;
}
});
}

你期望spring在執(zhí)行完execute回調(diào)后，在關(guān)閉session的時(shí)候提交事務(wù)，想法是很好的，但spring并不會(huì)這么做。讓我們來看看在Hibernate的源代碼中，session.beginTransation（）做了什么事。看如下代碼（2）：

public Transaction beginTransaction() throws HibernateException {
errorIfClosed();
if ( rootSession != null ) {
// todo : should seriously consider not allowing a txn to begin from a child session
//      can always route the request to the root session
log.warn( "Transaction started on non-root session" );
}
Transaction result = getTransaction();
result.begin();
return result;
}

這個(gè)方法中的result是一個(gè)org.hibernate.transaction.JDBCTransaction實(shí)例，而方法中的getTransaction（）方法源代碼為（3）：

public Transaction getTransaction() throws HibernateException {
if (hibernateTransaction==null) {
log.error(owner.getFactory().getSettings()
.getTransactionFactory().getClass());
hibernateTransaction = owner.getFactory().getSettings()
.getTransactionFactory()
.createTransaction( this, owner );
}
return hibernateTransaction;
}

再次追蹤，owner.getFactory（）。getSettings（） .getTransactionFactory（）的createTransaction（）方法源代碼如下（4）：

public Transaction createTransaction(JDBCContext jdbcContext, Context transactionContext)
throws HibernateException {
return new JDBCTransaction( jdbcContext, transactionContext );
}

它返回了一個(gè)JDBCTransaction，沒什么特別的。

在代碼2中，執(zhí)行了result.begin（），其實(shí)也就是JDBCTransaction實(shí)例的begin（）方法，來看看（5）：

public void begin() throws HibernateException {
if (begun) {
return;
}
if (commitFailed) {
throw new TransactionException("cannot re-start transaction after failed commit");
}
log.debug("begin");
try {
toggleAutoCommit = jdbcContext.connection().getAutoCommit();
if (log.isDebugEnabled()) {
log.debug("current autocommit status: " + toggleAutoCommit);
}
if (toggleAutoCommit) {
log.debug("disabling autocommit");
jdbcContext.connection().setAutoCommit(false);//把自動(dòng)提交設(shè)為了false
}
} catch (SQLException e) {
log.error("JDBC begin failed", e);
throw new TransactionException("JDBC begin failed: ", e);
}
callback = jdbcContext.registerCallbackIfNecessary();
begun = true;
committed = false;
rolledBack = false;
if (timeout > 0) {
jdbcContext.getConnectionManager().getBatcher().setTransactionTimeout(timeout);
}
jdbcContext.afterTransactionBegin(this);
}

在直接使用Hibernate時(shí)，要在事務(wù)結(jié)束的時(shí)候，寫上一句：tx.commit（），這個(gè)commit（）的源碼為：

public void commit() throws HibernateException {
if (!begun) {
throw new TransactionException("Transaction not successfully started");
}
log.debug("commit");
if (!transactionContext.isFlushModeNever() && callback) {
transactionContext.managedFlush(); // if an exception occurs during
// flush, user must call
// rollback()
}
notifyLocalSynchsBeforeTransactionCompletion();
if (callback) {
jdbcContext.beforeTransactionCompletion(this);
}
try {
commitAndResetAutoCommit();//重點(diǎn)代碼，它的作用是提交事務(wù)，并把connection的autocommit屬性恢復(fù)為true
log.debug("committed JDBC Connection");
committed = true;
if (callback) {
jdbcContext.afterTransactionCompletion(true, this);
}
notifyLocalSynchsAfterTransactionCompletion(Status.STATUS_COMMITTED);
} catch (SQLException e) {
log.error("JDBC commit failed", e);
commitFailed = true;
if (callback) {
jdbcContext.afterTransactionCompletion(false, this);
}
notifyLocalSynchsAfterTransactionCompletion(Status.STATUS_UNKNOWN);
throw new TransactionException("JDBC commit failed", e);
} finally {
closeIfRequired();
}
}

上面代碼中，commitAndResetAutoCommit（）方法的源碼如下：

private void commitAndResetAutoCommit() throws SQLException {
try {
jdbcContext.connection().commit();//這段不用說也能理解了
} finally {
toggleAutoCommit();//這段的作用是恢復(fù)connection的autocommit屬性為true
}
}

上述代碼的toggleAutoCommit（）源代碼如下：

    private void toggleAutoCommit() {
try {
if (toggleAutoCommit) {
log.debug("re-enabling autocommit");
jdbcContext.connection().setAutoCommit(true);//這行代碼的意義很明白了吧
}
} catch (Exception sqle) {
log.error("Could not toggle autocommit", sqle);
}
}

因此，如果你是直接使用hibernate，并手動(dòng)管理它的session，并手動(dòng)開啟事務(wù)關(guān)閉事務(wù)的話，完全可以保證你的事務(wù).

但是，如果你用的是HibernateTemplate，如同源代碼1一樣，則不要指望spring在關(guān)閉session的時(shí)候?yàn)槟闾峤皇聞?wù)（罪魁禍?zhǔn)拙褪窃诖a1中調(diào)用了session.flush（））。因?yàn)樵谑褂么a1時(shí)，spring中得到session的方式如下：Session session = （entityInterceptor ！= null ？ sessionFactory.openSession（entityInterceptor） ： sessionFactory。openSession（））；簡單地說它就是得到了一個(gè)session，而沒有對(duì)connection的autocommit（）作任何操作，spring管理范圍內(nèi)的session所持有的connection是autocommit=true的，spring借助這個(gè)屬性，在它關(guān)閉session時(shí)，提交數(shù)據(jù)庫事務(wù)。，因此如果你在源代碼1中加上一句話：

public static void main(String ss[]) {
CtxUtil.getBaseManager().getHibernateTemplate().execute(new HibernateCallback() {
public Object doInHibernate(Session session) throws HibernateException, SQLException {
log.info(session.connection().getAutoCommit());//打印一下事務(wù)提交方式
// 保存stu1
Student stu1 = new Student();
stu1.setName("aaaa");// 在數(shù)據(jù)庫中,name字段不允許為null
session.save(stu1);
session.flush();
Student stu2 = new Student();
session.save(stu2);// 沒有設(shè)置name字段，預(yù)期會(huì)報(bào)出例外
session.flush();
return null;
}
});
}

運(yùn)行后，它打出的結(jié)果是true，也就是說，雖然保存stu2時(shí)會(huì)報(bào)出例外，但如果commit屬性為true，則每一個(gè)到達(dá)數(shù)據(jù)庫的sql語句會(huì)立即被提交。換句話說，在調(diào)用完session.save（stu1）后，調(diào)用session.flush（），會(huì)發(fā)送sql語句到數(shù)據(jù)庫，再根據(jù)commit屬性為true，則保存stu1的操作已經(jīng)被持久到數(shù)據(jù)庫了，盡管后面的一條insert語句出了問題。

因此，如果你想在HibernateCallback中使用session的事務(wù)，需要如下寫：

public static void main(String ss[]) {
CtxUtil.getBaseManager().getHibernateTemplate().execute(new HibernateCallback() {
public Object doInHibernate(Session session) throws HibernateException, SQLException {
session.connection().setAutoCommit(false);
//保存stu1
Student stu1=new Student();
stu1.setName("aaaa");//在數(shù)據(jù)庫中,name字段不允許為null
session.save(stu1);
session.flush();

Student stu2 = new Student();
session.save(stu2);//沒有設(shè)置name字段，預(yù)期會(huì)報(bào)出例外
session.flush();
session.connection().commit();
//至于session的關(guān)閉就不用我們操心了
return null;
}
});
}

運(yùn)行上述代碼，沒問題了。至此，可能有些讀者早就對(duì)代碼1不滿意了：為什么每次save（）以后要調(diào)用flush（）？這是有原因的。下面我們來看看把session.flush（）去掉后會(huì)出什么問題。改掉后的代碼如下：

public static void main(String ss[]) {
CtxUtil.getBaseManager().getHibernateTemplate().execute(new HibernateCallback() {
public Object doInHibernate(Session session) throws HibernateException, SQLException {
session.connection().setAutoCommit(false);
// 保存stu1
Student stu1 = new Student();
stu1.setName("aaaa");// 在數(shù)據(jù)庫中,name字段不允許為null
session.save(stu1);
// session.flush();
Student stu2 = new Student();
session.save(stu2);// 沒有設(shè)置name字段，預(yù)期會(huì)報(bào)出例外
// session.flush();
session.connection().commit();
return null;
}
});
}

運(yùn)行上述代碼，后臺(tái)報(bào)數(shù)據(jù)庫的not null錯(cuò)誤，這個(gè)是合理的，打開數(shù)據(jù)庫，沒有發(fā)現(xiàn)新增記錄，這個(gè)也是合理的。你可能會(huì)說：由于事務(wù)失敗，數(shù)據(jù)庫當(dāng)然不可能會(huì)有任何新增記錄。好吧，我們?cè)侔汛a改一下，去除not null的錯(cuò)誤，以確保它能正常運(yùn)行。代碼如下：

public static void main(String ss[]) {
CtxUtil.getBaseManager().getHibernateTemplate().execute(new HibernateCallback() {
public Object doInHibernate(Session session) throws HibernateException, SQLException {
session.connection().setAutoCommit(false);
// 保存stu1
Student stu1 = new Student();
stu1.setName("aaaa");// 在數(shù)據(jù)庫中,name字段不允許為null
session.save(stu1);
// session.flush();
Student stu2 = new Student();
stu2.setName("asdfasdf");//好了，這個(gè)字段設(shè)過值，不會(huì)再報(bào)not null錯(cuò)誤了
session.save(stu2);
// session.flush();
session.connection().commit();
return null;
}
});
}

至此再運(yùn)行上述代碼，出現(xiàn)了一個(gè)奇怪的問題：雖然控制臺(tái)把insert語句打出來了，但是：數(shù)據(jù)庫沒有出現(xiàn)任何新的記錄。

究其原因，有二：

一、 session.connection（）。commit（）確實(shí)導(dǎo)致數(shù)據(jù)庫事務(wù)提交了，但是此刻session并沒有向數(shù)據(jù)庫發(fā)送任何語句。

二、 在spring后繼的flushIfNecessary（）和closeSessionOrRegisterDeferredClose（）方法中，***個(gè)方法向數(shù)據(jù)庫發(fā)送sql語句，第二個(gè)方法關(guān)閉session，同時(shí)關(guān)閉connection，然后問題在于：connection已經(jīng)在程序中被手動(dòng)設(shè)置為auttocommit=false了，因此在關(guān)閉數(shù)據(jù)庫時(shí)，也不會(huì)提交事務(wù)。

解決這個(gè)問題很容易，在程序中手動(dòng)調(diào)用session.flush（）就可以了。如下代碼：

public static void main(String ss[]) {
CtxUtil.getBaseManager().getHibernateTemplate().execute(new HibernateCallback() {
public Object doInHibernate(Session session) throws HibernateException, SQLException {
session.connection().setAutoCommit(false);

//保存stu1
Student stu1=new Student();
stu1.setName("aaaa");//在數(shù)據(jù)庫中,name字段不允許為null
session.save(stu1);

Student stu2 = new Student();
session.save(stu2);//沒有設(shè)置name字段，預(yù)期會(huì)報(bào)出例外

session.flush();//向數(shù)據(jù)庫發(fā)送sql
session.connection().commit();
return null;
}
});
}

運(yùn)行上述代碼，打開數(shù)據(jù)庫查看，沒有新增任何記錄。在代碼中新加一行stu2.setName（"aaa"）；再次運(yùn)行代碼，發(fā)現(xiàn)數(shù)據(jù)庫表中多了兩條記錄。事務(wù)操作成功。

至此，雖然操作成功，但事情還沒有結(jié)束。這是因?yàn)閟pring在調(diào)用doInHibernate（）的后繼的步驟中，還要進(jìn)行flushIfNecessary（）操作，這個(gè)操作其實(shí)***調(diào)用的還是session.flush（）。因?yàn)樵诔绦蛑幸呀?jīng)手動(dòng)調(diào)用過session.flush（），所以由spring調(diào)用的session.flush（）并不會(huì)對(duì)數(shù)據(jù)庫發(fā)送sql（因?yàn)榕K數(shù)據(jù)比對(duì)的原因）。雖然不會(huì)對(duì)結(jié)果有什么影響，但是多調(diào)了一次flush（），還是會(huì)對(duì)性能多少有些影響。能不能控制讓spring不調(diào)用session.flush（）呢？可以的，只要加上一句代碼，如下所示：

public static void main(String ss[]) {
CtxUtil.getBaseManager().getHibernateTemplate().setFlushMode(0);//0也就是FLUSH_NEVER
CtxUtil.getBaseManager().getHibernateTemplate().execute(new HibernateCallback() {
public Object doInHibernate(Session session) throws HibernateException, SQLException {
session.connection().setAutoCommit(false);

//保存stu1
Student stu1=new Student();
stu1.setName("aaaa");//在數(shù)據(jù)庫中,name字段不允許為null
session.save(stu1);

Student stu2 = new Student();
stu2.setName("sdf");
session.save(stu2);//沒有設(shè)置name字段，預(yù)期會(huì)報(bào)出例外

session.flush();
session.connection().commit();
return null;
}
});
}

通過設(shè)置HibernateTemplate的flushMode=FLUSH_NEVER來通知spring不進(jìn)行session.flush（）的調(diào)用，則spring的flushIfNecessary（）將不進(jìn)行任何操作，它的flushIfNecessary（）源代碼如下：

protected void flushIfNecessary(Session session, boolean existingTransaction) throws HibernateException {
if (getFlushMode() == FLUSH_EAGER || (!existingTransaction && getFlushMode() != FLUSH_NEVER)) {
logger.debug("Eagerly flushing Hibernate session");
session.flush();
}
}

至此，代碼1中的main（）終于修改完畢。但事實(shí)上，這樣的操作無疑是比較麻煩的，因此如果在spring中想利用session進(jìn)行事務(wù)操作時(shí)，***還是用TransactionTemplate（編程式事務(wù)）或是聲明式事務(wù)比較方便一些。

本例通過這么一個(gè)雖然簡單但又繞來繞去的例子，主要是說明hibernate事務(wù)的一些內(nèi)在特性，以及HibernateTemplate中如何處理session和事務(wù)的開關(guān)，讓讀者對(duì)HibernateTemplate的源代碼處理細(xì)節(jié)有一些了解，希望能給讀者有拋磚引玉的作用。

到此，關(guān)于“Hibernate Template類的使用方法”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí)，請(qǐng)繼續(xù)關(guān)注億速云網(wǎng)站，小編會(huì)繼續(xù)努力為大家?guī)砀鄬?shí)用的文章！

向AI問一下細(xì)節(jié)

免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如果涉及侵權(quán)請(qǐng)聯(lián)系站長郵箱：is@yisu.com進(jìn)行舉報(bào)，并提供相關(guān)證據(jù)，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手