java 数据库基本操作 ;vX1U8
1、java数据库操作基本流程 Ze#DFe$
2、几个常用的重要技巧: 7-}5
W
可滚动、更新的记录集 e+4Eiv
批量更新 Z5)v
事务处理 EYCZuJxv
9d(#/n
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 C+5X8
1、取得数据库连接 u7Ix7`V
1)用DriverManager取数据库连接 VEn3b
例子 r
)_*MPY
String className,url,uid,pwd; {d0-.
className = "oracle.jdbc.driver.OracleDriver"; 7y)Ar 8!D
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; Fpeokr"i
uid = "system"; de.f?y
pwd = "manager"; rX>b R/
Class.forName(className); twbxi{8e.
Connection cn = DriverManager.getConnection(url,uid,pwd); 8ZM#.yBB
2)用jndi(java的命名和目录服务)方式 GU/-L<g
例子 P4eH:0=#
String jndi = "jdbc/db"; Q7<VuXy
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); U|\ .)h=
DataSource ds = (DataSource) ctx.lookup(jndi); 6KXW]a `
Connection cn = ds.getConnection(); i?uX'apk
多用于jsp中 RO%M9LISI
2、执行sql语句 !y'>sAf
1)用Statement来执行sql语句 Ht\2 IP
String sql; 9PV+Kr!c5I
Statement sm = cn.createStatement(); k_zn>aR$F
sm.executeQuery(sql); // 执行数据查询语句(select) [^6z>
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); Iwh0PfWJ
2)用PreparedStatement来执行sql语句 :M f8q!Q'
String sql; v2p0EOS
sql = "insert into user (id,name) values (?,?)"; n"D` =
PreparedStatement ps = cn.prepareStatement(sql); =NI?Jk*iAq
ps.setInt(1,xxx); fqq4Qc)#U&
ps.setString(2,xxx); hiA\~}sl n
... Di4GaKa/
ResultSet rs = ps.executeQuery(); // 查询 >w,jaQ
int c = ps.executeUpdate(); // 更新 ED" fi$
XuHR
3、处理执行结果 I.T?A9Z
查询语句,返回记录集ResultSet v-q-CI?B#
更新语句,返回数字,表示该更新影响的记录数 6akI5\b
ResultSet的方法 "19#{yX4
1、next(),将游标往后移动一行,如果成功返回true;否则返回false *FZav2]-
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 lz36;Fp
8~s0%%{,M
4、释放连接 d,Oagx
cn.close(); WVOj;c
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection %iEdU V\$
NqNU:_}
可滚动、更新的记录集 3(,m(+J[S
1、创建可滚动、更新的Statement y,ub*-:
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); udBIEW,`
该Statement取得的ResultSet就是可滚动的 N}ND()bf
2、创建PreparedStatement时指定参数 S4{vS?>j
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); !J X7y%J
ResultSet.absolute(9000); '-[hy>t
批量更新 Z~8%bfpe
1、Statement m6$&yKQ-=h
Statement sm = cn.createStatement(); DLqH*U
sm.addBatch(sql1); Vwh;QJxb
sm.addBatch(sql2); #W3H;'~/5
... _od /)#
sm.executeBatch() G e]NA]<
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 u~Po5W/i
2、PreparedStatement KF1iYo>p
PreparedStatement ps = cn.preparedStatement(sql); wQjYH!u,YZ
{ #\QW <I#/
ps.setXXX(1,xxx); XM
w6b*O
... I2*(v%.-
ps.addBatch(); {f)aFGp
} 5dN>Xjpu
ps.executeBatch(); dg|x(p#
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 SOM? 0.
C/qKa[mg
事务的处理 @fp@1n
1、关闭Connection的自动提交 3\
Mt+!1{
cn.setAutoCommit(false);
<HN+pi
2、执行一系列sql语句 yI#qkl-
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close jl(D;JnF
Statement sm ; Tj_K5uccU}
sm = cn.createStatement(insert into user...); UXdc'i g
sm.executeUpdate(); Qj_)^3`e
sm.close(); x>TIx[x
sm = cn.createStatement("insert into corp...); HR8YPU5
sm.executeUpdate(); I
*sT*;U
sm.close(); V6HZvuXV!
3、提交 ,Ww}xmq1H
cn.commit(); "5
~{
4、如果发生异常,那么回滚 sCzpNJ"8
cn.rollback();