java 数据库基本操作 XD
5n]AL
1、java数据库操作基本流程 Nuo^+z
E
2、几个常用的重要技巧: EoKo
可滚动、更新的记录集 '(T mV#3
批量更新 y,V6h*x2
事务处理 {=qEBbM
(HPz
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 \*Ts)EW
1、取得数据库连接 {x9j_/R
1)用DriverManager取数据库连接 F$[)Bd /"
例子 pbPz$Y
String className,url,uid,pwd; a^(2q{*
className = "oracle.jdbc.driver.OracleDriver"; _TrZ'iL}T
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; :q(D(mK
uid = "system"; f&f`J/(
pwd = "manager"; WqR7uiCi
Class.forName(className); el}hcAY/RP
Connection cn = DriverManager.getConnection(url,uid,pwd); X:U=MWc>
2)用jndi(java的命名和目录服务)方式 u |'8a1
例子 k?<i*;7
String jndi = "jdbc/db"; ma1(EJ/
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ~};]k }
DataSource ds = (DataSource) ctx.lookup(jndi); )=y.^@UT@
Connection cn = ds.getConnection(); $,.3&zsy
多用于jsp中 $.``OxJk%
2、执行sql语句 [#IBYJ.6
1)用Statement来执行sql语句 [;*\P\Xih
String sql; 40R"^*
Statement sm = cn.createStatement();
\|blRm;
sm.executeQuery(sql); // 执行数据查询语句(select) WFRsSp2
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ~m!#FTc*
2)用PreparedStatement来执行sql语句 :MK:TJV
String sql; 1E8$% 6VV
sql = "insert into user (id,name) values (?,?)"; uL
bp.N8
PreparedStatement ps = cn.prepareStatement(sql); 6={IMkmA
ps.setInt(1,xxx); re]%f"v:5
ps.setString(2,xxx); Ndo}Tk!
... J_|7$
l/
ResultSet rs = ps.executeQuery(); // 查询 axOi5
int c = ps.executeUpdate(); // 更新 $y8mK|3.3u
&ycjSBK
3、处理执行结果 w<Zdq}{jO
查询语句,返回记录集ResultSet !X%S)VSMU
更新语句,返回数字,表示该更新影响的记录数 ZT r:xX{R6
ResultSet的方法 Wa(W&]
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 7qpzk7X?pR
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 9z+vFk`
0,:iE\
4、释放连接 JIVo=5c}
cn.close(); +I*k0"gj6
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection h]<GTWj
_cR6ik zW(
可滚动、更新的记录集 eR7qE) h
1、创建可滚动、更新的Statement ?0 HR(N(z!
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Pa3{Ds
该Statement取得的ResultSet就是可滚动的 L7X7Zt8%
2、创建PreparedStatement时指定参数
0K&_D)
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ejP,29
ResultSet.absolute(9000); >y]?MGk
批量更新 xT:qe
1、Statement ;&RUE
Statement sm = cn.createStatement(); pi|\0lH6W
sm.addBatch(sql1); iK ohuZr
sm.addBatch(sql2); ]U_5\$
... p 7
,f6kG
sm.executeBatch() 3gC\{y!8
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 dv}8YH["
2、PreparedStatement TViBCed40
PreparedStatement ps = cn.preparedStatement(sql); {F<)z%^
{ kZJt~}
ps.setXXX(1,xxx); eH ;Wfs2f
... o^8*aH)I>Y
ps.addBatch(); f;e_04K
} :x8Jy4L
ps.executeBatch(); =g/4{IL%
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 d#E(~t(^
-K:yU4V
事务的处理 I).=v{@9V<
1、关闭Connection的自动提交 >?^~s(t
cn.setAutoCommit(false); :uOZjEZi
2、执行一系列sql语句 z`c%?_EK
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close yb[{aL^4%
Statement sm ; SCgyp(
sm = cn.createStatement(insert into user...); _2NN1/F5
sm.executeUpdate(); ,.~
W
sm.close(); C/SapX
sm = cn.createStatement("insert into corp...); sGXp}{E9
sm.executeUpdate(); uCY(:;[<
sm.close(); F~tm`n8Z
3、提交 @~JB\j9
cn.commit(); P]|J?$1K
4、如果发生异常,那么回滚 R1II k
cn.rollback();