java 数据库基本操作 5%6r,?/7KM
1、java数据库操作基本流程 D>Ph))QI
2、几个常用的重要技巧: IT0*~WMZ
可滚动、更新的记录集 G#A& Y$
批量更新 Sud5F4S
事务处理 g:nU&-x#R
G|Y9F|.!
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 - '5OX/Szq
1、取得数据库连接 }n JG<rY
1)用DriverManager取数据库连接 +EBoFeeIG
例子 onj:+zl
String className,url,uid,pwd; bbU{ />yW
className = "oracle.jdbc.driver.OracleDriver"; p#dpDjh
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ,M&[c|
uid = "system"; +Ss|4O}'
pwd = "manager"; W:16qbK
Class.forName(className); `Z0#IeX=
Connection cn = DriverManager.getConnection(url,uid,pwd); ,HdFE|
2)用jndi(java的命名和目录服务)方式 <C_FI` wk
例子 W=EvEx^?%
String jndi = "jdbc/db"; AyMMr_q
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); hol54)7$3:
DataSource ds = (DataSource) ctx.lookup(jndi); ii@O&g
Connection cn = ds.getConnection(); DOm5 azO!>
多用于jsp中 TBYRY)~f
2、执行sql语句 %%w]-`^h,
1)用Statement来执行sql语句 3q.O^`y FU
String sql; L_YVe(dT
Statement sm = cn.createStatement(); (9J,Qs[;
sm.executeQuery(sql); // 执行数据查询语句(select) cEd!t6Z
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); Mb(aI!;A
2)用PreparedStatement来执行sql语句 N5=;
PZub
String sql; Gm.n@U p
sql = "insert into user (id,name) values (?,?)"; 'L2M
W
PreparedStatement ps = cn.prepareStatement(sql); 3J{`]v5`
ps.setInt(1,xxx); 217KJ~)'
ps.setString(2,xxx); $h-5PwHp
... -)tu$W*
ResultSet rs = ps.executeQuery(); // 查询 r='"X#CmV/
int c = ps.executeUpdate(); // 更新 dviL5Eaj
pU*dE
3、处理执行结果 ,]'?Gd
查询语句,返回记录集ResultSet aMFUJrXo
更新语句,返回数字,表示该更新影响的记录数 ~sQN\]5VW
ResultSet的方法 ;?i(WV}ee
1、next(),将游标往后移动一行,如果成功返回true;否则返回false wKCHG/W
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 y$At$i>u
XY8s \DK
4、释放连接 \@4_l?M
cn.close(); 5"5D(
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 8uX1('+T*
B;?"R
可滚动、更新的记录集 -zd*tujx
1、创建可滚动、更新的Statement ,"u-V<>6O
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); gHC -Y 0_
该Statement取得的ResultSet就是可滚动的 N}>XBZy
2、创建PreparedStatement时指定参数 mlY0G w_e
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); J..>ApX
ResultSet.absolute(9000); 1TKOvy_
批量更新 vb}; _/#?
1、Statement sSi1;9^o
Statement sm = cn.createStatement(); por[p\ M.
sm.addBatch(sql1); ]iuM2]
sm.addBatch(sql2); O=#FpPHrdw
... g`!:7|&,_
sm.executeBatch() J8$G-~MeJ
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 DLkNL?a
2、PreparedStatement $@t-Oor;
PreparedStatement ps = cn.preparedStatement(sql); _gB`;zo
{ lu(<(t,Lbs
ps.setXXX(1,xxx); V,($I'&/
... +xwz.:::
ps.addBatch(); p
IXBJk
} fi%u]
ps.executeBatch(); 6v0^'}
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 3Bz0B a
RV|: mI
事务的处理 vS:%(Y"!<
1、关闭Connection的自动提交 ;PJWd|3
cn.setAutoCommit(false); 02} &h
2、执行一系列sql语句 A}sb2P
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close ]S[zD|U%
Statement sm ; m El*{]
sm = cn.createStatement(insert into user...); IEdC
_6G
sm.executeUpdate(); |*7uF<ink6
sm.close(); dx@#6Fhy
sm = cn.createStatement("insert into corp...); Rv6{'\:
sm.executeUpdate(); !Ljs9 =UF
sm.close(); X|H%jdta
3、提交 su(y*187A
cn.commit(); |8h<Ls_
4、如果发生异常,那么回滚 5f7;pS<
cn.rollback();