java 数据库基本操作 7.DtdyM
1、java数据库操作基本流程 `cPywn@uGZ
2、几个常用的重要技巧: lb'GXd %
可滚动、更新的记录集 vN2u34
批量更新 d(g^M1m
事务处理 F+ E|r6'i
*f,DhT/P
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 J]m{b09F
1、取得数据库连接 z0|&W&&D
1)用DriverManager取数据库连接 O+%WR
例子 W@yJAQ
String className,url,uid,pwd; $P1O>x>LIL
className = "oracle.jdbc.driver.OracleDriver"; N`)$[&NG]
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; b-3*Nl _%
uid = "system"; TKk-;Y=N
pwd = "manager"; qwIa?!8o
Class.forName(className); 4iW'kuK
Connection cn = DriverManager.getConnection(url,uid,pwd); D:Q
21Ch
2)用jndi(java的命名和目录服务)方式 *Z m^
~Vo
例子 )tCX
y4
String jndi = "jdbc/db"; -n'F v@U
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); )c l5B{1P
DataSource ds = (DataSource) ctx.lookup(jndi); Zy|Mz&
Connection cn = ds.getConnection(); sp@E8G%xO
多用于jsp中 ,K:ll4{b
2、执行sql语句 PrudhUI^
1)用Statement来执行sql语句 kId
n6 Wx,
String sql; A
AHt218
Statement sm = cn.createStatement(); J8Yd1.Qj
sm.executeQuery(sql); // 执行数据查询语句(select) }I@L}f5N
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); )DYI
.
2)用PreparedStatement来执行sql语句 "t^URp3
String sql; hJzxbr
<
sql = "insert into user (id,name) values (?,?)"; <hwy*uBrD
PreparedStatement ps = cn.prepareStatement(sql); Fg Lrb#
ps.setInt(1,xxx); WK="J6K5
ps.setString(2,xxx); w.&1%X(k
... ',GS#~
ResultSet rs = ps.executeQuery(); // 查询 4t)%<4
int c = ps.executeUpdate(); // 更新 %pXAeeSY`;
}(egMx;"3J
3、处理执行结果 k</%YKk
查询语句,返回记录集ResultSet s?ko?qN(
更新语句,返回数字,表示该更新影响的记录数 $T :un.TM
ResultSet的方法 -l%J/ :
1、next(),将游标往后移动一行,如果成功返回true;否则返回false S(\9T1DVe
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 -=.V
'
c)@>zto#
4、释放连接 c5|:,wkx
cn.close(); 0\2\*I}?
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection K\vSB~{[
['%69dPh
可滚动、更新的记录集 VXR]"W=
1、创建可滚动、更新的Statement %lg=YGLQB
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); }E`dZW*!!
该Statement取得的ResultSet就是可滚动的 G;f/Tch
2、创建PreparedStatement时指定参数 {QCf}@_]h
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); d|T!v
ResultSet.absolute(9000); gocrjjAHk
批量更新 "*,XL
uv>
1、Statement QXF
aAb=(7
Statement sm = cn.createStatement(); tDr#H!2
3
sm.addBatch(sql1); K-&V,MI
sm.addBatch(sql2); t%530EB3
... )P7)0c
sm.executeBatch() _0gKK2
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 _gD
pKEaY
2、PreparedStatement
&YDK (&>
PreparedStatement ps = cn.preparedStatement(sql); JsO
*1{6g
{ iMfngIs |
ps.setXXX(1,xxx); XJ2^MF2BU
... \;rYo.+
ps.addBatch(); 3=W!4
} 9o>8o
ps.executeBatch(); 5wUUx#
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 ?8W("W
t<n"-Tqu
事务的处理 .(Qx{r$
1、关闭Connection的自动提交 ,RN:^5 p
cn.setAutoCommit(false); p">EHWc}D
2、执行一系列sql语句 w1UA?+43
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close j[Uxa
Statement sm ; 7<H
|QL&
sm = cn.createStatement(insert into user...); LHJ":^
sm.executeUpdate(); ~Y.tz`2D
sm.close(); o!Rd ^
sm = cn.createStatement("insert into corp...); 'Wa,OFd\8
sm.executeUpdate(); tl'n->G>v
sm.close(); C{2xHd/*
3、提交 qYhs|tY)
cn.commit(); OM{WI27
4、如果发生异常,那么回滚 Jjl`_X$CB
cn.rollback();