java 数据库基本操作 6\,DnO
1、java数据库操作基本流程 z'?7]C2b
2、几个常用的重要技巧: Mvy6"Q:
可滚动、更新的记录集 iUeV5cB
批量更新 <=;H[}
e
事务处理 Y|%anTP
o,S!RG&
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 jzl?e[qPA
1、取得数据库连接 *F\T}k7
1)用DriverManager取数据库连接 vF9*tK'
例子 ]>
nPqL
String className,url,uid,pwd; h^o+E2<]
className = "oracle.jdbc.driver.OracleDriver"; F^.om2V|9
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; t{/:( Nu
uid = "system"; 4*0:bhhhf_
pwd = "manager"; 0V<Aub[${
Class.forName(className); tt+>8rxF:;
Connection cn = DriverManager.getConnection(url,uid,pwd); TqS2!/jp
2)用jndi(java的命名和目录服务)方式 m0=cMVCA!
例子 :dc"b?Ch
String jndi = "jdbc/db"; A#v|@sul
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); D ?Nd; [
DataSource ds = (DataSource) ctx.lookup(jndi); zW%>"y
Connection cn = ds.getConnection(); ^y&q5p jj
多用于jsp中 vC)"*wYB{
2、执行sql语句 p&i.)/
1)用Statement来执行sql语句 a$ C2}
String sql; B3y?.
Statement sm = cn.createStatement(); y]yine
sm.executeQuery(sql); // 执行数据查询语句(select) bH'S.RWp=
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); If~95fy~c
2)用PreparedStatement来执行sql语句 >%9^%p^
String sql; SV$nyV
sql = "insert into user (id,name) values (?,?)"; W*YxBn4
PreparedStatement ps = cn.prepareStatement(sql); ooTc/QEYi
ps.setInt(1,xxx); 7n\ ThfH{
ps.setString(2,xxx); Z7JKaP9{:
... y\^@p=e
ResultSet rs = ps.executeQuery(); // 查询 c*N50%=4
int c = ps.executeUpdate(); // 更新 x1t{SQ-C
v2Dt3$@H6
3、处理执行结果 )D:9R)m
查询语句,返回记录集ResultSet S4L-/<s[*
更新语句,返回数字,表示该更新影响的记录数 q}#iV$dAj
ResultSet的方法 MQwIPjk8
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ^ Xm/
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ( V$Zc0
sB?2*S"X)<
4、释放连接 qOW#Q:T
cn.close(); t(}/g
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection *%:@
cbF-M
hdo&\Q2D8
可滚动、更新的记录集 n%F-cw
1、创建可滚动、更新的Statement 0z<H(|
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); gh TcB
该Statement取得的ResultSet就是可滚动的 `&7mHa61
2、创建PreparedStatement时指定参数 K'x4l,rq
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); wz|DT3"Xs
ResultSet.absolute(9000); }x]&L/
批量更新 ( :
1、Statement @zo7.'7P
Statement sm = cn.createStatement(); cI2Fpf`2Wj
sm.addBatch(sql1); 1hR
(N
sm.addBatch(sql2); ar Q)%W
... E_~x==cb
sm.executeBatch() |z:Q(d06
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 tE[H8
2、PreparedStatement os[ZIHph
PreparedStatement ps = cn.preparedStatement(sql); M ~als3
{ ,"B?_d6
ps.setXXX(1,xxx); yk<VlS
... Nu@5 kwH
ps.addBatch(); 7skljw(
} >W
r$Y{
ps.executeBatch(); J7:9_/e0T
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 b \:~ ;
)Nbc/nB$
事务的处理 Kv}k*A% S
1、关闭Connection的自动提交 N&"QKd l
cn.setAutoCommit(false); U2bzUxK
2、执行一系列sql语句 S`=n&'
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close EJ`Q8uz
Statement sm ; |k6Ox*
sm = cn.createStatement(insert into user...); #EJP(wXa
sm.executeUpdate(); )Ob]T{GY
sm.close(); kae2 73"
sm = cn.createStatement("insert into corp...); ]BfS270
sm.executeUpdate(); J_PH7Z*=,
sm.close(); j9:/RJS
3、提交 z$|;-u|
cn.commit(); |H
W(
vA
4、如果发生异常,那么回滚 :N2E}hxk
cn.rollback();