java 数据库基本操作 A
i9*w?C
1、java数据库操作基本流程 <4{@g]0RV
2、几个常用的重要技巧: *&UVr
可滚动、更新的记录集 y%TR2CvT
批量更新 Jkm\{;
事务处理 2WE
I6y&6g
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 yc]ni.Hz
1、取得数据库连接 0 nWV1)Q0=
1)用DriverManager取数据库连接 rxa"ji!)
例子 v_c'npC
String className,url,uid,pwd; ![abDT5![
className = "oracle.jdbc.driver.OracleDriver"; {, APZ`q|
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; c#"\&~. P
uid = "system"; _5
tw1 >
pwd = "manager"; 5B2x#
m|8
Class.forName(className); bHS2;K~
Connection cn = DriverManager.getConnection(url,uid,pwd); K!I]/0L
2)用jndi(java的命名和目录服务)方式 `yYgL@Zt
例子 dN |w;|M
String jndi = "jdbc/db"; //ZB B,[@
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); GeHDc[7
DataSource ds = (DataSource) ctx.lookup(jndi); >+vWtO2
Connection cn = ds.getConnection(); :1 Fm~'
多用于jsp中 B"KsYB79t
2、执行sql语句 *$#r%
1)用Statement来执行sql语句 9d[0i#` :q
String sql; Bf'jXM{-
Statement sm = cn.createStatement(); }%k"qW<Y
sm.executeQuery(sql); // 执行数据查询语句(select) <u2*(BM4
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); fy_'K}i3k
2)用PreparedStatement来执行sql语句 #Z$6>
Xt
String sql; & p_;&P_
sql = "insert into user (id,name) values (?,?)"; ` V^#Sb
PreparedStatement ps = cn.prepareStatement(sql); i $I|JJJ
ps.setInt(1,xxx); :-"J)^V
ps.setString(2,xxx); {]D!@87
... x;Gyo
ResultSet rs = ps.executeQuery(); // 查询 k}lx!Ck
int c = ps.executeUpdate(); // 更新 Z7.)[
;
R@VO3zs W
3、处理执行结果 BLaXp0
查询语句,返回记录集ResultSet 'dU$QO
更新语句,返回数字,表示该更新影响的记录数 RTY$oUqlZ
ResultSet的方法 o=`9JKB~
1、next(),将游标往后移动一行,如果成功返回true;否则返回false (
?/0$DB
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 TdQ^^{SRp
r]HLO'<]
4、释放连接 !%s7I^f*
cn.close(); "apv)xdW
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection Qgx~'9
TJ;v}HSo
可滚动、更新的记录集 =dA T^e##
1、创建可滚动、更新的Statement (ZEVbAY?i
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); |%RFXkHS
该Statement取得的ResultSet就是可滚动的 GU[Cq=k
2、创建PreparedStatement时指定参数 `=KrV#/758
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); zi-+@9T
ResultSet.absolute(9000); TS[Z<m
批量更新 b$$XriD]
1、Statement wd#AA#J;*
Statement sm = cn.createStatement(); yPQ{tS*t
sm.addBatch(sql1); +'n1?^U
sm.addBatch(sql2); /pk;E$qv
... e0$mu?wd-
sm.executeBatch() bR8)s{p6
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 SD.ze(P
2、PreparedStatement OT *W]f
PreparedStatement ps = cn.preparedStatement(sql); /Hx0=I
{ w`7l;7[
ps.setXXX(1,xxx); c=b\9!hr_E
... ^_=0.:QaW
ps.addBatch(); GUp51*#XR
} ;XtDz
ps.executeBatch(); ]cA~%$c89s
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 I9Sh~vTm=u
h{JVq72R
事务的处理 ^|K*lI/
1、关闭Connection的自动提交 ?x[>g!r
cn.setAutoCommit(false); kW:!$MX!
2、执行一系列sql语句 C,<TAm
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close _:K}DU'6
Statement sm ; jU#%@d6!#
sm = cn.createStatement(insert into user...); nb|MHt PX
sm.executeUpdate(); `nM4kt7
sm.close(); -[`W m7en
sm = cn.createStatement("insert into corp...); <QkfvK]Q
sm.executeUpdate(); #-f^;=7
sm.close(); 5-3gsy/Mo
3、提交 ^7''x,I
cn.commit(); .XE]vo
4、如果发生异常,那么回滚 ?#[K&$}
cn.rollback();