java 数据库基本操作 dvz6
1、java数据库操作基本流程 RGkV%u^
2、几个常用的重要技巧: d|)ARRW
可滚动、更新的记录集 #p]V?
批量更新
n_k`L(8*
事务处理 ~wOMT
jeJspch+#
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 qk>SM|{
1、取得数据库连接 h9!4\{V;h
1)用DriverManager取数据库连接 [9j,5d&m
例子 2|]
<U[
String className,url,uid,pwd; "5'eiYms
className = "oracle.jdbc.driver.OracleDriver"; ,4 q^(
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; 27,c}OS5o
uid = "system"; 3<N2ehi?
pwd = "manager"; {v|ib112;
Class.forName(className); F! Cn'*
Connection cn = DriverManager.getConnection(url,uid,pwd); 7FD,TJs
2)用jndi(java的命名和目录服务)方式 m,J
IId%O
例子 5wha _Yet
String jndi = "jdbc/db"; I+S fZ:q^
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); <#199`R
DataSource ds = (DataSource) ctx.lookup(jndi); RlbJ4`a
Connection cn = ds.getConnection(); D>o u,
多用于jsp中 B&y?Dc
2、执行sql语句 }Kp$/CYd
1)用Statement来执行sql语句 bg_io* K
String sql; Iza;~8dH5
Statement sm = cn.createStatement(); 3orL;(.G
sm.executeQuery(sql); // 执行数据查询语句(select) 5|>ms)[RQ
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); i)$+#N
2)用PreparedStatement来执行sql语句 j]`hy"
String sql; ~D`R"vzw=
sql = "insert into user (id,name) values (?,?)"; }_}
PreparedStatement ps = cn.prepareStatement(sql); bj0<A
ps.setInt(1,xxx); Ciz,1IV
ps.setString(2,xxx); ShvC4Xb 0
... o|c&$)m
ResultSet rs = ps.executeQuery(); // 查询 ?<Hgq8J
int c = ps.executeUpdate(); // 更新 jC$~m#F
O '`|(L
3、处理执行结果 %++S;#)~
查询语句,返回记录集ResultSet 7y42)X
更新语句,返回数字,表示该更新影响的记录数 o?~27
ResultSet的方法 8 nqF i
1、next(),将游标往后移动一行,如果成功返回true;否则返回false qJO6m-
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 -dN`Ok<g
~l.C-
4、释放连接 59v=\; UI
cn.close(); UV av^<_
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection (Q
^=^s|
L; A#N9
可滚动、更新的记录集 DMs8B&Y=
1、创建可滚动、更新的Statement wZbT*rU
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); $sZ4r>-
该Statement取得的ResultSet就是可滚动的 Z#[%JUYp'
2、创建PreparedStatement时指定参数 +ZGH
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); yx6^ mis4
ResultSet.absolute(9000); `[XH=-p
批量更新 0;,Y_61
1、Statement 1vCp<D9<
Statement sm = cn.createStatement(); 0(9gTxdB
sm.addBatch(sql1); Xc^(e?L4
sm.addBatch(sql2); m^0 I3;
... S4_ZG>\VT
sm.executeBatch() +
65<|0
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 TiZ
MY:^
2、PreparedStatement nD)SR
PreparedStatement ps = cn.preparedStatement(sql); Y5B!*+h
{ k6Vs#K7a
ps.setXXX(1,xxx); <{hB&4oL
... 20}]b*C}
ps.addBatch(); Zm|il9y4m
} mo=@Zt
ps.executeBatch(); <7B;_3/
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 /R?*i@rvf
G&MO(r}B
事务的处理 dS \n2Qb
1、关闭Connection的自动提交 3-n&&<
cn.setAutoCommit(false); \$t{K
2、执行一系列sql语句 3[l\l5'm8
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close :D>flZi
Statement sm ; [nX{sM%
sm = cn.createStatement(insert into user...); -;RAW1]}Y$
sm.executeUpdate(); TaKHr$h
sm.close(); eb,QT\/G
sm = cn.createStatement("insert into corp...); ^h#A7 g
sm.executeUpdate(); R$MR|
sm.close(); &hi][Pt
3、提交 +9')G-`qj
cn.commit(); )cZ KB0*+
4、如果发生异常,那么回滚 ^YfAsBs&
cn.rollback();