java 数据库基本操作 1$8@CT^m
1、java数据库操作基本流程 jM&di
2、几个常用的重要技巧: l2LLM {B
可滚动、更新的记录集 D8<C7
批量更新 qXg&E}]:=
事务处理 0:`|T jf_
:{2~s
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ]q.%_
1、取得数据库连接
p"#\E0GM
1)用DriverManager取数据库连接 kzjuW
例子 JwB'B
String className,url,uid,pwd; ~L"$(^/
className = "oracle.jdbc.driver.OracleDriver"; 8[KKi ~A
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; &s='$a;4
uid = "system"; >UMxlvTg&
pwd = "manager"; :oXSh;\
Class.forName(className); Bl*}*S PU
Connection cn = DriverManager.getConnection(url,uid,pwd); (Kwqa"Hk4{
2)用jndi(java的命名和目录服务)方式 >Jmla~A
例子 6,A|9UX=`
String jndi = "jdbc/db"; W;'fAohr
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 9H/>M4RT
DataSource ds = (DataSource) ctx.lookup(jndi); +bS\iw +
Connection cn = ds.getConnection(); uMEM7$o
多用于jsp中 `R$i|,9)
2、执行sql语句 u0h%4f!X
1)用Statement来执行sql语句 %(1OjfZc
String sql; VD$5 Djq
Statement sm = cn.createStatement(); %+H _V1F
sm.executeQuery(sql); // 执行数据查询语句(select) B=!!R]dxA
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 7ocUFY0"
2)用PreparedStatement来执行sql语句 Qz,2PO
String sql; 8i154#l+\
sql = "insert into user (id,name) values (?,?)"; b2OwLt9
PreparedStatement ps = cn.prepareStatement(sql); |gA@WV-%
ps.setInt(1,xxx); 4AS%^&ah
ps.setString(2,xxx); Y
{^*y
... Qds<j{2
ResultSet rs = ps.executeQuery(); // 查询 ->rqr#
int c = ps.executeUpdate(); // 更新 1EXT^2!D
o{G*7V@H
3、处理执行结果 `9co7[Z
查询语句,返回记录集ResultSet =I`S7oF
更新语句,返回数字,表示该更新影响的记录数 TKR#YJQ?K
ResultSet的方法 E{<#h9=>
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ZC N}iQu4
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 y#j7vO
`qc"JB
4、释放连接 WR{m?neE_N
cn.close();
6sBt6?_T
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection cu N9RG
w'K7$F51
可滚动、更新的记录集 y>EW,%leC
1、创建可滚动、更新的Statement kk /#&b2
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); gsbr8zwG,
该Statement取得的ResultSet就是可滚动的 "[N2qJ}p
2、创建PreparedStatement时指定参数 7GOBb|
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); c!ZZMCs
ResultSet.absolute(9000); [)Nt;|U
批量更新 cXPpxRXBD
1、Statement L5bq\
Statement sm = cn.createStatement(); V: D;?$Jl
sm.addBatch(sql1); pUHgjwT'U
sm.addBatch(sql2); '#7k9\
... A0<g8pv
sm.executeBatch() = LNU%0m
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 AioW*`[WjA
2、PreparedStatement Wx:v~/r
PreparedStatement ps = cn.preparedStatement(sql); @Chl>s
{ pAOKy
ps.setXXX(1,xxx); k24I1DlR8
... 4Y8=
ps.addBatch(); x4I!f)8Q
} I?'*vAW<
ps.executeBatch(); 98Vv K?
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 "z{/*uM2<
4Hz3KKu
事务的处理 gD9CA*
1、关闭Connection的自动提交 ^
8 }P_
cn.setAutoCommit(false); ESCN/ocV
2、执行一系列sql语句 Mt4
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close cy8>M))c
Statement sm ; @D;K&:~|N
sm = cn.createStatement(insert into user...); q-(~w!e
sm.executeUpdate(); IU8zidn&
sm.close(); R4'.QZ-x
sm = cn.createStatement("insert into corp...); kH eD(Ea
sm.executeUpdate(); peVY2\1>R
sm.close(); ;0dH@b
3、提交 $mPR)T
cn.commit(); /(^-=pAX
4、如果发生异常,那么回滚 %unn{92)
cn.rollback();