java 数据库基本操作 7.hBc;%2u
1、java数据库操作基本流程 \{ @m
2、几个常用的重要技巧: TQT3]h6
可滚动、更新的记录集 =G:Krc8w@
批量更新 b^$`2m-?@f
事务处理 rJpr;QKf%
]
#@:VR
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 lH4Nbluc^
1、取得数据库连接 (Lgea
1)用DriverManager取数据库连接 (<eLj Q
例子 &))d],tJX
String className,url,uid,pwd; 1 %P-X!
className = "oracle.jdbc.driver.OracleDriver"; -lhIL}mGf
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; CW+kKN
uid = "system"; $&as5z8
pwd = "manager"; @KTuG ?.
Class.forName(className); tTy !o=
Connection cn = DriverManager.getConnection(url,uid,pwd); 9r].rzf9
2)用jndi(java的命名和目录服务)方式 <R7{W"QTA)
例子 O`~#X w
String jndi = "jdbc/db"; #"N60T@
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); v0\l~_|H
DataSource ds = (DataSource) ctx.lookup(jndi); .t_t)'L
Connection cn = ds.getConnection(); A3a/ /e
多用于jsp中 jsN[Drr a
2、执行sql语句 P\j\p
=
1)用Statement来执行sql语句 '5BD%#[
String sql; r tuaU=U
Statement sm = cn.createStatement(); 1,wcf,
sm.executeQuery(sql); // 执行数据查询语句(select) V'&;r'#O
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); e_=K0fFz
2)用PreparedStatement来执行sql语句 sG`x |%t
String sql; ab2FK
sql = "insert into user (id,name) values (?,?)"; |SkQe[t
PreparedStatement ps = cn.prepareStatement(sql); MT-Tt
ps.setInt(1,xxx); L]kBY2c
ps.setString(2,xxx); duG3-E
... {$^'oRk
ResultSet rs = ps.executeQuery(); // 查询 qPQIcJ
int c = ps.executeUpdate(); // 更新 M@cFcykK
Kv|
x
-_7
3、处理执行结果 n5$#M
查询语句,返回记录集ResultSet /3ohm|!rW
更新语句,返回数字,表示该更新影响的记录数 62sl6WWS3
ResultSet的方法 =-2~>B
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ~!$"J}d}<
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 3ay},3MCV%
EV?}oh"x
4、释放连接 gK rUv0&F
cn.close(); .?45:Ey~g
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 7 9tE
<o%T]
可滚动、更新的记录集 fQfn7FaW_\
1、创建可滚动、更新的Statement $%~JG(
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); <8:h%%$?
该Statement取得的ResultSet就是可滚动的 aD: #AmbJ
2、创建PreparedStatement时指定参数 uN`/&_$c
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); x"b'Pmw
ResultSet.absolute(9000); 0fOhCxtL@
批量更新 oai=1vt@
1、Statement MKBDWLCB
Statement sm = cn.createStatement(); 36=aahXd\
sm.addBatch(sql1); AQ'%}(#0
sm.addBatch(sql2); ]DVr-f
~
... J'%i?cuV
sm.executeBatch() u}5CzV `
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 @su<h\)
2、PreparedStatement ME)Tx3d
PreparedStatement ps = cn.preparedStatement(sql); .ck?JXg
{ I\mF dE
ps.setXXX(1,xxx); WE) *~5
... 5NhFjPETr
ps.addBatch(); /s4~Ij`be
} XKWq{,Ks
ps.executeBatch(); yx]9rD1cz
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 Y^+x<
*JJ8\R&P0
事务的处理 p\&O;48=
1、关闭Connection的自动提交 {+67<&g
cn.setAutoCommit(false); B\Nbt!Ps
2、执行一系列sql语句 >.
K
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close vJ&_-CX
Statement sm ; 0/GBs~P
sm = cn.createStatement(insert into user...); Lwl1ta-
sm.executeUpdate(); $*0-+h
sm.close(); IJ Jp5[w
sm = cn.createStatement("insert into corp...); qZd*'ki<
sm.executeUpdate(); @ VWED
sm.close(); -pC'C%Q
3、提交 \bARp z?a
cn.commit(); @62,.\F
4、如果发生异常,那么回滚 Pxr/*X
cn.rollback();