java 数据库基本操作 A3\%t@y
1、java数据库操作基本流程 kpe7\nd=>
2、几个常用的重要技巧: d%"?^e
可滚动、更新的记录集 :;wb{q$O
批量更新 !uC`7a
事务处理 }G:5P3f
+cDz`)N,,
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 [i8,rOa7
1、取得数据库连接 FUq>+U!Qu
1)用DriverManager取数据库连接 uV\ _j3,2
例子 d1MVhE
String className,url,uid,pwd; 6X@]<R
className = "oracle.jdbc.driver.OracleDriver"; R^fk :3
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; AADvk_R
uid = "system"; :4{;^|RgU
pwd = "manager"; c:a5pd7T
Class.forName(className); cY}Nr#%s@U
Connection cn = DriverManager.getConnection(url,uid,pwd); q ;@:,^
2)用jndi(java的命名和目录服务)方式 k 5<[N2D|!
例子 #4WA2EW
String jndi = "jdbc/db"; 7\BGeI
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); qep<7 QO
DataSource ds = (DataSource) ctx.lookup(jndi); hhS]wM?B
Connection cn = ds.getConnection(); \F|L y >g
多用于jsp中 AYC22(
2、执行sql语句 X j'7nj
1)用Statement来执行sql语句
Tl.%7)
String sql; v7"Hvp3w
Statement sm = cn.createStatement(); 64#6L.Q-c
sm.executeQuery(sql); // 执行数据查询语句(select) d/Sx+1
"{T
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); W|go*+`W%
2)用PreparedStatement来执行sql语句 aS7[s6
String sql; Ly0U')D:
sql = "insert into user (id,name) values (?,?)"; <lx~/3<m
PreparedStatement ps = cn.prepareStatement(sql); \Ty%E<
ps.setInt(1,xxx); bt$+l[U^J
ps.setString(2,xxx); /K#t$O4
... a"!D @a
ResultSet rs = ps.executeQuery(); // 查询 ]Z@+
|&@L
int c = ps.executeUpdate(); // 更新 7R$]BY=
O_PKS$sz{
3、处理执行结果 l
)hg!(
查询语句,返回记录集ResultSet dMA"% R
更新语句,返回数字,表示该更新影响的记录数 ~}SOd<n)|
ResultSet的方法 BjT0mk"P
1、next(),将游标往后移动一行,如果成功返回true;否则返回false OV l,o
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 nFVQOr;
;K'1dsA
4、释放连接 bdn{Y
cn.close(); lC/4CPKtV
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection :Kc}R)6
Q7ez?]j6
可滚动、更新的记录集 aB`x5vg7ho
1、创建可滚动、更新的Statement t^|+|>S
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ] -6=+\]
该Statement取得的ResultSet就是可滚动的 qR
WWG&
2、创建PreparedStatement时指定参数 {y{&tzZ
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 67uUeCW
ResultSet.absolute(9000); E57J).x-BP
批量更新 #+1*g4m~B
1、Statement ]LvpYRU$P
Statement sm = cn.createStatement(); %hYol89F
sm.addBatch(sql1); MTKd:.J6
sm.addBatch(sql2); KcGM=z?:
...
+["t@Q4IQ
sm.executeBatch() &{s`=IeN
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 N XwQvm;q
2、PreparedStatement GC{)3)_ t
PreparedStatement ps = cn.preparedStatement(sql); x<
Td
{ F5CV<-jB
ps.setXXX(1,xxx); lP@/x+6tg
... py,B6UB5
ps.addBatch(); c3\z
} 6%mFiX
ps.executeBatch(); SX$Nef9p
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 ^9})@,(D
RVxlN*
事务的处理 !MOgM
1、关闭Connection的自动提交 YN\!I
cn.setAutoCommit(false); o{EWNkmj
2、执行一系列sql语句 MP Ma
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 4{d`-reHg
Statement sm ; QyJ2P{z
sm = cn.createStatement(insert into user...); (6C%w)8'
sm.executeUpdate(); FFT h}>>
sm.close(); !aSu;Ln
sm = cn.createStatement("insert into corp...); ub|tX 'o
sm.executeUpdate(); t83n` LC
sm.close(); 8:j8>K*6
3、提交 C|kZT<,]
cn.commit(); MIcF"fB![
4、如果发生异常,那么回滚 e1e2Wk
cn.rollback();