java 数据库基本操作 b{M}5~e=B
1、java数据库操作基本流程 RPH1''*!
2、几个常用的重要技巧: B76 v}O:
可滚动、更新的记录集 rQJ"&CapT
批量更新 8gC)5Y
事务处理 Hm
fXe
wzh]97b
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 GX?*1
1、取得数据库连接 YTQps&mD.
1)用DriverManager取数据库连接 J -V49X#
例子 _6MdF<Xb/
String className,url,uid,pwd; B[F-gq-
className = "oracle.jdbc.driver.OracleDriver"; ka/XK[/'
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; 02\JzBU
uid = "system"; Gr: 3{o`
pwd = "manager"; !8R@@,_v
Class.forName(className); ^:u?ye;
Connection cn = DriverManager.getConnection(url,uid,pwd); *5OCqU+g
2)用jndi(java的命名和目录服务)方式 Cqxv"NN
例子 +@<KC
String jndi = "jdbc/db"; .VM3D0aV
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ghAi{@s$)
DataSource ds = (DataSource) ctx.lookup(jndi); Hx2En:^Gf
Connection cn = ds.getConnection(); tHh HrMxO
多用于jsp中 c#lPc>0xb
2、执行sql语句 -.iNNM&a
1)用Statement来执行sql语句 vfw A$7N
String sql; r&%.z*q
Statement sm = cn.createStatement(); ^$-Ye]<
sm.executeQuery(sql); // 执行数据查询语句(select) :!Ig- +W
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); = 96P7#%
2)用PreparedStatement来执行sql语句 !MVj=(
String sql; p!zJ;rh)
sql = "insert into user (id,name) values (?,?)"; g%a|q~)
PreparedStatement ps = cn.prepareStatement(sql); |0.Xl+7
ps.setInt(1,xxx); r-IT(DzkD
ps.setString(2,xxx); A}5fCx.{
... "e6|"w@8
ResultSet rs = ps.executeQuery(); // 查询 iiG f'@/
int c = ps.executeUpdate(); // 更新 fD4ICO @
0Fw6Dq<8-!
3、处理执行结果 .lN s4e
查询语句,返回记录集ResultSet !bU\zH
更新语句,返回数字,表示该更新影响的记录数 Xsuwa-G!5~
ResultSet的方法 z0bJ?~w,
1、next(),将游标往后移动一行,如果成功返回true;否则返回false iqwkARG"
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 Ai"-w"
'91".c,3?
4、释放连接 "i&"* ~
cn.close(); u~1o(Zn
=
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection T$+-IAE
_S@aGw
可滚动、更新的记录集 |Au ]1}
1、创建可滚动、更新的Statement M4m$\~zf
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); zj|WZ=1*Wp
该Statement取得的ResultSet就是可滚动的 RJ4.
kt
2、创建PreparedStatement时指定参数 PRB{VC<k
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); wy,p&g)>
ResultSet.absolute(9000); )ev<7g9*q
批量更新 bb-q O#E
1、Statement g(ogXA1
Statement sm = cn.createStatement(); v [njdP
sm.addBatch(sql1); 3c3OG.H$8
sm.addBatch(sql2); wJ+Aw
... XYEv&-M`?w
sm.executeBatch() 9z>z3,ftN
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 EME.h&A\G`
2、PreparedStatement 1HT_
PreparedStatement ps = cn.preparedStatement(sql); E?)656F[
{ mQ~:Y
ps.setXXX(1,xxx); Wu1{[a|
... ?rYT4vi
ps.addBatch(); b)#Oc,
} $s5a G)?7
ps.executeBatch(); ^U[D4UM
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 X"aEJ|y
MXD4|r(
事务的处理 >~nF=
1、关闭Connection的自动提交 58tVx'1y
cn.setAutoCommit(false); s{bdl[7
2、执行一系列sql语句 o@bNpflb`
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close od' /%
Statement sm ; ANi)q$:{
sm = cn.createStatement(insert into user...); 28.~iw
sm.executeUpdate(); tBATZ0nK`Q
sm.close(); Gi2$B76<
sm = cn.createStatement("insert into corp...); zDTv\3rZ4X
sm.executeUpdate(); xdvh-%A4
sm.close(); &>g'$a<[
3、提交 0k,-; j,
cn.commit(); 790-)\:CY
4、如果发生异常,那么回滚 Cq)IayD@
cn.rollback();