java 数据库基本操作 '/^qJ7eb
1、java数据库操作基本流程 *GL/aEI<$
2、几个常用的重要技巧: xHD=\,{ig
可滚动、更新的记录集 2#c<\s|C
批量更新 ww],y@da
事务处理 JzQ )jdvp
+%ee8|\
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 |#]@Z)xa
1、取得数据库连接 X:vghOt?
1)用DriverManager取数据库连接 lPw%ErG
例子 u>2
l7PA|
String className,url,uid,pwd; 3h$6t7=C
className = "oracle.jdbc.driver.OracleDriver"; .\)U@L~
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; &m-PC(W+
uid = "system"; E87Ww,z8
pwd = "manager"; E2R&[Q"%
Class.forName(className); 6ZP(E^.
Connection cn = DriverManager.getConnection(url,uid,pwd); PHZ0P7
2)用jndi(java的命名和目录服务)方式 J IUx
例子 JB<Sl4
String jndi = "jdbc/db"; um!J]N^
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ,$s8GAmq
DataSource ds = (DataSource) ctx.lookup(jndi); n\*!CXc
Connection cn = ds.getConnection(); |)(VsVG&
多用于jsp中 Egg=yF>T
2、执行sql语句 X= 5xh
1)用Statement来执行sql语句 u)}$~E>
String sql; CDQW !XHc
Statement sm = cn.createStatement(); =8AO:
sm.executeQuery(sql); // 执行数据查询语句(select) K,+LG7ec
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); n"G&ENN"$
2)用PreparedStatement来执行sql语句 }`%*W`9b
String sql; J&W)(Cf
sql = "insert into user (id,name) values (?,?)"; =P't(<
PreparedStatement ps = cn.prepareStatement(sql); zv0l,-o
ps.setInt(1,xxx); Yc_8r+;(
ps.setString(2,xxx); p<2L.\6"
... 1w@(5 ^V
ResultSet rs = ps.executeQuery(); // 查询 TN+iA~kQ
int c = ps.executeUpdate(); // 更新 42G)~lun-d
kMi/>gpQ
3、处理执行结果 [j=yMP38!:
查询语句,返回记录集ResultSet HK,cJahq
更新语句,返回数字,表示该更新影响的记录数 }wr{W:j
ResultSet的方法 X' H[7 ^W
1、next(),将游标往后移动一行,如果成功返回true;否则返回false RJ 8+h
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 dCi?SIN
hYPl&^
4、释放连接 I*{4rDt
cn.close(); ,':fu
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection
P5a4ze
Mo?~_|}
可滚动、更新的记录集 8m2Tk\;:
1、创建可滚动、更新的Statement *|%@6I(
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); =,spvy'"*C
该Statement取得的ResultSet就是可滚动的 yu!h<nfzA
2、创建PreparedStatement时指定参数 Ugu[|,
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); uki#/GzaO
ResultSet.absolute(9000); +ga k#M"n\
批量更新 HHDl8lo
1、Statement U}yW<#$+
Statement sm = cn.createStatement(); T!+5[
sm.addBatch(sql1); QM5R`i{r
sm.addBatch(sql2); }()5"QB
... y"bByd|6
sm.executeBatch() 0m%|U'm|j
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 gd%NkxmW
2、PreparedStatement q)X$^oE!6
PreparedStatement ps = cn.preparedStatement(sql); OK[T3/v,
{ Uzz'.K(Mv|
ps.setXXX(1,xxx); rI= v
... S%bCyK%p
ps.addBatch(); & ?h#Z!
} s.bc>E0
ps.executeBatch(); g7}Gip}.>
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 t3*wjQ3
.k,1f*%
事务的处理 RDW8]=uM
1、关闭Connection的自动提交 )97SnCkal
cn.setAutoCommit(false); h`KFL/fT
2、执行一系列sql语句 hn5h\M?
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close Zn&,
t &z
Statement sm ; K0-ypU*P
sm = cn.createStatement(insert into user...); HePUWL'
sm.executeUpdate(); >80;8\
sm.close(); HW3 }uP\c
sm = cn.createStatement("insert into corp...); B~ ]k#Ot)
sm.executeUpdate(); Aydm2!l1
sm.close(); xSktg]u Se
3、提交 7C,&*Ax,9
cn.commit(); O@u?h9?cf>
4、如果发生异常,那么回滚 Yw4n-0g
cn.rollback();