java 数据库基本操作 w~1K93/p!
1、java数据库操作基本流程 <5q:mG88
2、几个常用的重要技巧: dNbN]gHC
可滚动、更新的记录集 .dl1sv
U
批量更新 V4xZC\)Gk
事务处理 Xhi9\wteYw
(R Ttz
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ?p6+?\H
1、取得数据库连接 8Zwq:lV Q
1)用DriverManager取数据库连接 dG6Mo76
例子 Mi:$<fEX
String className,url,uid,pwd; [NH[n#
className = "oracle.jdbc.driver.OracleDriver"; ZW*"Kok
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; W;u~}k<
uid = "system"; +tl THK
pwd = "manager"; a0y;c@pkO
Class.forName(className); VNA VdP
Connection cn = DriverManager.getConnection(url,uid,pwd); o6oZk0
2)用jndi(java的命名和目录服务)方式 Rl$NiY?2
例子 ud!iy
String jndi = "jdbc/db"; y%3Yr?]
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); [@.%6aD
DataSource ds = (DataSource) ctx.lookup(jndi); Qt!l-/flh
Connection cn = ds.getConnection(); uKhfZSx0w
多用于jsp中 JCS$Tm6y<_
2、执行sql语句 Vb0hlJb
1)用Statement来执行sql语句 OTalR;:]r
String sql; ^Cpvh}1#
Statement sm = cn.createStatement(); z\Qg 3BS
sm.executeQuery(sql); // 执行数据查询语句(select) 2NI3&;{4
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); id GM%Faur
2)用PreparedStatement来执行sql语句 UB(Q &U_
String sql; |67<h5Q1
sql = "insert into user (id,name) values (?,?)"; aBol9`6
PreparedStatement ps = cn.prepareStatement(sql); }1Q]C"hY
ps.setInt(1,xxx); &Zq43~
ps.setString(2,xxx); I
gA0RY1
... 2&06Db (
ResultSet rs = ps.executeQuery(); // 查询 yO$]9
int c = ps.executeUpdate(); // 更新 TzerAX^
uFG]8pj2V1
3、处理执行结果 3'*SSZmnOB
查询语句,返回记录集ResultSet m9xO& @#vx
更新语句,返回数字,表示该更新影响的记录数 O`~T:N|D
ResultSet的方法 36.L1!d)pE
1、next(),将游标往后移动一行,如果成功返回true;否则返回false =U3!D;XP
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 k`kmmb>
"-(yZigQ
4、释放连接 ADlPdkmym
cn.close(); n16,u$|
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection zj"J~s;?
[C/h{WPC-
可滚动、更新的记录集 !</5 )B`5:
1、创建可滚动、更新的Statement |.)dOk,o
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); f;
>DM
该Statement取得的ResultSet就是可滚动的 7S 1
Y)
2、创建PreparedStatement时指定参数 9cX
~
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); @yS
ResultSet.absolute(9000); r|6S&Ia>
批量更新
fW|1AUD,
1、Statement MQw{^6Z>1
Statement sm = cn.createStatement(); LW0't}
z
sm.addBatch(sql1); FZb\VUmnV
sm.addBatch(sql2); A2$:p$[
... !,INrl[
sm.executeBatch() ~h tV*R
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 |"vqM)V$
2、PreparedStatement pH'#v]"
PreparedStatement ps = cn.preparedStatement(sql); bU(t5
[
{ W1Ur~x`
ps.setXXX(1,xxx); Kh'/Ne?
... fqFE GyeNr
ps.addBatch(); )m
\}ITf
} ES}@mO
ps.executeBatch(); W}.;]x%1B
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 WF-B=BRZ
doVBV Tk^
事务的处理
O0';j!?X
1、关闭Connection的自动提交 B TgL:
cn.setAutoCommit(false); @T>)fKCg
2、执行一系列sql语句 \oLRNr[F
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close b78'yM&
Statement sm ; L:%;
Fx2
sm = cn.createStatement(insert into user...); M[@).4h
sm.executeUpdate(); (X QgOR#
sm.close(); &
/UcFB
sm = cn.createStatement("insert into corp...); ?L+@?fVN
sm.executeUpdate(); a]BnHLx
sm.close(); D />REC^
3、提交 K zKHC
cn.commit(); b.Z K1
4、如果发生异常,那么回滚 e*Sv}4e=.
cn.rollback();