java 数据库基本操作 UK9MWC5g9
1、java数据库操作基本流程 7bW!u*v-c
2、几个常用的重要技巧: }\qdow-
可滚动、更新的记录集 jm!C^5!
批量更新 .mU.eLM
事务处理 Ac(Vw%
wjGjVTtHs
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 H_r'q9@<>
1、取得数据库连接 blkJm9]v
1)用DriverManager取数据库连接 9^h%}>
例子 Y8xnvK*
String className,url,uid,pwd; FH5 bC6
className = "oracle.jdbc.driver.OracleDriver"; wuC tg=
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; Zkep7L
uid = "system"; tcdn"]#U
pwd = "manager"; 80"=Qu{s
Class.forName(className); Rm1` D
Connection cn = DriverManager.getConnection(url,uid,pwd); 2 g8P$+;
2)用jndi(java的命名和目录服务)方式 ZUI\0qh+
例子 6&Ir0K/
String jndi = "jdbc/db"; zi&d
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); P
T.jR*
DataSource ds = (DataSource) ctx.lookup(jndi); \@t5S
Connection cn = ds.getConnection(); NB#*`|qt
多用于jsp中 m8A_P:MQq
2、执行sql语句 1KR|i"
1)用Statement来执行sql语句 |dzF>8< )
String sql; ^W05Z!}
Statement sm = cn.createStatement(); pNWp3+a'
sm.executeQuery(sql); // 执行数据查询语句(select) .v&h>@'m
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); qiryC7.E
2)用PreparedStatement来执行sql语句 6(^9D_"@
String sql; ymCIk/\
sql = "insert into user (id,name) values (?,?)"; io'Ovhf:
PreparedStatement ps = cn.prepareStatement(sql); `5&V}"lB
ps.setInt(1,xxx); #iDFGkK/
ps.setString(2,xxx); i*/U.'#
... z$5C(! )
ResultSet rs = ps.executeQuery(); // 查询 cY]Y8T)
int c = ps.executeUpdate(); // 更新
4N0nU
bD-Em#>
3、处理执行结果 u\?u4
查询语句,返回记录集ResultSet lM%fgyX
更新语句,返回数字,表示该更新影响的记录数 sZDJ+
ResultSet的方法 *?"{T;4u~O
1、next(),将游标往后移动一行,如果成功返回true;否则返回false X($SBUS6
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 :J-5Q]#
lhj2u]yU0S
4、释放连接 4TE ?mh}
cn.close(); 6|Q'\
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection W
(=B H
c3t8yifQ
可滚动、更新的记录集 /CE d14.
1、创建可滚动、更新的Statement Cw5K*
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); =1[g`b
该Statement取得的ResultSet就是可滚动的 ~=ys~em e
2、创建PreparedStatement时指定参数 S$WM&9U
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); O3Mv"Py%
ResultSet.absolute(9000); ;BVhkWA
批量更新 r/2:O92E
1、Statement W10fjMC}^
Statement sm = cn.createStatement(); :n9^:srGZH
sm.addBatch(sql1); GA}^Rh`T-
sm.addBatch(sql2); .Tv(1HAc2l
... NvZ?e
sm.executeBatch() sdD[`#
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 FM[To
2、PreparedStatement Fo~v.+^?
PreparedStatement ps = cn.preparedStatement(sql); V/e_:xECC
{ hspg-|R
ps.setXXX(1,xxx); n<*]`do,w
... }C.{+U
ps.addBatch(); QovC*1'
} 0 XzO`*
ps.executeBatch(); mO.U)tL[
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 1}*;
zmRK%a(
事务的处理 ,eCXT=6
1、关闭Connection的自动提交 (=rv `1
cn.setAutoCommit(false); eUlb6{!y?
2、执行一系列sql语句 koZp~W-
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close -+|[0hpw
Statement sm ; )xy6R]_b
sm = cn.createStatement(insert into user...); +~O{
UGB=
sm.executeUpdate(); >oDP(]YGg
sm.close(); KL]!E ~i
sm = cn.createStatement("insert into corp...); P.DWC'IBN
sm.executeUpdate(); F DX+
sm.close(); d
4R+gIA
3、提交 mM>|fHGA
cn.commit(); g<%-n,
4、如果发生异常,那么回滚 [rU8
#4.
cn.rollback();