java 数据库基本操作 I>5@s;
1、java数据库操作基本流程 lX4p'R-h
2、几个常用的重要技巧: Ww(_EW
可滚动、更新的记录集 "n6Y^
批量更新 G'py)C5;
事务处理 /)I9+s#q9o
biG9?
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 }gW}Vr <
1、取得数据库连接 u7=[~l&L
1)用DriverManager取数据库连接 ".)_kt[
例子 #~x5}8
String className,url,uid,pwd; _5T7A><q<
className = "oracle.jdbc.driver.OracleDriver"; +Y~+o-_
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; Vd0GTpB?1
uid = "system"; ifs*-f
pwd = "manager"; =vc5,
Class.forName(className); 6\3k0z
Connection cn = DriverManager.getConnection(url,uid,pwd); jVINc=o
2)用jndi(java的命名和目录服务)方式 zFtGc
例子 ja;5:=8A5
String jndi = "jdbc/db"; Z ~(XyaN
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); [tzSr=,Cg
DataSource ds = (DataSource) ctx.lookup(jndi); $P(nh'\
Connection cn = ds.getConnection();
/Xz4q!Ul
多用于jsp中 A,{D9-%
2、执行sql语句 OkZ! ZS
h
1)用Statement来执行sql语句 rl%Kn^JJ~
String sql; yU|ji?)e
Statement sm = cn.createStatement(); 'D&G~$
sm.executeQuery(sql); // 执行数据查询语句(select) C.E>)
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); .dCP8|
2)用PreparedStatement来执行sql语句 GX)QIe~;qJ
String sql; W6O.E
sql = "insert into user (id,name) values (?,?)"; %20-^&zZ
PreparedStatement ps = cn.prepareStatement(sql); w.aFaR)04
ps.setInt(1,xxx); q=Yerp3~
ps.setString(2,xxx); M:M>@|)
... l _O~v?
ResultSet rs = ps.executeQuery(); // 查询 s7o*|Xv
int c = ps.executeUpdate(); // 更新 t4_K>Mj+d
Q)BoWd
3、处理执行结果 ]&U| d
查询语句,返回记录集ResultSet [\9(@Bx
更新语句,返回数字,表示该更新影响的记录数 2w|u)ow)
ResultSet的方法 ?ev G=S4>
1、next(),将游标往后移动一行,如果成功返回true;否则返回false +)JqEwCrq
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 /Q8A"'Nk
hu(K!>{
4、释放连接 &H1D!N
cn.close(); ,?<h] !aQ
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection Zfv(\SI
ff1B)e
可滚动、更新的记录集 Z034wn\N
1、创建可滚动、更新的Statement j' KobyX<
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); SP7g qM
该Statement取得的ResultSet就是可滚动的 7(8
2、创建PreparedStatement时指定参数 P .4b+9Tx
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 8+a<#?;
ResultSet.absolute(9000); ,beR:60)
批量更新 0nz@O^*g(
1、Statement T{4fa^c2J
Statement sm = cn.createStatement(); 7]xz8t
sm.addBatch(sql1); jjwMvf.R
sm.addBatch(sql2); m2uML*&O5K
... Xb@z7X#O!
sm.executeBatch() z!C4>,
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 8+|V!q
2、PreparedStatement `J#xyDL6?
PreparedStatement ps = cn.preparedStatement(sql); J=SB/8tQ)T
{ uM)9b*Vbo
ps.setXXX(1,xxx); K'5sn|)
... ICCCCG*[
ps.addBatch(); {9.~]dI|L
} G'?f!fz;
ps.executeBatch(); e4YfTr
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 sJI-
R c:cVK
事务的处理 hW!@$Ph
1、关闭Connection的自动提交 aRO_,n9
cn.setAutoCommit(false); B,vHn2W
2、执行一系列sql语句 `-K)K<
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close _h=<_Z
Statement sm ; S5E,f?l
sm = cn.createStatement(insert into user...); z@l!\m-
sm.executeUpdate(); 9 CK\tx&
sm.close(); \LoSUl
i
sm = cn.createStatement("insert into corp...); f-v ND'@
sm.executeUpdate(); :Bv&)RK
sm.close(); ^,Y~M_=
3、提交 K jn&
cn.commit(); |6(qg5"
4、如果发生异常,那么回滚 (m3I#L
cn.rollback();