java 数据库基本操作 u]#8$M2
1、java数据库操作基本流程 -faw:
2、几个常用的重要技巧: ~ i'C/[P
可滚动、更新的记录集 .-%oDuB5zF
批量更新 ]>*I) H)
事务处理 d#Wn[h$"
2w7@u/OC'
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 9BurjG1k?
1、取得数据库连接 KM@`YV_"g
1)用DriverManager取数据库连接 %\ _h7:
例子 gyg|Tno
String className,url,uid,pwd; 4sQ~&@[Q+
className = "oracle.jdbc.driver.OracleDriver"; Bf(Mot^
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; )#mW7m9M#
uid = "system"; !$XO
U'n
pwd = "manager"; G`WzJS*}v
Class.forName(className); #nDL
Connection cn = DriverManager.getConnection(url,uid,pwd); yEnKUo[
2)用jndi(java的命名和目录服务)方式 2}@*Ki7
例子 KK .cDAR
String jndi = "jdbc/db"; WMA*.$Zi
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); `|NevpXY1
DataSource ds = (DataSource) ctx.lookup(jndi); LVWxd}0
Connection cn = ds.getConnection(); yOM
-;h
多用于jsp中 h!~|6nj
2、执行sql语句 p+5#dbyr
1)用Statement来执行sql语句 %rX\
P
String sql; [L)V(o)v
Statement sm = cn.createStatement(); Z%A<#%
sm.executeQuery(sql); // 执行数据查询语句(select) @Zh8 QI+
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); Y~x`6
2)用PreparedStatement来执行sql语句 a1_o.A
String sql; k0=|10bi
sql = "insert into user (id,name) values (?,?)"; Q!M sy<v
PreparedStatement ps = cn.prepareStatement(sql); >sB=\
ps.setInt(1,xxx); LsUFz_
ps.setString(2,xxx); 739l%u }<
... oRV]p
ResultSet rs = ps.executeQuery(); // 查询 l.yJA>\24I
int c = ps.executeUpdate(); // 更新 Hv+:fr"
Q0_M-^~WT
3、处理执行结果 !zF4 G,W
查询语句,返回记录集ResultSet UU-v;_oP
更新语句,返回数字,表示该更新影响的记录数 }v,W-gA
ResultSet的方法 yqC+P
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ~F=#}6kg_
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 8UlB~fVg
.Wd.)^?
4、释放连接 E)RI!0Ra
cn.close(); :v''"+\
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection ,!8*g[^O
(#CBq
可滚动、更新的记录集 EPR(i#xU
1、创建可滚动、更新的Statement Qdh"X^^
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ~rQ4n9G
该Statement取得的ResultSet就是可滚动的 0 %C!`7
2、创建PreparedStatement时指定参数 U_.n=d ~B
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); k_-vT
ResultSet.absolute(9000); 56VE[G
批量更新 lu<Np9/5<
1、Statement {8ld:ZP
Statement sm = cn.createStatement(); `*|LI
sm.addBatch(sql1); H@Kl
sm.addBatch(sql2); hVROzGZk
... k?z
[hZg0
sm.executeBatch() X*43!\
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 %kaTQ"PB
2、PreparedStatement aEV|>K=6Y'
PreparedStatement ps = cn.preparedStatement(sql); p]X!g
{ xuw//F
ps.setXXX(1,xxx); <x.]OZgO
... ^Osd/g
ps.addBatch(); =]2
b8
} l;.[W|
ps.executeBatch(); $@lq}FQ%
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 U1OLI]P
O1l4gduN|i
事务的处理 e_;%F`
1、关闭Connection的自动提交 '|h./.K
cn.setAutoCommit(false); #mi0x06
2、执行一系列sql语句 uKaf{=*
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 7H/!rx
Statement sm ; @#G6z`,
sm = cn.createStatement(insert into user...); v3iDh8.__
sm.executeUpdate(); KE }o
sm.close(); ]QjXh>
sm = cn.createStatement("insert into corp...); "E4i >g
sm.executeUpdate(); 7"h=MB_
sm.close(); ;D%5 nnr
3、提交 0e[ tKn(
cn.commit(); L|dab{9
4、如果发生异常,那么回滚 WW,r9D:/
cn.rollback();