java 数据库基本操作 9CWezI+
1、java数据库操作基本流程 &&8IU;J
2、几个常用的重要技巧: VKG&Y_7N
可滚动、更新的记录集 ijK"^4i
批量更新 <(fRn`)PT
事务处理 }o?AP vd
oldA#sA$
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 eoG$.M"
1、取得数据库连接 |Sy<@oq
1)用DriverManager取数据库连接 )I^7)x
例子 87
$dBb{
String className,url,uid,pwd; .yqM7U_
className = "oracle.jdbc.driver.OracleDriver"; f=r<nb'H
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; -~v2BN/
uid = "system"; %4,O 2\0?&
pwd = "manager"; pm
9"4 z
Class.forName(className); YA_c
N5p/@
Connection cn = DriverManager.getConnection(url,uid,pwd); 9CWF{"
2)用jndi(java的命名和目录服务)方式 iXVe.n
例子 1AM!8VR2
String jndi = "jdbc/db"; *U,@q4
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); :*Z4yx
DataSource ds = (DataSource) ctx.lookup(jndi); 4gz
H8sF
Connection cn = ds.getConnection(); d"*uBVzXm
多用于jsp中 }Mp:JPH&S4
2、执行sql语句
H Y&DmE
1)用Statement来执行sql语句 [S9K6%w_!
String sql; Mh:L$f0A%O
Statement sm = cn.createStatement(); l3Q(TH ~I
sm.executeQuery(sql); // 执行数据查询语句(select) 6z#acE1)M
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); p'*>vk
2)用PreparedStatement来执行sql语句 G\Cp7:j}
String sql; Eg#K.5hJ
sql = "insert into user (id,name) values (?,?)"; wnEyl[ac
PreparedStatement ps = cn.prepareStatement(sql); 8pIP
ps.setInt(1,xxx); lm-dW'7&
ps.setString(2,xxx); |Mup8(gCk
... [B#R94
ResultSet rs = ps.executeQuery(); // 查询 'MUv5Th
int c = ps.executeUpdate(); // 更新 m.#
VYN`+A
bYpntV
3、处理执行结果 hKLCJ#T
查询语句,返回记录集ResultSet |,gc_G
更新语句,返回数字,表示该更新影响的记录数 2Mc3|T4)U
ResultSet的方法 1PQ~jfGi
1、next(),将游标往后移动一行,如果成功返回true;否则返回false nYR#
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 Wz49i9e+d
V3Q+s8OIF
4、释放连接 bMg(B-uF7
cn.close();
-D
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection !;Yg/'vD-
eg\v0Y!rI
可滚动、更新的记录集 cl[BF'.H
1、创建可滚动、更新的Statement >z{d0{\
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); XHK<AO^
该Statement取得的ResultSet就是可滚动的 }Jy8.<Gd^
2、创建PreparedStatement时指定参数 5cL83FQh
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); LrM=*Rh,O
ResultSet.absolute(9000); DCIxRPw
批量更新 B(LWdap~
1、Statement S;3R S;
Statement sm = cn.createStatement(); /YP{,#p
sm.addBatch(sql1); J>wt(] y
sm.addBatch(sql2); NO "xL,
... nBjqTud
sm.executeBatch() v5!d$Vctu
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 +7D|4
2、PreparedStatement 0=@?ob7
PreparedStatement ps = cn.preparedStatement(sql); bv]`!g:
C
{ S!jTyY7e
ps.setXXX(1,xxx); /32Fy`KV
... X@+{5%
ps.addBatch(); A-Sv;/yD_
} L-jJg,eY
ps.executeBatch(); h58`XH
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 Zd^rNHhA
,&]S(|2%>t
事务的处理 rdl;M>0@
1、关闭Connection的自动提交 y I HXg#
cn.setAutoCommit(false); AK,J 7
2、执行一系列sql语句 Su
586;\
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close #I{h\x><?
Statement sm ; PWaw]*dFmy
sm = cn.createStatement(insert into user...); gn8R[5:!V
sm.executeUpdate(); FcR=v0),
sm.close(); T6O::o6
sm = cn.createStatement("insert into corp...); |% F=po>w
sm.executeUpdate(); 3KRd
sm.close(); b3&zjjQ
3、提交 Y>|B;Kj0(
cn.commit(); l4 D+Y
4、如果发生异常,那么回滚 ?{P"O!I{
cn.rollback();