java 数据库基本操作 6iQqOAG
1、java数据库操作基本流程 RCqL~7C+ k
2、几个常用的重要技巧: b5g^{bzwu
可滚动、更新的记录集 -6 v?iiZr
批量更新 AkjoD7.*
事务处理 VFV8ik)
F4(;O7j9
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 b c
.Vy
1、取得数据库连接 NO*~C',cI/
1)用DriverManager取数据库连接 R7Tl1!,h
例子 b<fN,U<k
String className,url,uid,pwd; j,,#B4b
className = "oracle.jdbc.driver.OracleDriver"; JF&$'
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; \^F6)COy
uid = "system"; a[^dK-
pwd = "manager"; i_6 wD
Class.forName(className); ICo Z<;p
Connection cn = DriverManager.getConnection(url,uid,pwd); 9LQy0Gx
2)用jndi(java的命名和目录服务)方式 "6$+B/5
例子 5}NO~Xd<
String jndi = "jdbc/db"; y^p%/p%
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); P\c0Q;){h"
DataSource ds = (DataSource) ctx.lookup(jndi); IsL=DV/
Connection cn = ds.getConnection(); x2i`$iNhmP
多用于jsp中 <.7W:s,f=
2、执行sql语句 fv3)#>Dgp>
1)用Statement来执行sql语句 HV3wU EI3
String sql; h^9Ne/s~
Statement sm = cn.createStatement(); 43J8PMY
sm.executeQuery(sql); // 执行数据查询语句(select) Sdmynuv
U
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); `0ju=FP'u5
2)用PreparedStatement来执行sql语句 -JF|770i
String sql; MD:kfPQ
sql = "insert into user (id,name) values (?,?)"; WY~}sE
PreparedStatement ps = cn.prepareStatement(sql); ;rta#pRn
ps.setInt(1,xxx); Y@'1}=`J
ps.setString(2,xxx); sEfGf.
... CtDS lJ
ResultSet rs = ps.executeQuery(); // 查询 UE\@7
int c = ps.executeUpdate(); // 更新 B<'V7#L_
c9E9Rx
3、处理执行结果 -p!KsU
查询语句,返回记录集ResultSet eEe8T=mD
更新语句,返回数字,表示该更新影响的记录数
?Ve5}N
ResultSet的方法 cfe[6N
1、next(),将游标往后移动一行,如果成功返回true;否则返回false /C8(cVNZ
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 "/XS3sv"s
CM's6qhQnn
4、释放连接 l1_X5DI
cn.close(); |V~P6o(/
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection ;1OTK6
$l[*Y
可滚动、更新的记录集 !%M-w0vC9
1、创建可滚动、更新的Statement d`nS0Tf'
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); s*#|EdD6@
该Statement取得的ResultSet就是可滚动的 IA!ixabG
2、创建PreparedStatement时指定参数 !`#9#T|
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); N$,)vb<
ResultSet.absolute(9000); _&![s]
批量更新 zB]T5]
1、Statement ;<X3AhF
Statement sm = cn.createStatement(); '}YXpB
sm.addBatch(sql1); K
:q-[\G
sm.addBatch(sql2); u#UeJuO
... et ~gO!1:*
sm.executeBatch() ta 6WZu
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ;qk~>
2、PreparedStatement =<_5gR
PreparedStatement ps = cn.preparedStatement(sql); &{=~)>h
{ g4$%)0x%
ps.setXXX(1,xxx); 2nieI*[
... XP;&iZJ
ps.addBatch(); eB@i)w?@o
} J+|ohA
ps.executeBatch(); x[^A9
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 n)7icSc
+l/j6)O`(m
事务的处理 i
}gxq
1、关闭Connection的自动提交 K]Cvk%
cn.setAutoCommit(false); *f#4S_ws`
2、执行一系列sql语句 `U3
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close ?(<AT]h V:
Statement sm ; +?:V\niQI
sm = cn.createStatement(insert into user...); #rr-4$w+
sm.executeUpdate(); =GVhAzD3
sm.close(); bgK(l d`
sm = cn.createStatement("insert into corp...); 6qJB"_.
sm.executeUpdate(); D)sEAfvX
sm.close(); bX(*f>G'
3、提交 9h(hx7]
cn.commit(); e,*[5xQ
4、如果发生异常,那么回滚 5#o,]tP
cn.rollback();