java 数据库基本操作 8}0wSVsxV$
1、java数据库操作基本流程 P 2WAnm
2、几个常用的重要技巧: <w9~T TS
可滚动、更新的记录集 cXb*d|-|N
批量更新 o!tC{"g
事务处理 K?uZIDo
+u$l]~St\
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 #LasTN9
1、取得数据库连接 ok\-IU?
1)用DriverManager取数据库连接 b}K,wAx
例子 y#GHmHeh
String className,url,uid,pwd; {:1j>4m2
className = "oracle.jdbc.driver.OracleDriver"; q}LDFsU
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; lbHgxZ
uid = "system"; >bW=oTFz
pwd = "manager"; T-] {gc
Class.forName(className); ?Lg(,-:
Connection cn = DriverManager.getConnection(url,uid,pwd); joe)b
2)用jndi(java的命名和目录服务)方式 d/; tq
例子 "`% ,l|D
String jndi = "jdbc/db"; [M\ an6h6O
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 3x[Cpg,
DataSource ds = (DataSource) ctx.lookup(jndi); GL
n M1
Connection cn = ds.getConnection(); ;u<Ah?w=Z
多用于jsp中 2z-Nw <bA
2、执行sql语句 D4L&6[W
1)用Statement来执行sql语句 Bv<g Vt
String sql; %,@pV%2
Statement sm = cn.createStatement(); _*o<<C\E
sm.executeQuery(sql); // 执行数据查询语句(select) Xz^nm\
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ^^b'tP1>
2)用PreparedStatement来执行sql语句 .a@12J(I
String sql; V%8(zt
sql = "insert into user (id,name) values (?,?)"; KsKE#])&l
PreparedStatement ps = cn.prepareStatement(sql); eh9?GUr5
ps.setInt(1,xxx); \Bo$
3
ps.setString(2,xxx); _WEJ,0*#'
... =.3#l@E!C
ResultSet rs = ps.executeQuery(); // 查询 #~
x7G
int c = ps.executeUpdate(); // 更新 `p()ko
k6bct@7
3、处理执行结果 >$D!mraih
查询语句,返回记录集ResultSet ~q ^o|?
更新语句,返回数字,表示该更新影响的记录数 OFtaOjsyUa
ResultSet的方法 jqaX|)8|$
1、next(),将游标往后移动一行,如果成功返回true;否则返回false U`(=iyWP=
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 CTNL->
"6jt$-?
4、释放连接 QY;(Ny/(y
cn.close(); !UoA6C:
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection nm5DNpHk
&>\;4E.O5
可滚动、更新的记录集 *V2;ds.~
1、创建可滚动、更新的Statement 1/97_:M0~F
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); <st<oR'
该Statement取得的ResultSet就是可滚动的 roQI;gq^
2、创建PreparedStatement时指定参数 W![K#r5T
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); [^"*I.Z_
ResultSet.absolute(9000); ^C'S-2nGH
批量更新 4A2}3$c9
1、Statement \ptO4E
Statement sm = cn.createStatement(); DkWp
sm.addBatch(sql1); CP7Fe{P
sm.addBatch(sql2); 8B GZ
... }B-$}
sm.executeBatch() lUu0AZQmG
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ;^ME
2、PreparedStatement ?\Z pVL<>
PreparedStatement ps = cn.preparedStatement(sql); w
% Hj'
{ M@.l#
[@U
ps.setXXX(1,xxx); j-K[]$
... H^-Y]{7
ps.addBatch(); :+"4_f0
} ;oOTL'Vu
ps.executeBatch(); 4t[7lL`Z
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 U6&`s%mIa
E+ /Nicn=
事务的处理 tc'iKJ5)
1、关闭Connection的自动提交 x$d[Ovw-
cn.setAutoCommit(false); h?xgOb!4
2、执行一系列sql语句 bN_e~ z
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close )k(K/m
Statement sm ; X~r9yl>
sm = cn.createStatement(insert into user...); LA Crg
sm.executeUpdate();
o
]*yI[\
sm.close(); Xe_ <]|
sm = cn.createStatement("insert into corp...); D)PX |xrn
sm.executeUpdate(); 3;v)f": [
sm.close(); )E.AY
3、提交 LQ~|VRRX<
cn.commit(); 0
P YYG
4、如果发生异常,那么回滚 dEk#"cvg
cn.rollback();