java 数据库基本操作 4(IP
1、java数据库操作基本流程 Ey%NqOs0#
2、几个常用的重要技巧: mg]dK p
可滚动、更新的记录集 nVD
YAg'
批量更新 WRM}gWv*
事务处理 A/aQpEb%
gQwmYe
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 UkKpSL}Q2
1、取得数据库连接 SO"P3X
1)用DriverManager取数据库连接 ?sE21m?b-
例子 gV BV@v!W
String className,url,uid,pwd; $!w%=
className = "oracle.jdbc.driver.OracleDriver"; voE c'JET
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ny}utO
uid = "system"; 6 [E"
pwd = "manager"; ^u{$$.&
Class.forName(className); +=4b5*+qG
Connection cn = DriverManager.getConnection(url,uid,pwd); 9b6h!(
2)用jndi(java的命名和目录服务)方式 HS9U.G>
例子 1uMdgrJRR
String jndi = "jdbc/db"; {lJpcS
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); } d6^
DataSource ds = (DataSource) ctx.lookup(jndi); 471}'3
Connection cn = ds.getConnection(); *uR'eXW
多用于jsp中 cB^lSmu5
2、执行sql语句 Gx($q;8
1)用Statement来执行sql语句 Sq%R
String sql; vD t?N9
Statement sm = cn.createStatement(); *fZ'#C~x
sm.executeQuery(sql); // 执行数据查询语句(select) g.Q ?Z{
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); |1R@Jz`
2)用PreparedStatement来执行sql语句 >{Q2S
String sql; 3&f{lsLAC
sql = "insert into user (id,name) values (?,?)"; 8pk">"#s
PreparedStatement ps = cn.prepareStatement(sql); ;p8xL)mUP
ps.setInt(1,xxx); \&0NH=*^
ps.setString(2,xxx); >{Djx
... >E3OYa?G
ResultSet rs = ps.executeQuery(); // 查询 *6DKUCA/
int c = ps.executeUpdate(); // 更新 J%'|IwA
t[Q\T0E
3、处理执行结果 AsOI`@FV
查询语句,返回记录集ResultSet ~7g6o^A>
更新语句,返回数字,表示该更新影响的记录数 fsoS!6h0k
ResultSet的方法 SbY i|V,H
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ;7}*Xr|
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 Q>$v~v?9
b._pG(o1
4、释放连接 e6Y0G,K
cn.close(); ]h6<o*
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection tEl_A"^e
}<p%PyM
可滚动、更新的记录集 I]58;|J
1、创建可滚动、更新的Statement L 'y+^L|X
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); %o>1$f]
该Statement取得的ResultSet就是可滚动的 q_bB/
2、创建PreparedStatement时指定参数 E),T,
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); `fXcW)
ResultSet.absolute(9000); rE
8-MB
批量更新 Rd/!CJ@g
1、Statement lCXo+|$?s
Statement sm = cn.createStatement();
Ox RzKT
sm.addBatch(sql1); 2\n6XAQ*
sm.addBatch(sql2); qW*)]s)z
... G8VWx&RE
sm.executeBatch() ! WNr09`
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 }tN"C 3)@
2、PreparedStatement Flsf5 Tr0
PreparedStatement ps = cn.preparedStatement(sql); HXX"B,N
{ TD<. :ul]
ps.setXXX(1,xxx); 3 }XS|Y
... 0:nyOx(;
ps.addBatch(); $|KbjpQ
} iM-@?!WF
ps.executeBatch(); HUH=Y;
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 ;IyQqP#,<
q-'zZ#
事务的处理 8l6R.l
1、关闭Connection的自动提交 j1)w1WY0@
cn.setAutoCommit(false); :7gIm|2"]
2、执行一系列sql语句 {8eNQ-4I
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close _:J!
|'
Statement sm ; q4{ 6@q
sm = cn.createStatement(insert into user...); {.v+ iSM
sm.executeUpdate(); t5S S]
sm.close(); ~_Aclm?
sm = cn.createStatement("insert into corp...); S[Et!gj:
sm.executeUpdate(); /n_N`VJ7H
sm.close(); HjrCX>v
3、提交 lq74Fz&(
cn.commit(); ^c*'O0y[D
4、如果发生异常,那么回滚 s&4Y+dk93
cn.rollback();