java 数据库基本操作 .!,T>:R
1、java数据库操作基本流程 hI;tB6
2、几个常用的重要技巧: MaXgy|yB1
可滚动、更新的记录集 `*8p T
批量更新 z`xdRe{QP
事务处理 ed2QGTgR
~DhYiOSo
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 LnxJFc:1K
1、取得数据库连接 Wze\z
1)用DriverManager取数据库连接 CP'?Om2
例子 br>"96A1l
String className,url,uid,pwd; E*.D_F
className = "oracle.jdbc.driver.OracleDriver"; _%;$y5]v
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; OYgD9T.8^
uid = "system"; 3F[z]B
pwd = "manager"; 1N1MD@C?P
Class.forName(className); 7
\!t/<
Connection cn = DriverManager.getConnection(url,uid,pwd); 5)2lZ(5.A#
2)用jndi(java的命名和目录服务)方式 zy8W8h(?
例子 +I5@Gys
String jndi = "jdbc/db"; eL#pS=
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); }9aYU;9D
DataSource ds = (DataSource) ctx.lookup(jndi); y!."FoQ
Connection cn = ds.getConnection(); 5"c#OU
多用于jsp中 :U0z;
2、执行sql语句 eFp4MD8?
1)用Statement来执行sql语句 %w=*4!NWb
String sql; 41^+T<+
Statement sm = cn.createStatement(); 7<mY{!2iF?
sm.executeQuery(sql); // 执行数据查询语句(select) =\ iV=1iB
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); !BP/#
2)用PreparedStatement来执行sql语句 "D2`=D!+
String sql; ,*Tf9=z
sql = "insert into user (id,name) values (?,?)"; .4Jea#M&x
PreparedStatement ps = cn.prepareStatement(sql); `Ou\:Iz0u
ps.setInt(1,xxx); M8ZpNa
ps.setString(2,xxx); 4H]Go~<
... Im+<oZ
ResultSet rs = ps.executeQuery(); // 查询 TPt<(-}W
int c = ps.executeUpdate(); // 更新 /^G1wz2
6OF&Q`*4
3、处理执行结果 ib0M$Y1tIS
查询语句,返回记录集ResultSet `!kOyh:X
更新语句,返回数字,表示该更新影响的记录数 CQW#o_\
ResultSet的方法 {l%Of
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ,H2[["1DH
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 [:
i!LEA/"V
4、释放连接 'mp@!@_
cn.close(); 8Sd<!
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection [DC8X P5<
?V4?r2$c
可滚动、更新的记录集 (q59cA w~X
1、创建可滚动、更新的Statement y9{KBM%h
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ?"N,do
该Statement取得的ResultSet就是可滚动的 btJ:Wt}
2、创建PreparedStatement时指定参数 Waj6.PCFm
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); X&8&NkH
ResultSet.absolute(9000); oa? bOm
批量更新 <xKer<D
%
1、Statement ) kfA5xi[
Statement sm = cn.createStatement(); S4aN7.'Q
sm.addBatch(sql1); [
p$f)'
sm.addBatch(sql2); $d3al%Uo
... lRF04
sm.executeBatch() ]wMd!.lm-
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 )gYsg
2、PreparedStatement 0D+[W5TB
PreparedStatement ps = cn.preparedStatement(sql); Wl/oun~o
{ 7+0Kg'^+n
ps.setXXX(1,xxx); c3W9"
... y4PR&^l?g
ps.addBatch(); Z,^`R] 9
} OS;qb:;
ps.executeBatch(); pwtB{6)VH{
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 !}<d6&!py
S}f3b N
事务的处理 rG|lRT3-K
1、关闭Connection的自动提交 rkugV&BhV
cn.setAutoCommit(false); )y4bb^;z
2、执行一系列sql语句 ON.C%-T-
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 5R\{&
Statement sm ; "j;"\i0
sm = cn.createStatement(insert into user...); 18f!k
sm.executeUpdate(); :W6`{Z
sm.close(); hOw
sm = cn.createStatement("insert into corp...); S.pL^Ru
sm.executeUpdate(); ecDni>W
sm.close(); IL;JdIa
3、提交 kU{+@MA;
cn.commit(); j*+[=X/
4、如果发生异常,那么回滚 Tw*:Vw
cn.rollback();