java 数据库基本操作 DSp@
1、java数据库操作基本流程 AH+J:8k
2、几个常用的重要技巧: 511q\w M
可滚动、更新的记录集 Heu@{t.[!D
批量更新 xh$[E&2u
事务处理 b;vO`
YzqhFFaj.
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 xC(PH?_
1、取得数据库连接 ^8)d8?}
1)用DriverManager取数据库连接 *k -UQLJ
例子 "-sz7}Mb
String className,url,uid,pwd; 3 a`-_<
className = "oracle.jdbc.driver.OracleDriver"; TEtZPGFl
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; B=7L+6
uid = "system"; WD:5C3;
pwd = "manager"; 9 )qx0
Class.forName(className); 6gXc-}dp
Connection cn = DriverManager.getConnection(url,uid,pwd); e9hQJ
1{)x
2)用jndi(java的命名和目录服务)方式 s#ykD{Z
例子 *0@e_h
String jndi = "jdbc/db"; /VQ<}S[k}-
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); x,+zw9
DataSource ds = (DataSource) ctx.lookup(jndi);
hT[O5
Connection cn = ds.getConnection(); vEkz5$
多用于jsp中 rcOmpgew
2、执行sql语句 :Pv{E
1)用Statement来执行sql语句 jsj" W&J
String sql; dj#<,e\
Statement sm = cn.createStatement(); o<y7Ut
sm.executeQuery(sql); // 执行数据查询语句(select) .?qS8:yA
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); c<=1,TB"-_
2)用PreparedStatement来执行sql语句 be_t;p`3
String sql; 'JydaF~>
sql = "insert into user (id,name) values (?,?)"; !VW#hc\A5
PreparedStatement ps = cn.prepareStatement(sql); :n=+$Dq
ps.setInt(1,xxx); R0>L[1o
ps.setString(2,xxx); '@FKgy;B)-
... BshS@"8r
ResultSet rs = ps.executeQuery(); // 查询 XcXd7e
int c = ps.executeUpdate(); // 更新 8Vx'sJ>r4
.dV!d u
3、处理执行结果 6O}r4*
查询语句,返回记录集ResultSet tF4"28"h
更新语句,返回数字,表示该更新影响的记录数 )u$A!+fo
ResultSet的方法 N.]8qzW
1、next(),将游标往后移动一行,如果成功返回true;否则返回false N^)OlH
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 YeQX13C"Z
&^Io\
4、释放连接 t0Uax-E(
cn.close(); PF~&!~S>W
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 4D8q Gti
d;z`xy(C
可滚动、更新的记录集 a)]N#gx
1、创建可滚动、更新的Statement XX =A1#H
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); :\ S3[(FV
该Statement取得的ResultSet就是可滚动的 iH2|w
2、创建PreparedStatement时指定参数 I'";
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); u}$?r\H'(
ResultSet.absolute(9000); OtJS5A
批量更新 W;1Hyk
1、Statement vCJjZ%eO%D
Statement sm = cn.createStatement(); :mij%nQ>$
sm.addBatch(sql1); : v]< h
sm.addBatch(sql2); 6i%)'dl
... p8Pvctc
sm.executeBatch() ?@ O[$9y
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 z;-2xD0&U[
2、PreparedStatement cla4%|kq3Y
PreparedStatement ps = cn.preparedStatement(sql); KF.?b]
{ $ysC)5q.
ps.setXXX(1,xxx); z~F!zigNAc
... 83@+X4ptp
ps.addBatch(); !e?\>
'
} (g 8K?Q
ps.executeBatch(); ?/;<32cE,
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 T"$"`A"
=T1i(M#
事务的处理 1\1o65en
1、关闭Connection的自动提交 E0YXgQa
cn.setAutoCommit(false); l)?c3
2、执行一系列sql语句 f@yST z;u
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close RtSk;U1
Statement sm ; :Z<-J`
sm = cn.createStatement(insert into user...); jYU#]
|k~
sm.executeUpdate(); VB Ce=<
sm.close(); _vad>-=D*U
sm = cn.createStatement("insert into corp...); P/27+5(|
sm.executeUpdate(); !=a8^CV
sm.close(); ^ H'|iju
3、提交 9%4rO\q
cn.commit(); e|`&K"fnq
4、如果发生异常,那么回滚 hI"I#(*jA%
cn.rollback();