java 数据库基本操作 |=5/Rax^
1、java数据库操作基本流程 9 Cvn6{
2、几个常用的重要技巧: KOSQQf
o
可滚动、更新的记录集 %Q~CB7ILK
批量更新 !9 f4R/ ?
事务处理 u
#~;&D*q
ST;t,
D:
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 2"&)W dm
1、取得数据库连接 > 0.W`j(s
1)用DriverManager取数据库连接 |/T43ADW
例子 "HlgRp]u
String className,url,uid,pwd; 6+`tn
className = "oracle.jdbc.driver.OracleDriver"; 50n}my'2h
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; >]?H`>4(
uid = "system"; =k{`oO~:9+
pwd = "manager"; BX< dSK
Class.forName(className); =SBBvnPLI
Connection cn = DriverManager.getConnection(url,uid,pwd); ln<]-)&C
2)用jndi(java的命名和目录服务)方式 >NM\TLET~
例子 D7?C
String jndi = "jdbc/db"; !')y&7a~
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); L
CSeOR
DataSource ds = (DataSource) ctx.lookup(jndi); &.N$
Connection cn = ds.getConnection(); ~?U*6P)o
多用于jsp中 2R.2D'4)`
2、执行sql语句 !;3PG9n3|h
1)用Statement来执行sql语句 tju|UhP3
String sql; -]S.<8<$
Statement sm = cn.createStatement(); c`G&KCw)d
sm.executeQuery(sql); // 执行数据查询语句(select) BfmsMW
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); io%')0p5q
2)用PreparedStatement来执行sql语句 jbte
*Ae
String sql; EKZVF`L
sql = "insert into user (id,name) values (?,?)"; la^
DjHA$
PreparedStatement ps = cn.prepareStatement(sql); PQ U]l"A
ps.setInt(1,xxx); H0*,8i5I
ps.setString(2,xxx); ^g>1U5c
... HY}j!X
ResultSet rs = ps.executeQuery(); // 查询 :`Az/U[
int c = ps.executeUpdate(); // 更新 5VE2@Fn}
K_/B?h
3、处理执行结果 {nMAm/kyj
查询语句,返回记录集ResultSet -1r2 K
更新语句,返回数字,表示该更新影响的记录数 y,Q5;$w8
ResultSet的方法 e@]Wh)
1、next(),将游标往后移动一行,如果成功返回true;否则返回false <7sIm^N
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 d&(_|xq#
7Z,/g|s}z
4、释放连接 yTBS=+X
cn.close(); C>QIrZu
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection -yx/7B5@
C+V*
Fh3
可滚动、更新的记录集 0$vj!-Mb^j
1、创建可滚动、更新的Statement 2+"r~#K*
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); q6q1\YB
该Statement取得的ResultSet就是可滚动的 fI|[Z+"
2、创建PreparedStatement时指定参数 *nTU#U
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); oFC)
ResultSet.absolute(9000); +cB&Mi5
批量更新 ~H6;I$e[
1、Statement @gfDp<
Statement sm = cn.createStatement(); e [0w5)X
sm.addBatch(sql1); xytr2V ]aV
sm.addBatch(sql2); E^Gg
'1
... `,Vv["^ PB
sm.executeBatch() <vc`^Q&4B
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 mY&ud>,U:
2、PreparedStatement HAB#pd9
PreparedStatement ps = cn.preparedStatement(sql); RDQ^dui
{ eiMH['X5
ps.setXXX(1,xxx); yJJ4~j){l
...
*~VxC{
ps.addBatch(); ]s1 YaNq
} $1Nd_pD=
ps.executeBatch(); Tupiq
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 ]<w:V`(
Qvoqx>2p5
事务的处理 5z/Er".P
1、关闭Connection的自动提交 i%{X9!*%TX
cn.setAutoCommit(false); \ FzM4-
2、执行一系列sql语句 G*8GGWB^a
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close mxG ]kqi
Statement sm ; :
mGAt[Cc
sm = cn.createStatement(insert into user...); gUax'^w;V;
sm.executeUpdate(); d]v+mVAyE
sm.close(); Q5+_u/
sm = cn.createStatement("insert into corp...); 6j9)/ HP
sm.executeUpdate(); |;vi*u
sm.close(); j|_E$L A\
3、提交 U bz"rCjq
cn.commit(); )LHj+B
4、如果发生异常,那么回滚 b\55,La
cn.rollback();