java 数据库基本操作 we6+2
1、java数据库操作基本流程 LC~CPV'F
2、几个常用的重要技巧: tuL\7
(R
可滚动、更新的记录集
hg<"Yg=
批量更新 yf0vR%,\
事务处理 5i}CzA96
cKvAR5|
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 \;A50U|r
1、取得数据库连接 r{;VTQ
1)用DriverManager取数据库连接 ~*,Ddwr0a
例子 uD0(aqAZ
String className,url,uid,pwd; DctX9U(
className = "oracle.jdbc.driver.OracleDriver"; x9FLr}e
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; /h.:br?M#P
uid = "system"; E7d~#
pwd = "manager"; 48*Oh2BA
Class.forName(className); y@2vY[)3s
Connection cn = DriverManager.getConnection(url,uid,pwd); #U\&i`
2)用jndi(java的命名和目录服务)方式 Huc3|~9
例子 YD0vfwh
String jndi = "jdbc/db"; yBXkN&1=%;
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); =|j*VF 2y"
DataSource ds = (DataSource) ctx.lookup(jndi); Zi2Eu4p l{
Connection cn = ds.getConnection(); =H.<"7
多用于jsp中 nm{'HH-4
2、执行sql语句 \FY/eQ*07
1)用Statement来执行sql语句 E-BOIy,
String sql; 0XBBA0tq
Statement sm = cn.createStatement(); E.zYi7YUKK
sm.executeQuery(sql); // 执行数据查询语句(select) Pl>nd)i`
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); d=xI
2)用PreparedStatement来执行sql语句 ;L\!g%a
String sql; qY*%p
sql = "insert into user (id,name) values (?,?)"; T_5*iwI
PreparedStatement ps = cn.prepareStatement(sql); m M\!4Yi`7
ps.setInt(1,xxx); >uP{9kDm
ps.setString(2,xxx); |g: '')>[
... !.tL"U~4
ResultSet rs = ps.executeQuery(); // 查询 &"~,V6,q
int c = ps.executeUpdate(); // 更新 [FeJ8P>z
mlsvP%[f.
3、处理执行结果 vkNZ -`+I
查询语句,返回记录集ResultSet p3,(*eZ
更新语句,返回数字,表示该更新影响的记录数 n;S0fg
ResultSet的方法 L:k@BCQM
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 7>W+Uq
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 9}'l=b:Jms
O|^6UH
4、释放连接 4X(1
cn.close(); 'aSZ!R
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection _^ CQ*+F
z$8e6*
可滚动、更新的记录集 z Et6
1、创建可滚动、更新的Statement :3E8`q~c1
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 3Aqe;Wf9%+
该Statement取得的ResultSet就是可滚动的 ^G7n#
2、创建PreparedStatement时指定参数 ]`CKQ>
o
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); $@ T6g
ResultSet.absolute(9000); )+Y\NO?O
批量更新 gOES2
4$2
1、Statement g# 9*bF
Statement sm = cn.createStatement(); K\Y6
cj
sm.addBatch(sql1); fxtYo,;$
sm.addBatch(sql2); @'NaA SB
... =oKPMmpCZ
sm.executeBatch() <Vr]2mw
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 lhIr]'?l
2、PreparedStatement c!(~BH3p
PreparedStatement ps = cn.preparedStatement(sql); wFoR,oXtL/
{ U#FJ8CD&u
ps.setXXX(1,xxx); LzEE]i
... fO^EMy\
ps.addBatch(); .eDxIWW+ft
} mXN1b!
ps.executeBatch(); 6"rFfdns
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 +gD)Yd
kHo;9j-U
事务的处理 o}AqNw60v
1、关闭Connection的自动提交 J~yd]L>
cn.setAutoCommit(false); *fuGVA
2、执行一系列sql语句 zM9) .D
H
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close =%nqMV(y
Statement sm ; CB{k;H
sm = cn.createStatement(insert into user...); :'^dy%&UB
sm.executeUpdate(); +2k|g2
sm.close(); rTH[?mkf4
sm = cn.createStatement("insert into corp...); ?XTg%U
sm.executeUpdate(); MR l*rK
sm.close(); /S=;DxZ,r
3、提交 2}xFv2X
cn.commit(); NdED8 iRc
4、如果发生异常,那么回滚 s_Ge22BZ
cn.rollback();