java 数据库基本操作 "7T9d)
1、java数据库操作基本流程 qAF.i^
2、几个常用的重要技巧: [qEd`8V(
可滚动、更新的记录集 &xGcxFd
批量更新 ?H.7
WtTC
事务处理 aybfBC
H)${"
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ]_ON\v1
1、取得数据库连接 =h{jF7
1)用DriverManager取数据库连接 ;1&7v
例子 ]5=C3Y
String className,url,uid,pwd; *A,h^
className = "oracle.jdbc.driver.OracleDriver"; )Z2l*fV
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; X~Yj#@
uid = "system"; 5l&9BS&
pwd = "manager"; 3]iBX`Ni
Class.forName(className); kZsat4r
Connection cn = DriverManager.getConnection(url,uid,pwd); ^?5[M^
2)用jndi(java的命名和目录服务)方式 UUF;Q0X
例子 *:*Kdt`'G
String jndi = "jdbc/db"; .>{.!a
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 9Xu
O\+z
DataSource ds = (DataSource) ctx.lookup(jndi); 5V^+;eO
Connection cn = ds.getConnection(); Y`x54_32
多用于jsp中 D\Nhq Vw
2、执行sql语句 cS'|c06
1)用Statement来执行sql语句 Y;L,}/[
String sql; )$Erfu
Statement sm = cn.createStatement(); HZ#<+~J
sm.executeQuery(sql); // 执行数据查询语句(select) wd/"! A4(
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); oA _,jsD4
2)用PreparedStatement来执行sql语句 pErre2fS
String sql; fgg;WXcT ~
sql = "insert into user (id,name) values (?,?)"; Q+O3Wgjy
PreparedStatement ps = cn.prepareStatement(sql); Ny.s
u?E
ps.setInt(1,xxx); nEZoF
ps.setString(2,xxx); q0oNRAvn"
... W* XG9
ResultSet rs = ps.executeQuery(); // 查询 "Zh6j)[o
int c = ps.executeUpdate(); // 更新 ,DHiM-v
RSNukg
3、处理执行结果 U(.3[x
查询语句,返回记录集ResultSet O=HT3gp&
更新语句,返回数字,表示该更新影响的记录数 1w)#BYc=L
ResultSet的方法
{ws:g![
1、next(),将游标往后移动一行,如果成功返回true;否则返回false o771q}?&`
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 /uc*V6Xd
(
@y (9LSs
4、释放连接 i_? S#L]h
cn.close(); Wm5/>Cu,
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection K#B)@W?9
Btmv{'T_y@
可滚动、更新的记录集 S}=euY'i
1、创建可滚动、更新的Statement Tn~b#-0
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); *E Z'S+wR
该Statement取得的ResultSet就是可滚动的 Kw%n;GFl'
2、创建PreparedStatement时指定参数 .}}w@NO
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); xp395ub6
ResultSet.absolute(9000); RtrESwtR
批量更新 !,#42TY*X
1、Statement $)5F3a|
Statement sm = cn.createStatement(); F+Qp
mVU
sm.addBatch(sql1); 2BU%4IG
sm.addBatch(sql2); ?#8s=t
... *Ge2P3
sm.executeBatch() MLL4nkO,`
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 )"im|9
2、PreparedStatement /
M(A
kNy
PreparedStatement ps = cn.preparedStatement(sql); g4 BEo'
{ :
kVEB<G
ps.setXXX(1,xxx); A6APU><dm^
... I/ pv0
ps.addBatch(); fIo7R-XP
} s2*^ PG
ps.executeBatch(); FbMX?T"yH
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 pPUv8, %
PYldqY
事务的处理 {2`:7U~|
1、关闭Connection的自动提交 VO|2
cn.setAutoCommit(false); -r9G5Z!|n
2、执行一系列sql语句 qM(n]{H
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close QGtKu:c.81
Statement sm ; \:cr2 w'c
sm = cn.createStatement(insert into user...); (fc
/"B-
sm.executeUpdate(); Ou~|Q&f'
sm.close(); 7l"N%e
sm = cn.createStatement("insert into corp...); wl1JKiodg
sm.executeUpdate(); T{1Z(M+
sm.close(); ,t4g^67R{
3、提交 5>J{JW|
cn.commit(); V+/Vk1
4、如果发生异常,那么回滚 9kcp(
cn.rollback();