java 数据库基本操作 [L9e.n1
1、java数据库操作基本流程 (\M&/X~q
2、几个常用的重要技巧: H.Pts>3r(
可滚动、更新的记录集 2<U5d`
批量更新 ~vG~Z*F
事务处理 O8n\>p kI
XKMJsEPsW
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 `/0X].s#o
1、取得数据库连接 'ApWYt
1)用DriverManager取数据库连接 FWPkvL
例子 #2Mz.=#G
String className,url,uid,pwd; nwW`Q>+#U
className = "oracle.jdbc.driver.OracleDriver";
aS:17+!
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; 82>zu}
uid = "system"; ~pwp B2c
pwd = "manager"; 7nfQ=?XNK
Class.forName(className); =7#)8p[
Connection cn = DriverManager.getConnection(url,uid,pwd); M="%NxuS
2)用jndi(java的命名和目录服务)方式 c5^i5de
例子 4B!]%Mw;c
String jndi = "jdbc/db"; BL,YJM(y
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); )%WS(S>8
DataSource ds = (DataSource) ctx.lookup(jndi); Fb[<YX"
Connection cn = ds.getConnection(); tNfku
多用于jsp中 N\ GBjr-d
2、执行sql语句 Qz[~{-<
1)用Statement来执行sql语句 dIMs{!
String sql; P2 f~sx9
Statement sm = cn.createStatement(); A+:K!|w
sm.executeQuery(sql); // 执行数据查询语句(select) PK!=3fK4\F
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); D55dD>
2)用PreparedStatement来执行sql语句 &!Y^DR/
String sql; ~99Ta]U
sql = "insert into user (id,name) values (?,?)"; 4*d_2:|u
PreparedStatement ps = cn.prepareStatement(sql); hDzKB))<w
ps.setInt(1,xxx); sd.:PE <
ps.setString(2,xxx); "'dt"x)
... k45xtKS>d
ResultSet rs = ps.executeQuery(); // 查询 = DvnfT<
int c = ps.executeUpdate(); // 更新 sj
Yg
3E:wyf)i"
3、处理执行结果 Vh4z+JOC
查询语句,返回记录集ResultSet ,8EeSnI
更新语句,返回数字,表示该更新影响的记录数 )7[>/2aGd
ResultSet的方法 1rT}mm/e;
1、next(),将游标往后移动一行,如果成功返回true;否则返回false '2v,!G]^
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ; #e-pkV
c:hOQZ
4、释放连接 !dSY?1>U<
cn.close(); f4]nz:2
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection *#dXW\8qu
) Q]kUG#`
可滚动、更新的记录集 ;. /Tv84I^
1、创建可滚动、更新的Statement v!K%\h2A
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); \O72PC+
该Statement取得的ResultSet就是可滚动的 }JAg<qy}
2、创建PreparedStatement时指定参数 JzCfs<D
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); z`m-Ca>6
ResultSet.absolute(9000); ] E`J5o}op
批量更新 FpCj$y~3
1、Statement Nl PP|=o
Statement sm = cn.createStatement(); Xy=|qu
sm.addBatch(sql1); rsy'ZVLUj
sm.addBatch(sql2); n"d~UV^Uw
... >"N \ZC^
sm.executeBatch() 4|7L26,]5
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 1&U'pp|T
2、PreparedStatement rJKX4,M
PreparedStatement ps = cn.preparedStatement(sql); DJT)7l {
{ Fl^.J<Dz
ps.setXXX(1,xxx); !Kd/
lDY
... *+lnAxRa?
ps.addBatch(); @ U:WWTzf
} sw8Ic\vT
ps.executeBatch(); wzT+V,
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 __'Z0?.4#
+#,t
事务的处理 auaFP-$`f
1、关闭Connection的自动提交 ZXe[>H
cn.setAutoCommit(false); &I <R|a
2、执行一系列sql语句 2mVH*\D
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close i#iY;R8
Statement sm ; )6^b\`
sm = cn.createStatement(insert into user...); Vr`UF0_3q
sm.executeUpdate(); c[@>#7p`o
sm.close(); <o^mQq&
sm = cn.createStatement("insert into corp...); c{s<W}3Ds
sm.executeUpdate(); 9O~1o?ni
sm.close(); hFs0qPVY
3、提交 %[&cy'
cn.commit(); _nOio ?
4、如果发生异常,那么回滚 !fyE
Hk
cn.rollback();