java 数据库基本操作 ~b3xn T
1、java数据库操作基本流程 @D9c
2、几个常用的重要技巧: .#5<ZAh/?
可滚动、更新的记录集 M4nM%qRGQ
批量更新 v_{`O'#j^
事务处理 BG-uKJ ^
=H>rX
2k
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 #MHnJ
1、取得数据库连接 9 ?MOeOV8
1)用DriverManager取数据库连接 u 6la
例子 gSZNsiH
String className,url,uid,pwd; >kz5azV0
className = "oracle.jdbc.driver.OracleDriver"; V/"0'H\"1
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; /B|#GJ\\3
uid = "system"; #c+N}eX{
pwd = "manager"; KKGAk\X
Class.forName(className); YDi_Gl$
Connection cn = DriverManager.getConnection(url,uid,pwd); oxPOfI1%]
2)用jndi(java的命名和目录服务)方式 v^[tK2&v
例子 .{5)$w>
String jndi = "jdbc/db"; s:*gjoL
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); g}ciG!0
DataSource ds = (DataSource) ctx.lookup(jndi); asQ pVP
Connection cn = ds.getConnection(); z ]o&^Q
多用于jsp中 : 60PO
2、执行sql语句 xb8fV*RO8A
1)用Statement来执行sql语句 m?;)C~[
String sql; o%M~Q<wf
Statement sm = cn.createStatement(); Arir=q^2
sm.executeQuery(sql); // 执行数据查询语句(select) 0Hff/~J
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); H",yVD
2)用PreparedStatement来执行sql语句 rU<
H7U
String sql; x:xKlPGd
sql = "insert into user (id,name) values (?,?)"; Ad@))o2
PreparedStatement ps = cn.prepareStatement(sql); eff6=DP
ps.setInt(1,xxx); ^._)HM
ps.setString(2,xxx); M`BD]{tN}
... 6x*ImhQ.J
ResultSet rs = ps.executeQuery(); // 查询 Mr2dhSQ!
int c = ps.executeUpdate(); // 更新 Fdm7k){A
XXuU@G6Z7$
3、处理执行结果 cX7xG U
查询语句,返回记录集ResultSet >p\IC
更新语句,返回数字,表示该更新影响的记录数 0z#+^
ResultSet的方法 }=s@y"["
1、next(),将游标往后移动一行,如果成功返回true;否则返回false &m>`+uVBP
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 CyzvQfpZr
?.\CUVK
4、释放连接 #q==GT7
cn.close(); IJS9%m#
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection .A\9|sRZ5
fAUtqkB
可滚动、更新的记录集 "uTzmm$
1、创建可滚动、更新的Statement \dIIZSN
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); "h$A. S
该Statement取得的ResultSet就是可滚动的 P8DJv-f`
2、创建PreparedStatement时指定参数 8@6:UR.)
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ^5=}Y>EJO
ResultSet.absolute(9000); 0J@)?,V-.
批量更新 \ts:'
1、Statement G{+sC2
Statement sm = cn.createStatement(); B*Hp
sm.addBatch(sql1); k/?+jb
sm.addBatch(sql2); %
eW>IN]5
... N(t1?R/e,
sm.executeBatch() 0x[vB5R
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ;o%r{:lng
2、PreparedStatement 0RtqqNFD
PreparedStatement ps = cn.preparedStatement(sql); l=
~]MSwY
{ >W.Pg`'D
ps.setXXX(1,xxx); "E/F{6NH
... wF?THkdFo
ps.addBatch(); 0@*rp7
} 72~)bu
ps.executeBatch(); GG(rp]rgl
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 U+~0m!|4
b=K
事务的处理 $Jb+}mlT
1、关闭Connection的自动提交 W zy8
cn.setAutoCommit(false); NkNw9?:#4
2、执行一系列sql语句 Wf0ui1@
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close `@?l{
Statement sm ; ln9MVF'!&
sm = cn.createStatement(insert into user...); ^Bm9yR
sm.executeUpdate(); ^tc@bsUF
sm.close(); {r[*}Bv
sm = cn.createStatement("insert into corp...); WZ6!VE{
sm.executeUpdate(); [g&Q_+,j
sm.close(); 8*>6+"w
3、提交 [7|}h/
cn.commit(); ;op+~@*!
4、如果发生异常,那么回滚 c!{.BgGN
cn.rollback();