java 数据库基本操作 :t(gD8 ;
1、java数据库操作基本流程 0Q;T
<%U
2、几个常用的重要技巧: .hg<\-:_
可滚动、更新的记录集 H
#J"'
批量更新 :u'X
~ID[
事务处理 }yLdU|'W
; QR|v
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 prlnK
1、取得数据库连接 5u:+hB
1)用DriverManager取数据库连接 GuV-[
例子 blid* @-
String className,url,uid,pwd; %{yr#F=t#]
className = "oracle.jdbc.driver.OracleDriver"; u%V=Ze
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; -]Z!_[MlDF
uid = "system"; vROl}s;
pwd = "manager"; dY~3YD[
Class.forName(className); UX41/# 4
Connection cn = DriverManager.getConnection(url,uid,pwd); L:`|lc=^
2)用jndi(java的命名和目录服务)方式 U#-&%|b$
例子 394u']M
String jndi = "jdbc/db"; \C
ZiU3
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); B+jT|Y'
DataSource ds = (DataSource) ctx.lookup(jndi); $sU?VA'h
Connection cn = ds.getConnection(); =P'=P0G
多用于jsp中 !}"npUgE
2、执行sql语句 !__f
1)用Statement来执行sql语句 Umv_{n`
String sql; 3HO4h\mp
Statement sm = cn.createStatement(); S5"xb
sm.executeQuery(sql); // 执行数据查询语句(select) K^J;iu 4
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); RT9fp(6*
2)用PreparedStatement来执行sql语句 56G5JSB=\
String sql; J6hWcA6g
sql = "insert into user (id,name) values (?,?)"; 1|;WaO1Q
PreparedStatement ps = cn.prepareStatement(sql); jn^i4f>N
ps.setInt(1,xxx); YM 7P!8Gc
ps.setString(2,xxx); U@|{RP
... 8hQ"rrj+
ResultSet rs = ps.executeQuery(); // 查询 XZV)4=5iSO
int c = ps.executeUpdate(); // 更新 dDi 1{s
q
.tVNKy%
3、处理执行结果 w6Dysg:
查询语句,返回记录集ResultSet /Or76kE
更新语句,返回数字,表示该更新影响的记录数 y@~.b^?_u
ResultSet的方法 `y;&M8.
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ).9-=P HlX
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ;)83tx
/
3Nr8H.u&q
4、释放连接 k|BY 7C
cn.close(); Xvi{A]V
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 56>Zqtp*
,$}P<WZMu
可滚动、更新的记录集 \z:p"eua z
1、创建可滚动、更新的Statement %a5Sc|&-
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY);
G2;Uv/vR
该Statement取得的ResultSet就是可滚动的 *#N%3:@T
2、创建PreparedStatement时指定参数
U^VFHIm
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); uji])e MN~
ResultSet.absolute(9000); +P~zn=
批量更新 To}L%)
1、Statement klT6?'S
Statement sm = cn.createStatement(); PgB=<#9
sm.addBatch(sql1); 5G(y
sm.addBatch(sql2); 2EG"xA5%
... bkmX@+Pe
sm.executeBatch() @`%.\_
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 #@2 `^1
2、PreparedStatement /iy2j8:z
PreparedStatement ps = cn.preparedStatement(sql); /J/r 62
{ W;~^3Hz6
ps.setXXX(1,xxx); %- %/3
... \Vm{5[ :SA
ps.addBatch(); @F=ZGmq
} 8}xU]N#EV
ps.executeBatch(); E IEwrC
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 {4}Sl^kn*
6@H&S
事务的处理 |8`}yRsQ
1、关闭Connection的自动提交 [DGq{(O
cn.setAutoCommit(false); e Yyl=YW
2、执行一系列sql语句 zFP}=K:o)
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close :eHh }
Statement sm ; \M:,Vg
sm = cn.createStatement(insert into user...); rvw1'y
sm.executeUpdate(); z]Ql/AK
sm.close(); &Radpb2p6
sm = cn.createStatement("insert into corp...); FE M_7M
sm.executeUpdate(); QHP^1W`
sm.close(); lDMYDy{<
3、提交 ~+l%}4RZ
cn.commit(); _[0Ugfz(
4、如果发生异常,那么回滚 9nM {x?
cn.rollback();