java 数据库基本操作 ! D1zXXq
1、java数据库操作基本流程 A7Y_HIo
2、几个常用的重要技巧: gGfq6{9g
可滚动、更新的记录集 =/Juh7[C
批量更新 uqZ3Hyb
事务处理 ,2zKQ2z
m&El)
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 3|eUy_d3
1、取得数据库连接 (!</%^ZI
1)用DriverManager取数据库连接 \E
hr@g
例子 Yj8&
String className,url,uid,pwd; dY'Y5Th~
className = "oracle.jdbc.driver.OracleDriver"; JvJ;bFXD
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; qgexb\x\4
uid = "system"; e\N0@
pwd = "manager"; w}k B6o]
Class.forName(className); ]|LgVXEpx
Connection cn = DriverManager.getConnection(url,uid,pwd); z8iENECwj
2)用jndi(java的命名和目录服务)方式
GX38~pq
例子 08r[K(bfb,
String jndi = "jdbc/db"; K51fC4'{
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); -!R
l(if
DataSource ds = (DataSource) ctx.lookup(jndi); &?T ${*~
Connection cn = ds.getConnection(); gCV rC
多用于jsp中 0wvU?z%WK
2、执行sql语句 JDhwN<0R
1)用Statement来执行sql语句 K&S@F!#g
String sql; S0xIvzS
Statement sm = cn.createStatement(); 'Y)/~\FI
sm.executeQuery(sql); // 执行数据查询语句(select) T`Hw49
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); +x]e-P%
2)用PreparedStatement来执行sql语句 - L`7+
String sql; uUS)#qM|
sql = "insert into user (id,name) values (?,?)"; ^
f{qJ[,
PreparedStatement ps = cn.prepareStatement(sql); Q8Te'1Ln!
ps.setInt(1,xxx); ^H!Lp[5c
ps.setString(2,xxx); i+ic23$4M
... r@|ZlM@O
ResultSet rs = ps.executeQuery(); // 查询 b]#~39Iph
int c = ps.executeUpdate(); // 更新 `A{'s %$?!
m+T2vi
3、处理执行结果 065A?KyD
查询语句,返回记录集ResultSet cx:jUsb6
更新语句,返回数字,表示该更新影响的记录数 3-
)kwy6L
ResultSet的方法 9::YR;NY
1、next(),将游标往后移动一行,如果成功返回true;否则返回false VjTAN=
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 *vs~SzF$
#pa\2d|
4、释放连接 k2uBaj]
cn.close(); t>oM%/H
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection
5KaSWw/
9|a)sb7/
可滚动、更新的记录集 a71}y;W
1、创建可滚动、更新的Statement me$$he
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 8Mb$+^zU
该Statement取得的ResultSet就是可滚动的 OR~G Ov|
2、创建PreparedStatement时指定参数 (WMLNv
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); G5+]DogS
ResultSet.absolute(9000); 7b,AQ9
批量更新 !Bncx`pl
1、Statement ,O9`X6rh'
Statement sm = cn.createStatement(); UP*yeT,P,
sm.addBatch(sql1); u[J7Y
sm.addBatch(sql2); Y-7.Vjt^
... Tvrc%L(]
sm.executeBatch() ]>*I) H)
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 d#Wn[h$"
2、PreparedStatement ;]u1~
PreparedStatement ps = cn.preparedStatement(sql); w6v1 q:20
{ KM@`YV_"g
ps.setXXX(1,xxx); yh$ ~*UV
... ?a8nz, zb
ps.addBatch(); 4sQ~&@[Q+
} Bf(Mot^
ps.executeBatch(); 04[)qPPS
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 !$XO
U'n
G`WzJS*}v
事务的处理 #nDL
1、关闭Connection的自动提交 yEnKUo[
cn.setAutoCommit(false); 2}@*Ki7
2、执行一系列sql语句 KK .cDAR
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close s9kTuhoK
Statement sm ; `|NevpXY1
sm = cn.createStatement(insert into user...); "mG!L$
sm.executeUpdate(); z22N7W=7
sm.close(); P^n{Y~P=Q
sm = cn.createStatement("insert into corp...); ~Gwas0eNa
sm.executeUpdate(); rcW#6VZ=
sm.close(); .Btv}b
3、提交 "rf\' 9=
cn.commit(); GMyoSe%1/
4、如果发生异常,那么回滚 {AtfK>D
cn.rollback();