java 数据库基本操作 6cdMS[_SD(
1、java数据库操作基本流程 ExSO|g]%
2、几个常用的重要技巧: FP#FB$eP
可滚动、更新的记录集 uNHdpni
批量更新 4Hb $0l
事务处理 aup6?'G;
dI*'!wK
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 1`LXz3uBe
1、取得数据库连接
0G <hn8>
1)用DriverManager取数据库连接 KtB!"yy#
例子 R0;efD
String className,url,uid,pwd; )9B:wc"
className = "oracle.jdbc.driver.OracleDriver"; G~wF nl%
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; HPQ/~0$
uid = "system"; %d m-?`
pwd = "manager"; 1|ZhPsD.}g
Class.forName(className); h{}mBQl
Connection cn = DriverManager.getConnection(url,uid,pwd); [pg}S#A
2)用jndi(java的命名和目录服务)方式 |!H?+Jj:
例子 #fs|BV
!
String jndi = "jdbc/db"; {%.Lk'#9
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); joa5|t!D9
DataSource ds = (DataSource) ctx.lookup(jndi); QM5 .f+/
Connection cn = ds.getConnection(); Ch_xyuJ
多用于jsp中 SQWafD
2、执行sql语句 J4tcQ
1)用Statement来执行sql语句 a$9A(Pte
String sql; r7]"?#
Statement sm = cn.createStatement(); y^Vw`-e
sm.executeQuery(sql); // 执行数据查询语句(select) 1ndJ+H0H
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); kax\h
2)用PreparedStatement来执行sql语句 Jqr)V2Y
String sql; bm}6{28R
sql = "insert into user (id,name) values (?,?)"; ~%ozgzr^
PreparedStatement ps = cn.prepareStatement(sql); 9
L?;FY)_
ps.setInt(1,xxx); %8)W0WMe
ps.setString(2,xxx); 2 ?|gnbE:
... td{O}\s7D
ResultSet rs = ps.executeQuery(); // 查询 ~%#mK:+
int c = ps.executeUpdate(); // 更新 `C_'|d<HA
K{cbn1\,H
3、处理执行结果 ?@R")$
查询语句,返回记录集ResultSet YCy2 2@C
更新语句,返回数字,表示该更新影响的记录数 8I+d)(:
ResultSet的方法 g):]'
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ?Qqd "=k4
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 K(T\9J.
'GJVWpvUU
4、释放连接 Ep ~wWQh
cn.close(); 0{^H]Y
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection %*z-PT22
mzD^Y<LTd
可滚动、更新的记录集 8cm@a*2%
1、创建可滚动、更新的Statement 2GWDEgI1o
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); b^`AJK
该Statement取得的ResultSet就是可滚动的 ohc1 ~?3b
2、创建PreparedStatement时指定参数 XidxNPz0^
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); {hqAnZ@]vr
ResultSet.absolute(9000); F9XT
lA
批量更新 X1A<$Am1
1、Statement b
X)|MiWI
Statement sm = cn.createStatement(); ~!+ _[uJ
sm.addBatch(sql1); ?M6ag_h3
sm.addBatch(sql2); ~fzuwz
... }Ia 0"J4
sm.executeBatch() H5nS%D
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 !0 Q8iW:
2、PreparedStatement xi'<y
PreparedStatement ps = cn.preparedStatement(sql); 8NimZ(
{ lQ*eH10H
ps.setXXX(1,xxx); 7w58L:)B.
... TYjA:d9YH
ps.addBatch(); =qoRS0Qa
} 2H[)1|]l
ps.executeBatch(); ^uaFg`S
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 0,FC
YTtj$
\gccQig1CJ
事务的处理 }fIqH4bp
1、关闭Connection的自动提交 ;vO@m!h}U
cn.setAutoCommit(false); 6~5$s1Yc
2、执行一系列sql语句 ARL
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close }uX|5&=~f
Statement sm ; kI*Uk M-
sm = cn.createStatement(insert into user...); eZF'Ck y
sm.executeUpdate(); K]N~~*`%`
sm.close(); P#G.lft"O
sm = cn.createStatement("insert into corp...); cfoYnM
sm.executeUpdate(); B}*V%}:)
sm.close(); -G ?%QG`v
3、提交 w;yx<1f
cn.commit(); ]TK=>;&
4、如果发生异常,那么回滚 2eok@1
cn.rollback();