java 数据库基本操作 7oUo [
1、java数据库操作基本流程 eW3?3l`fvt
2、几个常用的重要技巧: _Fv6S}~Q
可滚动、更新的记录集 Oo(xYy
批量更新 NL-PQ%lUA
事务处理 "la0@/n
:*|So5fs
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 P$AHw;n[R
1、取得数据库连接 &A/b9GW^-
1)用DriverManager取数据库连接 eDNY|}$}v
例子 HJ"sK5Q
String className,url,uid,pwd; D( TfW
className = "oracle.jdbc.driver.OracleDriver"; AOL=;z9c#
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; >nK (
uid = "system"; |)O;+e\
pwd = "manager"; oHSDi
Class.forName(className); MDd2B9cy[
Connection cn = DriverManager.getConnection(url,uid,pwd); I7|a,Q^f
2)用jndi(java的命名和目录服务)方式 ev/)#i#s{
例子 Dq!YB[Z$:
String jndi = "jdbc/db"; UN;U+5,t
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); TOSk+2P
DataSource ds = (DataSource) ctx.lookup(jndi); o2]Np~`g,
Connection cn = ds.getConnection(); 94*MRn1E
多用于jsp中 ) 54cG
2、执行sql语句 _x!/40^G
1)用Statement来执行sql语句 }I`o%GL
String sql; *(/b{!~
Statement sm = cn.createStatement(); 4{6,Sx
sm.executeQuery(sql); // 执行数据查询语句(select) o?.VW/"
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); XJS^{=/
2)用PreparedStatement来执行sql语句 Kh&a# ~c
String sql; ?h#F& y
sql = "insert into user (id,name) values (?,?)"; !@ AnwV]
PreparedStatement ps = cn.prepareStatement(sql); F<2gM#jLB
ps.setInt(1,xxx); ^y|`\oyqwN
ps.setString(2,xxx); =ty{ugM<
... <FZ*'F*M
ResultSet rs = ps.executeQuery(); // 查询 bsI?=lO
int c = ps.executeUpdate(); // 更新 a~-k} G5
MfFmJ7>Bg
3、处理执行结果 gMZrtK`<
查询语句,返回记录集ResultSet >k/
rJ[Sc
更新语句,返回数字,表示该更新影响的记录数 = 4'r+2[
ResultSet的方法 z! k
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 7vGAuTfi/@
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 Yc5)
^v
EF 8rh
4、释放连接 w5Ucj*A\
cn.close(); j \ #y
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection w/(2fU (
y{tM|
可滚动、更新的记录集 ,|UwZ_.
1、创建可滚动、更新的Statement $"Ci{iE
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); oMq:4W,
该Statement取得的ResultSet就是可滚动的 ._'.F'd
2、创建PreparedStatement时指定参数 ~"R;p}5"
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ukD:4sv
ResultSet.absolute(9000); 2Aa
批量更新 kCoEdQ_
1、Statement ah!RQ2hDrV
Statement sm = cn.createStatement();
2&o3OKt
sm.addBatch(sql1); jgYe\dinM
sm.addBatch(sql2); YB]^Y^" e
... {qS Ye!`
sm.executeBatch() {qH+S/
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 k)9
pkPl
2、PreparedStatement T^X um2Ec
PreparedStatement ps = cn.preparedStatement(sql); o1&Oug
{ c&SSf_0O*
ps.setXXX(1,xxx); Y#U0g|UDn
... W[73q>'
ps.addBatch(); 7Uh/Gl
} D;DI8.4`N
ps.executeBatch(); dFnu&u"
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 P>*`<$FR
`DP4u\6_
事务的处理 {E1^Wn1M
1、关闭Connection的自动提交 dJ{'b'#
cn.setAutoCommit(false); <Lq.J`|+
2、执行一系列sql语句 9\6ZdnEKu,
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close f kdJgK
Statement sm ; %b ^.Gw\L
sm = cn.createStatement(insert into user...); oi^pU
sm.executeUpdate(); @CCDe`R*
sm.close(); [;7$ 'lr%D
sm = cn.createStatement("insert into corp...); p,OB;Ncf/
sm.executeUpdate(); PV/ hnVUl
sm.close(); &=-{adm
3、提交 G\r>3Ys
cn.commit(); t@BhosR-
4、如果发生异常,那么回滚 c 9zMI
cn.rollback();