JDBC讲课流程.docx
《JDBC讲课流程.docx》由会员分享，可在线阅读，更多相关《JDBC讲课流程.docx（66页珍藏版）》请在冰点文库上搜索。
JDBC讲课流程
ＪDBC讲课流程
第一课ﻬJDBC概述和基本数据库操作
JDBＣ（jaｖadaｔaｂａse cｏｎnectiｖｉty）用于在java程序中实现数据库操作的数据库编程接口,支持基本的SＱＬ语句，为应用程序和数据库之间提供了桥梁
java程序和数据库之间的关系如下图：
JDBC的版本：
JDK1.4,1.5对应ＪDBC３.0
JDK1.6对应ＪＤBC4.0
介绍jａｖa中和操作数据库相关的APＩ,解释这些API都是未实现的,真正实现操作的是数据库厂家提供的类库，例如ｏｒacle提供的claｓsｅs１２.jaｒ,sｑlseｒver提供的ｍｓsqlsｅrver.jaｒ等。
将oracle安装文件下的cｌａｓses１2.jａr文件构建到myeclｉpｓe开发工具下。
开始数据库编程：
（别忘先导入包）
第一步加载数据库驱动程序
Class.forNａｍe（＂oｒacle.jdbｃ.ｄrｉｖer．ＯraｃleＤriver"）;这是利用反射注册一个数据库驱动
或者用驱动管理器也可以注册数据库驱动
ＤｒiveｒMａnaｇeｒ.regｉsteｒDｒiver（newｏracle.jｄbｃ.ｄrｉｖｅｒ.ＯｒaclｅＤrｉveｒ（））；
第二步创建数据库连接对象
Strinｇurl＝"ｊdｂc：
oraｃle:
tｈｉn:
＠12７.0．0.１:
１521:
ｄhc";
Ｓtrｉnguseｒ="scｏｔt"；
Ｓｔriｎｇｐｗd= "tｉger";
Conｎｅctionconn=ＤriverManageｒ.ｇeｔＣoｎnecｔion（uｒl,ｕseｒ，ｐｗd）；
其中dhc表示的是数据库名或域名而并非是服务名
DriverＭａnagｅｒ类存有已注册的 Dｒｉver类的清单。
当调用方法ｇeｔCｏｎnｅｃｔiｏｎ时，它将检查清单中的每个驱动程序,直到找到可与URＬ中指定的数据库进行连接的驱动程序为止。
如果改成用OCＩ形式连接，url字符串改为类似以下语句:
Ｓtｒinｇurl="jdｂc:
ｏrａｃle:
oci８:
sｃoｔt/tiｇeｒ＠dhc"；
或者
Stringuｒl ＝＂ｊｄbｃ:
oracｌe:
oci:
sｃott/tｉger@ｄhc";
第三步创建ＳQL语句载体对象
Stａtemenｔｓtmｔ =conn.creatｅStatement（）;
第四步执行SQL语句返回结果集对象
ResulｔSetｒｓ= stmt.ｅｘecuteQuery（"seleｃt*fｒomemployｅes＂）；
第五步遍历结果集返回数据
while（rs.neｘt（））{
System.ouｔ.printｌｎ（"编号：
" + rs.ｇeｔInｔ
（1）＋ "\t姓名:
＂+ ｒｓ.gｅｔSｔriｎg（３））;
}
在这一步讲解结果集指针的概念,默认状态下游标只能向下移动
需要注意ｇｅｔXXX方法的数据类型要和表中字段的数据类型兼容。
讲解gｅtXXX（）括号中的参数既可以是列索引，也可以是列名，如果使用列名并且结果集中有多个列的名字是相同的，那么返回第一列的的列值,一般用列索引效率会高一些
介绍rs.wasNｕlｌ方法，当前最后一次getXXX（）返回的列值是否为nulｌ,需要注意的是如果get方法以数字的形式获取列值且返回的列值为null,得到的结果会自动的转换为0或0.0
别忘记在下面介绍java的数据类型和SQＬ的数据类型之间的映射关系
第六步关闭对象释放资源
采取逆向关闭对象的顺序
rｓ．ｃlosｅ（）;
stmt.cｌｏｓe（）；
ｃonｎ.close（）；
在关闭sｔmt对象或利用sｔmt对象重新执行其他SQL语句时时会自动关闭rs对象。
解讲数据类型之间的映射关系
SQL类型
JＡVA类型
CHAＲ
Ｓtring
REAL
Fｌｏａt
ＤATALＩNK
java．neｔ.UＲＬ
REF
Ref
ＳTＲUCＴ
Ｓtrucｔ
DISTINCＴ
Ｍａppｉnｇｏfｕｎｄerlyｉnｇｔｙpe
ARRAＹ
Aｒray
BLOB
Bloｂ
ＣLＯB
Clｏb
ＴIMＥＳTAMP
javａ.ｓｑl.Tiｍeｓtamp
TIME
java.ｓｑｌ.Tｉme
DATE
java.ｓqｌ．Date
LONGVAＲＢINARY
byte［]
VＡRBINARY
bytｅ[]
BIＮAＲY
byｔe[]
DＯUBＬE
dｏubｌｅ
ＦLOAT
ｄoublｅ
VＡＲCHＡＲ
Sｔｒｉng
ＬONGＶARCHＡＲ
Sｔｒing
以上操作的完整代码：
iｍporｔjａva.sql.＊;
publicclass JDBC1{
pｕbｌicsｔatiｃvoiｄmａｉn（String[］aｒgｓ）throwｓSQLEｘceptiｏn{
／/注册数据库驱动程序
ﻩＤriveｒＭａnａgｅr.ｒｅgｉｓtｅｒDrｉver（ｎeｗoraclｅ.jdｂｃ.dｒivｅr．OrａｃleDrｉver（））;
//创建数据库连接对象
String url= ＂ｊdbc:
oracｌe:
tｈin:
@127.0.０．1：
1521:
dhc";
ﻩＳtｒｉnguser = "sｃott"；
ﻩＳtｒinｇpｗd="tiger";
Coｎnecｔionｃonn ＝DrｉverMａnageｒ.geｔCｏnnection（ｕrｌ, useｒ,pwd）;
/／创建SQＬ语句载体对象
Staｔeｍentstmt＝ｃｏｎn.crｅaｔeStatｅｍent（）;
ﻩﻩ//返回结果集对象
ﻩResｕｌｔSetｒs=stmt.ｅxeｃutｅQuery（"sｅlecｔ*froｍｅｍployees＂）；
ﻩ／／遍历结果集返回数据
ﻩwhile（ｒｓ.ｎｅxｔ（））{
ﻩﻩSysteｍ．out.prｉntlｎ（＂编号：
"+ ｒs.getＩnt
（1）＋ "＼ｔ姓名：
＂+rs.gｅtString（3））；
}
ﻩﻩ//关闭对象
ﻩrs．ｃloｓｅ（）;
ﻩstmt.cloｓe（）;
ﻩｃonn.close（）;
}
}
经过优化的代码：
imｐｏrｔjava.sqｌ．*;
pubｌiｃｃlasｓＪＤBC１｛
ﻩpuｂｌicｓtaticｖoidmain（Ｓtring[］ ａrgs）{
Coｎnecｔｉonconn＝ null;
ﻩStatementsｔmt＝ null;
ﻩﻩRｅsｕltSｅｔｒs=ｎull;
ﻩﻩtry｛
ﻩﻩﻩ／/ 注册数据库驱动程序
ﻩDriｖeｒManagｅｒ.ｒｅgisterDｒiver（newｏracle．jdbｃ.drｉｖer.OraclｅDriveｒ（））;
／／创建数据库连接对象
ﻩﻩStｒing urｌ =＂jｄbc:
oracｌe:
thin：
@1２7.０．0.1:
１５21:
ｄhc";
ﻩStrinｇｕser =＂scott";
ﻩＳｔrｉng pwd ＝"tiger";
ﻩﻩconn= DrｉveｒMａnaｇeｒ.ｇetCoｎnectiｏn（url, ｕser,pwd）;
ﻩﻩﻩ//创建SQL语句载体对象
ﻩﻩｓtmｔ=conｎ.ｃｒeatｅStateｍent（）；
ﻩﻩ//返回结果集对象
ﻩﻩrs = stｍt.eｘecuｔｅQueｒｙ（"sｅleｃt ＊ ｆrｏmemploｙees"）;
ﻩﻩ//遍历结果集返回数据
ﻩﻩwｈile （ｒs．nｅxt（）） ｛
ﻩﻩＳystｅm.out．prｉntln（＂编号:
＂+rs.getInt（１）+＂＼t姓名：
＂
ﻩﻩ+rs.geｔStrｉｎｇ（３））;
｝
ﻩ} catch（SQLＥxceptioｎe）{
e.printStaｃkTrａcｅ（）;
} finallｙ{
ﻩﻩﻩtrｙ｛
ﻩ//关闭对象
ﻩﻩif （rｓ!
=ｎull）
ﻩﻩrs.close（）;
ﻩﻩﻩif（stmt！
=null）
ﻩﻩﻩﻩｓｔmt.clｏｓe（）;
ﻩif（conn!
=nuｌl）
ﻩﻩﻩﻩｃonn.close（）;
ﻩ}catch（SＱＬＥxcｅpｔione）{
ﻩe.ｐrinｔＳtacｋTracｅ（）;
ﻩﻩ}
ﻩﻩ｝
ﻩ}
}
练习:
查询ｄepartments表中的５0～１90号部门信息（部门编号，部门名称,部门管理者姓名，部门所在城市）
impoｒｔjaｖa.sｑl.＊；
publｉcclasｓTesｔ6{
pｕbliｃstａtｉｃvoｉdmain（Strinｇ[]argｓ）｛
ﻩCoｎｎectioｎ conn=null;
ﻩﻩStateｍｅntstｍt=nuｌｌ;
ﻩＲｅｓｕｌtSet rs= null；
ﻩﻩtｒｙ｛
ＤriｖerＭａnageｒ.rｅgisterDｒiver（neworacle.jdｂc.driveｒ．OｒacleDriｖer（））;
ﻩＳｔringｕrｌ＝"jdbc:
ｏracｌe:
thin：
@loｃalhosｔ:
1５21：
ｄhc";
ﻩStrｉｎｇuser=＂scｏtｔ";
ﻩﻩﻩStｒingpwd＝ ＂tｉger";
ﻩﻩconn =DｒivｅrManａger.geｔConnｅctioｎ（ｕrl,user, pwd）;
ﻩﻩstmt=conn.cｒeａteStatｅｍenｔ（）;
ﻩｒs=stmt
ﻩﻩ．exeｃｕteQuｅｒy（"sｅlｅcｔd．deｐaｒtmｅｎt_iｄ,depaｒtmenｔ_name，lａｓｔ_nａmｅ,cｉtｙfrｏmdepartmenｔsd,emploｙeｅse，locations l ｗheｒｅｄ．ｍanager_id＝e.emｐloｙee_id（＋）ａnｄd.loｃaｔｉon＿iｄ=l.loｃatｉon_idａnｄ d.depａｒtment＿ｉｄ beｔweｅn５０anｄ１90ordｅr byd.ｄｅｐartｍｅnｔ＿iｄ"）;
ﻩwhiｌｅ（rｓ.nｅｘt（）） {
ﻩSystem.oｕt.ｐriｎｔｌn（rs.geｔIｎt
（1） +＂"＋rｓ.geｔStrｉng
（2） ＋""
ﻩﻩﻩﻩﻩ+rs．ｇetStrｉｎｇ（３）+ ＂ﻩ＂ + rs.getＳtring（４））；
ﻩ}
ﻩ｝catｃh（SQLEｘcｅpｔioｎ ｅ） {
ﻩe.prｉntStacｋTｒaｃe（）;
ﻩ}finａlly{
ﻩﻩtｒy{
ﻩﻩﻩif（rs!
=null）
ﻩﻩﻩﻩrs.close（）;
ﻩﻩｉf（stmt!
= ｎull）
ﻩﻩﻩﻩｓｔmt.ｃlose（）;
ﻩﻩｉf （cｏｎｎ！
=nulｌ）
ﻩﻩconn.clｏse（）;
}caｔｃh（Eｘｃepｔion e） {
ﻩﻩﻩｅ．prｉnｔStackTrａｃｅ（）;
ﻩﻩﻩ｝
ﻩ}
ﻩ}
}
综合练习:
查询job_hｉstｏry表中所有数据，将数据写入到文本文件中，一条记录一行,列值之间用｜隔开
imｐｏrtｊavａ.ｓｑl.*；
iｍporｔjａva.io.*;
ｐuｂlicｃlaｓsTest７{
ﻩpuｂｌｉcｓｔａticｖoidｍaｉn（Stｒinｇ[] arｇｓ） {
ﻩCｏnｎectｉｏn conn=ｎull;
Stateｍｅｎｔstmt=null;
ﻩﻩＲesultＳｅtrs= null;
ﻩ fw=ｎull;
ﻩﻩBufferedＷriｔer bw=nｕll;
trｙ｛
ﻩDriｖerManagｅr.rｅgiｓｔｅrDrｉver（nｅworａclｅ．jdbc．drｉver.ＯracｌeDriｖer（））；
ﻩﻩStｒing uｒl="jdbc:
orａcｌe:
tｈｉn：
@loｃalhｏｓt:
1５21:
dｈc";
ﻩStriｎguser ＝"ｓcｏtt＂;
ﻩﻩＳｔringpwd="tiｇer";
ﻩconn=DriverMａnager.gｅtConnｅｃtｉｏn（urｌ,usｅr， pwd）;
ﻩﻩﻩsｔmt =ｃonn．creａteSｔaｔement（）;
ﻩrs=sｔmｔ.ｅxecuteQuｅrｙ（"seｌect*from joｂ＿histｏｒｙ"）;
ﻩﻩfw＝nｅｗ（"e:
＼\job_history．txｔ"）；
ﻩﻩｂw = ｎew ＢuｆferedWritｅr（fw）;
ﻩﻩwhile（rs.next（））{
ﻩﻩbｗ.writｅ（rs.ｇetＩnt
（1）+"｜"+ rs.ｇetString
（2） ＋"｜"
ﻩﻩﻩ+rs.getＳtring（3）+"|＂＋ rｓ.getStriｎg（４）+＂|"
ﻩﻩﻩ＋ rｓ.ｇｅtIｎｔ（5））;
ﻩﻩﻩbw.nｅｗＬine（）;
｝
ﻩ｝ｃaｔch（ＳＱLＥｘceptiｏne）{
ﻩｅ．printStackＴracｅ（）;
ﻩﻩ｝caｔch（IＯＥｘceｐtione）｛
ﻩe．pｒiｎtStackＴrａce（）;
} fｉnaｌly{
ﻩﻩｔry｛
ﻩﻩﻩif（bw !
=null）
ﻩﻩﻩbw.ｃｌose（）;
ﻩｉｆ（rs!
= null）
ﻩﻩｒs.cｌose（）;
ﻩﻩｉf （stmｔ !
=nulｌ）
ﻩﻩﻩﻩsｔmt.close（）；
ﻩﻩif（cｏnn！
=null）
ﻩﻩﻩcｏｎｎ.cｌosｅ（）；ﻩﻩ
ﻩﻩ}catcｈ （Excepｔione）{
ﻩﻩﻩe.priｎｔＳｔaｃｋTｒace（）；
ﻩﻩ}
ﻩ}
}
}
第二课ﻬ数据增删改和可滚动结果集
讲述Ｓｔatement对象执行SＱL语句的三种方法：
eｘｅcｕｔeQuｅry（）执行查询单个结果集的语句，该语句返回单个ＲｅｓulｔSｅt对象
eｘｅcｕteUpdaｔe（）执行给定 SQL语句，该语句可能为ＩNSERT、UPＤATE 或ＤELETE 语句,或者不返回任何内容的SQL 语句（如 SQLＤＤL语句），该语句返回影响的行数，如果是ＤDL语句则返回0
exｅcute（）执行给定的 SQＬ语句，这个ＳQL语句可能实现并不知道是查询还是增删改,返回值是布尔值,如果是查询语句返回结果则为trｕｅ,可以用ｇｅｔResultＳeｔ得到RｅsｕｌｔＳeｔ结果
创建一个学生表做数据增删改试验：
createtableStｕｄenｔ
（
ｓiｄ ｎｕmber,ﻫsnamevａrｃｈar２（50），ﻫaddDatedａteﻫ）;
演示增加学生数据
impoｒtjavａ.sql.＊;
ｐuｂlｉcclass Tｅsｔ８｛
ﻩpｕbｌicstaticｖoｉd main（Ｓtring［]args） {
ﻩConnectiｏn ｃonｎ= nuｌl;
ﻩStatemｅnt stｍt=ｎull；
ｔry{
ﻩﻩＤriｖｅｒManager.regisｔeｒDriver（new ｏraｃle.jdbc.driver.ＯraｃleDriｖer（））;
ﻩﻩﻩSｔrｉｎg ｕrl＝"ｊdbc:
oracle:
tｈin:
＠localhoｓt:
１５21：
dhc";
Stｒinguｓer=＂scott";
ﻩStrｉngpwd="tiｇeｒ＂;
ﻩcoｎn =DriverManagｅr.geｔCoｎｎectioｎ（url,uｓer,ｐｗｄ）;
ﻩstｍt＝conn．ｃreａｔeＳtateｍｅｎt（）;
ﻩﻩｉntｉ=ｓｔmｔ
ﻩﻩﻩﻩ．exeｃuteUpdatｅ（"inseｒｔiｎto Ｓtudentvaluｅs （１０1,'tom',to_dａte（'２０08-3-１','yyｙy－ｍm-dd'））"）;
ﻩﻩSystｅm．ouｔ.ｐｒｉnｔｌｎ（"操作了"+ｉ+＂行"）;
ﻩ}cａtch（ＳQLExｃeptｉone）｛
ﻩﻩe．ｐrｉｎｔStackTrace（）；
}ｆｉｎａｌｌy{
tｒy{
ﻩﻩiｆ（stmt！
= nｕll）
ﻩﻩﻩsｔmt.ｃlose（）;
ﻩﻩｉf（coｎｎ!
＝ ｎull）
ﻩｃonn.ｃｌose（）;
ﻩ}caｔch （Exceptione）{
ﻩﻩｅ.ｐrｉntStackTrａｃｅ（）;
ﻩﻩ}
ﻩﻩ}
ﻩ}
}
演示修改学生数据:
……
inｔ ｉ =ｓｔmt
ﻩﻩﻩ．exeｃuteＵｐｄaｔe（"updａteＳtudentsｅｔsnaｍe＝'jacｋ＇,addＤate=ｔo＿daｔe（'2007-3-1＇，'yyyy-mｍ-ｄd'）where sid=10１"）;
Ｓystem.ouｔ.pｒintｌn（"操作了"+i＋"行"）;
……
学生自己动手改成删除１０1学生数据：
……
ｉnｔ i＝ stmt
ﻩﻩﻩ．ｅxecuteUpdａｔｅ（＂delete ｆromSｔuｄenｔｗheｒe ｓid=101"）;
Sｙｓtｅm.ouｔ.pｒiｎtlｎ（"操作了＂+i+"行"）;
……
学生试验执行DDＬ语句删除表：
……
intｉ=sｔmt
ﻩ.executeUpｄatｅ（"dｒｏｐｔable Ｓtudent"）;
Sｙｓｔem.ouｔ.priｎtln（"操作了" +i +＂行"）;
……
学生练习:
提供一个原始文本文件Ｓｔudent．txt，将文本文件中的数据导入到数据库中的表中
Ｓtudent.txt文件内容
1０1,tom,2008-3－1
102，ｊａck,20０８－３－2
103,ｒｏsｅ，2008-3-3
1０４,smith,2008-３-４
１05,john，2008-3-5
106,zｈaｎｇ，２008－３-6
１07,li,２0０８-３-７
impｏｒｔjaｖa.sｑl．*;
iｍportjava.io.＊；
publicclass Tｅsｔ10{
ﻩpｕblic sｔatｉｃｖoｉdmaiｎ（Ｓtring[] arｇｓ）thｒｏwsＥxceｐtion{
ﻩConnｅctioｎｃoｎn＝null;
ﻩSｔatemeｎｔｓtmt＝nｕll;
ﻩReｓultＳetrｓ =nuｌl;
ﻩＤriverＭａnａgeｒ.regｉsterDriｖer（ｎｅwｏｒacle．jdbc.ｄｒivｅr.OraｃｌｅＤrｉver（））；
Stｒing url=＂jdｂc:
ｏrａcle:
tｈiｎ:
@localｈｏsｔ:
1521:
dｈc";
ﻩﻩSｔｒing user=＂scott";
Strinｇpwd＝"tiger";
ｃonｎ=DriverManaｇeｒ．getConnectioｎ（uｒl， usｅr,pwd）;
ﻩﻩstmt=coｎn．createStatement（RｅsultＳet.TYPE＿SCRＯLＬ＿INSENSIＴＩVE,
ﻩRｅsultSeｔ.CONＣＵR_UPDATABLＥ）;
fｒ =neｗ（"ｅ:
＼\Student．txt＂）；
ﻩﻩＢuｆfｅredReaderbr=neｗBｕffeｒedReadｅr（fr）;
Ｓtring s = ｂr.reａdLiｎe（）;
ﻩｗhile （s!
＝ｎuｌｌ）{
ﻩﻩﻩSｔｒing[］rows＝s.ｓpｌit（","）；
ﻩstmt．exeｃuteＵｐdate（"inｓｅrtiｎtoＳtｕdeｎｔvａlues（"+ｒｏws[0]+",'＂
ﻩﻩ+rowｓ[1]+"'，to_dａｔｅ（'＂＋rows[2] + "'，＇yyｙy-mm-dd'））"）;
s=br.reaｄLine（）;
ﻩ}
ﻩﻩ
ﻩﻩｂr.cｌｏｓe（）;
ﻩﻩstｍt.close（）；
ﻩcoｎn.close（）;
ﻩ}
}
讲解可滚动的结果集游标指针
Conｎｅction对象创建Ｓtaｔｅment对象有两种形式：
●一种是用createStateｍent（）无参方法，这种方法创建的Statemeｎt对象执行的查询的结果集指针只能向下移动
●另一种方法是用crｅateＳｔatement（inｔ ｒｅsultＳeｔType,inｔｒesultSｅtＣｏncurｒency）有参方法,这种方法创建的Ｓtatement对象执行的查询结果集的指针是可以任意移动的
后一种方法有两个参数：
分别是结果集游标类型和结果集是否可更新
结果集游标类型有三个设置值：
1.ＲesｕlｔSｅｔ．TＹPE＿FORWＡRD＿ＯNLＹ指针只能向下移动（默认）
2.ResultSｅt.ＴYPE_SＣＲOＬＬ_INSENＳＩTＩVE 指针可任意滚动，但结果集中被更新的行不可视
3.ResultSet.TYPE＿ＳCROLL_SENSIＴＩVE指针可任意滚动，结果集中被更新的行可视
结果集是否可更新有两个设置值：
1.ResｕｌtＳet．ＣONCＵR_ＲＥAD_ONＬY只读（默认）
2.RｅｓultSet.ＣONＣUR_ＵPDATABLE可更新记录
关于指针移动的方法：
默认打开结果集的时候指针位于第一行记录的上面
nexｔ（）下一行
previous（）上一行
firsｔ（） 第一行
last（）最后一行
aｂsoｌutｅ（n） 定位到第n条
relａtive（n）相对于当前指针位置定位到第ｎ条，n为正数下移，n为负数上移
bｅfｏreＦirst（）第一条的前面
afteｒLaｓt（）最后一条的后面
ｇetRow（） 获得当前行的行号
学生练习：
查询出工资排名在第6位到第10位的员工编号，姓名和工资
……
stmt =conn.cｒeaｔeStatemeｎｔ（ResulｔＳet．TYPＥ_SCRＯLＬ_INSEＮＳITＩVＥ,
ﻩﻩResｕltＳeｔ.ＣONCUＲ＿RＥＡD＿OＮLY）;
rs=stmt.executeQuery（＂ｓelecｔ*from ｅmｐloｙｅesoｒder bysaｌarydesc＂）;
ｉf （rs.abｓｏｌuｔe（６）） {
ﻩfoｒ（inｔi =6;i<＝１0;i＋+）{
ﻩﻩSyｓtem．out.prinｔln（i＋ ":
＼t" ＋ｒs.ｇｅtＩnｔ
（1） ＋"/
升级会员 