java 数据库基本操作 vTP'\^;
1、java数据库操作基本流程 xxiEL2"`>
2、几个常用的重要技巧: CO5?UgA
可滚动、更新的记录集 'DRyOJn r
批量更新 O_KL#xo
事务处理 _oe2pL&
mw?,oiT,)
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 _g$6vx&
1、取得数据库连接 {9_CH<$W%U
1)用DriverManager取数据库连接 `Z/"Dd;F^3
例子 QJ>+!p*
String className,url,uid,pwd; 6ZCt xs!
className = "oracle.jdbc.driver.OracleDriver"; YI&^j2
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; 2Hy $SSH
uid = "system"; YX@[z
5*
pwd = "manager";
mEhVc!
Class.forName(className); xjv?Z"X
Connection cn = DriverManager.getConnection(url,uid,pwd); Q4_j`q
2)用jndi(java的命名和目录服务)方式 g%[lUxL
例子 E]_sl/`{od
String jndi = "jdbc/db";
5Lm ?
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); >|uZIcs 6
DataSource ds = (DataSource) ctx.lookup(jndi); m|=/|Hm
Connection cn = ds.getConnection(); el- %#0
多用于jsp中 XZIj' a0d
2、执行sql语句 +r4^oT[-
1)用Statement来执行sql语句 /':kJOk<[
String sql; F9-xp7T
Statement sm = cn.createStatement(); 8Qek![3^
sm.executeQuery(sql); // 执行数据查询语句(select) f>l}y->-Ug
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ,58D=EgFy
2)用PreparedStatement来执行sql语句 :);GeZ
String sql; cKF 8(
sql = "insert into user (id,name) values (?,?)"; 4}fG{Bk
PreparedStatement ps = cn.prepareStatement(sql); tb{l(up/a
ps.setInt(1,xxx); hZc$`V=R
ps.setString(2,xxx); xNE<$Bz
... ?w /tq!
ResultSet rs = ps.executeQuery(); // 查询 R9fM9
int c = ps.executeUpdate(); // 更新 /R 2:Js
u@[D*c1!H
3、处理执行结果 vKol@7%N
查询语句,返回记录集ResultSet a&wl-
更新语句,返回数字,表示该更新影响的记录数 BEifUgCh
ResultSet的方法 z/6eP`jj
1、next(),将游标往后移动一行,如果成功返回true;否则返回false O6lj^
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 DoNbCVZ
G|IO~o0+
4、释放连接 mqw&SxU9
cn.close(); h-Ffs
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection VmV/~- <Z
!W .ooy5(
可滚动、更新的记录集 k +&LOb7
1、创建可滚动、更新的Statement
PgxD?Oi8
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); WPpl9)Qc
该Statement取得的ResultSet就是可滚动的 ^'6!)y#
2、创建PreparedStatement时指定参数 (A/V(.!
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); I>b!4?h
ResultSet.absolute(9000); |f?tyQ
批量更新 bC)diC
1、Statement {b=]JPE
Statement sm = cn.createStatement(); cZ%weQa#N)
sm.addBatch(sql1); IGOqV>;
sm.addBatch(sql2); %j{gZTz-
... ]rXRon='
sm.executeBatch() W?5^cEF
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 qZG "{8
2、PreparedStatement vfcj,1
PreparedStatement ps = cn.preparedStatement(sql); UIovv%7zZ
{ YPFjAQ
ps.setXXX(1,xxx); |SQ5 Sb
... Et4gRS)\
ps.addBatch(); >Vn;1 |w
} '@ (WT~g
ps.executeBatch(); Ef:.)!;jy
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 8u!!a^F
j<Lj1P3
事务的处理 >z.o?F
1、关闭Connection的自动提交 $ R,7#7bG
cn.setAutoCommit(false); 31Y+bxQ
2、执行一系列sql语句 PIsMx -i0
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close bL ] *K$
Statement sm ; qOqQt=ObU
sm = cn.createStatement(insert into user...);
-[" .km
sm.executeUpdate(); Iyz} ;7yVI
sm.close(); *'1qA0Xc
sm = cn.createStatement("insert into corp...); g75)&U`>}
sm.executeUpdate();
TB1E1
sm.close(); Gt2NUGU
3、提交 Qf6Vj,~N
cn.commit(); gle_~es'K
4、如果发生异常,那么回滚 aS-rRL|\L
cn.rollback();