java 数据库基本操作 ,=P0rbtK
1、java数据库操作基本流程 .|K\1qGW0
2、几个常用的重要技巧: E
eCgV{9B
可滚动、更新的记录集 @T-}\AU
批量更新 _"'-fl98*
事务处理 :wJ!rn,4
SHCVjI6
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接
T f^O(
1、取得数据库连接 .gI9jRdKw
1)用DriverManager取数据库连接 UKSI"/8I
例子 c:}K(yAdd
String className,url,uid,pwd; y)Lyo'`
className = "oracle.jdbc.driver.OracleDriver"; ,]?l(H $x'
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ? oGmGKq
uid = "system"; EtB56FU\
pwd = "manager"; Sq2yQSd
Class.forName(className); iainl@3Qj
Connection cn = DriverManager.getConnection(url,uid,pwd); (yz8}L3
2)用jndi(java的命名和目录服务)方式 OZh+x`' #
例子 Xg97[ I8/
String jndi = "jdbc/db"; < YuI}d~'
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); \y/+H
DataSource ds = (DataSource) ctx.lookup(jndi); JDC,]
Connection cn = ds.getConnection(); "(?[$R
多用于jsp中 wT\dzp>/
2、执行sql语句 $E@ke:
1)用Statement来执行sql语句 o6
[i0S
String sql; #/pZ#ny
Statement sm = cn.createStatement(); #60<$HO:Z
sm.executeQuery(sql); // 执行数据查询语句(select) 4>@-1nt}
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); KL*UU,qU
2)用PreparedStatement来执行sql语句 k?=V?JWY
String sql; &nZ.$UK<
sql = "insert into user (id,name) values (?,?)"; ZZ6F0FLXJ
PreparedStatement ps = cn.prepareStatement(sql); =j~}];I
ps.setInt(1,xxx); or]s
ps.setString(2,xxx); sfNAGez
... m;I;{+"u
ResultSet rs = ps.executeQuery(); // 查询 |&%l @X6
int c = ps.executeUpdate(); // 更新 %u|qAF2uS
~LzTqMHM
3、处理执行结果 >:P3j<xTv
查询语句,返回记录集ResultSet r,dxW5v.
更新语句,返回数字,表示该更新影响的记录数 ^A$~8?f
ResultSet的方法 BF6H_g
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ihhnB
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 E0S[TEDa]
oApI/o
4、释放连接 l@YpgyqaL
cn.close(); #$%gs]
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection Wkv**X}
Afa{f}st
可滚动、更新的记录集 J XnPKAN
1、创建可滚动、更新的Statement O^gq\X4}
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); PZl(S}VY
该Statement取得的ResultSet就是可滚动的 >Y< y]vM:
2、创建PreparedStatement时指定参数 Cj):g,[a
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); Bf88f<Z
ResultSet.absolute(9000); y]\R0lR
批量更新 i&FC-{|Z
1、Statement wGQ{
Statement sm = cn.createStatement(); Dl/_jM
sm.addBatch(sql1); XT_BiZ%l5O
sm.addBatch(sql2); "$8<\k$LGT
... et ]*5Y6
sm.executeBatch() bvR*sT#rg
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 U^0vLyqW^5
2、PreparedStatement .< vg[
PreparedStatement ps = cn.preparedStatement(sql); 7\U1K^q
{ *id|za|:k
ps.setXXX(1,xxx); {UZli[W1
... h?YjG^'9
ps.addBatch(); 0QIocha
} emS +%6U
ps.executeBatch(); k*c:%vC!
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 NI s4v(!
@4B2O"z`
事务的处理 U w`LWG3T
1、关闭Connection的自动提交 L{fP_DIa
cn.setAutoCommit(false); UmgLH Cz
2、执行一系列sql语句 e?lqs,m@"
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close <p0$Q!^dK=
Statement sm ; 8h20*@wSN
sm = cn.createStatement(insert into user...); -{b1&
sm.executeUpdate(); 6l
vx
sm.close(); e#HP+b$
sm = cn.createStatement("insert into corp...); [Iihk5TT
sm.executeUpdate(); L
kq>>?T=
sm.close(); (Fgt #H(B
3、提交 Nyqm0C6m^
cn.commit(); X)f"`$
4、如果发生异常,那么回滚 |f?C*t',
cn.rollback();