java 数据库基本操作 KN|<yF
1、java数据库操作基本流程 &[-(=43@
2、几个常用的重要技巧: 11yXI[
可滚动、更新的记录集 1W{N6+u
批量更新 El<*)
事务处理 Q p>b
A%.mIc.
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 l}z<q
1、取得数据库连接 Dd5
9xNKm
1)用DriverManager取数据库连接 4$&l`yWU+
例子 /=/Ki%hh
String className,url,uid,pwd; )FQ"l{P
className = "oracle.jdbc.driver.OracleDriver"; @=VxWU
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; M-"j8:en
uid = "system"; _K~h?
\u
pwd = "manager"; lWId
0eNS
Class.forName(className); eA4:]A"
Connection cn = DriverManager.getConnection(url,uid,pwd); +Ua|0>?
2)用jndi(java的命名和目录服务)方式 F$?Ab\#B
例子 ;yt6Yp.6e
String jndi = "jdbc/db"; ?N<My&E
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ;9T}h2^`B
DataSource ds = (DataSource) ctx.lookup(jndi); %f1%9YH
Connection cn = ds.getConnection(); h$l/wn
多用于jsp中 }%jF!d
2、执行sql语句 R#d~a;j
1)用Statement来执行sql语句 V|MGG
String sql; ={:a
N)
Statement sm = cn.createStatement(); .Ix3wR9
sm.executeQuery(sql); // 执行数据查询语句(select) X=$Jp.
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); _AX9Mu]
2)用PreparedStatement来执行sql语句 'V:Q :
String sql; /88s~=
sql = "insert into user (id,name) values (?,?)"; 6^"QABc
PreparedStatement ps = cn.prepareStatement(sql); w==BSH[
ps.setInt(1,xxx); 4!Js="
ps.setString(2,xxx); %hnBpz
... r<+C,h;aww
ResultSet rs = ps.executeQuery(); // 查询 k5S;G"iJ
int c = ps.executeUpdate(); // 更新 2!/Kt
O)i^
wGArR7r
3、处理执行结果 LlQsc{Ddf
查询语句,返回记录集ResultSet 6L<:>55
更新语句,返回数字,表示该更新影响的记录数 3^o(\=-JX
ResultSet的方法 k6Kc{kY
1、next(),将游标往后移动一行,如果成功返回true;否则返回false fc9;ZX7
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 Ap
dXsL
R{#< NE
4、释放连接 l$;"yVdks
cn.close(); 9* )&hhBs,
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection dEoIVy _9R
c|Ivet>3
可滚动、更新的记录集 nj[TTndJt
1、创建可滚动、更新的Statement `>:5[Y
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ;}46Uc#WS
该Statement取得的ResultSet就是可滚动的 +94)BxrY
2、创建PreparedStatement时指定参数 &bsq;)wzs
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); xo"GNFh!
ResultSet.absolute(9000); cfLLFPhv)
批量更新 @k?vbq
1、Statement Xul`>8y|
Statement sm = cn.createStatement(); &uNec(c
sm.addBatch(sql1); 7*5B
sm.addBatch(sql2); @Po5AK3cy
... pp"X0
sm.executeBatch() ]at$ohS
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 5p0~AN)
2、PreparedStatement tDK@?PfKz
PreparedStatement ps = cn.preparedStatement(sql); Q]k<Y
{ B5lwQp]
ps.setXXX(1,xxx); <XdnVe1
... [RyVR
ps.addBatch(); Cy~ IB [
} ;,4*uU'vq
ps.executeBatch(); fzSkl`K}
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 /7AHd ;
BPY7O
事务的处理 ;KL7SM%g4
1、关闭Connection的自动提交 D#g-mqar:
cn.setAutoCommit(false); E'QAsU8pP
2、执行一系列sql语句 -+".ut:R
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close I\@r~]+y
Statement sm ; *QC6zJ
sm = cn.createStatement(insert into user...); wNf:_^|}
sm.executeUpdate(); UUt"8]@[
sm.close(); yZleots1
sm = cn.createStatement("insert into corp...); dfDjOZSL
sm.executeUpdate(); I5Vn#_q+b
sm.close(); `0d0T~
3、提交 jl,gqMn"V
cn.commit(); / ;`H )
4、如果发生异常,那么回滚 E)v~kC}7.
cn.rollback();