java 数据库基本操作 4_E{
1、java数据库操作基本流程 \WnI&nu
2、几个常用的重要技巧: 32r2<QrX
可滚动、更新的记录集 >t,BNsWB
批量更新 EhkvC>y
事务处理 h$Z_r($b
ix<sorR H
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 k#I4^
1、取得数据库连接 S'NZb!1+
1)用DriverManager取数据库连接 .&AS-">Z
例子 w~eF0{h
String className,url,uid,pwd; QGYO{S
className = "oracle.jdbc.driver.OracleDriver"; ?X1vU0c
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; uj_ OWre
uid = "system"; ~@x@uY$5
pwd = "manager"; %8 )GuxG*
Class.forName(className); xbFoXYqgP
Connection cn = DriverManager.getConnection(url,uid,pwd); ZLBv\VQ
2)用jndi(java的命名和目录服务)方式 )2|'`
例子 Ub%al
D
String jndi = "jdbc/db"; o!`.LL%
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); !}D!_z,)u
DataSource ds = (DataSource) ctx.lookup(jndi); +)#d+@-
Connection cn = ds.getConnection(); P~V0<$C
多用于jsp中 0jsU^m<g
2、执行sql语句 _y q"F#,*
1)用Statement来执行sql语句 >;N0( xB
String sql; 3le/(=&1
Statement sm = cn.createStatement(); ,!BiB*
sm.executeQuery(sql); // 执行数据查询语句(select) h\k!X/
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); T [
`t?,
2)用PreparedStatement来执行sql语句 Q7X6OFl?
String sql; ?8g[0/
sql = "insert into user (id,name) values (?,?)"; 7-"ml\z
PreparedStatement ps = cn.prepareStatement(sql); \$o!M1j
ps.setInt(1,xxx); uFM]4v3
ps.setString(2,xxx); uUUj?%
... T-)Ur/qp
ResultSet rs = ps.executeQuery(); // 查询 @;iW)a_M
int c = ps.executeUpdate(); // 更新 KJ]:0'T
\Gh]$sp
3、处理执行结果 N@$g"w
查询语句,返回记录集ResultSet +1j@n.)ft
更新语句,返回数字,表示该更新影响的记录数 [-)N}rL>
ResultSet的方法 (Yz EsY
1、next(),将游标往后移动一行,如果成功返回true;否则返回false _cqBp7
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 1us-ootsjP
yIBT*,4
4、释放连接 n&Q{
[E
cn.close(); *Z! #6(G
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection Fi+v:L|
bq/*99``
可滚动、更新的记录集 =@U~sl[
1、创建可滚动、更新的Statement 7]t$t3I`
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); x |
=
该Statement取得的ResultSet就是可滚动的 HtUFl
2、创建PreparedStatement时指定参数 };[~>Mzl
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); | I_,;c
ResultSet.absolute(9000); TSHsEcfO
批量更新 e&G!5kz!
1、Statement B w1ir
Statement sm = cn.createStatement(); Om%{fq&
sm.addBatch(sql1); LXr
yv;H
sm.addBatch(sql2); jTbJL
... _RT3Fk
sm.executeBatch() CQf!<
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 cXx?MF5
2、PreparedStatement e_Na_l]
PreparedStatement ps = cn.preparedStatement(sql); EQDsbG0x
{ c"w}<8
ps.setXXX(1,xxx); [hs_HYqJ
... TAbd[:2{F
ps.addBatch(); CeD O:J=,
} pqmS
w
ps.executeBatch(); ) -+u8#
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 {_0m0
8
H#IJ&w|
事务的处理 `+_UG^aeW
1、关闭Connection的自动提交 -lr)z=})
cn.setAutoCommit(false); eMk?#&a)
2、执行一系列sql语句 6eSc`t&
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 8_8r{a<xW
Statement sm ; 8X":,s!
sm = cn.createStatement(insert into user...); ;Wa4d`K
sm.executeUpdate(); aZt5/|B
sm.close(); VG*Tdaua~
sm = cn.createStatement("insert into corp...); C~PrIM?
sm.executeUpdate(); lf4V;|!^
sm.close(); ~|e?@3_G
3、提交 RG [*:ReB9
cn.commit(); OOy]:t4 /
4、如果发生异常,那么回滚 .
:Q[Z
cn.rollback();