java 数据库基本操作 AO~f=GW
1、java数据库操作基本流程 #<o=W#[
2、几个常用的重要技巧: 6qK`X
可滚动、更新的记录集 MG-#p8
批量更新 8k_cC$*Ng
事务处理 K'f`}y9
MJugno
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 m'PU0x
1、取得数据库连接 T8W;Lb9hQ
1)用DriverManager取数据库连接 _L%
=Q ulu
例子 pZ)N,O3
String className,url,uid,pwd; FByA4VxB
className = "oracle.jdbc.driver.OracleDriver"; (TTS-(
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; iPCDxDLN3V
uid = "system"; K:L_y1!T
pwd = "manager"; a\ZNN k
Class.forName(className); c1sVdM}|
Connection cn = DriverManager.getConnection(url,uid,pwd); G/N 1[)
2)用jndi(java的命名和目录服务)方式 Msst:}QY
例子 ]S+KH
\2
String jndi = "jdbc/db"; FI8vABq
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 5#U=x ,7e
DataSource ds = (DataSource) ctx.lookup(jndi); k{C03=xk
Connection cn = ds.getConnection(); 1a79]-j
多用于jsp中 Y{I,ipU.
2、执行sql语句 n`.JI(|
1)用Statement来执行sql语句 e5$S2o~JF
String sql; =Q~@dP
Statement sm = cn.createStatement(); SQ
la]%
sm.executeQuery(sql); // 执行数据查询语句(select) ,!vI@>nhG
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); +[2ep"5H
2)用PreparedStatement来执行sql语句 3,^.
String sql; ngOGo =
sql = "insert into user (id,name) values (?,?)"; l}_6_g>6
PreparedStatement ps = cn.prepareStatement(sql); -LU%z'
ps.setInt(1,xxx); bc]SY =
ps.setString(2,xxx); fJD+GvV$x
... C+%6N@
ResultSet rs = ps.executeQuery(); // 查询 PrhGp
_5
int c = ps.executeUpdate(); // 更新 ApTE:Fm1
b_w(F_0
3、处理执行结果 LhCwZ1
查询语句,返回记录集ResultSet !X4m6gRaP
更新语句,返回数字,表示该更新影响的记录数 CLgfNrW~
ResultSet的方法 SsCV}[
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ?+G
/5,e
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 @iBaJ"*,
c>%%'c
4、释放连接 ^i!I0Q2yd
cn.close(); 821;; ]H
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection !,9;AMO
-
Cg3 d
可滚动、更新的记录集 ST1c`0e
1、创建可滚动、更新的Statement 61Wh %8-
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); LV@tt&|N
该Statement取得的ResultSet就是可滚动的 x4XCR,-
2、创建PreparedStatement时指定参数 dLbSvK<(I
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); yYiu69v
ResultSet.absolute(9000); ^l{q{O7U$
批量更新 F% z$^ m-
1、Statement _c>8y
Statement sm = cn.createStatement(); 4SJb\R)XK
sm.addBatch(sql1); I~Q
G
sm.addBatch(sql2);
<.=-9O6
... 9@>Q7AUCQ
sm.executeBatch() nLY(%):(P
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 zALtG<_t
2、PreparedStatement x7!gmbMfK'
PreparedStatement ps = cn.preparedStatement(sql); ."Q}2
{ 6,~]2H'zq
ps.setXXX(1,xxx); lf\x`3Vd
... LnPG+<
ps.addBatch(); q0{ _w
} #|/+znJm
ps.executeBatch(); }=p+X:k=
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 GL,( N|
l#TE$d^ym
事务的处理 "t%Jj89a\
1、关闭Connection的自动提交 F^CR$L& K
cn.setAutoCommit(false); t!\B6!Fo
2、执行一系列sql语句 &3 *#h
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close ?N=`}}Ky-
Statement sm ; ;r}yeISf
sm = cn.createStatement(insert into user...); sBa&]9>m
sm.executeUpdate(); |4rqj1*U
sm.close(); .l$U:d
sm = cn.createStatement("insert into corp...); y I} >
sm.executeUpdate(); kD}vK+
sm.close(); RT<HiVr`
3、提交 INY?@in
cn.commit(); rE%HNPO
4、如果发生异常,那么回滚 '7
t:.88
cn.rollback();