java 数据库基本操作 8[;U|SR"
1、java数据库操作基本流程 .Su9fjy%
2、几个常用的重要技巧: 'rdg
可滚动、更新的记录集 Nl1v*9_x
批量更新 "V cG3.
事务处理 t1
.6+
wBXgzd%L
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 8V3SZ17
1、取得数据库连接 K]q OLtc
1)用DriverManager取数据库连接 }3!.e
例子 ;dYpdy
String className,url,uid,pwd; p68)
0
className = "oracle.jdbc.driver.OracleDriver"; EmR#)c~(W
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ?<slB>8
uid = "system"; e&u HU8k*
pwd = "manager"; Ip4SdbU
Class.forName(className); PF-
sb&q
Connection cn = DriverManager.getConnection(url,uid,pwd); ,*V{gpC7
2)用jndi(java的命名和目录服务)方式 !g~xn2m$R
例子 |&TRN1
String jndi = "jdbc/db"; |nj%G<
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); <H~ (iQ
DataSource ds = (DataSource) ctx.lookup(jndi); ZUMzWK5Th
Connection cn = ds.getConnection(); >g6:{-b^a
多用于jsp中 @4b"0ne}h
2、执行sql语句 .yF7{/
1)用Statement来执行sql语句 #.%;U' #O
String sql; P Z;O
pp
Statement sm = cn.createStatement(); MqI!i>
sm.executeQuery(sql); // 执行数据查询语句(select) 7Q.?]k&
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); T;}pMRd%
2)用PreparedStatement来执行sql语句 |S:St HZm
String sql; 0BIH.ZV#
sql = "insert into user (id,name) values (?,?)"; kf$0}T`
PreparedStatement ps = cn.prepareStatement(sql); *, o)`
ps.setInt(1,xxx); M(S:&GOU
ps.setString(2,xxx); ]#[R^t
... mY3x
(#I
ResultSet rs = ps.executeQuery(); // 查询 m`-{ V<(M
int c = ps.executeUpdate(); // 更新 d7tH~9GX8
H6*d#!
3、处理执行结果 C
sn"sf
查询语句,返回记录集ResultSet I/MYS5}
更新语句,返回数字,表示该更新影响的记录数 Zl.}J,0F
ResultSet的方法 / '}O-h
1、next(),将游标往后移动一行,如果成功返回true;否则返回false A=|&N%lP'
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 O&irgc!
V5RfxWtm:
4、释放连接 ,y?0Iwf
cn.close(); y:Qo:Z~
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection (3"V5r`*;
#G^?4Za
可滚动、更新的记录集 r/fLm8+
1、创建可滚动、更新的Statement [HK[{M=v=
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); dGcG7*EX
该Statement取得的ResultSet就是可滚动的 (6fh[eK86
2、创建PreparedStatement时指定参数 -pc*$oe
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); X'WbS
ResultSet.absolute(9000); 'zZN]P
批量更新 q!9SANTx
1、Statement Ry0n_J:7
Statement sm = cn.createStatement(); zrG&p Z
sm.addBatch(sql1); _Y*]'?g`
sm.addBatch(sql2); Q5/".x^@
... 5B@+$D[0?3
sm.executeBatch() _w=si?q
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 "wT[LA9\
2、PreparedStatement ]Z@-r
PreparedStatement ps = cn.preparedStatement(sql); ep Eg6
{ W)?B{\
ps.setXXX(1,xxx); $AUC#<*C
... _bn*B$
ps.addBatch(); p^A9iieHp=
} Ylll4w62N
ps.executeBatch(); BYrj#n5
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 y}5H<ZcXA
/N7j5v(
事务的处理 {o4m3[C7=}
1、关闭Connection的自动提交 `$7j:<c=
cn.setAutoCommit(false); O!kBp(?]
2、执行一系列sql语句 vWcU+GBZI
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close ; 7[5%xM
Statement sm ; `TOm.YZG
sm = cn.createStatement(insert into user...); @%fNB,H`
sm.executeUpdate(); Y dmYE$
sm.close(); &mKtW$K` q
sm = cn.createStatement("insert into corp...); EV z>#GC
sm.executeUpdate(); \;}F6g
sm.close(); )&<BQIv9/
3、提交 me#VCkr#
cn.commit(); kf>oZ*/
4、如果发生异常,那么回滚 a8FC#kfq
cn.rollback();