java 数据库基本操作 }sTo,F$
1、java数据库操作基本流程 1rhsmcE
2、几个常用的重要技巧: j.C)KwelBS
可滚动、更新的记录集 @V$,H/v:
批量更新 C+{du^c$
事务处理 cG%ttfq\
V,,/}f'
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 )9_jr(s
1、取得数据库连接 &cj/8A5-
1)用DriverManager取数据库连接 %9.]
bd|%F
例子 KX*Hev'K
String className,url,uid,pwd; 99Xbp P55
className = "oracle.jdbc.driver.OracleDriver"; a
}6Fj&hj
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; V>#iR>w_4,
uid = "system"; oZvQ/|:p!
pwd = "manager"; d~L`*"/)[
Class.forName(className); 1_JxDT,=>
Connection cn = DriverManager.getConnection(url,uid,pwd); ucm3'j
2)用jndi(java的命名和目录服务)方式 BKoc;20;
例子 1FfdW>ay*
String jndi = "jdbc/db"; /m,0H)w1
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); _!FM^N}|
DataSource ds = (DataSource) ctx.lookup(jndi); p/V
Connection cn = ds.getConnection(); +3VDapfin
多用于jsp中 _Q<wb8+/
2、执行sql语句 p%304oP6
1)用Statement来执行sql语句 zGz^T
String sql; J"w!Q\_
Statement sm = cn.createStatement(); ]h (TZu
sm.executeQuery(sql); // 执行数据查询语句(select) jRz2l`~7#
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); =~r?(u6d
2)用PreparedStatement来执行sql语句 p'afCX@J
String sql; j!r4 p,
sql = "insert into user (id,name) values (?,?)"; |_l\.
PreparedStatement ps = cn.prepareStatement(sql); Qy ;
M:q
ps.setInt(1,xxx); ?DVO\Cp
ps.setString(2,xxx); D
.3Q0a6
... i<D}"h|
ResultSet rs = ps.executeQuery(); // 查询 gi`K^L=C
int c = ps.executeUpdate(); // 更新 s:Us*i=H,
yjvH)t/!.
3、处理执行结果 )c@I|L
查询语句,返回记录集ResultSet ld1t1'I'
更新语句,返回数字,表示该更新影响的记录数 DQg:W |A
ResultSet的方法 7e&R6j
1、next(),将游标往后移动一行,如果成功返回true;否则返回false Oq{&hH/'}
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 *[*E|by
p},6W,f
4、释放连接 hq9b
cn.close(); od>DSn3T
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection y:!MWZ
=YX/]g|9K
可滚动、更新的记录集 ]ABpOrg
1、创建可滚动、更新的Statement 4QWDuLu
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 9H*$3
该Statement取得的ResultSet就是可滚动的 ~CRr)(M
2、创建PreparedStatement时指定参数 s~$kzEtjjU
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 7BCCQsz<
ResultSet.absolute(9000); /'1UfjW>
批量更新 TX{DZ#
1、Statement D={|&:`L e
Statement sm = cn.createStatement(); bo&!oY#
sm.addBatch(sql1); Gy[;yLnX
sm.addBatch(sql2); $Aww5G5e
... 8k'UEf`'(
sm.executeBatch() -@ #b<"1
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 <[xxCW(2
2、PreparedStatement GY4:9Lub7
PreparedStatement ps = cn.preparedStatement(sql); &Pt|
{ EWN$ILdD
ps.setXXX(1,xxx); e ,zR
... /:>f$k4~h
ps.addBatch(); bG+p
} 5VWXUNe@_q
ps.executeBatch(); 3+m#v8h1
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 q`09
)8oI
s
事务的处理 wgSA6mQZ
1、关闭Connection的自动提交 >]"5K<-1
cn.setAutoCommit(false); ~Dr/+h:^\
2、执行一系列sql语句 gcr,?rE<
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close zQxZR}'
Statement sm ; sS OI5W3A
sm = cn.createStatement(insert into user...); ZZTPAmIr
sm.executeUpdate(); _,b%t1v
sm.close(); T3['6%
sm = cn.createStatement("insert into corp...); 3y> .1
sm.executeUpdate(); u*[,W-R&
sm.close(); >H@
dgb
3、提交 }M
f}gCEW
cn.commit(); I"3Qdi
4、如果发生异常,那么回滚 ?)Lktn9%
cn.rollback();