java 数据库基本操作 kLVn(dC "
1、java数据库操作基本流程 vif8{S
2、几个常用的重要技巧: NceB'YG|
可滚动、更新的记录集 t/*K#]26
批量更新 7+a%ehwU
事务处理 F> QT|
`f+8WPJPZ
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 2ly,l[p8
1、取得数据库连接 eq~c
1)用DriverManager取数据库连接 `MsYgd
例子 >I&
jurU#
String className,url,uid,pwd; e$EF% cKH
className = "oracle.jdbc.driver.OracleDriver"; @y(Wy}
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; v"r9|m~ '
uid = "system"; 0R}Sw[M.
pwd = "manager"; >_`D3@Rz
Class.forName(className); [DxefYyI
Connection cn = DriverManager.getConnection(url,uid,pwd); Z SRRlkU
2)用jndi(java的命名和目录服务)方式 "P'&+dH8
例子 e:J'&r& 1
String jndi = "jdbc/db"; hO/5>Zv?
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); k&A7alw
DataSource ds = (DataSource) ctx.lookup(jndi); nF<y7XkO
Connection cn = ds.getConnection(); lW$&fuDHF
多用于jsp中 Z|(c(H2
2、执行sql语句 "Ug/
',jkV
1)用Statement来执行sql语句 D*cyFAF
String sql; ,xYsH+ybA
Statement sm = cn.createStatement(); DMQNr(w{!2
sm.executeQuery(sql); // 执行数据查询语句(select) =~hsKBt*
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); rocB"0
2)用PreparedStatement来执行sql语句 (.,'}+1
String sql; P-+M,>vNy[
sql = "insert into user (id,name) values (?,?)"; ZS XRzH~0
PreparedStatement ps = cn.prepareStatement(sql); WY"Y)S
ps.setInt(1,xxx); X&(ERY,h
ps.setString(2,xxx); #$=8g
RZj
... H=&/ Q
ResultSet rs = ps.executeQuery(); // 查询 WBr:|F+~s
int c = ps.executeUpdate(); // 更新 4Oy.,MDQP
9$+^"ilk
3、处理执行结果 aZj J]~bO
查询语句,返回记录集ResultSet }r}RRd
更新语句,返回数字,表示该更新影响的记录数 *`ZB+ \*
ResultSet的方法 #*$_S@
1、next(),将游标往后移动一行,如果成功返回true;否则返回false I
f3{E
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 TF=k(@9J?
3qiJwo>
4、释放连接 c6,s+^^
cn.close(); l
Io9,Ke
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection A<SOT >m]
d1V^2Hb?
可滚动、更新的记录集 DD!MGf/
1、创建可滚动、更新的Statement [0u.}c;(
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); EmX>T>~#D
该Statement取得的ResultSet就是可滚动的 9zZ5Lr^21
2、创建PreparedStatement时指定参数 8QVE_ Eu
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); StU 4{
ResultSet.absolute(9000); +Y>"/i.
N
批量更新 [eNkU">}
1、Statement |rHG%VnBH
Statement sm = cn.createStatement();
u>}w-
sm.addBatch(sql1); 1Xy8|OFc[
sm.addBatch(sql2); M3Khc#5S(
... P+dA~2k
sm.executeBatch() 9-
xlvU,o
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 mRhd/|g*
2、PreparedStatement )MWUS;O<
PreparedStatement ps = cn.preparedStatement(sql); vi]r
{ &8<<!#ob
ps.setXXX(1,xxx); 0R HS]cN
... +yf(Rs)!
ps.addBatch(); GilQtd3\
} A~Z6jK
ps.executeBatch(); v7i^O`{eD?
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 d,c8Hs8
K8HIuQ!=
事务的处理 #l*a~^dhqC
1、关闭Connection的自动提交 ? YF${
cn.setAutoCommit(false); $#%U\mIz
2、执行一系列sql语句 hv+|s(
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 4q>7OB:e
Statement sm ; (O\U /daB
sm = cn.createStatement(insert into user...); \ Md
3
sm.executeUpdate(); Fe!D%p Qv
sm.close(); ^WE4*.(
sm = cn.createStatement("insert into corp...); YD&|1h
sm.executeUpdate(); F9(._ow[
sm.close(); GX4QaT%
3、提交 _om0
e=5)
cn.commit(); AV40:y\RW
4、如果发生异常,那么回滚 Q6"uK
cn.rollback();