java 数据库基本操作 iB~dO @
1、java数据库操作基本流程 { /8s`m
2、几个常用的重要技巧: SN7_^F
可滚动、更新的记录集 lA6{TH.x
批量更新 pp#!sRUKPV
事务处理 cYOcl-*af
FyXO @yF
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 eH*i_g'
1、取得数据库连接 wpNb/U
1)用DriverManager取数据库连接 F7=\*U
例子 U3M;{_g
String className,url,uid,pwd; n~jW
className = "oracle.jdbc.driver.OracleDriver"; q{[y4c1bG{
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; }lq$Fi/
uid = "system"; /7a3*a
pwd = "manager"; P $r!u%W
Class.forName(className); TL-ALtG
Connection cn = DriverManager.getConnection(url,uid,pwd); xvWP^Qkb
2)用jndi(java的命名和目录服务)方式 !af;5F
例子 8@6*d.+e
String jndi = "jdbc/db"; 3EA_-?
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); fkk9&QB%(
DataSource ds = (DataSource) ctx.lookup(jndi); }\A0g}
Connection cn = ds.getConnection(); E1A5<^t
多用于jsp中 G!D~*B9G
2、执行sql语句 AGx(IK/_
1)用Statement来执行sql语句 Sl
\EPKZD
String sql; dJb7d`
Statement sm = cn.createStatement(); HuxvIg
sm.executeQuery(sql); // 执行数据查询语句(select) K)\D,5X^
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); >;s2V_d
2)用PreparedStatement来执行sql语句 6hFs{P7
String sql; d%!yFix;<
sql = "insert into user (id,name) values (?,?)"; J3r':I}\
PreparedStatement ps = cn.prepareStatement(sql); JmBMc}54
ps.setInt(1,xxx); CWD
$\K G
ps.setString(2,xxx); D{+D.4\
... $ Fy)+<
ResultSet rs = ps.executeQuery(); // 查询 #S|On[Q!
int c = ps.executeUpdate(); // 更新 dVJ9cJ9^
E
/ycPqD
3、处理执行结果
y}W*P#BDO
查询语句,返回记录集ResultSet
@3I?T
Q1
更新语句,返回数字,表示该更新影响的记录数 m
.En!~t
ResultSet的方法 (+TL
]9P
1、next(),将游标往后移动一行,如果成功返回true;否则返回false \qJ^n %
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 v1NFz>Hx
\J6e/ G
4、释放连接 #vR5a}BAk
cn.close(); JgldC[|7
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection ,nw5 M.D_
`_{,4oi
可滚动、更新的记录集 'f.5hX(Y
1、创建可滚动、更新的Statement z2dW)_fU$
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ;s-fYS6(>{
该Statement取得的ResultSet就是可滚动的 7.
eiM!7g
2、创建PreparedStatement时指定参数 &{x`K4N
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); :O*62olC5
ResultSet.absolute(9000); }sfvzw_
批量更新 <yKyM#4X
1、Statement ~HBx5Cpi
Statement sm = cn.createStatement(); !j0iLYo(*
sm.addBatch(sql1); /
DST|2
sm.addBatch(sql2); aS+i`A :a
... i32S(3se
sm.executeBatch() +AOpB L'
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 j<vU[J+gx~
2、PreparedStatement y)`q% J&
PreparedStatement ps = cn.preparedStatement(sql); []H0{a2{<
{ wq#'o9s,
ps.setXXX(1,xxx); R)GDsgXy
... c=IjR3F
ps.addBatch(); ">R`S<W
} oeG?2!Zh
ps.executeBatch(); ?? Dv\yLZI
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 xb^M33-y
S%w67sGl4n
事务的处理 7+J<N@.d
1、关闭Connection的自动提交 V} t8H
cn.setAutoCommit(false); &. "ltB
2、执行一系列sql语句 d|$-Sz
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close FHZQyO<|
Statement sm ; <V4"+5cJ8
sm = cn.createStatement(insert into user...); A@I3:V
sm.executeUpdate(); ?h ym~,
sm.close(); -k@Uo(MB
sm = cn.createStatement("insert into corp...); -"n8Wv
sm.executeUpdate(); 4' <y
sm.close(); izr
3{y5
3、提交 xh!aB6m8R
cn.commit(); )0 i$Bo
4、如果发生异常,那么回滚
d>1#|
cn.rollback();