java 数据库基本操作 {PKER$C
1、java数据库操作基本流程 hCgNS1%4
2、几个常用的重要技巧: o%a$m9I
可滚动、更新的记录集 3'wBX
批量更新 8TZe=sD~cr
事务处理 g d -fJ._1
mN`a]L'
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 MgekLP)&
1、取得数据库连接 T$e_ao|
1)用DriverManager取数据库连接 I
f(_$>
例子 uu>g(q?4II
String className,url,uid,pwd; EbQ} w"{
className = "oracle.jdbc.driver.OracleDriver"; *bx cq
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; .z"[z^/uF
uid = "system"; 7^F?key?
pwd = "manager"; /<@tbZJ*8
Class.forName(className); !IS,[
Connection cn = DriverManager.getConnection(url,uid,pwd); vhC"f*
2)用jndi(java的命名和目录服务)方式 ?m6E@.{
例子 ]2jnY&a5
String jndi = "jdbc/db"; G r)+O
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ]rS+v^@QH
DataSource ds = (DataSource) ctx.lookup(jndi); C1J'. !
Connection cn = ds.getConnection(); -_3.]o/J
多用于jsp中 b%BwGS(z
2、执行sql语句 o>YRKb
1)用Statement来执行sql语句 2-4%h!
String sql; oaHBz_pg
Statement sm = cn.createStatement(); ~EBZlTN
sm.executeQuery(sql); // 执行数据查询语句(select) *K;~V
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 2+.m44>Ti
2)用PreparedStatement来执行sql语句 z!%}0
String sql; e#wn;wo?
sql = "insert into user (id,name) values (?,?)"; $f+9svq
PreparedStatement ps = cn.prepareStatement(sql); 19S,>
ps.setInt(1,xxx); x^"OH
ps.setString(2,xxx); @;0Ep0[
... -3fvO~
ResultSet rs = ps.executeQuery(); // 查询 = 4If7
int c = ps.executeUpdate(); // 更新 [ ,dsVd
:MVD83?4
3、处理执行结果 a'Z"Yz^Eo
查询语句,返回记录集ResultSet ktCh*R[`
更新语句,返回数字,表示该更新影响的记录数 F2&KTK
ResultSet的方法 G>Q{[m$
1、next(),将游标往后移动一行,如果成功返回true;否则返回false <
5ow81
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 .XmD[=
:X^B1z3X4
4、释放连接 tua+R_"
cn.close(); L4!$bB~L-
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 7;XdTx
_ AFgx8
可滚动、更新的记录集 7Q`4*H6
1、创建可滚动、更新的Statement pr2d}~q4{
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); AXyuXB
该Statement取得的ResultSet就是可滚动的 SG~R!kN}Q
2、创建PreparedStatement时指定参数 fKfi
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ,O2F}5|;
ResultSet.absolute(9000); ;23F8M%wH
批量更新 [8"nRlXH
1、Statement V;m3=k0U
Statement sm = cn.createStatement(); ^^Ius ]
sm.addBatch(sql1); +m1edPA[
sm.addBatch(sql2); O@[q./VV,
... loZfzN&6A
sm.executeBatch() Na=q(OKN
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ukw'$Yt2
2、PreparedStatement dL"v*3Fy
PreparedStatement ps = cn.preparedStatement(sql); ()7=(<x{
{ D526X0
ps.setXXX(1,xxx); yS?1JWUC>
... u*M*WpY
ps.addBatch(); u$0>K,f
} Cc^t&Eg
ps.executeBatch(); ~"-wSAm
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 !} 1p:@
qRU8uu
事务的处理 {M=tw
1、关闭Connection的自动提交 {f!m m3'2v
cn.setAutoCommit(false); <Z vG&
2、执行一系列sql语句 =q._Qsj?fu
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close o5)U3U1|
Statement sm ; A`@we
sm = cn.createStatement(insert into user...); f.,-KIiF
sm.executeUpdate(); 9+L!
A
sm.close(); Q/< $ (Y
sm = cn.createStatement("insert into corp...); )P$
IXA\
sm.executeUpdate(); Nk7Q
sm.close(); P"- ,^?6
3、提交 X\ h]N
cn.commit(); p5*i
d5
4、如果发生异常,那么回滚 39OZZaWL
cn.rollback();