java 数据库基本操作 LHps2,
1、java数据库操作基本流程 8Bhng;jX
2、几个常用的重要技巧: A.[T#ZB.4
可滚动、更新的记录集 kcle|B
批量更新 zv41Yv!x}
事务处理 vzL>ZBeZ
&m`
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 39"'Fz?1
1、取得数据库连接 j[9B,C4
1)用DriverManager取数据库连接 IH5thL@D
例子 7?Fl [FW$
String className,url,uid,pwd; \ys3&<;b
className = "oracle.jdbc.driver.OracleDriver"; +=R:n^r^,
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; M`(xAVl
uid = "system"; -Jhf]
pwd = "manager"; z"<PveVo
Class.forName(className); G 6][@q
Connection cn = DriverManager.getConnection(url,uid,pwd); tQ/U'Ap&
2)用jndi(java的命名和目录服务)方式 &HWH
UWB
例子 @wo9;DW`
String jndi = "jdbc/db"; <C&UDj
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); Z1Ms~tch
DataSource ds = (DataSource) ctx.lookup(jndi); v#~,)-D&
Connection cn = ds.getConnection(); R{T4AZ@,'
多用于jsp中 VAq:q8(K
2、执行sql语句 BjA|H
1)用Statement来执行sql语句 ;,viE~n
String sql; 7l?=$q>k"
Statement sm = cn.createStatement(); ^3el-dZ
sm.executeQuery(sql); // 执行数据查询语句(select) +G?3j ,a\
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); +/ #J]v-
2)用PreparedStatement来执行sql语句 <Sz9: hg-
String sql; lB-Njr
sql = "insert into user (id,name) values (?,?)"; k2xjcrg
PreparedStatement ps = cn.prepareStatement(sql); F*a+&% Q
ps.setInt(1,xxx); lU\|F5O@#
ps.setString(2,xxx); l!oU9
... a(m#GES
ResultSet rs = ps.executeQuery(); // 查询 Va1|XQ<CL
int c = ps.executeUpdate(); // 更新 NWKD:{
pD){K
3、处理执行结果 QPBf++|
查询语句,返回记录集ResultSet tvd/Y|bV=
更新语句,返回数字,表示该更新影响的记录数 6ds&n#n
ResultSet的方法 W7.]V)$wM
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 5bgx;z9
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 2hquE_1S[w
*{XbC\j
4、释放连接 poM VB{U
cn.close(); nF7Ozxm#
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection /ZAEvdO*P
xEbcF+@
可滚动、更新的记录集 ](%-5G1<
1、创建可滚动、更新的Statement HbCM{A9
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Jr#ptf"Wu
该Statement取得的ResultSet就是可滚动的 ]E,
2、创建PreparedStatement时指定参数 Rrs z{a
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); OYe @P
ResultSet.absolute(9000); `DEz `
D
批量更新 dD#A.C,Rz
1、Statement ;0ake%v]
Statement sm = cn.createStatement(); J.~$^-&!
sm.addBatch(sql1); :[,n`0lH
sm.addBatch(sql2); Cfa?LgSz
... KpSHf9!&[
sm.executeBatch() Y@Ty_j~
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 si)920?E&
2、PreparedStatement \vKMNk;kz
PreparedStatement ps = cn.preparedStatement(sql); =T9QmEBm
{ $LKniK
ps.setXXX(1,xxx); mhh8<BI
... 92XzbbLp
ps.addBatch(); uQrD}%GI
} P.LMu
ps.executeBatch(); vX&Nh"0H&
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 EFV'hMjS)
i:@00)V{,
事务的处理 -(~CZ
1、关闭Connection的自动提交 -$t#AYKz
cn.setAutoCommit(false); X5=Dc+
2、执行一系列sql语句 ]5B5J
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close k|1/gd5
Statement sm ; cu.f]'
sm = cn.createStatement(insert into user...); ga VWfG
sm.executeUpdate(); W,}C*8{+
sm.close(); wQDKv'zU1
sm = cn.createStatement("insert into corp...); |6$6Za]:
sm.executeUpdate(); mI@]{K}Q%
sm.close(); LY/K,6^a
3、提交 /z`LB
cn.commit(); zuXJf+]
4、如果发生异常,那么回滚 sFMSH:5z
cn.rollback();