java 数据库基本操作 aFC3yMKXh
1、java数据库操作基本流程 \?C(fpR
2、几个常用的重要技巧: I|`K;a
可滚动、更新的记录集 i;\i4MT
批量更新 Z,d/FC#y(
事务处理 @*c+`5)_
x[>A'.m@)
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 eEU:
1、取得数据库连接 5-C6; 7%:
1)用DriverManager取数据库连接 7'&Xg_
例子 !c*^:0
String className,url,uid,pwd; T}\U:@b
className = "oracle.jdbc.driver.OracleDriver"; &O%Kj8)
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ;bA9(:?
uid = "system"; I{RktO;1
pwd = "manager"; fB:M'A'
Class.forName(className); p(U'Ydl~
Connection cn = DriverManager.getConnection(url,uid,pwd); n&Al~-Q:^
2)用jndi(java的命名和目录服务)方式 kKj YMYT6
例子 opIcSm&
String jndi = "jdbc/db"; pw$I~3OFd
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 'l;?P
DataSource ds = (DataSource) ctx.lookup(jndi); |YlUt~H>
Connection cn = ds.getConnection(); $[>wJXj3R
多用于jsp中 CId`6W
2、执行sql语句 C&;'Pw9H
1)用Statement来执行sql语句 F^aD!O ~
String sql; r1=Zoxc=w
Statement sm = cn.createStatement(); ;=n7 Z
sm.executeQuery(sql); // 执行数据查询语句(select) 9:kb0oBa?l
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 8F@6^9C
2)用PreparedStatement来执行sql语句 Tok"-$`N
String sql; !?+3jzG
sql = "insert into user (id,name) values (?,?)"; "jpjBH:c$
PreparedStatement ps = cn.prepareStatement(sql); lRO8}XSI
ps.setInt(1,xxx); i>rn!?b
ps.setString(2,xxx); ^%<v| Y(X
... >*_?^F_
ResultSet rs = ps.executeQuery(); // 查询 _>aesp%
int c = ps.executeUpdate(); // 更新 )pvZM?
$GPA6
3、处理执行结果 j&&^PH9ZY
查询语句,返回记录集ResultSet ct]5\g?U'
更新语句,返回数字,表示该更新影响的记录数 Y] n^(V
ResultSet的方法 +(P;4ZOmB
1、next(),将游标往后移动一行,如果成功返回true;否则返回false G_o/ lIz"
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 Onc!5L
G!Uq#l>
4、释放连接 s/T5aJR
cn.close(); =-:o?&64
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection E@@quK
R4v=i)A~Z
可滚动、更新的记录集 C2b.([HE
1、创建可滚动、更新的Statement '@W72ML.
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); U}5uy9A
该Statement取得的ResultSet就是可滚动的 JZ c5U}i
2、创建PreparedStatement时指定参数 M.128J+xfS
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); #A))#sT'R
ResultSet.absolute(9000); mj,r@@k:=+
批量更新 d3![b 1
1、Statement |MRxm"]A
Statement sm = cn.createStatement(); JZ<O-G+
sm.addBatch(sql1); @vv`86bm
sm.addBatch(sql2); UtWoSFZ'o!
... -meKaQv
sm.executeBatch() iFHVr'Og'
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 My[L3KTTp
2、PreparedStatement 3!}#@<j
PreparedStatement ps = cn.preparedStatement(sql); i$F)h<OU+
{ $6J5yE
ps.setXXX(1,xxx); '2
)d9_ w
... c^=:]^
ps.addBatch(); 1XZ&X]
} -p)HH@6a
ps.executeBatch(); NT-du$!u
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 pG4Hy$e
! [: K/
事务的处理
/!9949XV
1、关闭Connection的自动提交 t=pG6U
cn.setAutoCommit(false); #uH1!UQb
2、执行一系列sql语句 HD`%Ma
Yhc
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close hyBSS,I
Statement sm ; ; w+A38N$J
sm = cn.createStatement(insert into user...); !sLn;1l
sm.executeUpdate(); 6F<L4*4U
sm.close(); Z$pR_dazU
sm = cn.createStatement("insert into corp...); C
qxP@
sm.executeUpdate(); LCdc7
sm.close(); *(HH71Y
3、提交 c]n4vhUa5
cn.commit(); XRz.R/
4、如果发生异常,那么回滚 `Yut1N
cn.rollback();