java 数据库基本操作 YMj iJTl
1、java数据库操作基本流程 3*-!0
2、几个常用的重要技巧: a\KM^jrCD
可滚动、更新的记录集 +1c[!;'
批量更新 g`4WisL1n
事务处理 q><wzCnRu~
O;.DQ
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 P>R u
1、取得数据库连接 M-(,*6Q
1)用DriverManager取数据库连接 6\? 2=dNX
例子 \W|ymV_Ki
String className,url,uid,pwd; sn+ kFvk}S
className = "oracle.jdbc.driver.OracleDriver"; o1H6E1$=
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; IiV]lxiE]
uid = "system"; Nx!7sE*b$1
pwd = "manager"; 57EL&V%j
Class.forName(className); cL4Xh|NBp
Connection cn = DriverManager.getConnection(url,uid,pwd); [K1z/ea)V
2)用jndi(java的命名和目录服务)方式 Rp>%umDyL
例子 TJ|do`fw>
String jndi = "jdbc/db"; h<7@3Ur
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); \"d\b><R
DataSource ds = (DataSource) ctx.lookup(jndi); O7p=|F"
Connection cn = ds.getConnection(); ;aH3{TS
多用于jsp中 ek d[|g
2、执行sql语句 :\^jIKvZ
1)用Statement来执行sql语句 #-l+cu{
String sql; tUGF8?&
G
Statement sm = cn.createStatement(); tO3#kV\,
sm.executeQuery(sql); // 执行数据查询语句(select) 3bHB$n
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 0Y8Cz /$
2)用PreparedStatement来执行sql语句 6 kD.
String sql; me90|GOx+
sql = "insert into user (id,name) values (?,?)"; eL
[.;_
PreparedStatement ps = cn.prepareStatement(sql); azG"Mt|7Z
ps.setInt(1,xxx); J^zB5W,)
ps.setString(2,xxx); o'? WWJK6w
... .>2]m[53
ResultSet rs = ps.executeQuery(); // 查询 ^ZFK:|Ju
int c = ps.executeUpdate(); // 更新 3teP6|K'g
ViU5l*n;
3、处理执行结果 eKRE1DK
查询语句,返回记录集ResultSet <Vh}d/
更新语句,返回数字,表示该更新影响的记录数 W9S6
SO^\
ResultSet的方法 bQdu= s[
1、next(),将游标往后移动一行,如果成功返回true;否则返回false u R]8ZT")
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 4r#4h4`y|
y s[ z[
4、释放连接 1JV-X G6
cn.close(); 27MwZz
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection Z7k ku:9
D#[<N
可滚动、更新的记录集 ei~f1$zc#h
1、创建可滚动、更新的Statement V?~!D p
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); {
PS0.UZ
该Statement取得的ResultSet就是可滚动的 &g]s@S|%
2、创建PreparedStatement时指定参数 GtKSA#oYZB
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); B?4Iu)bCxI
ResultSet.absolute(9000); vVSf'w
批量更新 VFKFO9
1、Statement B &3sV+
Statement sm = cn.createStatement(); AB<%GzW0(
sm.addBatch(sql1); #$l:%
sm.addBatch(sql2); g*!1S
... q9c-UQB(!
sm.executeBatch() U[z2{\
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 o
^ 08<
2、PreparedStatement UK)wV
PreparedStatement ps = cn.preparedStatement(sql); h;R>|2A
{ 6=Sz5MC
ps.setXXX(1,xxx); E`]un.
... Iu^I?c[
ps.addBatch(); ZuKOscVS#T
} %AA-G
ps.executeBatch(); +^%)QH>9
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 qRq4PQ@
<v?2p{U%
事务的处理 ux)Wh.5
1、关闭Connection的自动提交 +o35${
cn.setAutoCommit(false); `/<f([w
2、执行一系列sql语句 bGK-?BE5+A
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close fS p
Statement sm ; #}Bv/`t
sm = cn.createStatement(insert into user...); n6 wx/:
sm.executeUpdate(); QHd|cg
sm.close(); 5UX- Qqr
sm = cn.createStatement("insert into corp...); !E,|EdIr
sm.executeUpdate(); # wyjb:Ql
sm.close(); ~*`wRiUhis
3、提交 ($gmN 4
cn.commit(); g[;&_gL
4、如果发生异常,那么回滚 yM7FR);
cn.rollback();