java 数据库基本操作 B8sc;Z.
1、java数据库操作基本流程 1 /dy@'
2、几个常用的重要技巧: #`(-Oj2hH
可滚动、更新的记录集 @+P7BE}
批量更新 ql_GN[c/
事务处理 qkk!1W
fce~a\y0
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 DcL;7 IT
1、取得数据库连接 =2rkaBFC
1)用DriverManager取数据库连接 Sdn4y(&TP
例子 B(TE?[ #
String className,url,uid,pwd; ]> dCt<
className = "oracle.jdbc.driver.OracleDriver"; ]
3UlF'{
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; AYnk.H-v
uid = "system"; -cqR]'u
pwd = "manager"; 9p{7x[ C
Class.forName(className); {i09e1
Connection cn = DriverManager.getConnection(url,uid,pwd); g4-UBDtYt
2)用jndi(java的命名和目录服务)方式 K[~fpQGbV1
例子 z;#]xCV
String jndi = "jdbc/db"; y6C3u5`
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); Hk8pKpn3
DataSource ds = (DataSource) ctx.lookup(jndi); 5U!yc7eBI/
Connection cn = ds.getConnection(); n?=d)[]
多用于jsp中 B{ptP4As-
2、执行sql语句
VwKo)zH
1)用Statement来执行sql语句 rMy(NAo_
String sql; zs<2Ozv
Statement sm = cn.createStatement();
^D.u
sm.executeQuery(sql); // 执行数据查询语句(select) :,'yHVG\
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 0
P]+/
2)用PreparedStatement来执行sql语句 Je1'0h9d
String sql; [W#M(`}D
sql = "insert into user (id,name) values (?,?)"; Q]v><
PreparedStatement ps = cn.prepareStatement(sql); e[
9
ps.setInt(1,xxx); }Jr!aM'
ps.setString(2,xxx); 7)Y0D@wg
... xP61^*-2
ResultSet rs = ps.executeQuery(); // 查询 6myF!
H=
int c = ps.executeUpdate(); // 更新 '1r<g\l
{/E_l
3、处理执行结果 Qf:#{~/
查询语句,返回记录集ResultSet lI*uF~ 'D
更新语句,返回数字,表示该更新影响的记录数 %c"t`
ResultSet的方法 WH6Bs=G\}
1、next(),将游标往后移动一行,如果成功返回true;否则返回false bAVlL&^@|
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 b Y^K)0+^s
(G<fvl!~
4、释放连接 2C59fXfd
cn.close(); vkgAI<
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection
q0y#Y
Fk*C8
可滚动、更新的记录集 cq#=Vb
1、创建可滚动、更新的Statement &]_2tN=S$
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); lv=rL
该Statement取得的ResultSet就是可滚动的 =(cfo_B@K
2、创建PreparedStatement时指定参数 7(W"NF{r
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); snm1EPj
ResultSet.absolute(9000); u#^~([I
批量更新 aSVR+of
1、Statement j+6`nN7L
Statement sm = cn.createStatement(); pHKGK7 S-
sm.addBatch(sql1); (S)jV0
sm.addBatch(sql2); (ibj~g?U,
... ]r\d 5
sm.executeBatch() Gj ka %
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 !0DOj["
2、PreparedStatement MLk%U 4
PreparedStatement ps = cn.preparedStatement(sql); lK yeG(
{ `vc?*"
ps.setXXX(1,xxx); sb"h:i>O4
... kmZ
U;Z
ps.addBatch(); vZJu=t
} I/`\>Hk
ps.executeBatch(); *ud/'HR8]
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 Y0Bd[
RJ0:O
事务的处理 k,0lA#>
1、关闭Connection的自动提交 agUdPl$e\
cn.setAutoCommit(false); ,JONc9
2、执行一系列sql语句 3U!#rz"
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close (\o &Gl
Statement sm ; <#%kmYSL
sm = cn.createStatement(insert into user...); d:{#Dk#
sm.executeUpdate(); [+.P'6/[$R
sm.close(); }h=}!R'm
sm = cn.createStatement("insert into corp...); c)B
<d#
sm.executeUpdate(); 9JBVG~m+
sm.close(); 25wvB@0&
3、提交 -?Kd[Ma
cn.commit(); K^f&+`v6_
4、如果发生异常,那么回滚 ]rMHO
cn.rollback();