這篇文章給大家分享的是有關(guān)Hibernate+JDBC實現(xiàn)批量插入、更新及刪除的內(nèi)容。小編覺得挺實用的,因此分享給大家做個參考,一起跟隨小編過來看看吧。
成都創(chuàng)新互聯(lián)是一家專業(yè)從事成都網(wǎng)站設(shè)計、做網(wǎng)站、成都外貿(mào)網(wǎng)站建設(shè)公司的網(wǎng)絡(luò)公司。作為專業(yè)網(wǎng)站制作公司,成都創(chuàng)新互聯(lián)依托的技術(shù)實力、以及多年的網(wǎng)站運營經(jīng)驗,為您提供專業(yè)的成都網(wǎng)站建設(shè)、營銷型網(wǎng)站建設(shè)及網(wǎng)站設(shè)計開發(fā)服務(wù)!
具體如下:
一、批量插入(兩種方式)
1. 通過Hibernate緩存
如果這樣寫代碼進行批量插入(初始設(shè)想):
package com.anlw.util; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.Transaction; import org.hibernate.boot.registry.StandardServiceRegistryBuilder; import org.hibernate.cfg.Configuration; import org.hibernate.service.ServiceRegistry; import com.anlw.entity.Student; public class SessionUtil { Configuration conf = null; ServiceRegistry st = null; SessionFactory sf = null; Session sess = null; Transaction tx = null; public void HIbernateTest() { conf = new Configuration().configure(); st = new StandardServiceRegistryBuilder().applySettings(conf.getProperties()).build(); sf = conf.buildSessionFactory(st); try { sess = sf.openSession(); tx = sess.beginTransaction(); for (int i = 0; i < 10; i++) { Student s = new Student(); s.setAge(i + 1); s.setName("test"); sess.save(s); } tx.commit(); } catch (Exception e) { if (tx != null) { tx.rollback(); } } finally { sess.close(); sf.close(); } } public static void main(String[] args) { new SessionUtil().HIbernateTest(); } }
如果數(shù)據(jù)量太大,會有可能出現(xiàn)內(nèi)存溢出的異常;
小知識:
(1).Hibernate一級緩存,對其容量沒有限制,強制使用,由于所有的對象都被保存到這個緩存中,內(nèi)存總會達到一定數(shù)目時出現(xiàn)內(nèi)存溢出的情況;
(2).Hibernate二級緩存可以進行大小配置;
要解決內(nèi)存溢出的問題,就應(yīng)該定時的將Sessiion緩存中的數(shù)據(jù)刷到數(shù)據(jù)庫,正確的批量插入方式:
(1).設(shè)置批量尺寸(博主至今還沒有明白下面這個屬性和flush()方法的區(qū)別)
<property name="hibernate.jdbc.batch_size">2</property>
配置這個參數(shù)的原因就是盡量少讀數(shù)據(jù)庫,該參數(shù)值越大,讀數(shù)據(jù)庫的次數(shù)越少,速度越快;上面這個配置,是Hibernate是等到程序積累了100個sql之后在批量提交;
(2).關(guān)閉二級緩存(這個博主也不是很明白)
<property name="hibernate.cache.use_second_level_cache">false</property>
除了Session級別的一級緩存,Hibernate還有一個SessionFactory級別的二級緩存,如果啟用了二級緩存,從機制上來說,Hibernate為了維護二級緩存,在批量插入時,hibernate會將對象納入二級緩存,性能上就會有很大損失,也可能引發(fā)異常,因此最好關(guān)閉SessionFactory級別的二級緩存;
(3).在一二設(shè)置完成的基礎(chǔ)上,清空Session級別的一級緩存;
package com.anlw.util; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.Transaction; import org.hibernate.boot.registry.StandardServiceRegistryBuilder; import org.hibernate.cfg.Configuration; import org.hibernate.service.ServiceRegistry; import com.anlw.entity.Student; public class SessionUtil { Configuration conf = null; ServiceRegistry st = null; SessionFactory sf = null; Session sess = null; Transaction tx = null; public void HIbernateTest() { conf = new Configuration().configure(); st = new StandardServiceRegistryBuilder().applySettings(conf.getProperties()).build(); sf = conf.buildSessionFactory(st); try { sess = sf.openSession(); tx = sess.beginTransaction(); for (int i = 0; i < 10; i++) { Student s = new Student(); s.setAge(i + 1); s.setName("test"); sess.save(s); if(i%100 == 0){ //以每100個數(shù)據(jù)作為一個處理單元 sess.flush(); //保持與數(shù)據(jù)庫數(shù)據(jù)的同步 sess.clear(); //清楚Session級別的一級緩存的全部數(shù)據(jù),及時釋放占用的內(nèi)存 } } tx.commit(); } catch (Exception e) { if (tx != null) { tx.rollback(); } } finally { sess.close(); sf.close(); } } public static void main(String[] args) { new SessionUtil().HIbernateTest(); } }
2. 繞過Hibernate,直接調(diào)用JDBC API
package com.anlw.util; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.Transaction; import org.hibernate.boot.registry.StandardServiceRegistryBuilder; import org.hibernate.cfg.Configuration; import org.hibernate.jdbc.Work; import org.hibernate.service.ServiceRegistry; public class SessionUtil { Configuration conf = null; ServiceRegistry st = null; SessionFactory sf = null; Session sess = null; Transaction tx = null; public void HIbernateTest() { conf = new Configuration().configure(); st = new StandardServiceRegistryBuilder().applySettings(conf.getProperties()).build(); sf = conf.buildSessionFactory(st); try { sess = sf.openSession(); tx = sess.beginTransaction(); //執(zhí)行Work對象指定的操作,即調(diào)用Work對象的execute()方法 //Session會把當前使用的數(shù)據(jù)庫連接傳給execute()方法 sess.doWork(new Work() { @Override public void execute(Connection arg0) throws SQLException {//需要注意的是,不需要調(diào)用close()方法關(guān)閉這個連接 //通過JDBC API執(zhí)行用于批量插入的sql語句 String sql = "insert into student(name,age) values(?,?)"; PreparedStatement ps = arg0.prepareStatement(sql); for(int i=0;i<10;i++){ ps.setString(1, "kobe"); ps.setInt(2,12); ps.addBatch(); } ps.executeBatch(); } }); tx.commit(); } catch (Exception e) { if (tx != null) { tx.rollback(); } } finally { sess.close(); sf.close(); } } public static void main(String[] args) { new SessionUtil().HIbernateTest(); } }
注意:通過JDBC API中的PreparedStatement接口來執(zhí)行sql語句,sql語句涉及到的數(shù)據(jù)不會被加載到Session的緩存中,因此不會占用內(nèi)存空間,因此直接調(diào)用JDBC API批量化插入的效率要高于Hibernate緩存的批量插入;
更新&&刪除
語法格式:(HQL)
update | delete from? <ClassName> [where where_conditions]
1>在from子句中,from關(guān)鍵字是可選的,即完全可以不寫from關(guān)鍵字
2>在from子句中,只能有一個類名,可以在該類名后指定別名
3>不能在批量HQL語句中使用連接,顯示或者隱式的都不行,但可以在where子句中使用子查詢
4>整個where子句是可選的,where子句的語法sql語句中where子句的語法完全相同
5>Query.executeUpdate()方法返回一個整型值,該值是受此操作影響的記錄數(shù)量,由于hibernate的底層操作實際上是由JDBC完成的,因此,如果有批量update或delete操作被轉(zhuǎn)換成多條update或delete語句,(關(guān)聯(lián)或者繼承映射),該方法只能返回最后一條sql語句影響的記錄行數(shù),不是所有的記錄行數(shù),需要注意;
二、批量更新(兩種方式)
1. 使用Hibernate直接進行批量更新
(1)方式1:(Hibernate的HQL直接支持update/delete的批量更新語法)
package com.anlw.util; import org.hibernate.Query; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.Transaction; import org.hibernate.boot.registry.StandardServiceRegistryBuilder; import org.hibernate.cfg.Configuration; import org.hibernate.service.ServiceRegistry; public class SessionUtil { Configuration conf = null; ServiceRegistry st = null; SessionFactory sf = null; Session sess = null; Transaction tx = null; public void HIbernateTest() { conf = new Configuration().configure(); st = new StandardServiceRegistryBuilder().applySettings(conf.getProperties()).build(); sf = conf.buildSessionFactory(st); try { sess = sf.openSession(); tx = sess.beginTransaction(); //在HQL查詢中使用update進行批量更新,下面的的語句是HQL語句,不是sql語句 Query query = sess.createQuery("update Student set name = 'www'"); query.executeUpdate(); tx.commit(); } catch (Exception e) { if (tx != null) { tx.rollback(); } } finally { sess.close(); sf.close(); } } public static void main(String[] args) { new SessionUtil().HIbernateTest(); } }
(2)方式2:(強烈不推薦)
package com.anlw.util; import java.sql.Connection; import java.sql.SQLException; import java.sql.Statement; import org.hibernate.CacheMode; import org.hibernate.Query; import org.hibernate.ScrollMode; import org.hibernate.ScrollableResults; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.Transaction; import org.hibernate.boot.registry.StandardServiceRegistryBuilder; import org.hibernate.cfg.Configuration; import org.hibernate.jdbc.Work; import org.hibernate.service.ServiceRegistry; import com.anlw.entity.Student; public class SessionUtil { Configuration conf = null; ServiceRegistry st = null; SessionFactory sf = null; Session sess = null; Transaction tx = null; public void HIbernateTest() { conf = new Configuration().configure(); st = new StandardServiceRegistryBuilder().applySettings(conf.getProperties()).build(); sf = conf.buildSessionFactory(st); try { sess = sf.openSession(); tx = sess.beginTransaction(); //查詢表中的所有數(shù)據(jù) ScrollableResults student = sess.createQuery("from Student") .setCacheMode(CacheMode.IGNORE) .scroll(ScrollMode.FORWARD_ONLY); int count = 0; while(student.next()){ Student s = (Student)student.get(0); s.setName("haha"); if(++count%3 == 0){ sess.flush(); sess.clear(); } } tx.commit(); } catch (Exception e) { if (tx != null) { tx.rollback(); } } finally { sess.close(); sf.close(); } } public static void main(String[] args) { new SessionUtil().HIbernateTest(); } }
通過這種方式,雖然可以執(zhí)行批量更新,但效果非常不好,執(zhí)行效率不高,需要先執(zhí)行數(shù)據(jù)查詢,然后再執(zhí)行數(shù)據(jù)更新,而且這種更新將是逐行更新,即每更新一行記錄,都要執(zhí)行一條update語句,性能非常低;
2. 繞過Hibernate,調(diào)用JDBC API
(1)方式1:
package com.anlw.util; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; import java.sql.Statement; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.Transaction; import org.hibernate.boot.registry.StandardServiceRegistryBuilder; import org.hibernate.cfg.Configuration; import org.hibernate.jdbc.Work; import org.hibernate.service.ServiceRegistry; public class SessionUtil { Configuration conf = null; ServiceRegistry st = null; SessionFactory sf = null; Session sess = null; Transaction tx = null; public void HIbernateTest() { conf = new Configuration().configure(); st = new StandardServiceRegistryBuilder().applySettings(conf.getProperties()).build(); sf = conf.buildSessionFactory(st); try { sess = sf.openSession(); tx = sess.beginTransaction(); //執(zhí)行Work對象指定的操作,即調(diào)用Work對象的execute()方法 //Session會把當前使用的數(shù)據(jù)庫連接傳給execute()方法 sess.doWork(new Work() { @Override public void execute(Connection arg0) throws SQLException {//需要注意的是,不需要調(diào)用close()方法關(guān)閉這個連接 String sql = "update student set name = 'oracle'"; //創(chuàng)建一個Satement對象 Statement st = arg0.createStatement(); //調(diào)用JDBC的update進行批量更新 st.executeUpdate(sql); } }); tx.commit(); } catch (Exception e) { if (tx != null) { tx.rollback(); } } finally { sess.close(); sf.close(); } } public static void main(String[] args) { new SessionUtil().HIbernateTest(); } }
(2)方式2:
package com.anlw.util; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; import java.sql.Statement; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.Transaction; import org.hibernate.boot.registry.StandardServiceRegistryBuilder; import org.hibernate.cfg.Configuration; import org.hibernate.jdbc.Work; import org.hibernate.service.ServiceRegistry; public class SessionUtil { Configuration conf = null; ServiceRegistry st = null; SessionFactory sf = null; Session sess = null; Transaction tx = null; public void HIbernateTest() { conf = new Configuration().configure(); st = new StandardServiceRegistryBuilder().applySettings(conf.getProperties()).build(); sf = conf.buildSessionFactory(st); try { sess = sf.openSession(); tx = sess.beginTransaction(); //執(zhí)行Work對象指定的操作,即調(diào)用Work對象的execute()方法 //Session會把當前使用的數(shù)據(jù)庫連接傳給execute()方法 sess.doWork(new Work() { @Override public void execute(Connection arg0) throws SQLException {//需要注意的是,不需要調(diào)用close()方法關(guān)閉這個連接 String sql = "update student set name = ? where name=?"; PreparedStatement ps = arg0.prepareStatement(sql); for(int i=0;i<10;i++){ ps.setString(1,"tom"); ps.setString(2, "oracle"); ps.addBatch(); } ps.executeBatch(); } }); tx.commit(); } catch (Exception e) { if (tx != null) { tx.rollback(); } } finally { sess.close(); sf.close(); } } public static void main(String[] args) { new SessionUtil().HIbernateTest(); } }
三、批量刪除(兩種方式)
1. 使用Hibernate直接進行批量刪除
(1)方式1:(Hibernate的HQL直接支持update/delete的批量更新語法)
package com.anlw.util; import org.hibernate.Query; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.Transaction; import org.hibernate.boot.registry.StandardServiceRegistryBuilder; import org.hibernate.cfg.Configuration; import org.hibernate.service.ServiceRegistry; public class SessionUtil { Configuration conf = null; ServiceRegistry st = null; SessionFactory sf = null; Session sess = null; Transaction tx = null; public void HIbernateTest() { conf = new Configuration().configure(); st = new StandardServiceRegistryBuilder().applySettings(conf.getProperties()).build(); sf = conf.buildSessionFactory(st); try { sess = sf.openSession(); tx = sess.beginTransaction(); //在HQL查詢中使用delete進行批量刪除,下面的的語句是HQL語句,不是sql Query query = sess.createQuery("delete Student");//也可以是delete from,from關(guān)鍵字是可選的,可以不要,加條件的時候可以指定類的別名 query.executeUpdate(); tx.commit(); } catch (Exception e) { if (tx != null) { tx.rollback(); } } finally { sess.close(); sf.close(); } } public static void main(String[] args) { new SessionUtil().HIbernateTest(); } }
(2)方式2:(強烈不推薦)
package com.anlw.util; import java.sql.Connection; import java.sql.SQLException; import java.sql.Statement; import org.hibernate.CacheMode; import org.hibernate.Query; import org.hibernate.ScrollMode; import org.hibernate.ScrollableResults; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.Transaction; import org.hibernate.boot.registry.StandardServiceRegistryBuilder; import org.hibernate.cfg.Configuration; import org.hibernate.jdbc.Work; import org.hibernate.service.ServiceRegistry; import com.anlw.entity.Student; public class SessionUtil { Configuration conf = null; ServiceRegistry st = null; SessionFactory sf = null; Session sess = null; Transaction tx = null; public void HIbernateTest() { conf = new Configuration().configure(); st = new StandardServiceRegistryBuilder().applySettings(conf.getProperties()).build(); sf = conf.buildSessionFactory(st); try { sess = sf.openSession(); tx = sess.beginTransaction(); //查詢表中的所有數(shù)據(jù) ScrollableResults student = sess.createQuery("from Student") .setCacheMode(CacheMode.IGNORE) .scroll(ScrollMode.FORWARD_ONLY); int count = 0; while(student.next()){ Student s = (Student)student.get(0); sess.delete(s); } tx.commit(); } catch (Exception e) { if (tx != null) { tx.rollback(); } } finally { sess.close(); sf.close(); } } public static void main(String[] args) { new SessionUtil().HIbernateTest(); } }
通過這種方式,雖然可以執(zhí)行批量刪除,但效果非常不好,執(zhí)行效率不高,需要先執(zhí)行數(shù)據(jù)查詢,然后再執(zhí)行數(shù)據(jù)刪除,而且這種刪除將是逐行刪除,即每刪除一行記錄,都要執(zhí)行一條delete語句,性能非常低;
2. 繞過Hibernate,調(diào)用JDBC API
(1)方式1:
package com.anlw.util; import java.sql.Connection; import java.sql.SQLException; import java.sql.Statement; import org.hibernate.Query; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.Transaction; import org.hibernate.boot.registry.StandardServiceRegistryBuilder; import org.hibernate.cfg.Configuration; import org.hibernate.jdbc.Work; import org.hibernate.service.ServiceRegistry; import com.anlw.entity.Student; public class SessionUtil { Configuration conf = null; ServiceRegistry st = null; SessionFactory sf = null; Session sess = null; Transaction tx = null; public void HIbernateTest() { conf = new Configuration().configure(); st = new StandardServiceRegistryBuilder().applySettings(conf.getProperties()).build(); sf = conf.buildSessionFactory(st); try { sess = sf.openSession(); tx = sess.beginTransaction(); sess.doWork(new Work() { @Override public void execute(Connection arg0) throws SQLException { String sql = "delete from student where age > 5"; //MySQL中刪除語句不能省略from Statement st = arg0.createStatement(); st.executeUpdate(sql); } }); tx.commit(); } catch (Exception e) { if (tx != null) { tx.rollback(); } } finally { sess.close(); sf.close(); } } public static void main(String[] args) { new SessionUtil().HIbernateTest(); } }
2)方式2:
package com.anlw.util; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; import java.sql.Statement; import org.hibernate.Query; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.Transaction; import org.hibernate.boot.registry.StandardServiceRegistryBuilder; import org.hibernate.cfg.Configuration; import org.hibernate.jdbc.Work; import org.hibernate.service.ServiceRegistry; import com.anlw.entity.Student; public class SessionUtil { Configuration conf = null; ServiceRegistry st = null; SessionFactory sf = null; Session sess = null; Transaction tx = null; public void HIbernateTest() { conf = new Configuration().configure(); st = new StandardServiceRegistryBuilder().applySettings(conf.getProperties()).build(); sf = conf.buildSessionFactory(st); try { sess = sf.openSession(); tx = sess.beginTransaction(); sess.doWork(new Work() { @Override public void execute(Connection arg0) throws SQLException { String sql = "delete from student where age = ?"; //mysql中刪除語句不能省略from PreparedStatement ps = arg0.prepareStatement(sql); for(int i=0;i<10;i++){ if(i%2 == 0){ ps.setInt(1, i); ps.addBatch(); } ps.executeBatch(); } } }); tx.commit(); } catch (Exception e) { if (tx != null) { tx.rollback(); } } finally { sess.close(); sf.close(); } } public static void main(String[] args) { new SessionUtil().HIbernateTest(); } }
感謝各位的閱讀!關(guān)于“Hibernate+JDBC實現(xiàn)批量插入、更新及刪除”這篇文章就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,讓大家可以學(xué)到更多知識,如果覺得文章不錯,可以把它分享出去讓更多的人看到吧!
網(wǎng)頁題目:Hibernate+JDBC實現(xiàn)批量插入、更新及刪除
文章鏈接:http://aaarwkj.com/article8/ijhiop.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站營銷、全網(wǎng)營銷推廣、電子商務(wù)、標簽優(yōu)化、定制網(wǎng)站、靜態(tài)網(wǎng)站
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)