java 数据库基本操作 TT3GGHR
1、java数据库操作基本流程 ct,;V/Dx
2、几个常用的重要技巧: F}[!OYyg
可滚动、更新的记录集 B9
?58v&
批量更新 O.y ?q
事务处理 )@Y<
<9'2
\pI {b9
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 nW\W<[O9
1、取得数据库连接 "|&3z/AUh
1)用DriverManager取数据库连接 Hiwij,1
例子 oz]3
Tx
String className,url,uid,pwd; }|8^+V&
className = "oracle.jdbc.driver.OracleDriver"; 6~{'\Z
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; "G*$#
uid = "system"; \AoqOC2u
pwd = "manager"; )J+OyR=
Class.forName(className);
}#&[[}@th
Connection cn = DriverManager.getConnection(url,uid,pwd); 9qGba=}Ey
2)用jndi(java的命名和目录服务)方式 #k d9}
例子 :nl,Ac
String jndi = "jdbc/db"; &ZFHWI(P
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 6pC1C.
DataSource ds = (DataSource) ctx.lookup(jndi); Vz-q7*o$S
Connection cn = ds.getConnection(); z"QtP[_m
多用于jsp中 PC255
2、执行sql语句 Z'5&N5hx
1)用Statement来执行sql语句 s7:_!Nd@8
String sql; y>h9:q|
Statement sm = cn.createStatement(); 87S,6 Y
sm.executeQuery(sql); // 执行数据查询语句(select) x}WP1YyT~
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ;[P>
2)用PreparedStatement来执行sql语句 5f0g7w =-
String sql; #M#$2Vt
sql = "insert into user (id,name) values (?,?)"; x)$0Nr62D
PreparedStatement ps = cn.prepareStatement(sql); t3^`:T\
ps.setInt(1,xxx); Q;q{1M >
ps.setString(2,xxx); T?Z^2.Pvc
... hG<[F@d
ResultSet rs = ps.executeQuery(); // 查询 -nUK%a"(D
int c = ps.executeUpdate(); // 更新 b-@9Xjv
CsT&}-C
3、处理执行结果
8sI$
查询语句,返回记录集ResultSet D ZZRu8~
更新语句,返回数字,表示该更新影响的记录数 #^aa&*<D_
ResultSet的方法 b9T6JS j
1、next(),将游标往后移动一行,如果成功返回true;否则返回false DYIp2-K
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 `0_
Y| 4KB
!.pcldx
4、释放连接 Vom,^`}
cn.close(); l(F\5Ys
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection }|M:MJ`
"s zJ[
_B
可滚动、更新的记录集 *h).V&::O
1、创建可滚动、更新的Statement qq[Dr|%7
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); &0G9v
该Statement取得的ResultSet就是可滚动的 EX, {1^h
2、创建PreparedStatement时指定参数 -,g.39u
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); .YB/7-%M[
ResultSet.absolute(9000); .rwW5"RPq
批量更新 Nq9M$Nt]
1、Statement k*,+ag*j
Statement sm = cn.createStatement(); EASmB
sm.addBatch(sql1); ; 5[W*,7s
sm.addBatch(sql2); z`Nss
o=
... $II~tO
sm.executeBatch() )~nieQEZQ
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 {wz_ngQ
2、PreparedStatement EDnZ/)6Gg
PreparedStatement ps = cn.preparedStatement(sql); fF#Fc&B
{ rL+.3ZO):P
ps.setXXX(1,xxx); SGy2&{\Z
... IBu\Sh-
ps.addBatch(); Pn@DHYP
} cmCD}Skk
ps.executeBatch(); SG0PQ
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 t7V7 TL!5'
(64es)B}"
事务的处理 {5%d#|?
1、关闭Connection的自动提交 a{JO8<dlm
cn.setAutoCommit(false); RDy&i
2、执行一系列sql语句 ;9 ChBA
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close -^7
$HD
Statement sm ; Tj<B;f!u
sm = cn.createStatement(insert into user...); 7D'D7=Z.
sm.executeUpdate(); 3a ZS1]/
sm.close(); mtE+}b@(!&
sm = cn.createStatement("insert into corp...); yFd942
sm.executeUpdate(); vLq%k+D#
sm.close(); SlT>S1`rnG
3、提交 Wy-y-wi:p
cn.commit(); ;<b7kepR
4、如果发生异常,那么回滚 C#)T$wl[E
cn.rollback();