java 数据库基本操作 lBCM;#P
1、java数据库操作基本流程 i@2?5U>h
2、几个常用的重要技巧: 8S0)_L#S
可滚动、更新的记录集 w4OVfTlN
批量更新 'j.{o
事务处理 Rk'Dd4"m,
P=h2Z,2
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 = *sP,
6
1、取得数据库连接 a7+BAma<
1)用DriverManager取数据库连接 mBNa;6w?{*
例子 3y@'p(}Az
String className,url,uid,pwd; )b
=$!
className = "oracle.jdbc.driver.OracleDriver"; W?$
ImW
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; y]/{W}D
uid = "system"; ]`MRH[{
pwd = "manager"; { "/@,!9rJ
Class.forName(className); ;{>z\6N
Connection cn = DriverManager.getConnection(url,uid,pwd); gAE}3//
2)用jndi(java的命名和目录服务)方式 eC1cE
例子 '{J!5x?L^
String jndi = "jdbc/db"; #hai3>9|B
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); Hi?],5,/
DataSource ds = (DataSource) ctx.lookup(jndi); E_h 9y
Connection cn = ds.getConnection(); $,
=n
多用于jsp中 '?-GZ0oM
2、执行sql语句 Jzr(A^vwo
1)用Statement来执行sql语句 U $+rlw}
String sql; l_8t[
Statement sm = cn.createStatement(); s?=J#WV1y
sm.executeQuery(sql); // 执行数据查询语句(select) ,3^N_>d$W
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); Tj>~#~
2)用PreparedStatement来执行sql语句 $N+azal+y
String sql; Xdjxt?*
sql = "insert into user (id,name) values (?,?)"; *bZV4}
PreparedStatement ps = cn.prepareStatement(sql); !D1F4v[c=
ps.setInt(1,xxx); ?^yZVmAo]
ps.setString(2,xxx); N%`ikdaTd
... *u-TNg
ResultSet rs = ps.executeQuery(); // 查询 yXDf;`J
int c = ps.executeUpdate(); // 更新 c=ZX7U
E;h#3
B9
3、处理执行结果 s |qB;
查询语句,返回记录集ResultSet N &=,)d~M
更新语句,返回数字,表示该更新影响的记录数 1{DHlyA6g
ResultSet的方法 )9Jt550(
1、next(),将游标往后移动一行,如果成功返回true;否则返回false md<%Z4+
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 8zr)oQ:
LaLA}1!
4、释放连接 I@[.W!w
cn.close(); -0>@jfP^D
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection hG3b7!^#g
*iYs,4
可滚动、更新的记录集 ; LTc4t
1、创建可滚动、更新的Statement [u~#F,_ow
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 6N]v9uXZ
该Statement取得的ResultSet就是可滚动的 ^oA^z1>3
2、创建PreparedStatement时指定参数 Ij#?r2Z%
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); lT*Hj.
ResultSet.absolute(9000); %GAEZH,2sG
批量更新 n2$*Z6.G
1、Statement *F&C`]
Statement sm = cn.createStatement(); e\/Lcng
sm.addBatch(sql1); 6tP^_9njy
sm.addBatch(sql2); iA=9Lel
... Nn%{Ka
sm.executeBatch() Jln dypE
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 f4uK_{
2、PreparedStatement K^9!Qp
PreparedStatement ps = cn.preparedStatement(sql); p7|~x@q+
{ :U?Kwv8 s
ps.setXXX(1,xxx); Q~uj:A]n<
... G:f]z;Xdp
ps.addBatch(); o-/Xa[yC
} 9!PJLI=D
ps.executeBatch(); l^fz
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 V7 c7(G
z )k\p'0"
事务的处理 i5|!MIY
1、关闭Connection的自动提交 M7En%sBp
cn.setAutoCommit(false); 7Sr7a{
2、执行一系列sql语句 pnDD9u-4;
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 7ej"q
Statement sm ; LR}b^QU7
sm = cn.createStatement(insert into user...); !K_%@|: 7%
sm.executeUpdate(); >`u} G1T\
sm.close(); GYCc)Guc
sm = cn.createStatement("insert into corp...); eFbr1IV
sm.executeUpdate(); g3j@o/Y
sm.close(); WFy90*@Z
3、提交 M" %w9)@
cn.commit(); entO"~*EX
4、如果发生异常,那么回滚 C2FewsRz
cn.rollback();