java 数据库基本操作 K.>wQA&
1、java数据库操作基本流程 ~@I@} n
2、几个常用的重要技巧: p4X{"Z\mn
可滚动、更新的记录集 =G-N`
39
批量更新 1M%S
gV-#
事务处理 }4%/pOi:f
W^g[L:s
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 H5wb_yBQ+
1、取得数据库连接 i4Z4xTn
1)用DriverManager取数据库连接 >tRHNB_
例子 i6no;}j
String className,url,uid,pwd; =N.!k Vkl
className = "oracle.jdbc.driver.OracleDriver"; _; ]e@
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; }4c/YP"a'E
uid = "system"; 2BB<mv
K4
pwd = "manager"; 8IY19>4'5J
Class.forName(className); ,8K'F
Connection cn = DriverManager.getConnection(url,uid,pwd); 3"
Vd==oK~
2)用jndi(java的命名和目录服务)方式 e (\I_
例子 _Sj}~H
String jndi = "jdbc/db"; ;q#]-^
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); fu\s`W6f&
DataSource ds = (DataSource) ctx.lookup(jndi); iL?iz?+.%@
Connection cn = ds.getConnection(); 6`nR5 fh
多用于jsp中 #ch
2、执行sql语句 ?{J!#`tfV
1)用Statement来执行sql语句 eG]a zt
String sql; wODvc9p}]
Statement sm = cn.createStatement(); hCc0sRp
sm.executeQuery(sql); // 执行数据查询语句(select) lxb 8xY
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); QocQowz
2)用PreparedStatement来执行sql语句 D$Kea
String sql; W3pQ?
sql = "insert into user (id,name) values (?,?)"; H/cTJ9zz
PreparedStatement ps = cn.prepareStatement(sql); h_
!>yK
ps.setInt(1,xxx); c{88m/;eP
ps.setString(2,xxx); d!{7r7ob\
... :\}U9QfCw
ResultSet rs = ps.executeQuery(); // 查询 k
'zat3#f
int c = ps.executeUpdate(); // 更新 ,-#GX{!
`<vxG4=62\
3、处理执行结果 we]>(|
查询语句,返回记录集ResultSet ;El <%{(
更新语句,返回数字,表示该更新影响的记录数 H7IW"UkBR
ResultSet的方法 {7#03 k
1、next(),将游标往后移动一行,如果成功返回true;否则返回false x*8O*!ZZ
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 h
W.2p+
C|e+0aW
4、释放连接 $-G`&oT
cn.close(); F1u)i
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection d/j@_3'
5:gj&jt;)7
可滚动、更新的记录集 QUP|FIpZ
1、创建可滚动、更新的Statement wGXwzU
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); wJIB$3OT
该Statement取得的ResultSet就是可滚动的 Ph)|j&]
2、创建PreparedStatement时指定参数 6v47 QW|'
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); QrS$P09=\
ResultSet.absolute(9000); __)qw#
批量更新 nm):SEkC
1、Statement YOw?'+8
Statement sm = cn.createStatement(); :EB,{|m
sm.addBatch(sql1); "3y} F
sm.addBatch(sql2); k,_i#9X
... `jW4H$D
sm.executeBatch() ZgF/;8!~V-
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 76MsrOv55
2、PreparedStatement 1_3?R}$Wl
PreparedStatement ps = cn.preparedStatement(sql); LZV}U*
{ /yK"t<p
ps.setXXX(1,xxx); @36S}5Oa
... YX;nMyD?~
ps.addBatch(); FzhT$7Gw
} iG-N
ps.executeBatch(); C_-E4I
Z)
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 gM, &Spn
QMb^&?;s
事务的处理 "L_-}BK
1、关闭Connection的自动提交 "?H+
u/8$
cn.setAutoCommit(false); oyQ0V94j
2、执行一系列sql语句 /.ZaE+
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close M:|/ijpN
Statement sm ; 8A/>JD3^
sm = cn.createStatement(insert into user...); 3]S`|#J
sm.executeUpdate();
TcZN%
sm.close(); *gSO&O=
sm = cn.createStatement("insert into corp...); r<_2qICgP
sm.executeUpdate(); "^"'uO$
sm.close(); csvOg[
3、提交
q)oN2-
cn.commit(); E\!n49
4、如果发生异常,那么回滚 !3x*k;0
cn.rollback();