java 数据库基本操作 yt5<J-m
1、java数据库操作基本流程 hhZ%{lqL
2、几个常用的重要技巧: PsXCpyY!s
可滚动、更新的记录集 FdzdoMY
批量更新 'ROz| iJ
事务处理 SlR//h
ZAN~TG<n
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 >(.|oT\Tb
1、取得数据库连接 =#y;J(>~|
1)用DriverManager取数据库连接 PQSmBTs.
例子 KA?%1s(kJ
String className,url,uid,pwd; sCrP+K0D
className = "oracle.jdbc.driver.OracleDriver"; ,zHL8SiTX
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; tcv(<0
uid = "system"; V,d\Wk k/
pwd = "manager"; O_4B>
)zd
Class.forName(className); jaKW[@<
Connection cn = DriverManager.getConnection(url,uid,pwd); <4vCx
2)用jndi(java的命名和目录服务)方式 jK*d
例子 4OgH+<G
String jndi = "jdbc/db"; yF.Gz`yi
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); Pvi2j&W84
DataSource ds = (DataSource) ctx.lookup(jndi); *PL&CDu=)
Connection cn = ds.getConnection(); d4\JM 65
多用于jsp中 };9s8VZE
2、执行sql语句 w(S~}'Sg*P
1)用Statement来执行sql语句 iCg%$h
String sql; e"eIQI|N
Statement sm = cn.createStatement(); :}Yk0*
sm.executeQuery(sql); // 执行数据查询语句(select) Hv,ll1@h
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); U), HrI>;
2)用PreparedStatement来执行sql语句
nYZ6'Iwi'
String sql; Y)5O %@Rl
sql = "insert into user (id,name) values (?,?)"; la-:"gKC
PreparedStatement ps = cn.prepareStatement(sql); *!&?Xy%\"j
ps.setInt(1,xxx); ,pGA|ob
ps.setString(2,xxx); ~Hub\kn
... f)z(9JJL
ResultSet rs = ps.executeQuery(); // 查询 E wFq1~
int c = ps.executeUpdate(); // 更新 `P !idg*
pInEB6L.P
3、处理执行结果 3I~.'>Pd
查询语句,返回记录集ResultSet 9S}rTZkEq
更新语句,返回数字,表示该更新影响的记录数 `H$XO{w
ResultSet的方法 s_fe4K
1、next(),将游标往后移动一行,如果成功返回true;否则返回false @!!u>1
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 2672oFD
,iP
YsW]5
4、释放连接 ~B"HI+:\L
cn.close(); &DGz/o
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection }k%6X@
^IuhHP
可滚动、更新的记录集 a?r$E.W'&
1、创建可滚动、更新的Statement _!DH/?aU
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); r/ g{j
该Statement取得的ResultSet就是可滚动的 #.HnO_sK_
2、创建PreparedStatement时指定参数 l~]] RgU
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); *(q?O_3,b
ResultSet.absolute(9000); SF-"3M
批量更新 cRrJZ9
1、Statement |a#ikY _nd
Statement sm = cn.createStatement(); s<!G2~T
sm.addBatch(sql1); w[gt9]}N
sm.addBatch(sql2); ;iKtv+"
... sZ&|omN
sm.executeBatch() S8/~'<out
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 JP6 Noia
2、PreparedStatement ]zJO)(d$>
PreparedStatement ps = cn.preparedStatement(sql); 7UW\|r
{ ij-'M{f
ps.setXXX(1,xxx); } (-9d
... <Y}m/-sD5
ps.addBatch(); zE$HHY2ovi
} Tt~[hC
h
ps.executeBatch(); QA0uT{x90
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 +39uKOrZ
rmkBp_i{|
事务的处理 |LQ%sV
1、关闭Connection的自动提交 c8uw_6#r(D
cn.setAutoCommit(false); 1[Yl8W%pj
2、执行一系列sql语句 ?|W3RK;
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close Bt@?l]Y
Statement sm ; zc)nDyn
sm = cn.createStatement(insert into user...); *aCVkFp
sm.executeUpdate(); W9w(a:~hY
sm.close(); u]Vt>Ywu
sm = cn.createStatement("insert into corp...); q%kCTw
sm.executeUpdate(); eu$VKLY*
sm.close(); 9 CZ@IFS
3、提交 _^GBfM.
cn.commit(); MjC<N[WO>N
4、如果发生异常,那么回滚 TCyev[(
cn.rollback();