java 数据库基本操作 (x{6N^J.t
1、java数据库操作基本流程 > .L\ >
2、几个常用的重要技巧: 'N?,UtG R
可滚动、更新的记录集 ^-,
aB
批量更新 UN7>c0B
事务处理 "r6DZi(^K
wI!>IV(5
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ?U~9d"2=
1、取得数据库连接 ;(cqaB
1)用DriverManager取数据库连接 #$&!)13
例子 l.ri]e
String className,url,uid,pwd; |[ymNG
className = "oracle.jdbc.driver.OracleDriver"; *_
2db
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; -6(u09mb_
uid = "system"; )z'LXy8
pwd = "manager"; |K(j}^1k
Class.forName(className); Q+
r4
Connection cn = DriverManager.getConnection(url,uid,pwd); 1(z&0Y ;
2)用jndi(java的命名和目录服务)方式 t(-`==.R
例子 J. ;9-
String jndi = "jdbc/db"; :wn9bCom?M
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); A
%iZ_h^
DataSource ds = (DataSource) ctx.lookup(jndi); 9%>GOY
Connection cn = ds.getConnection(); P8lx\DA
多用于jsp中 |!VSed#FSn
2、执行sql语句 `GsFvxz
1)用Statement来执行sql语句 Sm6hyZFy
String sql; 1wX0x.4d
Statement sm = cn.createStatement(); FL}k0
sm.executeQuery(sql); // 执行数据查询语句(select) 6I0G.N
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); <!ewb=[_$
2)用PreparedStatement来执行sql语句 3jMHe~.E<
String sql; ')kn
sql = "insert into user (id,name) values (?,?)"; o1x IGP<
PreparedStatement ps = cn.prepareStatement(sql); r=Up-(j
ps.setInt(1,xxx); ai7*</ls
ps.setString(2,xxx); -e6~0%X
... N/ 7Q(^
ResultSet rs = ps.executeQuery(); // 查询 E1(2wJ-3"
int c = ps.executeUpdate(); // 更新 `N8?F3>
C-Q]f
3、处理执行结果 >7yOu!l
查询语句,返回记录集ResultSet >syQDB
更新语句,返回数字,表示该更新影响的记录数 D^+#RR'#,
ResultSet的方法 86bl'FdKS
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 0^l|W|.Z
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 L*TPLS[lh
xz1jRI$
4、释放连接 u{F^Ngy
)
cn.close(); zKycd*X
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection ykY#Y}?^
=|)W#x9=
可滚动、更新的记录集 N# o" W
1、创建可滚动、更新的Statement DA)mkp
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); F9DY\EI
该Statement取得的ResultSet就是可滚动的 [X +E
2、创建PreparedStatement时指定参数 Q~R7 ]AyR
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 3l?D%E]P
ResultSet.absolute(9000); q.s 2x0
批量更新
~f/nq/8
1、Statement CRK%%;=>
Statement sm = cn.createStatement(); A#:5b5R
sm.addBatch(sql1); |P{K\;-
sm.addBatch(sql2); A^/$ |@
... MO7:ZYq
sm.executeBatch() {0J TN%e
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 9,h'cf`F
2、PreparedStatement :JBvCyj4PE
PreparedStatement ps = cn.preparedStatement(sql); Qqt<
{ %nU8 Ca
ps.setXXX(1,xxx); QLx]%E\
... s bf\;_!
ps.addBatch(); *h=|KOS
} Ep/kb-~-
ps.executeBatch(); [nQ<pTg~r
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 N1dp%b9W(
e0i&?m
事务的处理 y'ZRoakz)
1、关闭Connection的自动提交 ?nW K s
cn.setAutoCommit(false); xHs8']*\
2、执行一系列sql语句 Z)RoFD1]C
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 4wLp
Statement sm ; %i!&Fr
sm = cn.createStatement(insert into user...); O gQE1{C
sm.executeUpdate(); {VWX?Mm
sm.close(); #b[B$
sm = cn.createStatement("insert into corp...); ET ;=o+\d
sm.executeUpdate(); d,r%LjNI
sm.close(); gwvy$H
3、提交 Q+d9D1b
cn.commit(); c< ke)@
4、如果发生异常,那么回滚 `4Jlf!
cn.rollback();