java 数据库基本操作 $s4Wkq
1、java数据库操作基本流程 0l=+$&D
2、几个常用的重要技巧: uK("<u|
可滚动、更新的记录集 sowd`I~
批量更新 4J|t?]ij|E
事务处理 ?f*Q>3S)
3IR
^
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 /({;0I*!i
1、取得数据库连接 B_ja&) !s1
1)用DriverManager取数据库连接 .}k(L4T|=
例子 nx:KoB"ny
String className,url,uid,pwd; FP#FB$eP
className = "oracle.jdbc.driver.OracleDriver"; Y4F6qyP)"
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; 1[E#vdbT
uid = "system"; 4Hb $0l
pwd = "manager"; aup6?'G;
Class.forName(className); w-b' LP
Connection cn = DriverManager.getConnection(url,uid,pwd); Vvt ;
2)用jndi(java的命名和目录服务)方式 Kzb`$CGK
例子 ?(
=p<TUw
String jndi = "jdbc/db"; x1gx$P
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 6*nAo8gl
DataSource ds = (DataSource) ctx.lookup(jndi); Bi~:>X\[^6
Connection cn = ds.getConnection(); spQLG_o,J
多用于jsp中 >r)X:K+I
2、执行sql语句 QC0!p"
1)用Statement来执行sql语句 3Db3xN
String sql; ~P-*}q2J
Statement sm = cn.createStatement(); B/J&l
sm.executeQuery(sql); // 执行数据查询语句(select) |2`"1gt
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); H]\Zn%.#
2)用PreparedStatement来执行sql语句 joa5|t!D9
String sql; QM5 .f+/
sql = "insert into user (id,name) values (?,?)"; Ch_xyuJ
PreparedStatement ps = cn.prepareStatement(sql); s$DrR
ps.setInt(1,xxx); pi@Xkw
ps.setString(2,xxx); fd8!KO
... VW@ x=m
ResultSet rs = ps.executeQuery(); // 查询 t` 8!AhOgc
int c = ps.executeUpdate(); // 更新 p T[gdhc
K"<*a"1I
3、处理执行结果 JR9$.fGJ
查询语句,返回记录集ResultSet )9=(|Lp
更新语句,返回数字,表示该更新影响的记录数 `@`1pOb
ResultSet的方法 4ZC!SgJo
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 64j|}wJ$
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 hzY[
G:
sk2%
4、释放连接 Y'`"9Db
cn.close(); .wK1El{bf
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection Y\+KoR';
[m'CR 4(|
可滚动、更新的记录集 oc{EuW{Ag
1、创建可滚动、更新的Statement [U\(G
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); p"`%
该Statement取得的ResultSet就是可滚动的 d"~(T:=r
2、创建PreparedStatement时指定参数 rrs"N3!aT
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 99OD=pxQ
ResultSet.absolute(9000); x`Fjf/1T*m
批量更新 mzD^Y<LTd
1、Statement uXQ >WI@eF
Statement sm = cn.createStatement(); "DSPPE&[c
sm.addBatch(sql1); 5V-jMB
sm.addBatch(sql2); $R^AEa7
... Q;h3v1GC\P
sm.executeBatch() |@j_2Q,
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 +&ZX$
2、PreparedStatement .~=HgOJ
PreparedStatement ps = cn.preparedStatement(sql); ,smF^l
{ Psa@@'w
ps.setXXX(1,xxx); znZ7*S >6\
... ~# 7wdP
ps.addBatch(); uCzii o`S
} Y:x/!-
ps.executeBatch(); V*65b(q)
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 AxCI 0
PI|`vC|yy&
事务的处理 *]s&8/Gmb
1、关闭Connection的自动提交 ';RI7)<
cn.setAutoCommit(false); x:5dCI
2、执行一系列sql语句
?RD *1
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close . p^xS6e{
Statement sm ; A8?[6^%O|
sm = cn.createStatement(insert into user...); ~U}Mv{y
sm.executeUpdate(); noA-)
sm.close(); .Gb+\E{M
sm = cn.createStatement("insert into corp...); *j*Du+
sm.executeUpdate(); 45}v^|Je\
sm.close(); s&*yk p
3、提交 BIWD/|LQ
cn.commit(); qeaA&(|5
4、如果发生异常,那么回滚 @?&Wm3x9
cn.rollback();