java 数据库基本操作 !
o?E.
1、java数据库操作基本流程 %CZGV7JdA
2、几个常用的重要技巧: IL,iu
可滚动、更新的记录集 33ZHrZ
批量更新 QFB2,k6jN
事务处理 _VB;fH$
4j}.=u* X7
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 1@N4Y9o
1、取得数据库连接 BXNC(^
1)用DriverManager取数据库连接 KBoW(OP4'
例子 vjVa),2
String className,url,uid,pwd; 3!h 3flE
className = "oracle.jdbc.driver.OracleDriver"; +W/{UddeKU
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; TtrV
-X>L
uid = "system"; .E9$j<SP-
pwd = "manager"; _aU
:[v*!
Class.forName(className); hltUf5m'b
Connection cn = DriverManager.getConnection(url,uid,pwd); BI<(]`FP;s
2)用jndi(java的命名和目录服务)方式 J vl-=~
例子 (tF/2cZk
String jndi = "jdbc/db"; RWB]uHzE
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 5s%FHa
DataSource ds = (DataSource) ctx.lookup(jndi); 2J Wp5
Connection cn = ds.getConnection(); R|k!w]
多用于jsp中 J|@O4g
2、执行sql语句 )h]tKYx
1)用Statement来执行sql语句 /uPMzl
String sql; #3O$B*gV6
Statement sm = cn.createStatement(); ?k=)T]-}
sm.executeQuery(sql); // 执行数据查询语句(select) YkQ=rurE
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 9 ge'Mo
2)用PreparedStatement来执行sql语句 |fb*<o eT
String sql; *&5./WEOH
sql = "insert into user (id,name) values (?,?)"; uG+eF
PreparedStatement ps = cn.prepareStatement(sql); k!T-X2L=
ps.setInt(1,xxx); [,Y;#;
ps.setString(2,xxx); 7CCSG{k
... ?es9j]
ResultSet rs = ps.executeQuery(); // 查询 /VFQbJ+`
int c = ps.executeUpdate(); // 更新 |}: D_TX
*o6QBb
3、处理执行结果 p`S~UBcL.
查询语句,返回记录集ResultSet 'X\C/8\
更新语句,返回数字,表示该更新影响的记录数 DB'3h7T
ResultSet的方法 1lsg|iVz
1、next(),将游标往后移动一行,如果成功返回true;否则返回false Oiw!d6"Ovq
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 V0bKtg1f?-
;[7#h8
4、释放连接 cef:>>6_
cn.close(); <899r \
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection X;{U? `b-
SbobXTbG
可滚动、更新的记录集 Wt=%.Y(x
1、创建可滚动、更新的Statement }5d|y*
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); :2lM7|@/
该Statement取得的ResultSet就是可滚动的 EkOn Rm_hn
2、创建PreparedStatement时指定参数 m:g%5'qDZ
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); zR%)@wh
ResultSet.absolute(9000); 9S?b &]
批量更新 e63io0g>
1、Statement q#0yu"<
Statement sm = cn.createStatement(); pW&8 =Ew
sm.addBatch(sql1); 0a+U >S#
sm.addBatch(sql2); C?rb}(m
... ']sIU;h3
sm.executeBatch() aSeh?2n8
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 HmV JkkksJ
2、PreparedStatement #b1/2=PA
PreparedStatement ps = cn.preparedStatement(sql); _Ry
{ @iVEnb.'
ps.setXXX(1,xxx); ZO \bCrk
... <2\QY
ps.addBatch(); 2~)q080jh
} G)=+Nt\*
ps.executeBatch(); rjH W
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 Egl1$,e
i;#AW($+a
事务的处理 E;r~8^9)
1、关闭Connection的自动提交 CasFj9,
cn.setAutoCommit(false); ,*wj~NE
2、执行一系列sql语句 jG^OF5.
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close ra]\!;}L0
Statement sm ; Bn
Nu/02.=
sm = cn.createStatement(insert into user...); mW."lzIl
sm.executeUpdate(); #~6X9,x=
sm.close(); HmpV;
<t3
sm = cn.createStatement("insert into corp...); (Jy >,~O
sm.executeUpdate(); z6OJT6<'
sm.close(); !Mk]%
3、提交 Z?'?+48xv4
cn.commit(); l 4cTN
@E
4、如果发生异常,那么回滚 6
wD
cn.rollback();