java 数据库基本操作 ]U[X1W+@
1、java数据库操作基本流程 U(&oj e
2、几个常用的重要技巧: :H.
可滚动、更新的记录集 NRnRMY-
批量更新 0U66y6
事务处理 )PkNWj6%y
Xf=XBoN|
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 H-rWDN#
1、取得数据库连接 IM=bK U
1)用DriverManager取数据库连接 0Q1FL MLV
例子 @RD+xYm
String className,url,uid,pwd; #5sD{:f`
className = "oracle.jdbc.driver.OracleDriver"; bLz*A-
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; kH*P n'
uid = "system"; l=`L7| ^/d
pwd = "manager"; @vgG1w
Class.forName(className); uBg 8h{>
Connection cn = DriverManager.getConnection(url,uid,pwd); |(
(zTf
2)用jndi(java的命名和目录服务)方式 s)voII&
例子 *y`%]Hy<
String jndi = "jdbc/db"; j^`X~gE
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); F}J-gZl
DataSource ds = (DataSource) ctx.lookup(jndi); /9Q3iV$I]
Connection cn = ds.getConnection(); nM=e]qH
多用于jsp中 Y**|N8e
2、执行sql语句 4!$
M q;U
1)用Statement来执行sql语句 a\kb^D=T
String sql; HQ!Xj.y
Statement sm = cn.createStatement(); puSLqouTM
sm.executeQuery(sql); // 执行数据查询语句(select) fQWIw
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); < (RC|?
2)用PreparedStatement来执行sql语句 x+? 9C
String sql; 1rw0sAuGy
sql = "insert into user (id,name) values (?,?)"; vv6$>SU
PreparedStatement ps = cn.prepareStatement(sql); [\)oo
ps.setInt(1,xxx); y<W8Q<9
ps.setString(2,xxx); kI*(V[i
... rh2LGuo4m
ResultSet rs = ps.executeQuery(); // 查询 k'`m97B
int c = ps.executeUpdate(); // 更新 hovGQHg
g*\/N,"z
3、处理执行结果 5OM?3M
查询语句,返回记录集ResultSet G@!z$
更新语句,返回数字,表示该更新影响的记录数 MgnM,95
ResultSet的方法 2.}R
1、next(),将游标往后移动一行,如果成功返回true;否则返回false sK$wN4k
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 CR4rDh8z a
?tf&pgo
4、释放连接 78n}rT%k1
cn.close(); ;y?);!g
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection ;N+$2w
dYFzye
可滚动、更新的记录集 @$Qof1j'%
1、创建可滚动、更新的Statement fi PIAT}
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); G"
b60RQ
该Statement取得的ResultSet就是可滚动的 (A k\Lm
2、创建PreparedStatement时指定参数 k!jNOqbb
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); t$&Qv)
ResultSet.absolute(9000); )!9Ifk0KH
批量更新 >(9F
1、Statement ,7]k fB
Statement sm = cn.createStatement(); 4}v@C|.p
sm.addBatch(sql1); 5`^o1nGO'
sm.addBatch(sql2); {mYP<NBT
... [c K^+s)N
sm.executeBatch() *#>F.#9
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 =1/NFlt8
2、PreparedStatement g]mtFrP
PreparedStatement ps = cn.preparedStatement(sql); s}M= oe
{ cl[!`Z
ps.setXXX(1,xxx); #~:P}<h
... Z{-Lc68
ps.addBatch(); xtV[p4U
} +%J\y^09kr
ps.executeBatch(); X[C3&NX#_
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 }6RT,O g
>hMUr*j
事务的处理 LDT(]HJ
1、关闭Connection的自动提交 ZU'!iU|8
cn.setAutoCommit(false); KV!<Oq
2、执行一系列sql语句 AH7L.L+$M
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close .;/L2Jv
Statement sm ; db=$zIB[:
sm = cn.createStatement(insert into user...); r2*<\ax
sm.executeUpdate(); )9"oL!2h
sm.close(); 0V,Nv9!S
sm = cn.createStatement("insert into corp...); )yee2(S
sm.executeUpdate(); Y,z??bm~J
sm.close(); u.|~
3、提交 C.a5RF0
cn.commit(); Q}%tt=KD
4、如果发生异常,那么回滚 Hy;Hs#
cn.rollback();