java 数据库基本操作 }JpslY*aS
1、java数据库操作基本流程 (-Ct!aW|
2、几个常用的重要技巧: +k(3+b$S-
可滚动、更新的记录集 )R
a/
批量更新 RwE*0 T
事务处理 Cf1wM:K|8
SFk11
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 `9Q,=D+
1、取得数据库连接 5(MZ%-~l
1)用DriverManager取数据库连接 [;V1y`/K1
例子 Er)_[^)
HG
String className,url,uid,pwd; yY@s(:
className = "oracle.jdbc.driver.OracleDriver"; ,0<F3h
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; X?}GPA4 W
uid = "system"; $vbAcWj
pwd = "manager"; BqEubP(si
Class.forName(className); <cfH'~
Connection cn = DriverManager.getConnection(url,uid,pwd); J!K/7uS
2)用jndi(java的命名和目录服务)方式 W1vAK
例子 XpAq=p0;
String jndi = "jdbc/db"; e=F( Zf+1^
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 9snyX7/!L
DataSource ds = (DataSource) ctx.lookup(jndi); '__3[D
Connection cn = ds.getConnection(); ZNH*[[Pf
多用于jsp中 GT\s!D;<
2、执行sql语句 3RH#e1Y
1)用Statement来执行sql语句 f{ 4G
String sql; v[yTk[zd0
Statement sm = cn.createStatement(); ^p- e
sm.executeQuery(sql); // 执行数据查询语句(select) <sWcS; x
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); @tv];t
2)用PreparedStatement来执行sql语句 8hdAXWPn
String sql; 5vh"PlK`s
sql = "insert into user (id,name) values (?,?)"; xMfv&q=k@
PreparedStatement ps = cn.prepareStatement(sql); b=QGbFf
ps.setInt(1,xxx); ";Ig%]
ps.setString(2,xxx); FnQ_=b
... ':R3._tw\
ResultSet rs = ps.executeQuery(); // 查询 ?D^,K`wY=B
int c = ps.executeUpdate(); // 更新 Xx<&6
4W
uA/.4 b
3、处理执行结果 *ZSp9g"Z
查询语句,返回记录集ResultSet A*;^F]~'
更新语句,返回数字,表示该更新影响的记录数 e'?doP
ResultSet的方法 )6R#k8'ERr
1、next(),将游标往后移动一行,如果成功返回true;否则返回false !9<RWNKV)Y
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 =!P?/
Iv|WeSL.
4、释放连接 UG?C=Tf
cn.close(); 5@Lxbe(
q
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 0)Um W{
VU0tyj$
可滚动、更新的记录集 .]ZuG
1、创建可滚动、更新的Statement acju!,G
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Py25k 0j!
该Statement取得的ResultSet就是可滚动的 c'Tu,-
2、创建PreparedStatement时指定参数 7D~O/#dcc
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); =5=Vm[
ResultSet.absolute(9000); y>cmKE
批量更新 w3bH|VnU8;
1、Statement 5NvyK[w]
Statement sm = cn.createStatement(); UV8r&O
sm.addBatch(sql1); 8W<)c
sm.addBatch(sql2); &'ETx"
... QKaj4?p$|S
sm.executeBatch() ut5!2t$c
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 6ewOZ,"j"4
2、PreparedStatement a&c#* 9t{
PreparedStatement ps = cn.preparedStatement(sql); [11-`v0
{ A%w]~ chC9
ps.setXXX(1,xxx); }:D~yEP
... Z
a1|fB
ps.addBatch(); gsR9M%mv
} y=qo-v59'
ps.executeBatch(); n]fbV/ x
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 ]GRq
DUliU8B}\
事务的处理 -r'seb5
1、关闭Connection的自动提交 ~S_IU">E
cn.setAutoCommit(false); (cA|N0
2、执行一系列sql语句 &?Z)V-1H
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close Jx>B %vZ\
Statement sm ; -hR\Y2?
sm = cn.createStatement(insert into user...); m^x\@!N:(
sm.executeUpdate(); q.b4m 'J
sm.close(); PXu<4VF
sm = cn.createStatement("insert into corp...); g!Yh=kA'N
sm.executeUpdate(); pfQZ|*>lkb
sm.close(); *|#JFy?c[
3、提交 tc2GI6]e'
cn.commit(); tP(bRQ>
4、如果发生异常,那么回滚 ee0>B86tE
cn.rollback();