java 数据库基本操作 SFk#bh
1、java数据库操作基本流程 N?;o_^C
2、几个常用的重要技巧: R*Z]
可滚动、更新的记录集 |xZcT4
批量更新 mE`qvavP|/
事务处理 Wk\@n+Q{]
^Pd37&B4V
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 _}OJPahw
1、取得数据库连接 GQ2PmnV+
1)用DriverManager取数据库连接 @b\ S.
例子 pYl{:uIPN8
String className,url,uid,pwd; ;9 ,mV(w
className = "oracle.jdbc.driver.OracleDriver"; HhmVV"g
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; TE%#$q
uid = "system"; ttaQlEa=Z
pwd = "manager"; mSzpRa
Class.forName(className); k%}89glm
Connection cn = DriverManager.getConnection(url,uid,pwd); 45sxF?GSwL
2)用jndi(java的命名和目录服务)方式 |<-F|v9og
例子 <{420
String jndi = "jdbc/db"; rAWl0y_m
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); +RV- VrV
DataSource ds = (DataSource) ctx.lookup(jndi); xwnoZ&h
Connection cn = ds.getConnection(); :KSor}t
多用于jsp中 vo
;F ;
2、执行sql语句 t-i6 FS-
1)用Statement来执行sql语句 +xfW`[.{
String sql; l (,;wAH
Statement sm = cn.createStatement(); ;{f?? G
sm.executeQuery(sql); // 执行数据查询语句(select) 0^_lj9B!
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); EB5_;
2)用PreparedStatement来执行sql语句 tIb21c q
String sql; ny(GTKoUz
sql = "insert into user (id,name) values (?,?)"; vX0"S
PreparedStatement ps = cn.prepareStatement(sql); yv)nW::D(
ps.setInt(1,xxx); [W$Z60?RR
ps.setString(2,xxx);
Hp}
... 6_<s=nTX
ResultSet rs = ps.executeQuery(); // 查询 c~UAr k S
int c = ps.executeUpdate(); // 更新 $i:||L^8p
ouVjZF@kS
3、处理执行结果 ;,=h59`
查询语句,返回记录集ResultSet F|?'9s*;6G
更新语句,返回数字,表示该更新影响的记录数 EeJqszmH
ResultSet的方法 j;20JA/b
1、next(),将游标往后移动一行,如果成功返回true;否则返回false "6N~2q,SW
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ,.jHV
7grt4k
4、释放连接 ~r^5-\[hZ
cn.close(); MJ*]fC3/
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection ?96-" l
cZr G:\A
可滚动、更新的记录集 Vp$wHB&
1、创建可滚动、更新的Statement Q"|kW[Sg
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ("E!Jyc!
该Statement取得的ResultSet就是可滚动的 %gu$_S
2、创建PreparedStatement时指定参数 )p<fL
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); AB"1(PbG
ResultSet.absolute(9000); 3`k[!!
批量更新 ?,:#8.9
1、Statement NdsX*o@a
Statement sm = cn.createStatement(); ?orh JS
sm.addBatch(sql1); vZE|Z[M+<
sm.addBatch(sql2); 9G#8%[W
... b>QM~mq3^I
sm.executeBatch() +z|UpI
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 jefNiEE[
2、PreparedStatement r|^lt7\
PreparedStatement ps = cn.preparedStatement(sql); 8nIMZV
{ 4e@&QOo`Cu
ps.setXXX(1,xxx); H+VO.s.a
... _7lt(f[S
ps.addBatch(); C NfJ:e2
} [Iw>|q<e
ps.executeBatch(); Qq T/1^imS
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 kqD*TJA
>wKu6-
]a
事务的处理 0AK?{y U
1、关闭Connection的自动提交 jQ_dw\
{0
cn.setAutoCommit(false); q*[!>\Z8
2、执行一系列sql语句 ]D LZ&5pv
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close OG`|td
Statement sm ; goDV2alC^
sm = cn.createStatement(insert into user...); )C>}"#J>
sm.executeUpdate(); Dc.n-ipv$
sm.close(); M!Z*QY."P
sm = cn.createStatement("insert into corp...); hIVI\U,
sm.executeUpdate(); x*me'?q
sm.close(); dUoWo3r=
3、提交 s]y-pZ
cn.commit(); 4jX@m
4、如果发生异常,那么回滚 Ak5[PBbW
cn.rollback();