java 数据库基本操作 &*0V!+#6
1、java数据库操作基本流程 b`IC)xN$
2、几个常用的重要技巧: SYyH_0N
可滚动、更新的记录集 rv^j&X+EH
批量更新 * fx<>aK
事务处理 nBQG.3
VFyt9:a
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 }=++Lr4*
1、取得数据库连接 >q}EZC
1)用DriverManager取数据库连接 =,sMOJc>
例子 {It4=I)M
String className,url,uid,pwd; 6oC(09
className = "oracle.jdbc.driver.OracleDriver"; _)ERi*}x8
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; #3.\}d)
uid = "system"; ms~ mg:
pwd = "manager"; V'_^g7}l&
Class.forName(className); /dCZoz~~T
Connection cn = DriverManager.getConnection(url,uid,pwd); UOq$88sr
2)用jndi(java的命名和目录服务)方式
o]
=
&
例子 `XTu$+
String jndi = "jdbc/db"; 3)=$BSC%
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); oo2VT
DataSource ds = (DataSource) ctx.lookup(jndi); OyVp 3O
Connection cn = ds.getConnection(); Fw=-gb_.
多用于jsp中 atYm.qb
2、执行sql语句 K@hv[4
1)用Statement来执行sql语句 Ly3^zFW
String sql; |*!I(wm2i
Statement sm = cn.createStatement(); z\v\T|C
sm.executeQuery(sql); // 执行数据查询语句(select) FG'1;x!
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); i~4:]r22
2)用PreparedStatement来执行sql语句 W}KtB1J
String sql; .n"aQ@!
sql = "insert into user (id,name) values (?,?)"; gB?#T
PreparedStatement ps = cn.prepareStatement(sql); G.9?ApG9
ps.setInt(1,xxx); @]~\H-8
ps.setString(2,xxx); jA6:-Gz
... Pocm.
ResultSet rs = ps.executeQuery(); // 查询 kfn5y#6NZ
int c = ps.executeUpdate(); // 更新 k;"=y)@o
Z_S~#[\7^]
3、处理执行结果 >RRb8=[J
查询语句,返回记录集ResultSet Rj-<tR{
更新语句,返回数字,表示该更新影响的记录数 ]NN9FM.2b/
ResultSet的方法 J)66\h=
1、next(),将游标往后移动一行,如果成功返回true;否则返回false C8i}~x<
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 s`&8tP
FFPO?y$
4、释放连接 T*z >A
cn.close(); O||M
|
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection I#m5Tl|#
"= HCP,
可滚动、更新的记录集 :H6Ipa
1、创建可滚动、更新的Statement sz_|py?0
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); b{9q
该Statement取得的ResultSet就是可滚动的 #;H+Kb5O
2、创建PreparedStatement时指定参数 5`0tG;
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ;A1pqHr
ResultSet.absolute(9000); Ig]Gg/1G
批量更新 qbmy~\ZY
1、Statement ;g*ab
Statement sm = cn.createStatement(); S.BM/M
sm.addBatch(sql1); 1S <V,9(
sm.addBatch(sql2); OLlNCb#t
... HA>b'lqBM
sm.executeBatch() wR1M_&-s
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 $TWt[
2、PreparedStatement ?-Fp rC
PreparedStatement ps = cn.preparedStatement(sql); ?~;G)5
{ G!@tW`HO
ps.setXXX(1,xxx); GYZzWN}U
... ?HttqK)
ps.addBatch(); JZ'`.yK:
} MJb!+E+
ps.executeBatch(); yX?& K}JI
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 RD<l<+C^~
AW1691Q
事务的处理 }_Jr[iaB
1、关闭Connection的自动提交 ?$v#;n?@I
cn.setAutoCommit(false); h`,dg%J*B
2、执行一系列sql语句 3S ,D~L^
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close NFv9%$l-
Statement sm ; ]_@5LvI
sm = cn.createStatement(insert into user...);
W& w-yZ
sm.executeUpdate(); pX+ `qxF\
sm.close(); Y;4nIWe
JL
sm = cn.createStatement("insert into corp...); O:WFh;c
sm.executeUpdate(); # KK>D?.:
sm.close(); 8" XbW7 ^o
3、提交 I HgYgn
cn.commit(); 5Jlz$]f
4、如果发生异常,那么回滚 UJ<eF/KSmG
cn.rollback();