java 数据库基本操作 n8J';F
=P
1、java数据库操作基本流程 t4h5R
2、几个常用的重要技巧: BwrMRMq"
可滚动、更新的记录集 /\h&t6B1
批量更新 =OTwP
事务处理 2=u5N[*
QfRt3\^`
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 oQFpIX;\m
1、取得数据库连接 O3B\K <l
1)用DriverManager取数据库连接 D6c4tA^EO
例子 ;w[|IRa
String className,url,uid,pwd; N!^U{;X7/
className = "oracle.jdbc.driver.OracleDriver"; GXJJOy1"!
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; z&9vKF
uid = "system"; 2A
{k>TjQ
pwd = "manager"; ad }^Dj/
Class.forName(className); <c^m|v
Connection cn = DriverManager.getConnection(url,uid,pwd); #W'jNX,h
2)用jndi(java的命名和目录服务)方式 T<?JL.8 g_
例子 `QAotSO+
String jndi = "jdbc/db"; !&ac}uD^g
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); -0Y8/6](
DataSource ds = (DataSource) ctx.lookup(jndi); =)(sN"%
Connection cn = ds.getConnection(); o1-Zh!*a*
多用于jsp中 _D[vMr[
2、执行sql语句 |Zncr9b
1)用Statement来执行sql语句 gey`HhZp)
String sql; @va)j
Statement sm = cn.createStatement(); f
\[Z`D
sm.executeQuery(sql); // 执行数据查询语句(select) D 0\
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 'C!b($Y
2)用PreparedStatement来执行sql语句 dGTAZ(1W
String sql; ,d@.@a]
`
sql = "insert into user (id,name) values (?,?)"; ZSU;>&>%v
PreparedStatement ps = cn.prepareStatement(sql); {pm>F}Cwy
ps.setInt(1,xxx); }"2
0:
ps.setString(2,xxx); zf4@:GM`
... 83Bp_K2\
ResultSet rs = ps.executeQuery(); // 查询 +wgNuj0=*
int c = ps.executeUpdate(); // 更新 O. V!L
a&M{y
3、处理执行结果 WdnCRFO?l
查询语句,返回记录集ResultSet DU|0#z=*t5
更新语句,返回数字,表示该更新影响的记录数 9#@dQ/*
ResultSet的方法 xW#r)aN]p
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 0".pw; .}
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 Y*dzoN.sW
^kzw/.I{
4、释放连接 /`Yp]l
cn.close(); 1#&*xF"
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection m("!
M~1
:W? 7J"
可滚动、更新的记录集 =ugxPgn
1、创建可滚动、更新的Statement "P~0 7
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); &w- QMjM>
该Statement取得的ResultSet就是可滚动的 mflH &Bx9
2、创建PreparedStatement时指定参数 7eqax33f
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); "'~'xaU!=a
ResultSet.absolute(9000); 9pb4!=g*
批量更新 Q!(C$&f
1、Statement !gWV4vC
Statement sm = cn.createStatement(); `s Az1/N
sm.addBatch(sql1); o2He}t2o
sm.addBatch(sql2); U:M?Ji5CY
... 0-oR
{
{
sm.executeBatch() `Jq
?+W
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 :CNHN2 J
2、PreparedStatement Rq%g5lK
PreparedStatement ps = cn.preparedStatement(sql); i<YatW~Pu
{ zC\ pd#
ps.setXXX(1,xxx); `i<;5s!rX
... Ysz{~E'
ps.addBatch(); !i&^H,
} T9osueh4
ps.executeBatch(); Hc ]/0:
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 w*Vf{[a'
yS _,lS
事务的处理 3)^-A4~E
1、关闭Connection的自动提交 /d ?)
cn.setAutoCommit(false); E5w.wx
2、执行一系列sql语句 <.s=)}'`P
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close Iw(deD
Statement sm ; g7res
sm = cn.createStatement(insert into user...); I83ZN]
sm.executeUpdate(); .Wv2aJq
sm.close(); >wS52ng
sm = cn.createStatement("insert into corp...); *y9 iuJ}
sm.executeUpdate(); >:%i,K*AM
sm.close(); ja3wXz$2
3、提交 (Hb
i+IHV
cn.commit(); D^W6Cq5\
4、如果发生异常,那么回滚 awQf$
cn.rollback();