java 数据库基本操作 uefrE53
1、java数据库操作基本流程 tu:W1?
2、几个常用的重要技巧: 'D:R]@eK]
可滚动、更新的记录集 $V\Dl]a1
批量更新 UGD B4S
事务处理 Ow50M;E
WI6h
G
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 X8\UTHT&0
1、取得数据库连接 { u %xc"0y
1)用DriverManager取数据库连接 %}}?Y`/W)
例子 x+8%4]u`
String className,url,uid,pwd; p~3 (nk<+
className = "oracle.jdbc.driver.OracleDriver"; C7=N`s}
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ,.z?=]'en
uid = "system"; NA!?.zn
pwd = "manager"; eqSCE6r9x
Class.forName(className); qx1+'
Connection cn = DriverManager.getConnection(url,uid,pwd); ufn%sA
2)用jndi(java的命名和目录服务)方式 N#p%^GH
例子 CxD=8X9m
String jndi = "jdbc/db"; fl}!V4
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ZKTY1JW_
DataSource ds = (DataSource) ctx.lookup(jndi); 8.zYa(<2
Connection cn = ds.getConnection(); }Y!v"DO#Q*
多用于jsp中 \k9]c3V
2、执行sql语句 | r,{# EE
1)用Statement来执行sql语句 D%*Ryg
String sql; < #zd]t
Statement sm = cn.createStatement(); u10;qYfL8o
sm.executeQuery(sql); // 执行数据查询语句(select) !Bv.@~
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); TZ#^AV=ae
2)用PreparedStatement来执行sql语句 EYRg,U&'
String sql; q|sT4}
=
sql = "insert into user (id,name) values (?,?)"; T"/dn%21
PreparedStatement ps = cn.prepareStatement(sql); ] B?NDxU
ps.setInt(1,xxx); GDQQ4-|O
ps.setString(2,xxx); )W/_2Q.
... Gzc`5n{"
ResultSet rs = ps.executeQuery(); // 查询 V<ii
int c = ps.executeUpdate(); // 更新 "BZL*hHq
ENy$sS6[D
3、处理执行结果 ny}_^3
查询语句,返回记录集ResultSet pv,z$3Q
更新语句,返回数字,表示该更新影响的记录数 *RmD%[f
ResultSet的方法 K SJ Ko
1、next(),将游标往后移动一行,如果成功返回true;否则返回false uhU'm@JZ
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 /5X_gjOL,
#wZbG|%
4、释放连接 0|6Y%a\U
cn.close(); aZ8f>t1Q
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection E(_lm&,4+
&ZL4/e
可滚动、更新的记录集 aA]wFZ
1、创建可滚动、更新的Statement :W#?U yo
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); N , ,[V
该Statement取得的ResultSet就是可滚动的 30YH}b#B
2、创建PreparedStatement时指定参数 Ln8r~[tVE<
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); pf&U$oR4
ResultSet.absolute(9000); N%S|Ey@f
批量更新 8~sC$sIlE
1、Statement p_i',5H(
Statement sm = cn.createStatement(); =&^tfD
sm.addBatch(sql1); 7AF6aog
sm.addBatch(sql2); =@D H hg
... 7-
|N&u
sm.executeBatch() !p Q*m`Xo
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 9&zQ5L>
2、PreparedStatement |-TxX:O-
PreparedStatement ps = cn.preparedStatement(sql); |S]T,`7u
{ IdCE<Oj\
ps.setXXX(1,xxx); R5xV_;wD
... 4|UtE<<b
ps.addBatch(); &\
K
} ?:6w6GwAA
ps.executeBatch(); Bkg./iP5x
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 -b)3+#f
+R_s(2vz
事务的处理 _zkTx7H
1、关闭Connection的自动提交 l{Et:W%|
cn.setAutoCommit(false); 8Vy/n^3)
2、执行一系列sql语句 r::0\{{r"p
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close e?N3&ezp
Statement sm ; .hjN*4RY
sm = cn.createStatement(insert into user...); K1w:JA6(
sm.executeUpdate(); tYG6Gl
sm.close(); =
toU?:.
sm = cn.createStatement("insert into corp...); 2J (nJT"
sm.executeUpdate(); 8Y_lQfJa
sm.close(); ts;^,|h
3、提交 B%5"B} nG
cn.commit(); `~D{]'j
4、如果发生异常,那么回滚 So=
B cX-
cn.rollback();