java 数据库基本操作 ^$oEM0h
1、java数据库操作基本流程 yC|odX#
2、几个常用的重要技巧: k#mL4$]V5N
可滚动、更新的记录集 56NDU>j$
批量更新 7s:cg
事务处理 2AxKB+c1`
YVz,P_\(m
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 SST@
1、取得数据库连接 ^tjM1uaZ5(
1)用DriverManager取数据库连接 =PjdL32
例子 >%t5j?p
String className,url,uid,pwd; i8R2Y9Q*O
className = "oracle.jdbc.driver.OracleDriver"; +f_3JL$
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; V{qR/
uid = "system"; =G'J@[d{d
pwd = "manager"; $\20Vgu<
Class.forName(className); 0PUSCka'6
Connection cn = DriverManager.getConnection(url,uid,pwd); C'sA0O@O
2)用jndi(java的命名和目录服务)方式 $Nj'_G\}
例子 R-f('[u
String jndi = "jdbc/db"; 5g9K|-
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); Q5Mn=
DataSource ds = (DataSource) ctx.lookup(jndi); $"Ci{iE
Connection cn = ds.getConnection(); oMq:4W,
多用于jsp中 su8()]|0x
2、执行sql语句 [e:ccm
1)用Statement来执行sql语句 [,z>msEB.
String sql; 6-{wo)p
Statement sm = cn.createStatement(); {;JFoe+
sm.executeQuery(sql); // 执行数据查询语句(select) *tDxwD7
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); &&96kg3
2)用PreparedStatement来执行sql语句 '0qKb*
String sql; S^i<_?nwg
sql = "insert into user (id,name) values (?,?)"; $KGRpI
PreparedStatement ps = cn.prepareStatement(sql); #_Lgo
ps.setInt(1,xxx); 5'(#Sf
ps.setString(2,xxx); x.(Sv]+[
... zj1_#=]
ResultSet rs = ps.executeQuery(); // 查询 pM!cF
int c = ps.executeUpdate(); // 更新 5* ~EdT
0{Zwg0&
3、处理执行结果 = o1&.v2j
查询语句,返回记录集ResultSet VK}H;
更新语句,返回数字,表示该更新影响的记录数 :+fW#:
ResultSet的方法 uH)v\Js
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ;,B $lgF
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 0qN?4h)7
a)/ }T
4、释放连接 h61BIc@>
cn.close(); U
owbk:
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection GM@0$
eI5W; Q4
可滚动、更新的记录集 )OQih+#?W
1、创建可滚动、更新的Statement oi^pU
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); @CCDe`R*
该Statement取得的ResultSet就是可滚动的 [;7$ 'lr%D
2、创建PreparedStatement时指定参数 Reg%ah|$/=
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); R&L^+?
ResultSet.absolute(9000); ,L(q/#p
批量更新 {w9GMqq
1、Statement 3 k)P*ME#
Statement sm = cn.createStatement(); KKw J=za
sm.addBatch(sql1); ~ \7peH%
sm.addBatch(sql2); 0VI[6t@
... E-$N!KY
sm.executeBatch() 5jc y*G}[
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 3DZ8-N
S
2、PreparedStatement =G1
5eZW
PreparedStatement ps = cn.preparedStatement(sql); P # Z+:T
{ X]Ma:1+
ps.setXXX(1,xxx); j"P}Wn
... 4Mjcx.21
ps.addBatch(); p+{*&Hm5
} g; ZVoD
ps.executeBatch();
m<:g\_<
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 J|WkPv2
Uv=hxV[7y
事务的处理 }& e#b]&:*
1、关闭Connection的自动提交 (d=knoo7A
cn.setAutoCommit(false); 1Qo2Z;h@
2、执行一系列sql语句 ?Ns aZ
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close uhr&P4EW
Statement sm ; T_4y;mf!@O
sm = cn.createStatement(insert into user...); 2?9gf,U
sm.executeUpdate(); Y:K1v:Knw
sm.close(); ?_G?SQ
sm = cn.createStatement("insert into corp...); qMmhmH)Gp
sm.executeUpdate(); zVtNT@1K>u
sm.close(); tc)4$"9)
3、提交 1}I%yOi)
cn.commit(); ?\T):o;/
4、如果发生异常,那么回滚 ?h|w7/9
cn.rollback();