java 数据库基本操作 EyY.KxCB
1、java数据库操作基本流程 K't]n{$
2、几个常用的重要技巧: lO2[JP
可滚动、更新的记录集 +cU>k}
批量更新 sB69R:U;
事务处理 8w({\=
;gC|
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 |yo\R{&6
1、取得数据库连接 V.wqZ {G
1)用DriverManager取数据库连接 64:fs?H
例子 $%VuSrZ&
String className,url,uid,pwd; p }[zt#v
className = "oracle.jdbc.driver.OracleDriver"; =_YG#yS
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; 0ZQ' _g|%
uid = "system";
ccd8O{G.M
pwd = "manager"; [pVamE
Class.forName(className); /c):}PJ^#7
Connection cn = DriverManager.getConnection(url,uid,pwd); 4Jx"A\5*G
2)用jndi(java的命名和目录服务)方式 G\NPV'
例子 Zw
wqSyuGf
String jndi = "jdbc/db"; ^&g=u5
d0
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); wcDRH)AW.
DataSource ds = (DataSource) ctx.lookup(jndi); VbBPB5 $q
Connection cn = ds.getConnection(); u{["50~
多用于jsp中 B c2p(z4
2、执行sql语句 >vo=]cw
1)用Statement来执行sql语句 l7De6A"
String sql; Fd*8N8Pi
Statement sm = cn.createStatement(); :x_'i_w
sm.executeQuery(sql); // 执行数据查询语句(select) TIvRhbu
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 'mV9 {lj7E
2)用PreparedStatement来执行sql语句 %4HRW;IU
String sql; 'U'yC2BI n
sql = "insert into user (id,name) values (?,?)"; #nh|=X
PreparedStatement ps = cn.prepareStatement(sql); 1
hg}(Hix
ps.setInt(1,xxx); :kfp_o+J
ps.setString(2,xxx); B:7mpSnEQ
... BL&LeSa
ResultSet rs = ps.executeQuery(); // 查询 /PsnD_s]5
int c = ps.executeUpdate(); // 更新 3P;>XGCxZ
^_lzZOhG
3、处理执行结果 |F#1C9]P
查询语句,返回记录集ResultSet 8b0d]*q
更新语句,返回数字,表示该更新影响的记录数 5E notp[
ResultSet的方法 | [>UH
1、next(),将游标往后移动一行,如果成功返回true;否则返回false S8e{K
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 H.UX,O@
[V:\\$
4、释放连接 " LJq%E
cn.close(); XkyKBg-
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection n@ G[
>ooZj9:'
可滚动、更新的记录集 qTQBt}
1、创建可滚动、更新的Statement Z(!00^
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); o6//IOZ
该Statement取得的ResultSet就是可滚动的 sN5B7)Vc
2、创建PreparedStatement时指定参数 CW<N: F.9
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); wb~@7,D
ResultSet.absolute(9000); J:skJ.Wx
批量更新 puT'y
1、Statement 8mQmi`
Statement sm = cn.createStatement(); MTUn3;c/
sm.addBatch(sql1); 6d+p7x
sm.addBatch(sql2); &5:tn=E
... B-l'vVx
sm.executeBatch() Uk\Id~xLV
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 [k-+AA>:
2、PreparedStatement B 2ec@]uD`
PreparedStatement ps = cn.preparedStatement(sql); "le>_Ze_>|
{ p0pWzwTG3
ps.setXXX(1,xxx); @}kv-*
... <jed!x
ps.addBatch(); dXnl'pFS
} Gm\/Y:U
ps.executeBatch(); Gdg"gi!4
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 Ge<nxl<Bd
@]ao"ui@/
事务的处理 : "1XPr
1、关闭Connection的自动提交 +o9":dl
cn.setAutoCommit(false); : >>@rF ,
2、执行一系列sql语句 -+O
9<3ly
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close `:axzCrCfR
Statement sm ; \m1~jMz*>k
sm = cn.createStatement(insert into user...); 6"}?.E$
sm.executeUpdate(); be +4junf
sm.close(); +a*tO@HG
sm = cn.createStatement("insert into corp...); \G-KplKS
sm.executeUpdate(); &~W:xg(jN
sm.close(); zk( U8C+
3、提交 l<N}!lG|
cn.commit(); 3$X'Y]5a
4、如果发生异常,那么回滚 ;amXY@RmH
cn.rollback();