java 数据库基本操作 |k[hk
1、java数据库操作基本流程 rT/4w#_3
2、几个常用的重要技巧: 8HxtmFqG
可滚动、更新的记录集 pY"&=I79tb
批量更新 &3~_9+
事务处理 mgL{t"$c
& Do|Hw
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 #_9Jam%M
1、取得数据库连接 9X ^D(
1)用DriverManager取数据库连接 [qHtN.
例子 N&YQZ^o
String className,url,uid,pwd; E!]d?t3b
className = "oracle.jdbc.driver.OracleDriver"; ;]I~AGH:
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; u7G9 eN
uid = "system"; f)9{D[InM^
pwd = "manager"; ZD`p$:pT
Class.forName(className); m1{OaHxKh
Connection cn = DriverManager.getConnection(url,uid,pwd); y-R:-K XH=
2)用jndi(java的命名和目录服务)方式 U!D\Vd
例子 !`qw"i
String jndi = "jdbc/db"; (|t)MnPfY
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); <HMmsw
DataSource ds = (DataSource) ctx.lookup(jndi);
I5H#]U
Connection cn = ds.getConnection(); ,Z aPY
多用于jsp中 -s,guW |
2、执行sql语句 &O;'?/4
S
1)用Statement来执行sql语句 k.K;7GZC
String sql; LP:U6 Z
Statement sm = cn.createStatement(); _]q%H ve
sm.executeQuery(sql); // 执行数据查询语句(select) =CGB}qU l0
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); em,j>qp
2)用PreparedStatement来执行sql语句 ]<<+#Rg
String sql; :(Uz`k7
sql = "insert into user (id,name) values (?,?)"; b+!I_g4P
PreparedStatement ps = cn.prepareStatement(sql); <cNg_ZZ;8
ps.setInt(1,xxx); gVU&Yl~/^
ps.setString(2,xxx); :!WKD@]
... -h1FrDBt
ResultSet rs = ps.executeQuery(); // 查询 ~9h/{$
int c = ps.executeUpdate(); // 更新 ^h~oxZJw
r3mQoTvnv
3、处理执行结果 vI1UFD
D
查询语句,返回记录集ResultSet 5nh:S0M6V
更新语句,返回数字,表示该更新影响的记录数 -gR
}^D
ResultSet的方法 e,I{+^P
1、next(),将游标往后移动一行,如果成功返回true;否则返回false z3|)WS^
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 j`LvS
V(6GM+
4、释放连接 u.R
cn.close(); 8Ssk>M*
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection @$]
CC1Y
r}~|,O3bc'
可滚动、更新的记录集 d_w^u|(K
1、创建可滚动、更新的Statement `@#,5S$ E
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); q+ )csgN
该Statement取得的ResultSet就是可滚动的 UukHz}(E
2、创建PreparedStatement时指定参数 ~RIn7/A
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 1EcXvT=
ResultSet.absolute(9000); C$#X6Q!,
批量更新 [>xGynU0
1、Statement M%@=BT
Statement sm = cn.createStatement(); * u{CnH
sm.addBatch(sql1); RQt\_x7P
sm.addBatch(sql2); 0$e]?]X6
... y+K21(z.
sm.executeBatch() &XH{,fv$
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 S)~Riuy$
2、PreparedStatement ;VIW/
PreparedStatement ps = cn.preparedStatement(sql); ^ Z~'>J
{ [/Ya4=C@
ps.setXXX(1,xxx); p&<X&D
... v.pj
PBU1
ps.addBatch(); 9G)q U
} `|d&ta[{
ps.executeBatch(); ?>
SH`\
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 .X(*mmH
Ii4lwZnz
事务的处理 nd?R|._R
1、关闭Connection的自动提交 (%^Bp\.02!
cn.setAutoCommit(false); jm$v0=W9#
2、执行一系列sql语句 5p5S_%R$e
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close ?Rg8u
Statement sm ; ~n$e
sm = cn.createStatement(insert into user...); f[$9k}.
sm.executeUpdate(); dab[x@#r>
sm.close(); ;zZGV4Qc~
sm = cn.createStatement("insert into corp...); {<}kqn83sT
sm.executeUpdate(); Ow7}&\;^-
sm.close(); {8as _
3、提交 i[x;k;m2q
cn.commit(); i~04 P
4、如果发生异常,那么回滚 ~e@pL*s
cn.rollback();