java 数据库基本操作 Ct9dV7SH
1、java数据库操作基本流程 9e0t
2、几个常用的重要技巧: 0<u(!iL
可滚动、更新的记录集 0jMS!"k
批量更新 r@ v&~pL
事务处理 @0fiui_
gF~#M1!!
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ^-dhz88wV
1、取得数据库连接 b9"HTQHl
1)用DriverManager取数据库连接 *s6(1S
例子 F~zrg+VDjL
String className,url,uid,pwd; _7N^<'B
className = "oracle.jdbc.driver.OracleDriver"; aSQvtv)91
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; N5Ih+8zT
uid = "system"; c-=z<:Kf
pwd = "manager"; /YD2F
Class.forName(className); Z
lR2
Connection cn = DriverManager.getConnection(url,uid,pwd); v|GDPq
2)用jndi(java的命名和目录服务)方式 LNI]IITx/
例子 x|U[|i,;
String jndi = "jdbc/db"; lvk
r2Meu<
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); z1m$8-4
DataSource ds = (DataSource) ctx.lookup(jndi); 6w*q~{"(
Connection cn = ds.getConnection(); }D*5PV%d
多用于jsp中 M:cW/&ZJ
2、执行sql语句 '<% ;Nv
1)用Statement来执行sql语句 BOWR}n!g
String sql; >;Vy{bL8
Statement sm = cn.createStatement(); %617f=(E?!
sm.executeQuery(sql); // 执行数据查询语句(select) k8O%gO
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); (VB-5&b
2)用PreparedStatement来执行sql语句 V^qkHm e
String sql; ILMXWw
sql = "insert into user (id,name) values (?,?)"; +hzS'z)n&
PreparedStatement ps = cn.prepareStatement(sql); .Uh|V-
ps.setInt(1,xxx); q+cx.Rc#
ps.setString(2,xxx); b";D*\=x
... B'~CFj0W%=
ResultSet rs = ps.executeQuery(); // 查询 "t:9jU
int c = ps.executeUpdate(); // 更新
g:
,*Y^T
;}QM#5Xdt
3、处理执行结果 ~WX40z
查询语句,返回记录集ResultSet 9P\R?~3
更新语句,返回数字,表示该更新影响的记录数 G_)(?
ResultSet的方法 Q4QF_um
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ;/)u/[KAv
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ;ep@
)Y
2sOetmWE7
4、释放连接 uH=^ILN.
cn.close(); Fv2U@n6'v
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection }8)iFP&"
jb0LMl}/A
可滚动、更新的记录集 2/.I6IbL
1、创建可滚动、更新的Statement #S*cFnd
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ;.#l[
该Statement取得的ResultSet就是可滚动的 Ub% 1OQ
2、创建PreparedStatement时指定参数 Fa^I 1fk
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); JF-ew"o<E
ResultSet.absolute(9000); .jvRUD8A7
批量更新 i5G"@4(
1、Statement 7B8.;0X$W
Statement sm = cn.createStatement(); aW@J]slg
sm.addBatch(sql1); 'c&S%Ra[3G
sm.addBatch(sql2);
M;zJ1
... 04P!l
sm.executeBatch() @o4n!Ip2x/
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ,G%?}TfC)
2、PreparedStatement Az4a|.
PreparedStatement ps = cn.preparedStatement(sql); 9#D?wR#J=
{ v*VId
l>
ps.setXXX(1,xxx); L"ob))GF
... ra>jVE0`
ps.addBatch(); ua
HB\Uc
} {((|IvP`
ps.executeBatch(); EhK5<v}
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 'Nn>W5#))
EL+P,q/b
事务的处理 U?sio%`(
1、关闭Connection的自动提交 fqQ(EVpQ
cn.setAutoCommit(false); ~
$QNp#dq
2、执行一系列sql语句 `6B jNV
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close NAt; r
Statement sm ; KQv97#n1
sm = cn.createStatement(insert into user...); +tSfx
sm.executeUpdate(); 2pn8PQfg)
sm.close(); W^Z#_{
sm = cn.createStatement("insert into corp...); kjOPsz*0
sm.executeUpdate(); q>H f2R
sm.close(); ^s[OvJb
3、提交 ._5"FUg
cn.commit(); R7j'XU
4、如果发生异常,那么回滚 jZLD^@AP
cn.rollback();