day14--dbutils的使用,事務(wù)處理,多表操作,oracle大數(shù)據(jù)處理

1、dbutils的使用,事務(wù)處理,多表操作,oracle大數(shù)據(jù)處理作者：呂鵬時(shí)間：2011-08-08首先還是簡單的回顧一下昨夭我們講的什么，我們昨天講了數(shù)據(jù)庫連接池，為防止頻繁訪問 數(shù)據(jù)庫而建芷的連接池的實(shí)現(xiàn)有兩種一個(gè)是自定義連接池，使用動(dòng)態(tài)代理方式，另外一個(gè)是 使用DBCRC3P0,Tomcat等服務(wù)器口帯的,都可以實(shí)現(xiàn)連接池 I、午講了動(dòng)編寫口（2的 JDBC框架，簡化了 CRUD操作，為我們今天講這個(gè)DBUtils打下一個(gè)基礎(chǔ)。目錄：一、DBUtils框架的使用1、使用dbutils做增刪改查，批處理以及人文本操作2、使用DBUtils框架管理事務(wù)。（模擬銀行轉(zhuǎn)賬）二、使用JDBC操作多

2、個(gè)表1、一對(duì)多（部門與員工）2、多對(duì)多（學(xué)生和老師 學(xué)生與課程）3、一對(duì)一（人和身份證）三、關(guān)于Oracle數(shù)據(jù)對(duì)于二進(jìn)制數(shù)據(jù)的存?。嬖囶}）一、DBUltk框架的使用jj apidocs2011/8/8 16:29文件夾common dbutils-1.22011/8/8 16:29文件交t I commons-dbutils-1.2.jar2009/3/15 12:04Executable Jar Filecommonsdbirtilsl'jaYadoc,jar2009/3/15 12:05Executable Jar Filecommons-dbutils-1.2-sources

3、 jar2009/3/15 12:05Executable Jar Fileg LICENSE.txt2009/3/15 12:04.NOTICE.txt2009/3/15 12:04文4,RELEASE-NOTES.txt2Q09/3/15 12:04文本文旨1、使用dbutils做增刪改査，批處理以及大文本操作package cn itcast dbutils. demo;import java.io.File;import j ava .10 FilelnputStream;import java.io.FileReader;impert java.util.List;import ja

4、vax sql rowset senal SenalBlob;import javax sql.rowset.senal.SenalClob;import org apache coninions.dbutils QueiyRumier;import org apache commons.dbutils handlers BeanHandler;import mons.dbutils handlers.BeaiiListHaiidler; Import org.jumt.BefbreClass;import orgjumt.Test;import cn. itcast. dbutil. JDB

5、CU tils;/*使用dbutils做增刪改杳批處理大文本操作* (author 呂鵬* public class DemoO 1 /"創(chuàng)建demo表+| Field | Type| Null | Key | Default | Extra | "4*|id | mt(ll) I YES I I NULL |I name | varchar(lO) | YES | NULL |+/static QuetyRuiiner runner.BefbreClasspublic static void befbreClass()獲取一個(gè)QueryRiumer對(duì)象(構(gòu)造方法帶數(shù)據(jù)源

6、口動(dòng)完成連接創(chuàng)建和釋放) rufiner= new QueiyRumier(JDBCUtilszZ?/f75<2/r();/*執(zhí)行插入操作/Testpublic void testlnsert()throws Exception!Strmg sql = "insert into demo values(?,?)H; J!, IsqlObject params = 2畀insert”;/初始化參數(shù)/7/7/:update(sql, params);/查詢對(duì)象操作 throws Exception/Testpublic void testObjectQueryO throws Ex

7、ceptionStrmg sql = ”select from demo where id = ?M;Demo demo = (Demo)廠科甲謝予(sg 1、newBeanHandler(DemoSystem /z/.pniitlii(MID:,t+demo.getId()+H Name:H+demo.getName();*執(zhí)行刪除操作 throws Exception/Testpublic void testDelete() throws Exception Stiing sql = Hdelete from demo where id = ?H;刃 update(sql, 1);/*執(zhí)行

8、更新操作 ©throws Exception/Testpublic void testUpdate() throws Exception Strmg sql = "update demo set name=? where id="Object params =update”,】;刃:update(sqL params);*査詢列表操作 throws Exception/Testpublic void testListQueiyO throws Exception String sql = Mselect from demo”；List<Demo> li

9、st =(List vDemo>)q . query (sq LnewBeanListHandler(Demo class)：for(int i=O;i<list. size();i+) System.d?/.pnntln(HID:H+list.get(i).getIdO+H 姓名是:H+list.get(i).getName();/*批處理操作 throws Exception/Testpublic void testBatch() throws Exception Strmg sql = "insert mto demo value (?，？)"；Objec

10、t paiains = new Object10; for(int i=0;i<10;i+)paramsfi = new Objectbatch”;Z7/w/7：batch(sql, paiains);/*人文本操作 throws Exception/Testpublic void testClobO throws ExceptionStrmg sql = "insert mto clob values(?)H;File file = new File(Hc:/a txtH);Long 1 = file.lengthO;char buffer = new a

11、lue();FileReader reader = new FileReader(file); reader read(buffer);SenalClob clob = new SenalClob(buffer);刃:update(sql, clob);/*二進(jìn)制圖像操作 throws Exception/Testpublic void testBlobO throws Exception String sql = "insert into blob values(?)H;File file = new File(Mc:/ajpgH);Long 1 = file.lengtliO；b

12、yte buffer = new bytel int alueO；Fileinputstream input = new hilelnputstream(file); input, read(buffer);Sena IB lob blob = new SenalBlob(buffer); update(sql,blob);以上代碼是使用DButils框架完成的增刪改差批處理以及大文本操作，其中，使用了 QueryRiumer這個(gè)類，這個(gè)類是專門負(fù)責(zé)處理sql語句的，有四個(gè)構(gòu)造方法，我們經(jīng)常使用 到的是一個(gè)無參的構(gòu)造方法和一個(gè)有參的，參數(shù)就是數(shù)據(jù)源，當(dāng)我們給其提供數(shù)據(jù)源的時(shí)候 就是讓框架為我們

13、口動(dòng)的創(chuàng)建數(shù)據(jù)庫連接，并釋放連接，當(dāng)這是處理一般操作的時(shí)候，當(dāng)我 們要進(jìn)行事務(wù)處理的時(shí)候，那么連接的釋放就要由我們口己來決定了，所以我們就不再使用 帶參數(shù)的QueryRuimer構(gòu)造方法了。具體用法下面詳解。2、使用DBUtils框架管理事務(wù)。剛才我們的增刪改差是為了演示我們的例子，所以我們忽略了異常也沒有使用事務(wù)，現(xiàn)在我 們使用爭務(wù)模擬一個(gè)銀行轉(zhuǎn)賬，看一下DBUtils框架是如何幫助我們完成爭務(wù)管理的。在講解事務(wù)之前，需要讓大家理解一件爭情就是，我們使用弔務(wù)就不能使用其QueryRimner 的有參構(gòu)造方法I大1為我們要自己定義爭務(wù)的開關(guān)，如果使用帶參數(shù)的構(gòu)造就要讓框架幫 助我們關(guān)閉數(shù)據(jù)庫連

14、接了，所以這里首先人家要明白.那么我們?nèi)绾螌⑽覀兊倪B接傳遞給持 久層呢，有同學(xué)說使用構(gòu)造方法，是挺好的，通過構(gòu)造方法將我們的conn傳遞給持久層， 但是為了降低耦合度，我們不想在業(yè)務(wù)層出現(xiàn)持久層的代碼，那我們就使用一個(gè)類幫助我們 把這個(gè)連接傳遞過去，就相當(dāng)于使用匸廠幫我們生成持久層對(duì)彖一樣，那我們使用什么類呢， 我們使用ThreadLoacl這個(gè)類關(guān)于TlireadLocal這個(gè)類，可以查閱幫助文檔了解，在這里我簡單的說明一下它的作用， 它的作用是在一個(gè)線程當(dāng)中記錄我們的變龜，這個(gè)變鼠可以是任意變晟，包括我們的連接， 就是說我們生成一個(gè)連接以后可以放在這個(gè)線程中，這樣，只要是這個(gè)線程中任何對(duì)象

15、都町 以共享這個(gè)連接，當(dāng)這個(gè)線程結(jié)束以后，線程要?jiǎng)h除這個(gè)連接。具體使用方法：聲明線程共享變量public static TlireadLocal<Connection> container = new TlireadLocal<Conuection>();獲取共享變量public static ThreadLocal<Coiinection> getContainerOreturn cont(iuiet這樣，那么我們就可以幫有關(guān)審務(wù)的操作，這些操作原本應(yīng)該在業(yè)務(wù)層出現(xiàn)的代碼，現(xiàn) 在我們都把它放在工具類中，因?yàn)椴还苁鞘聞?wù)開啟還是事務(wù)提交，回滾，都是利連接關(guān)聯(lián)的

16、.我們把連接放在了這個(gè)共享的線程當(dāng)中，那么其方法也是共享的：工其類如下：package cn.itcast.dbutil;import j ava sql Comiection;Import java.sql.SQLException;Import javax.sql DataSoiirce;import com.mchaiige.v2c3pO.ComboPooledDataSource,public class JDBCUtils c3pO連接池public static ComboPooledDataSomce ds= new ComboPooledDataSource();聲明線程共享變

17、量public static ThreadLocal<Coiinection> con tain er- new TlireadLocal<Comiection>();/獲取共享變量public static TlireadLocal<Coiinection> getContainerOreturn container.*獲取數(shù)據(jù)源/public static DataSource getDataSourceOfreturn ds/*茯取當(dāng)前線程上的連接 開啟事務(wù)public static void startTransactionO Connection

18、comi = containerfi 先茯取 j 前'戈 fT 的連接 if(comi = null) /如果連接為空conn = gerCofmecnofiQ 從連接池中獲収連接 cotitmner. set(conn); 7 將此連接丿,？上comi.setAutoComiuit(false); 11: t )； catch (SQLException e) throw new RuntuneException(e.getMessage(),e); /*提交事務(wù)/public static void coinmitO Connection conn = containerJ!從當(dāng)前

19、 I .獲取連接 if (conn != nuD) /如杲連接為字，則不做處理coiin commitO;/. 捉 龍!；并 catch (SQLException e) throw new RuntimeExceptionCe.getMessageO, e);/*回滾事務(wù)/public static void rollback。Connection conn = container.getO； V 化打前錢丘'l. m 1? 丫匚連綏 if(comi != null)try coiin.rollbackO;/ 回滾 M 務(wù)/container.removeO；/如果回滾了，就移除這個(gè)

20、連接 catch (SQLException e) throw new RimtimeException(e.getMessage(),e);/*關(guān)閉連接/public static void close()Connection conn = contmner Q if(conii != null)trycoiin.close(); catch (SQLException e) throw new RmituneException(e.getMessageO,e); finally e加0：remove();從當(dāng)前纟戈程移除連接 切記*獲取數(shù)據(jù)庫連接 return數(shù)據(jù)庫連接 連接方式(連接池

21、錯(cuò)c3pO)/public static Connection getCoiinection() try return .getComiectionO； catch (Exception e) throw new RuntuneException();在這個(gè)工具類里要特別注意，在關(guān)閉連接方法的里面，finally里需要將這個(gè)線程的連接 移除，不然這個(gè)線程的連接得不到釋放。這個(gè)明白了以后再看我們的銀行轉(zhuǎn)賬的模擬程序：首先我們?cè)谀M的DAO中完成査找賬戶和修改賬戶的方法：(1) 査找賬戶和修改賬戶代碼：*模擬DAO查詢賬戶更新賬戶* ©author 呂鵬*/class AccouiitD

22、AO 聲明連接private Connection conn;public AccountDAO() this.conn = JDBCUtils.g刃6加0().getO;/,線 共'? X>j 象獲収連接/*8*根據(jù)ID資找賬戶/public Account findAccount(int id) 處理事務(wù),無參構(gòu)造Query Runner nrnner = new QueryRuiiner();Strmg sql = "select * from account where id=?H;Object params=id;try 附加連接 處理者為BeanHandle

23、rreturn (Account) ruimer.qtt«=y(conih sql, params, newBeanHandler(Account daw)： cateh (Exception e) System.(2/.pnntln(HeeeeeeeeeeeeeeeH);throw new RuntuneException(e getMessage(),e);/*更新賬戶 param a/public void updateAccount(Account a)QueiyRumier nurner = new QueryRunner();String sql = "upda

24、te account set money=? where id=?M;Object params = a.getMoneyO,a getld();try rumier.update(comi, sql、params); catch (SQLException e) throw new RuntmieException(e getMessage(),e);(2) 完成業(yè)務(wù)邏輯層的轉(zhuǎn)賬事務(wù)class AccountSerxice /*r*轉(zhuǎn)賬方法 param fromlD 原始賬戶 param toID 目標(biāo)賬戶 param money轉(zhuǎn)入多少錢/public void tiafferAccoun

25、t(lnt fiomID,int toID,float money)tryJDBCUtils jTW"刀 丿 I 丿匸'K 務(wù)AccountDAO dao = Factory疥Z屜伽rcO.getAccountDAOO;/注意這彳亍代碼一定要放在開啟事務(wù)之后，連接才會(huì)被創(chuàng)建Account from = dao. findAccount(fioinlD);Account to = dao findAccount(tolD);from setMoney(from.getNIoney()-money); to.setMoney(to.getMoiiey()靜態(tài)工廠獲取操作對(duì)象* a

26、uthor 3 鵬*/class Factory 私有靜態(tài)工廠實(shí)例private static Factory itistance - null:私有構(gòu)造private FactoryO /*提供一個(gè)靜態(tài)公共方法獲取工廠實(shí)例 retum/public static Factoiy getlnstance() if instance null) synchronized (Factory class) If ltisfance null) instance = new FactoryO;moiiey);dao.update Accoiuit(from);dao.updateAccoimt(to)

27、;JDBCUtils e加O 捉交事務(wù)System out. printing 轉(zhuǎn) 賬成功”)； catch (Exception e) System.67/.pnntlnC* 轉(zhuǎn)賬失敗”)；JDBCUtils.rollbacki >1 滾'"務(wù)throw new RuntuneException();finaUyJDBCUtils.r/jO;被標(biāo)注紅色的代碼要注意，其重點(diǎn)不只是工廠模式的使用，更重要的一點(diǎn)要明白，我們的持 久層的連接是在其構(gòu)造方法中獲取的，如果我們把這個(gè)代碼放在前面的話，就提前構(gòu)造了其 對(duì)象，但是我們的連接卻是在半務(wù)開啟的時(shí)候才創(chuàng)建的，如此我們的連接就

28、無法傳遞到持久 層當(dāng)中了。所以這段代碼要放在之后。待我們的連接被放置在當(dāng)前線程以后再去調(diào)用工廠構(gòu) 造我們的對(duì)象。(3) 靜態(tài)工廠獲取實(shí)例return uistance./*獲取操作對(duì)象簡化代碼不讀配置文件了* return/public AccountDAO getAccouutDAO() return new AccountDAOO；public AccountSemce getAccountSenrice() return new AccouiitSeiviceO；(4)測(cè)試類：*轉(zhuǎn)賬測(cè)試類* anthor i_i 鵬*/public class Test public static vo

29、id mam(Stniig aigs) 使用工廠模式生成業(yè)務(wù)層對(duì)象AccountSen ice semce = Factory.77加7?zr0 getAccoimtService(); 調(diào)用業(yè)務(wù)層的方法從1號(hào)賬戶轉(zhuǎn)賬100到2號(hào)賬戶 semce.trafferAccoiuit( 1, 2, 100);效果:mysql> select from account;+| id I name money |I1 I tom I 30011 2|cc I 1700|2 rows m set (0.00 sec)轉(zhuǎn)賬成功。從這個(gè)模擬的銀行轉(zhuǎn)賬我們學(xué)到了 ：(1)在業(yè)務(wù)層完成事務(wù)的處理，持久層只負(fù)責(zé)

30、操作數(shù)據(jù)庫(1) DBUtils對(duì)事務(wù)的操作流程(2) 使用ThreadLoacl共享單線程信息二、使用JDBC操作多個(gè)表學(xué)習(xí)使用JDBC操作多個(gè)表是學(xué)習(xí)Hibernate的基礎(chǔ)，掌握了 JDBC對(duì)多表的操作其實(shí)就是 在學(xué)習(xí)Hibernate實(shí)現(xiàn)多表操作的底層原理。下面我們來看一下，使用JDBC如何完成對(duì)多 表的操作，學(xué)習(xí)多表操作之前我們需要明白什么叫多表操作：多表操作其實(shí)就是對(duì)多個(gè)對(duì)象的關(guān)系的操作，如果對(duì)帶仃關(guān)系的對(duì)象進(jìn)行數(shù)據(jù)庫操作就是 對(duì)操作操作。那對(duì)象和對(duì)象之間又有什么關(guān)系呢？(1) 一對(duì)多(2) 多對(duì)多一對(duì)一O O O O1、一對(duì)多關(guān)系操作我們舉部門和員工的例子，部門和員工就是典型的一

31、對(duì)多的范例，那么我們?nèi)绾蚊枋鏊麄冎?前的關(guān)系呢？要使用到外鍵，首先我們來看他們的表如何設(shè)計(jì)：package cn.itcast dao;import java.util. Set;import org. apache .commons dbutils. QueiyRumier;import nions.dbutils handlers.BeaiiHandler;import org mons.dbutils handlers BeanListHandler;Impert cn.itcast.dbutils.JDBCUtils;import cn. itcast.domain Departmen

32、t;import cn. itcast. domain Employee;pubtic class DepeitinentDAO /*增加一個(gè)部門同時(shí)増加其員工 param depart/public void addDepai1meiit(Depaitment depart) tryQueryRunner mn = new QuetyRunner( JDBCUtils getDafaSourci)Stnng sql = "insert mto department value(?,?,?)H;Object params = 1/開發(fā)部" nin.update(sql, p

33、aiains); 執(zhí)行插入一個(gè)部門Set<Employee> eins = depait. getEmployeesO；7 血詢；t :部 Xj 繚:rj 員 1* 集介for(Employee e : ems)Stiing sql2 = Minsert into employee value(?,?,?) where departed = ?”； Object params? = e.getld(),e getName(),e.getMoneyO,depart getld(); iiui.update(sql2, paiams2); /執(zhí)行插入女個(gè)員 Lcatch(Excepti

34、on e)throw new RuntnneException();*査詢一個(gè)部門.同時(shí)資詢其部門下的員工public Department fiiidDepartment(int id)Department depart = null;try首先查詢部門QueryRunner runner = new QueryRunner(JDBCUtils.gw/Z>"/5b/5f4)；Stnng sql = "select * fi om department where id = ?”；depart = (Department) runnerid、new EeanHandl

35、er(Departnieiit da翦);根據(jù)部門的ID也就是員工的外鍵查詢員工集合 設(shè)置到depart的屬性當(dāng)中去 Stnng sql2 = "select from employee where departed = ?H;Set<Employee> emps = (SetvEmployee>) runner 申tefy(sql2、id, newBeanListHandlerCEmplovee class)：depart.setEmployees(emps); catch (Exception e) throw new RuntnneException(e ge

36、tMessage(),e);return depart;2、多對(duì)多的關(guān)系多對(duì)多足比牧復(fù)雜的，在數(shù)據(jù)庫中我們需要三張表米維護(hù)他們的關(guān)系，一張中間表，但實(shí)體 對(duì)彖只有兩個(gè)，拿學(xué)生和課程來講，一個(gè)學(xué)生可以選擇務(wù)門課程而，而一個(gè)課程又可以彼多 個(gè)學(xué)生選擇，如果維護(hù)他們的關(guān)系呢，我們看例子: package cn.itcast.dao;import j ava.util. Set;impert moiis.dbutils.QueiyRuniier;impert mons.dbutils handlers.BeaiiHandler;impert org mons.dbutils handlers Bean

37、ListHandler;import cn.itcast.dbutils.JDBCUtils;import cn.itcast.domam Cowse;impert cn. itcast. domain Strident;public class StudentDAO *添加一個(gè)學(xué)生，同時(shí)添加其選課課程/public void addStudent(Student student) tryQueryRuiiner mn = new Quer)rRunner( JDBCUtils getDataSourc) String sqll = Minsert into student values(?,

38、?)H;Object params fl = student.getId(),stiident.getNameO；Set<Coiirse> courses = student.getCoiirses();for(Course c : courses"Stiing sql2=Hinsert into couise values(?,?)H;Object params2 = c.getId(),c.getName();nm update(sql2, params2);Stiing sql3=Hinsert into shident_course value(?,?)tf;Ob

39、ject params3=student getldO,c.getld(); iTui.update(sql3, paiains3);catch(Exception e)throw new RuntnneException(e getMessage(),e);/*査詢一個(gè)學(xué)生，同時(shí)將其選課信息査詢出來*/public Student findSUident(int id)Student student = null;try QueryRunner ninner = new QueryRunner(JDECUtils.gwzQ"A75切"()；Stnng sql = &quo

40、t;select * from student where id = ?M;student = (Student) iTmner.quefy(sqL id, new BeanHandler(Student class);/這句話什么意思呢？就是說我們要査詢學(xué)生的課程，要保證兩個(gè)條件(1)保證學(xué)生的id和中間表中的學(xué)生m是一樣的才能保證你要找的是這個(gè)學(xué) 生(2)保證課程的ID和中間表中的課程ID是一樣的才能保證你要找的是這些課 程兩者缺一不可，只有同時(shí)保證這個(gè)兩個(gè)條件才能確認(rèn)這些課程就是這個(gè)學(xué)生 的。Stnng sql2 = "select fiom shident_course sc

41、,course c where sc.sid=? and sc.cid= c.id”;Set<Coiirse> courses = (SetvCourse>) runner.e«eF¥(sal2, id, new BeanListHandler(Course.d>,$)：stiident.setCourses(courses); catch (Exception e) throw new RimtiineException(e.getMessaeeO,e);return student;(3) 對(duì)一的關(guān)系身份證和人的關(guān)系不就是一對(duì)一嗎？ packag

42、e cn itcast dao;import org. apache.conimons. dbutils. QueiyRumier;import org apache, conunons. dbutils handlers. BeaiiHandler;import cn.itcast.dbutils.JDBCUtils;import cn.itcast.domam Card;import cn. itcast. domam Person;public class PersonDAO /*增加一個(gè)人，同時(shí)増加一個(gè)身份證號(hào)碼 param person/public void addPerson(P

43、ei-son person) tryQueryRminer 11m = new QueryrRumier( JDB CUt 1 Is getDaraSourc);Stnng sqll = "insert into person values(?,?)M;Object paiains = persoiLgetId()：person.getName(); nin.updateCsqll, params);Card card = person.getCard();Stnng sql2 = "insert into card values(?,?)M,Objectf params2

44、 = card getIdO,card.getCard_idO； run update(sql2, params2); catch(Exception e)throw new RuntuneException(e.getMessage(),e);/*查詢一個(gè)人，同時(shí)査詢這個(gè)人的身份證號(hào)碼/public Person findPerson(int id)Person person = null,try QueryRunner ninner = new QueryRimner(JDBCUtils.gwzU7/N5切 “()； Stnng sql = "select * from pers

45、on where id = ?M;person = (Person) runner.QueFy(scil, id： new BeanHandlei(Persoii«l>w)：String sql2 = "select from card where person_id = ?”；Card card = (Card) runner.<ftieF¥(sql2, kL newBeanHaiidleifCardclass);person setCard(card); cateh (Exception e) throw new RuntHiieException

46、(e.getMessage(),e);return person;注意事項(xiàng)：不管的對(duì)象存在何種關(guān)系，反映到關(guān)系型數(shù)據(jù)庫中，都是使用外鍵表示紀(jì)錄（即對(duì)象） 的關(guān)聯(lián)關(guān)系。設(shè)計(jì)4"對(duì)象如涉及到多個(gè)對(duì)象相互引用，要盡量避免使用一對(duì)多，或多對(duì)多關(guān)系，而應(yīng) 使用多對(duì)一描述對(duì)象之間的關(guān)系（或使用延遲加載的方式人三.Oracle中大數(shù)據(jù)的處理注意：面試題.如何在Oracle數(shù)據(jù)庫中保存圖片（二進(jìn)制數(shù)據(jù)）?Oracle定義了一個(gè)BLOB字段用于保存二進(jìn)制數(shù)據(jù)，但這個(gè)字段并不能存放真正的二進(jìn)制 數(shù)據(jù)，只能向這個(gè)字段存一個(gè)指針，然后把數(shù)據(jù)放到指針?biāo)赶虻腛racle的LOB段中， LOB段是在數(shù)據(jù)庫內(nèi)部表

47、的一部分。因而在操作O“cle的Blob之前，必須獲得指針(定位器才能進(jìn)行Blob數(shù)據(jù)的讀取和寫 入.如何獲得表中的Blob指針呢？可以先使用insert語句向表中插入一個(gè)空的blob (調(diào)用 orade的函數(shù)empty blobO )»這將創(chuàng)建一個(gè)blob的指針，然后再把這個(gè)empty的blob 的指針查詢出來，這樣就可得到BLOB對(duì)象，從而讀寫blob數(shù)據(jù)了。1、插入空blobinsert into test(id4nuige) values(?>empty_blobO)；2、獲得 blob 的 cursorselect image from test where ld=

48、? for update;Blob b = rs.getBlob( "image");注意：須加for update,鎖定該行，直至該行被修改完畢，保證不產(chǎn)生并發(fā)沖突。3、利用io,和獲取到的cursoi往數(shù)據(jù)庫讀寫數(shù)據(jù)注意：以上操作需開啟事務(wù).package cn.itcast.oracle;import java.io File;import j a va. io. F llelnputS tream,import j a va. io. F lleOutputS tream;import j ava.io IiiputStream;import j ava io Outputstream;Import j ava. sql. Connection;import j ava. sql Dn verN lanager;import j ava. sql PreparedStatement;import j ava .sql Result Set;impert java.sql.Statement;import org.junit.Test;Impert oracle.sql BLOB;public class TestOracleBLOB 將圖片存入Oracle數(shù)據(jù)庫 Testpublic void