java 数据库基本操作 yGWxpzmRS
1、java数据库操作基本流程 IHe/xQ@
2、几个常用的重要技巧: j2ve^F:Q
可滚动、更新的记录集 ~T9/#-e>BF
批量更新 |y&*MTfV4L
事务处理 Z8zmHc"IH
]or>?{4g
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 cJN7bA{
1、取得数据库连接 XaCX!Lr,
1)用DriverManager取数据库连接 PRr2F-!P
例子 ]gmexa=(i
String className,url,uid,pwd; xgbJ2Mh
className = "oracle.jdbc.driver.OracleDriver"; ^=T$&gD
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; g,}_G3[j0m
uid = "system"; ^oVs+ vC
pwd = "manager"; |s"nM<ZNZ
Class.forName(className); 5i>$]*o
Connection cn = DriverManager.getConnection(url,uid,pwd); b@rVo;
2)用jndi(java的命名和目录服务)方式 9
TvV=
例子 -}=i 04^
String jndi = "jdbc/db"; Rec6c&5_
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); }vZ+A
DataSource ds = (DataSource) ctx.lookup(jndi); ' qWALu
Connection cn = ds.getConnection(); m5L-67[sB
多用于jsp中 +g` 'J$
2、执行sql语句 BbW^Wxd3
1)用Statement来执行sql语句 @{YS}&Q/
String sql; `4(e
Statement sm = cn.createStatement(); # ,7e
NM"
sm.executeQuery(sql); // 执行数据查询语句(select) g}f`,r9
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); C
'v+f=
2)用PreparedStatement来执行sql语句 \Z]UA&v_
String sql; eAXc:222
sql = "insert into user (id,name) values (?,?)"; v\!Be[ ?
PreparedStatement ps = cn.prepareStatement(sql); Y]NSN-t
ps.setInt(1,xxx); \]%6|V
ps.setString(2,xxx); qDv93
... 9F4Dm*_<
ResultSet rs = ps.executeQuery(); // 查询 <\Eh1[F
int c = ps.executeUpdate(); // 更新 ERpnuMb
crqpV F]1]
3、处理执行结果 1nQWW9i
查询语句,返回记录集ResultSet #cnq(S=.
更新语句,返回数字,表示该更新影响的记录数 XM1WfjE\
ResultSet的方法 ]%|GmtqZs,
1、next(),将游标往后移动一行,如果成功返回true;否则返回false vV[eWd.o6M
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 nN*w~f"
S/^"@?z,vE
4、释放连接 (IC]?n}
cn.close(); "]z-: \ V
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection Q7R~{5r>W
zN!ZyI$nqP
可滚动、更新的记录集 k%D+Y(WGz8
1、创建可滚动、更新的Statement Qk\A
c
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); eln&]d;
该Statement取得的ResultSet就是可滚动的 2ggdWg7z
2、创建PreparedStatement时指定参数 q8^^H$<Db
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); >;L6xt3
ResultSet.absolute(9000); _{r=.W+w
批量更新 nyBJb(5"B
1、Statement V>ieh2G(
Statement sm = cn.createStatement(); pcYG~pZ9
sm.addBatch(sql1); Rn{iaM2Y<
sm.addBatch(sql2); `|,`QqDQ
... )+}]+xRWGj
sm.executeBatch() p$h4u_
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 2C/$Ei^t
2、PreparedStatement @r#v[I
PreparedStatement ps = cn.preparedStatement(sql); |_`E1Y}}
{ HvM)e.!
ps.setXXX(1,xxx); Uc_'(IyO
... y>72{
ps.addBatch(); |
\'rP_I>
} !R1.7}O
ps.executeBatch(); gA:5M
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 t: #6sF
x9;gT&@H
事务的处理 pcT:]d[1)
1、关闭Connection的自动提交 Xb{
[c+.
cn.setAutoCommit(false); }z\_;\7
2、执行一系列sql语句 wQwQXNG
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close |g
#K]v
Statement sm ; J.ck~;3
sm = cn.createStatement(insert into user...); CAcS~ "
sm.executeUpdate(); wvbPnf^y
sm.close(); AgFVv5
sm = cn.createStatement("insert into corp...); $% 1vW=d
sm.executeUpdate(); %n
hm
sm.close(); q{t*34R
3、提交 ~ECD`N<YF
cn.commit(); q|Q k2M
4、如果发生异常,那么回滚 yqi^>Ce0
cn.rollback();