java 数据库基本操作 XJ1Bl
1、java数据库操作基本流程 (^58$IW71
2、几个常用的重要技巧: "YVr/u
可滚动、更新的记录集 Y4[oa?G
批量更新 k h6n(B\
事务处理 f[?JLp
@0%[4
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 *DQa6,b
1、取得数据库连接 xRZ/[1f!
1)用DriverManager取数据库连接 DeI3(o7
例子 BW ux!
String className,url,uid,pwd; w17CZa
6
className = "oracle.jdbc.driver.OracleDriver"; {
PS0.UZ
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; mdlMciP
uid = "system"; [MF&x9Ss?%
pwd = "manager"; GtKSA#oYZB
Class.forName(className); D$VRE^k
Connection cn = DriverManager.getConnection(url,uid,pwd); wM}AWmH
2)用jndi(java的命名和目录服务)方式 Kd*=-
例子 nuw7pEW@?
String jndi = "jdbc/db"; t
>Rh
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); z&\N^tBv
DataSource ds = (DataSource) ctx.lookup(jndi); Y/
%XkDC~
Connection cn = ds.getConnection(); TY?O$d2b3
多用于jsp中 szD9z{9"y
2、执行sql语句
Az/B/BLB
1)用Statement来执行sql语句 _/YM@%d
String sql; xl9S=^`=
Statement sm = cn.createStatement(); b&'YW*W
sm.executeQuery(sql); // 执行数据查询语句(select) #q5tG\gnM
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ndw&F'.r
2)用PreparedStatement来执行sql语句 fr}.#~{5Y
String sql; o
^ 08<
sql = "insert into user (id,name) values (?,?)"; 2s}G6'xE]P
PreparedStatement ps = cn.prepareStatement(sql); ;O~%y'
ps.setInt(1,xxx); QY*F(S,\
ps.setString(2,xxx); M^G9t*I
... QQD7NN>
ResultSet rs = ps.executeQuery(); // 查询 x:c'ek
int c = ps.executeUpdate(); // 更新 i?,\>LTG
.R^ R|<x
3、处理执行结果 cH707?p/I
查询语句,返回记录集ResultSet yE;S6 O
更新语句,返回数字,表示该更新影响的记录数 :k2J
&@8
ResultSet的方法 ^FZ9q
1、next(),将游标往后移动一行,如果成功返回true;否则返回false +^%)QH>9
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 w*X(bua@
*n EG<Y)
4、释放连接 Y Azj>c&
cn.close(); 'Z)#Sz Y
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection ux)Wh.5
+W8kMuM!
可滚动、更新的记录集 OHv9|&Tpl
1、创建可滚动、更新的Statement V6B[eV$D
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 40[@d
该Statement取得的ResultSet就是可滚动的 0a1Mu>P,
2、创建PreparedStatement时指定参数 0v``4z2Z
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); . HAFKB;
ResultSet.absolute(9000); qCq?`0&#
批量更新
[WXcp1p
1、Statement y( UWh4?t
Statement sm = cn.createStatement(); -h=wLYl@0i
sm.addBatch(sql1); '@5x=>
sm.addBatch(sql2); .N7&Jy
... E+/XKF
sm.executeBatch() tH:?aP*2
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 |nU%H=Rs/
2、PreparedStatement t{`uN
PreparedStatement ps = cn.preparedStatement(sql); Jgy6 !qUn_
{ r4fd@<=g
ps.setXXX(1,xxx); g[;&_gL
... ;u<F,o(
ps.addBatch(); {MUO25s02
} 4L r,}tA
ps.executeBatch(); X^i3(N
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 .=) *Qx+
ONUa7
事务的处理 j"+6aD/lv
1、关闭Connection的自动提交 -s^cy+jd
cn.setAutoCommit(false); D;OPsNQ
2、执行一系列sql语句 NOf{Xx<#k
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close N:EljzvP}
Statement sm ; =6N=5JePB
sm = cn.createStatement(insert into user...); fc4jbPp:M
sm.executeUpdate(); +e#(p<
sm.close(); /=QsZ,~xo
sm = cn.createStatement("insert into corp...); Wxgs66
sm.executeUpdate(); =@nW;PUZ
sm.close(); G0Z$p6z
3、提交 s !II}'Je
cn.commit(); ]qx!51S
4、如果发生异常,那么回滚 ^;$9>yi1
cn.rollback();