java 数据库基本操作 <$i4?)f(
1、java数据库操作基本流程 q,l)I+
2、几个常用的重要技巧： g>j| ]6
可滚动、更新的记录集 SF<Vds}A2
批量更新 f =s &n}
事务处理 ?M}S| dsmE
l-)B ivoi
java数据库操作基本流程：取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 Q* ju
sm
1、取得数据库连接 _8fA?q=
1）用DriverManager取数据库连接 JK)q Z =
例子 b{cU<;G)y.
String className,url,uid,pwd; 0b-?q&*_
className = "oracle.jdbc.driver.OracleDriver"; p] &j ;H.
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ;hDa@3|]34
uid = "system"; <+U|dX
pwd = "manager"; _D;@v?n6!O
Class.forName(className); =1hr2R(V
Connection cn = DriverManager.getConnection(url,uid,pwd); q mQfLz7&x
2）用jndi(java的命名和目录服务)方式 }DjYGMrTB
例子 5ukp^O xE
String jndi = "jdbc/db"; WlVl[/qt
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); pGGmA;TC1
DataSource ds = (DataSource) ctx.lookup(jndi); ?S[Y:<R{:
Connection cn = ds.getConnection(); *3+-W
多用于jsp中 ,/2LY4` 5
2、执行sql语句 `jsEN ;<
1）用Statement来执行sql语句 ERz;H!pU8
String sql; H[WQ =){
Statement sm = cn.createStatement(); lj[, |[X7`
sm.executeQuery(sql); // 执行数据查询语句（select） gK1g]Tc @G
sm.executeUpdate(sql); // 执行数据更新语句（delete、update、insert、drop等）statement.close(); ?dq#e9
2）用PreparedStatement来执行sql语句 ?=On%bh
String sql; M]rO;^ ;6?
sql = "insert into user (id,name) values (?,?)"; W`)<vGn=Y
PreparedStatement ps = cn.prepareStatement(sql); t~p
y=\
ps.setInt(1,xxx); 2U$"=:Cf
ps.setString(2,xxx); k&6I f0i
... 2}WDw>V
ResultSet rs = ps.executeQuery(); // 查询 {^ec(EsO#
int c = ps.executeUpdate(); // 更新 k$7Z^~?Fz
T0QvnIaP
3、处理执行结果 PlxIf L
查询语句，返回记录集ResultSet "&o,yd%
更新语句，返回数字，表示该更新影响的记录数 2xxB\J
ResultSet的方法 HZjf`eM,
1、next()，将游标往后移动一行，如果成功返回true；否则返回false v/QUjXBr
2、getInt("id")或getSting("name")，返回当前游标下某个字段的值 fg*@< '
OI/@3"L{
4、释放连接 2YBIWR8z
cn.close(); '\7G@g?UZ
一般，先关闭ResultSet，然后关闭Statement（或者PreparedStatement）；最后关闭Connection rpV1y$n<F
QWO]`q`|
可滚动、更新的记录集 L ^J- ("e_
1、创建可滚动、更新的Statement 4,P b g|
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); URTzX
2'[
该Statement取得的ResultSet就是可滚动的
R= 5 **
2、创建PreparedStatement时指定参数 -j2 (R?a
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); -K %5(Eg
ResultSet.absolute(9000); S-F o
批量更新 4Y ROB912
1、Statement <PD?f/4 /
Statement sm = cn.createStatement(); {E_{JB~`
sm.addBatch(sql1); 2KJ1V+g@a6
sm.addBatch(sql2); `N8 7 h"
... &X>7n~@0
sm.executeBatch() 5 f7zk
一个Statement对象，可以执行多个sql语句以后，批量更新。这多个语句可以是delete、update、insert等或兼有 ERMa# L
2、PreparedStatement ` lpz-"EEV
PreparedStatement ps = cn.preparedStatement(sql); U.oksD9 v
{ _t>"5s&i
ps.setXXX(1,xxx); )}lRd#V
... ^) )RM _ic
ps.addBatch(); p<GR SJIk=
} !PU ZWO
ps.executeBatch(); X&\ d)/Y
一个PreparedStatement，可以把一个sql语句，变换参数多次执行，一次更新。 kI\tqNJ i
J./ d!an
事务的处理 ~}9PuYaD@
1、关闭Connection的自动提交 #2p#VQh
cn.setAutoCommit(false); lFG9=Wf
2、执行一系列sql语句 fb ]S-z (
要点：执行每一个新的sql语句前，上一次执行sql语句的Statement（或者PreparedStatemet）必须先close 1T|$BK@)
Statement sm ; 4`v!Z#e/aX
sm = cn.createStatement(insert into user...); LDj<?'
sm.executeUpdate(); oOU1{[
sm.close(); Pcd *">v
sm = cn.createStatement("insert into corp...); 0~WF{_0|
sm.executeUpdate(); J5p8nmb
sm.close(); &l2TeC@;
3、提交 .T B"eUy
cn.commit(); \_]En43mg
4、如果发生异常，那么回滚 H=c`&N7E
cn.rollback();
