java 数据库基本操作 jAie[5
1、java数据库操作基本流程 lA<n}N)j
2、几个常用的重要技巧: ; :4&nJ*qG
可滚动、更新的记录集 P<ElH3J`
批量更新 LP-~;
事务处理 ="Zr. g~8
W8z4<o[$
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 O3/][\
1、取得数据库连接 A<fKO <d
1)用DriverManager取数据库连接 ;4>YPH
例子 @.0>gmY;:
String className,url,uid,pwd; PV$)k>H-
className = "oracle.jdbc.driver.OracleDriver"; n?!XNXb
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; S81%iz.n
uid = "system"; BZ*',\o
pwd = "manager"; j)xRzImu
Class.forName(className); lqe|1vN
Connection cn = DriverManager.getConnection(url,uid,pwd); Y3=5J\d!a
2)用jndi(java的命名和目录服务)方式 n("Xa#mY[
例子 lR5[UKr
String jndi = "jdbc/db"; X6)%2TwO
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); U6cpj
DataSource ds = (DataSource) ctx.lookup(jndi); 1j"G~TM
Connection cn = ds.getConnection(); P{fT5K|
多用于jsp中 ~"|MwR!0
2、执行sql语句 `?E|frz[
1)用Statement来执行sql语句 M(8dKj1+
String sql; n_QSuh/Wn
Statement sm = cn.createStatement(); )O\w'|$G
sm.executeQuery(sql); // 执行数据查询语句(select) 10R#}~D
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); .);~H#
2)用PreparedStatement来执行sql语句 >9dzl#
String sql; 17P5Dr&
sql = "insert into user (id,name) values (?,?)"; q)te/J@
PreparedStatement ps = cn.prepareStatement(sql); i^T@jg+K
ps.setInt(1,xxx); D+m#_'ocL
ps.setString(2,xxx); _/V<iv
... (KxI*
ResultSet rs = ps.executeQuery(); // 查询 C# zYZ JZ
int c = ps.executeUpdate(); // 更新 )l?1dR:sP
2 tD{c^
9<
3、处理执行结果 jV{?.0/h|
查询语句,返回记录集ResultSet D+#OB|&Dn
更新语句,返回数字,表示该更新影响的记录数 yC \dM1X
ResultSet的方法 A.tXAOM(VW
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 7>.d*?eao\
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 3E9 )~$
`(tVwX4
4、释放连接
IR JN
cn.close(); la4
#2>#WZ
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection PWci D '!
6`Hd)T5{w
可滚动、更新的记录集 gxnIur)
1、创建可滚动、更新的Statement }aO6%
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 8u8-:c%{
该Statement取得的ResultSet就是可滚动的 k_;g-r,
2、创建PreparedStatement时指定参数 q)j b9e
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); m.F}9HI%hN
ResultSet.absolute(9000); GdN9bA&,
批量更新 E? lK(C
1、Statement mR,w~wP
Statement sm = cn.createStatement(); {E=BFs
sm.addBatch(sql1); $, hHR:
sm.addBatch(sql2); zUuOX5-6x
... gGZ-B<
sm.executeBatch() 5 EhOvt8
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 3JYhF)G
2、PreparedStatement :1asY:)vNP
PreparedStatement ps = cn.preparedStatement(sql); B(|*u
{ @TJxU
ps.setXXX(1,xxx); tTEw"DL_-
... M.FY4~
ps.addBatch(); 90wGS_P04
} :j2?v(jT_l
ps.executeBatch(); 21k,{FB'?
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 =/5^/vwgY
hY5GNYDh
事务的处理 j(~e{HZ
1、关闭Connection的自动提交 3d>8~ANi=%
cn.setAutoCommit(false); !$u:[T_8
2、执行一系列sql语句 )J^5?A
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close @7HHi~1JK
Statement sm ; F8H4R7
8>;
sm = cn.createStatement(insert into user...); 'p FK+j
sm.executeUpdate(); :+_uyp2V
sm.close(); <)$&V*\
sm = cn.createStatement("insert into corp...); jOUM+QO
sm.executeUpdate(); F(O"S@
sm.close(); +Y?)?
3、提交 bG)EZ
cn.commit(); o$QC:%[#
4、如果发生异常,那么回滚 A"tE~m;"7
cn.rollback();