java 数据库基本操作 qu]a+cYY
1、java数据库操作基本流程 )"|wWu
2、几个常用的重要技巧: yB=R7E7
可滚动、更新的记录集 zlTLp-^Y
批量更新 8wZ
$Hq
事务处理 5p:2gsk
K`ygW|?gt
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 B}*\ pdJ
1、取得数据库连接 +l!.<:sp
1)用DriverManager取数据库连接 s|Vs#o.P)
例子 QwF.c28[
String className,url,uid,pwd; D+oV( Pw,
className = "oracle.jdbc.driver.OracleDriver"; -;RAW1]}Y$
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; PJe\PGh
uid = "system"; :B|rs&
pwd = "manager"; {!{T,_ J
Class.forName(className); pCa~:q*85
Connection cn = DriverManager.getConnection(url,uid,pwd); `/wXx5n5<
2)用jndi(java的命名和目录服务)方式 ;ByCtVm2
例子 k<f0moxs'
String jndi = "jdbc/db"; @y0kX<M
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); upJy,|5
DataSource ds = (DataSource) ctx.lookup(jndi); <Nc9F['
Connection cn = ds.getConnection(); *tkf)[(
多用于jsp中 f^5sJ0;%
2、执行sql语句 VeQ [A?pER
1)用Statement来执行sql语句 U~c9PqjZ
String sql; h\Zh^B6J
Statement sm = cn.createStatement(); I<xcVY9L
sm.executeQuery(sql); // 执行数据查询语句(select)
>Yv#t.!
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); y] Cx[
2)用PreparedStatement来执行sql语句 A^0-%Ygl
String sql; *]k E3
sql = "insert into user (id,name) values (?,?)"; ]x3 )OjH
PreparedStatement ps = cn.prepareStatement(sql); 9{A*[.XK]
ps.setInt(1,xxx); 6G-XZko~a
ps.setString(2,xxx); hKsx7`[
... y4!fu<[i
ResultSet rs = ps.executeQuery(); // 查询 ~wGjr7Wt
int c = ps.executeUpdate(); // 更新 #SD2b,f
lb"T'}q
3、处理执行结果 nRX<$OzTV
查询语句,返回记录集ResultSet ~IQjQz?
更新语句,返回数字,表示该更新影响的记录数 Xa&:Hg<
ResultSet的方法 O&">%aU1I
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ~ r$I&8
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 &N%-.&t'
7FP"]\x
4、释放连接 U?(,Z$:N
cn.close(); "DJ%Yo
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 3|Ar~_]
kYd=DY
可滚动、更新的记录集 T(~^X-k
1、创建可滚动、更新的Statement BMhuM~?(
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); lPl JL`e
该Statement取得的ResultSet就是可滚动的 \nQEvcH
2、创建PreparedStatement时指定参数 ,l\D@<F
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); V<REcII.
ResultSet.absolute(9000); W*4!A\K
批量更新 b|`
1、Statement Aca?C
Statement sm = cn.createStatement(); gti=GmL(L
sm.addBatch(sql1); 3v<9 Z9O
sm.addBatch(sql2); e9B$"_ &2
... u)ZZ/|
sm.executeBatch() / pR,l5
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有
+!wkTrV
2、PreparedStatement WxF@'kdn*,
PreparedStatement ps = cn.preparedStatement(sql); [{_K[5i
{
q0\$wI
ps.setXXX(1,xxx); .q$/#hN:e
... UX'tdB
!A
ps.addBatch(); ,k/<Nv;
} @;d7#!:cE
ps.executeBatch(); @{8805Dp
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 h3A|nd>\
nSU7,K`PM
事务的处理 u\UI6/
1、关闭Connection的自动提交 6IM:Xj
cn.setAutoCommit(false); 9,
792b
2、执行一系列sql语句 #DHeEE
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close Al]z=
Statement sm ; SCMZ-^b
sm = cn.createStatement(insert into user...); HM\gOz
sm.executeUpdate(); * (<3 oIRS
sm.close(); #.\X%!
sm = cn.createStatement("insert into corp...); kc:2ID&
sm.executeUpdate(); ^KFwO=I@PV
sm.close(); O<w7PS
3、提交 885
,3AdA
cn.commit(); /ec~^S8X
4、如果发生异常,那么回滚 /?QBMI
cn.rollback();