java 数据库基本操作 I^O`#SA (
1、java数据库操作基本流程 QjsN7h&%
2、几个常用的重要技巧: ks8x xY
可滚动、更新的记录集 %%Wn: c>
批量更新 Zk #C!]=
事务处理 =V^8RlBi
<h~_7Dn
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 C2?p>S/q
1、取得数据库连接 XOzZtt
1)用DriverManager取数据库连接 6
wD
例子 c`V~?]I>
String className,url,uid,pwd; .:;#[Z{-
className = "oracle.jdbc.driver.OracleDriver"; W0Q;1${
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; WoWBZ;+U
uid = "system"; N4,!b_1
pwd = "manager"; `{\10j*B
Class.forName(className); m6
a@Y<
Connection cn = DriverManager.getConnection(url,uid,pwd); oSoU9_W
2)用jndi(java的命名和目录服务)方式 LMYO>]dg
例子 gd ; e-.
String jndi = "jdbc/db"; .w~zW*M0
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); v&u8Ks
DataSource ds = (DataSource) ctx.lookup(jndi); ]m""ga
Connection cn = ds.getConnection(); @RS|}M^4
多用于jsp中 +tFl
2、执行sql语句 >l!DWi6
1)用Statement来执行sql语句 -\fn \n
String sql; f<( ysl1[
Statement sm = cn.createStatement(); W_G'wU3R
sm.executeQuery(sql); // 执行数据查询语句(select) z,=k F I
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 2o-Ie/"d\
2)用PreparedStatement来执行sql语句 8Vqh1<
String sql; ~D\ V!
sql = "insert into user (id,name) values (?,?)"; MQGR-WV=5
PreparedStatement ps = cn.prepareStatement(sql); 6\?<:Qto
ps.setInt(1,xxx); ]+i~Cbj
ps.setString(2,xxx); . xdSUe
... eI*o9k$Qs
ResultSet rs = ps.executeQuery(); // 查询 <f`G@
int c = ps.executeUpdate(); // 更新 k
M' :.QT
p/inATH
3、处理执行结果 ]Syr{|
查询语句,返回记录集ResultSet Sj<WiQ%<
更新语句,返回数字,表示该更新影响的记录数 m%km@G$
ResultSet的方法 :*/`"M)'
1、next(),将游标往后移动一行,如果成功返回true;否则返回false B>M @ '
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 2Fsv_t&*>
S&YC"
4、释放连接 JA~v:ec
cn.close(); pe$l'ur
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection Ljjuf=]
$Y5m"wySZ
可滚动、更新的记录集 y6nPs6kR
1、创建可滚动、更新的Statement aM|^t:
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); -(]s!,
该Statement取得的ResultSet就是可滚动的 Q4,!N(>D
2、创建PreparedStatement时指定参数 4R/cN'-
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 0xYPK7a=L\
ResultSet.absolute(9000); X]OVc<F
批量更新 Akbt%&
1、Statement 3B5GsI
Statement sm = cn.createStatement(); ]hL`HP
sm.addBatch(sql1); [_h/DhC:+
sm.addBatch(sql2); <,!e*V*U
... vC9Qe
]f
sm.executeBatch() JXIxk"m
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 IE|$mUabm
2、PreparedStatement `i,l)X]
PreparedStatement ps = cn.preparedStatement(sql); ~S, R`wo
{ M_wj>NXZ
ps.setXXX(1,xxx); LzW8)<N
... V6C*d:
ps.addBatch(); .A. VOf_
} `"/s," c:D
ps.executeBatch(); ^"e|)4_5\
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 5HZ t5="+
5QjM,"`mp
事务的处理 )oRF/Xx`g
1、关闭Connection的自动提交 5mxYzu;#]
cn.setAutoCommit(false); a$*)d($
2、执行一系列sql语句 ([r4N#lx
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close qBKRm0<W
Statement sm ; W'BB FG
sm = cn.createStatement(insert into user...); :QGd/JX$n`
sm.executeUpdate(); gua +-##)
sm.close(); [!ghI%VK
sm = cn.createStatement("insert into corp...); I0
78[3b
sm.executeUpdate(); ?~vVSY
sm.close(); `*J;4Ju@
3、提交 iz&$q]P8
cn.commit(); arR9uxP
4、如果发生异常,那么回滚 L|wD2iw
cn.rollback();