java 数据库基本操作 l, 1.6
1、java数据库操作基本流程 7>|p_o`e
2、几个常用的重要技巧: '>|5
可滚动、更新的记录集 n/GJ&qLi:g
批量更新
%Lgfi
事务处理 vX}mwK8
}i2dXC/
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 7=]Y7"XCf
1、取得数据库连接 ktK/s!bgY
1)用DriverManager取数据库连接 Z!qF0UDj
例子 P+;@?ofB
String className,url,uid,pwd; =v/x&,Uj@6
className = "oracle.jdbc.driver.OracleDriver"; M.}QXta
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; .s<tQU
uid = "system"; 74*iF'f?c
pwd = "manager"; Gh9dv|m=[;
Class.forName(className); *wfkjG
Connection cn = DriverManager.getConnection(url,uid,pwd); ak;S Ie
2)用jndi(java的命名和目录服务)方式 .;~K*GC
例子 .ZOyZnr
Z
String jndi = "jdbc/db"; 6c&OR2HGqO
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); n0kkUc-`
DataSource ds = (DataSource) ctx.lookup(jndi); g3,F+
Connection cn = ds.getConnection(); q"pnFK9/L
多用于jsp中 Nh\y@\F>
2、执行sql语句 t8FgQ)tk
1)用Statement来执行sql语句 =;A~$[ g
String sql; ~b{j`T
Statement sm = cn.createStatement(); u+uu?.bM
sm.executeQuery(sql); // 执行数据查询语句(select) auQfWO[ u
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); vW4N[ .+
2)用PreparedStatement来执行sql语句 \Rvsy;7
String sql; Bn{0-5nj
sql = "insert into user (id,name) values (?,?)"; ?GKm_b]JC
PreparedStatement ps = cn.prepareStatement(sql); q9"~sCH
ps.setInt(1,xxx); hk1jxnQh
ps.setString(2,xxx); MHKB:t]hA
... q CB9z
ResultSet rs = ps.executeQuery(); // 查询 mPo] .z
int c = ps.executeUpdate(); // 更新 ^7~w yAr
hKW!kA=gZ
3、处理执行结果 dbLxm!;(
查询语句,返回记录集ResultSet Q CB~x2C
更新语句,返回数字,表示该更新影响的记录数 7 }sj&
ResultSet的方法 Dbo.N`
1、next(),将游标往后移动一行,如果成功返回true;否则返回false -d6*M*{|
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 8?7:sfc
@3b|jJyf
4、释放连接 +j@|D@z
cn.close(); !w)Mm P Xb
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection Bnxzy
n
ReK@~#hLY
可滚动、更新的记录集 )7i?8XiSZF
1、创建可滚动、更新的Statement l5h9Eq
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); s)M2Z3>+
该Statement取得的ResultSet就是可滚动的 R<U?)8g,h~
2、创建PreparedStatement时指定参数 vy"Lsr3
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ;!~;05^iD
ResultSet.absolute(9000); dIpt&nH&$
批量更新 'Vrev8D
1、Statement /e7'5#v
Statement sm = cn.createStatement(); /t9w%Y
sm.addBatch(sql1); q/B+F%QiMQ
sm.addBatch(sql2); +p cj8K%
... HRb_ZJz
sm.executeBatch() Txfb-f!mv\
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 (bo bKr
2、PreparedStatement 1I@4xC
#X
PreparedStatement ps = cn.preparedStatement(sql); M5x!84
{ pz$$K?
ps.setXXX(1,xxx); NqwVsVL
... [{ { ?e6J
ps.addBatch(); 3,F/i+@
} mm{U5
ps.executeBatch(); +I Ze`M%n
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 -y\N 9
eLC&f}
事务的处理 <#s-hQ
1、关闭Connection的自动提交 O?2<rbx
cn.setAutoCommit(false); n7MS{`
2、执行一系列sql语句 c'|MC[^A
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close MV/~Rmd.
Statement sm ; cUm9s>^)/
sm = cn.createStatement(insert into user...); $>h#|?*?
sm.executeUpdate(); %&]}P;&
sm.close(); R_1C+
sm = cn.createStatement("insert into corp...); &
9]KkY=
sm.executeUpdate(); t~a$|(
9
sm.close(); .y0](
h
3、提交 %zelpBu+
cn.commit(); fgp7 |;Y
4、如果发生异常,那么回滚 ,m"ztu-
cn.rollback();