java 数据库基本操作 f+2mX"Z[F
1、java数据库操作基本流程 M[L@ej
2、几个常用的重要技巧: 8]WcW/1r !
可滚动、更新的记录集 s 4n<k]d
批量更新 i1!Y{
事务处理
&0OH:P%
o}yA{<"
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 |oR#j
`
1、取得数据库连接 vhN6_XD
1)用DriverManager取数据库连接 .GvZv>
例子 e<"sZK
String className,url,uid,pwd; 3(1UIu
className = "oracle.jdbc.driver.OracleDriver"; 4hW:c0
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; tD]vx`0>
uid = "system"; LftzW{>gI"
pwd = "manager"; 5?TX.h9B4
Class.forName(className); )9+H[
Connection cn = DriverManager.getConnection(url,uid,pwd); E>F6!qYm
2)用jndi(java的命名和目录服务)方式 H`7T;`Yb
例子 UFeQ%oRa8
String jndi = "jdbc/db"; 0kaMYV?
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ^j<2s"S
DataSource ds = (DataSource) ctx.lookup(jndi); }p*WH$!~
Connection cn = ds.getConnection(); M+7jJ?n
多用于jsp中 hO(A_Bw
2、执行sql语句 ZC)m&V1
1)用Statement来执行sql语句 +>:[irf
String sql; (lvp-<*
Statement sm = cn.createStatement(); _SQ]\Z
sm.executeQuery(sql); // 执行数据查询语句(select) Srrzj-9^)K
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); tNxKpA |F
2)用PreparedStatement来执行sql语句 v5.KCc}"
String sql; 4!Lj\.!$
sql = "insert into user (id,name) values (?,?)"; * K0aR!
PreparedStatement ps = cn.prepareStatement(sql); f_IsY+@
ps.setInt(1,xxx); f5'vjWJ30
ps.setString(2,xxx); :* J!
... +<WNAmh
ResultSet rs = ps.executeQuery(); // 查询 ge%tj O
int c = ps.executeUpdate(); // 更新 m21H68y
cZAf?,>u
3、处理执行结果 v=-T3
n
查询语句,返回记录集ResultSet +KIFLuL
更新语句,返回数字,表示该更新影响的记录数 y>ePCDR3
ResultSet的方法 .<6'*XR
1、next(),将游标往后移动一行,如果成功返回true;否则返回false K pmq C$
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 s2 $w>L
2=X.$&a
4、释放连接 ]MB6++.e
cn.close(); J n'SGR
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection /Y| <0tq
zn5|ewl@"
可滚动、更新的记录集 hdYd2
j
1、创建可滚动、更新的Statement i \@a&tw
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); D*ZswHT{y
该Statement取得的ResultSet就是可滚动的 KqXPxp^_Al
2、创建PreparedStatement时指定参数 8 LsJ}c
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 3/8<dc
ResultSet.absolute(9000); ~P"o_b6,k
批量更新 A#]78lR
1、Statement Xkf|^-n
Statement sm = cn.createStatement(); [vxHsY3z
sm.addBatch(sql1); ubl)$jZ:Q
sm.addBatch(sql2); P -X2A2
... MK <\:g
sm.executeBatch() ;t4YI7E*
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 `?SLp
2、PreparedStatement ]vH:@%3U
PreparedStatement ps = cn.preparedStatement(sql); ccy q~
{ @E=77Jn[px
ps.setXXX(1,xxx); o RK:{?Y
... %t]{C06w+{
ps.addBatch(); "MyMByomQ
} iXqRX';F'}
ps.executeBatch(); VBK |*Tl
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 yER
Sea6xGdq
事务的处理 Nu+DVIM
1、关闭Connection的自动提交 Bx|h)e9
cn.setAutoCommit(false); rf]x5%ij
2、执行一系列sql语句 (dHjf;
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 0+KSD{
Statement sm ; 2Vxx
sm = cn.createStatement(insert into user...); 9y j'->dL
sm.executeUpdate(); NBA`@K~4
sm.close(); 2h1P!4W85
sm = cn.createStatement("insert into corp...); YAd%d|Q
sm.executeUpdate(); "lL/OmG
sm.close(); rW`l1yi*$
3、提交 DDZnNSo<JQ
cn.commit(); 1tl qw
4、如果发生异常,那么回滚 vZXdc+2l
cn.rollback();