java 数据库基本操作 5G WC
1、java数据库操作基本流程 ' n "n;
2、几个常用的重要技巧: o:RO(oA0?
可滚动、更新的记录集 ]Cc8[ZC
批量更新 od]1:8OF
事务处理 Y^}c+)t
A}0u-W
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 NS^+n4
1、取得数据库连接 PWN$x`h g[
1)用DriverManager取数据库连接 7V;wCm#b
例子 >L88`
String className,url,uid,pwd; C,dRdEB>
className = "oracle.jdbc.driver.OracleDriver"; @t,Y<)U
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; KA]5tVQA
uid = "system"; G\H |\i
pwd = "manager"; K]Z];C#)
Class.forName(className); >Te h ?P
Connection cn = DriverManager.getConnection(url,uid,pwd); [kPF J f
2)用jndi(java的命名和目录服务)方式 2[Bw+<YA`
例子 d/` d:g
String jndi = "jdbc/db"; T2MXwd&l
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); TM`6:5ONv
DataSource ds = (DataSource) ctx.lookup(jndi); b:6e2|xf?
Connection cn = ds.getConnection(); 4mwA o
多用于jsp中 ey) 8q.5
2、执行sql语句 "I^pb.3
1)用Statement来执行sql语句 k(3FT%p
String sql; sKGR28e
Statement sm = cn.createStatement(); ;cW9NS3:
sm.executeQuery(sql); // 执行数据查询语句(select) @"BkLF
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); OC_i,
2)用PreparedStatement来执行sql语句 +Uf+`
String sql; Te&5IB-
sql = "insert into user (id,name) values (?,?)"; ~#9(Q
PreparedStatement ps = cn.prepareStatement(sql); *d,Z?S/
ps.setInt(1,xxx); {~~'
ps.setString(2,xxx); oa8xuFu(n
... 5?C) v}w+
ResultSet rs = ps.executeQuery(); // 查询 P#ot$@1v
int c = ps.executeUpdate(); // 更新 _[ufH*
J I[9c,N
3、处理执行结果 sGFC?1r?\
查询语句,返回记录集ResultSet A$XmO}+
更新语句,返回数字,表示该更新影响的记录数 0z=^_Fb
ResultSet的方法 '645Fr[lg
1、next(),将游标往后移动一行,如果成功返回true;否则返回false WRfhxl
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 B-EDVMu
Vi\kB%
4、释放连接 'jd fUB
cn.close(); Uk= L?t
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection _J33u3v
[5s4Jp$+
可滚动、更新的记录集 OE_A$8L
1、创建可滚动、更新的Statement ];au!
_o
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ?<eH!MHF
该Statement取得的ResultSet就是可滚动的 *odwg$
2、创建PreparedStatement时指定参数 qb7ur;
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); E0<$zP}V}F
ResultSet.absolute(9000); QB#rf='
批量更新 |s*tRag
1、Statement ~ YCZvJ
Statement sm = cn.createStatement(); o_&*?k*
sm.addBatch(sql1); ub=Bz1._
sm.addBatch(sql2); j+QE~L
... tk,Vp3p
sm.executeBatch() A&($X)t
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 <&p0:S7
2、PreparedStatement _q 1E4z
PreparedStatement ps = cn.preparedStatement(sql); @}iY(-V
{ B>,&{ah/5J
ps.setXXX(1,xxx); ,lr\XhO
... =@0/.oSD
ps.addBatch(); qr_:zXsob_
} V[r1bF
ps.executeBatch(); ok<!/"RX$
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 a;[=bp
O2C&XeB:4
事务的处理 $jgEB+
1、关闭Connection的自动提交 \N"=qw^ t
cn.setAutoCommit(false); w2e9Ue~WH
2、执行一系列sql语句 +'QE-#%{=
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close =hDFpb,mr
Statement sm ; m #}%l3$
sm = cn.createStatement(insert into user...); (SGU]@)g
sm.executeUpdate(); rk .tLk
sm.close(); 6F4OISy%3
sm = cn.createStatement("insert into corp...); $kCLS7 *
sm.executeUpdate(); [nG@
3n
sm.close(); %SlF7$
3、提交 kMY1Xb
cn.commit(); UfAN)SE"
4、如果发生异常,那么回滚 Mg76v<mv<
cn.rollback();