java 数据库基本操作 1WbawiG}
1、java数据库操作基本流程 #{L
!o5
2、几个常用的重要技巧: q oJ4w7
可滚动、更新的记录集 Ze>Pg.k+
批量更新 e) x;3r"j
事务处理 jpW(w($XL
t
9Dr%#
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 76M`{m
1、取得数据库连接 M_monj}Z
1)用DriverManager取数据库连接 eOI#T'5
例子 cojbuo
String className,url,uid,pwd; 8OW504AD
className = "oracle.jdbc.driver.OracleDriver"; DJ#z0)3<p
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; {Vj25Gt
uid = "system"; [AHZOA
pwd = "manager"; i<%
Class.forName(className); I-`qo7dQ_S
Connection cn = DriverManager.getConnection(url,uid,pwd); W=)wiRQm
2)用jndi(java的命名和目录服务)方式 6"UL+$k
例子 dS[="Set
String jndi = "jdbc/db"; H@R2mw
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); fpK`
DataSource ds = (DataSource) ctx.lookup(jndi); =P"Sm
r
Connection cn = ds.getConnection(); Z" !+p{u
多用于jsp中 68v59)0U
2、执行sql语句 c6NCy s
1)用Statement来执行sql语句 J@I-tS
String sql; 9&t!U+
Statement sm = cn.createStatement(); ;"@FLq(n
sm.executeQuery(sql); // 执行数据查询语句(select) bk#t+tuk
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); }hjJt,m
2)用PreparedStatement来执行sql语句 ^-'t`mRl]d
String sql; ->S6S_H/+&
sql = "insert into user (id,name) values (?,?)"; d{LQr}_o$$
PreparedStatement ps = cn.prepareStatement(sql); rH<iUiA?O
ps.setInt(1,xxx); $CYB&|d
ps.setString(2,xxx); 8(Y=MW;g
... [@_zsz,`L
ResultSet rs = ps.executeQuery(); // 查询 9ywPWT[^
int c = ps.executeUpdate(); // 更新 .+"SDtoX
i%R2#F7I
3、处理执行结果 :8<\]}J
查询语句,返回记录集ResultSet U.@j!UrZ
更新语句,返回数字,表示该更新影响的记录数 8/|~E
ResultSet的方法 N>A*N,+
1、next(),将游标往后移动一行,如果成功返回true;否则返回false #(`@D7S"
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 h""a#n)q}`
@e/40l|X
4、释放连接 G)E#wh_S^
cn.close(); Cl+TjmOV\`
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection {=NHidi~
,6%{9oW9Z:
可滚动、更新的记录集 vG<JOxP
1、创建可滚动、更新的Statement >iCkvQ
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Qs*6wF
该Statement取得的ResultSet就是可滚动的 M!s@w%0?'
2、创建PreparedStatement时指定参数 \q8D7/q
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); =lf&mD
_/
ResultSet.absolute(9000); Hkv4t5F
批量更新 U*'
YGv
1、Statement L|3wGY9E
Statement sm = cn.createStatement(); t:
=
sm.addBatch(sql1); srN>pO8u~
sm.addBatch(sql2); g8{?;
... Q1Jkt
sm.executeBatch() F H'jP`
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 .+H8c.
2、PreparedStatement $UZ4,S?V
PreparedStatement ps = cn.preparedStatement(sql); .bm#|X)RO
{ cs ?@Ri=g
ps.setXXX(1,xxx); &B^vHH
... vYD>m~Qc^
ps.addBatch(); PUUBn"U-
} *mM+(]8US
ps.executeBatch(); qO<'_7TN[
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 R0y@#}JH
3mIX9&/
事务的处理 ,uD>.->
1、关闭Connection的自动提交 >8V;:(nt
cn.setAutoCommit(false); ]]s_ 8u3
2、执行一系列sql语句 2O|o%`?
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close FxKb
Statement sm ; DlR&Lnv
sm = cn.createStatement(insert into user...); 6 qK0G$>
sm.executeUpdate(); =*q:R9V
sm.close(); eB:obz
sm = cn.createStatement("insert into corp...); N,w;s-*
sm.executeUpdate(); qVFz-!6b
sm.close(); |67j__XC
3、提交 U/M(4H3>H
cn.commit(); x7J|
4、如果发生异常,那么回滚 rbnu:+!
cn.rollback();