java 数据库基本操作 { /F rs*AF
1、java数据库操作基本流程 ySixYt
2、几个常用的重要技巧: )O2Nlk~l&
可滚动、更新的记录集 >2| [EZ
批量更新 ]e@0T{!
事务处理 !e:iB7<
{;Y 89&*R
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 Z92iil;t
1、取得数据库连接 ~|r'2V*
1)用DriverManager取数据库连接 eC+"mhB
例子 jsNH`"
String className,url,uid,pwd; =.qm8+
className = "oracle.jdbc.driver.OracleDriver"; 9k=U0]!ch
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; 7g A08M[O
uid = "system"; I9[1U
pwd = "manager"; kb"_6,[Ms
Class.forName(className); xb+RRTgj
Connection cn = DriverManager.getConnection(url,uid,pwd); qLQ <1>u
2)用jndi(java的命名和目录服务)方式 kvW|=
例子 BrlzN='j}
String jndi = "jdbc/db"; cQ3W;F8|n
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 0|fb< "
DataSource ds = (DataSource) ctx.lookup(jndi); n)
_dH/"
Connection cn = ds.getConnection(); ;t;Y.*&=S
多用于jsp中 ?fbgU
2、执行sql语句 @pF
fpHq?>
1)用Statement来执行sql语句 5|<yfk8*J
String sql; eKZ@FEZ
Statement sm = cn.createStatement(); C%}]"0Q1
sm.executeQuery(sql); // 执行数据查询语句(select) &dhcKO<4
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); %Ycx C0S[
2)用PreparedStatement来执行sql语句 kf%&d}2to
String sql; "*++55
sql = "insert into user (id,name) values (?,?)"; T3USNc51
PreparedStatement ps = cn.prepareStatement(sql); W_[|X}lWP
ps.setInt(1,xxx); ibd$%;bX3
ps.setString(2,xxx); KP[NuXA`
... GI2eJK
ResultSet rs = ps.executeQuery(); // 查询 "3{#d9Gs
int c = ps.executeUpdate(); // 更新 m,W) N9 M
>lD;0EN
3、处理执行结果 (O)\#%,@R
查询语句,返回记录集ResultSet Q0zW ]a
更新语句,返回数字,表示该更新影响的记录数 {fGd:2dh
ResultSet的方法 \H Wcd|
1、next(),将游标往后移动一行,如果成功返回true;否则返回false EJf #f
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 :]P~.PD5,
_BZ1Vnv
4、释放连接 CQ6'b,L&
cn.close(); .]W;2G
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection q"gqO%Wb|
qP~WEcH`[
可滚动、更新的记录集 ,?l~rc
1、创建可滚动、更新的Statement _j:UGMTi(U
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ;{<aA 5
该Statement取得的ResultSet就是可滚动的 q,[k7&HS
2、创建PreparedStatement时指定参数 C`\9cej
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ,HFs.9#&B
ResultSet.absolute(9000); uh]"(h(>
批量更新 z$JX'(<Z7
1、Statement +hE',i.
Statement sm = cn.createStatement(); bA}AD`5
sm.addBatch(sql1); {Ge+O<mD
sm.addBatch(sql2); z]^+^c_
... D
Irgq|8
sm.executeBatch() 96(R'^kNX
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 QBy{|sQ`
2、PreparedStatement R/^@cA
PreparedStatement ps = cn.preparedStatement(sql); e]lJqC
{ '
|&>/dyq
ps.setXXX(1,xxx); "-w^D!C
... rRB~=J"
ps.addBatch(); \HAJ\9*w)
} 95=gY
ps.executeBatch(); kOw=c Gt
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 J,f/fPaf7
z{ptm7
事务的处理 7;&(}
1、关闭Connection的自动提交 y|$R`P
cn.setAutoCommit(false); *)u?~r(F
2、执行一系列sql语句 5L8&/EN9-
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close ^:`oP"%-T
Statement sm ; ~12_D'8D[
sm = cn.createStatement(insert into user...); "`pNH'
sm.executeUpdate(); S]}}A
sm.close(); Q"40#RFA
sm = cn.createStatement("insert into corp...); B[r<m J
sm.executeUpdate(); vxZg &SRK
sm.close(); > 2#%$lX6
3、提交 n-DaX
kK
cn.commit(); R {HV]o|qk
4、如果发生异常,那么回滚 R (G2qi
cn.rollback();