java 数据库基本操作 ^Hdru]A$2
1、java数据库操作基本流程 zFR=inI
2、几个常用的重要技巧: ",qcqG(
可滚动、更新的记录集 O%$XgEJ8p
批量更新 uoryxKRjc~
事务处理 K|OowM4tv
]]InD N
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 7AOjlC9R}
1、取得数据库连接 2I!L+j_
1)用DriverManager取数据库连接 "!fvEE
例子 Qd{h3K^hlu
String className,url,uid,pwd; A#WvN>
className = "oracle.jdbc.driver.OracleDriver"; SEL7,8 Hm
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; bnm3
cR:h"
uid = "system"; miq"3
pwd = "manager"; gvoo1 Sa
Class.forName(className); ThvVLK
Connection cn = DriverManager.getConnection(url,uid,pwd); e%B;8)7
2)用jndi(java的命名和目录服务)方式 ~&UfnO
例子 ZjOUk;H?
String jndi = "jdbc/db"; `;:zZ8*
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); B?-~f^*,jG
DataSource ds = (DataSource) ctx.lookup(jndi); @S-p[u
Connection cn = ds.getConnection(); cP]5Qz
多用于jsp中 SU {U+
2、执行sql语句 t$*V*gK{
1)用Statement来执行sql语句 hPM:=@N$
String sql; ff1Em.
Statement sm = cn.createStatement(); T VuDK
sm.executeQuery(sql); // 执行数据查询语句(select) " %,KZI
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); DaK2P;WP
2)用PreparedStatement来执行sql语句 PCx] >&
String sql; #Q6.r.3@x
sql = "insert into user (id,name) values (?,?)"; cc$L56q
PreparedStatement ps = cn.prepareStatement(sql); W,g0n=2V
ps.setInt(1,xxx); HZG<aY="
ps.setString(2,xxx); *1>zE>nlP
... Bl
>)G X\l
ResultSet rs = ps.executeQuery(); // 查询 s--\<v
int c = ps.executeUpdate(); // 更新 =s\RK
:J'ibb1
3、处理执行结果 ,)CRozC\}K
查询语句,返回记录集ResultSet 5W(S~}
更新语句,返回数字,表示该更新影响的记录数 ToNRY<!
ResultSet的方法 h|DKD.
1、next(),将游标往后移动一行,如果成功返回true;否则返回false (I) e-1
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 PN +<C7/
fV\ eksBF
4、释放连接 ?11\@d
cn.close(); gO E3x^X*{
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection qXb{A*J
xIrRFK9[Q
可滚动、更新的记录集 8%Wg;:DZx
1、创建可滚动、更新的Statement ;`TSu5/
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 3 E~d
该Statement取得的ResultSet就是可滚动的 3XOf-v:~
2、创建PreparedStatement时指定参数 4Y=sTXbFt
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); l$:.bwXXO
ResultSet.absolute(9000); h
/. ^iT
批量更新 B!#F!Wk"
1、Statement rLy<3
Statement sm = cn.createStatement(); 7n_'2qY
sm.addBatch(sql1); ZgXn8O[a
sm.addBatch(sql2); Ao%;!(\I%
... IO(Y_7
sm.executeBatch() RyxEZ7dC<y
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ~MgU"P>
2、PreparedStatement e/h2E dY
PreparedStatement ps = cn.preparedStatement(sql);
H/eyc`
{ bay7%[BLB
ps.setXXX(1,xxx); 1e0O-aT#Q
... !.[N(%"
ps.addBatch(); )R QX1("O
} `D#3
ps.executeBatch(); <K#]1xCA
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 [qMFLY$
:*{>=BD
事务的处理 o`!7~n
1、关闭Connection的自动提交 \w]c<gM K
cn.setAutoCommit(false); 1 o;*`
2、执行一系列sql语句 c04"d"$ x
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close .hD2g"
Statement sm ; +>F #{b
sm = cn.createStatement(insert into user...); mp{r$tc
sm.executeUpdate(); iTt#%Fs)4M
sm.close(); $p}
/&
sm = cn.createStatement("insert into corp...); WLb*\
sm.executeUpdate(); kRyt|ryWh
sm.close(); LB)sk$)
3、提交 ]/_GHG9
cn.commit(); Hko(@z
4、如果发生异常,那么回滚 _>/T<Db
cn.rollback();