java 数据库基本操作 6nW]Q^N}
1、java数据库操作基本流程 VF g"AJf
2、几个常用的重要技巧: "`
kSI&2
可滚动、更新的记录集 XRXQ
7\n
批量更新 F,@uYMQs
事务处理 Xe@:Aun
M^0^l9w
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 gF r-P! 3
1、取得数据库连接 \6vr)1~N>
1)用DriverManager取数据库连接 tfPe-U
例子 {r_x\VC=p
String className,url,uid,pwd; &o7"L;
className = "oracle.jdbc.driver.OracleDriver"; 3j/~XT
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; 6gB;m$:fV
uid = "system"; 4td9=dNA+l
pwd = "manager"; h{?cs%lZ
Class.forName(className); 7a4h7/
Connection cn = DriverManager.getConnection(url,uid,pwd); 0t -=*7w%
2)用jndi(java的命名和目录服务)方式 Vs,
&
例子 0>U7]wZKc
String jndi = "jdbc/db"; 7rIEpN>*
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ,XsBm+Q(
DataSource ds = (DataSource) ctx.lookup(jndi); ;bkvdn}
Connection cn = ds.getConnection(); sYd)r%%AU
多用于jsp中 uw{K&Hxw
2、执行sql语句 y
hNy
1)用Statement来执行sql语句 =o_zsDv
String sql; YeVkX{y
Statement sm = cn.createStatement(); ? ;$f"Wl
sm.executeQuery(sql); // 执行数据查询语句(select) )CG,Udu
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); lnt}l
2)用PreparedStatement来执行sql语句 Wqas1yL_
String sql; dd!Q[]$ }
sql = "insert into user (id,name) values (?,?)"; )\QPUdOvx
PreparedStatement ps = cn.prepareStatement(sql); \Z$MH`_nu
ps.setInt(1,xxx); b:W
x[+
ps.setString(2,xxx); Wrs6t
... dWVm'd
ResultSet rs = ps.executeQuery(); // 查询 b$=c(@]
int c = ps.executeUpdate(); // 更新 "]x#kM
j&Y{
CFuZ
3、处理执行结果 $DhW=(YM_a
查询语句,返回记录集ResultSet b*<Fi#x1=
更新语句,返回数字,表示该更新影响的记录数 g!!:o(k
ResultSet的方法 5 8gkE94
1、next(),将游标往后移动一行,如果成功返回true;否则返回false "1ov<
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ]TSzT"_r~~
eRB
K= X
4、释放连接 [k
cn.close(); m4RiF
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection `WlQ<QEi
TQ25"bWi
可滚动、更新的记录集 }W5~89"
1、创建可滚动、更新的Statement 8eD/9PD=F
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ].3@ Dk
该Statement取得的ResultSet就是可滚动的 e+Sq&H!@
2、创建PreparedStatement时指定参数 Y>I9o)KR
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); o~ReeZ7)Zg
ResultSet.absolute(9000); gCv[AIE_m
批量更新 ?xb2jZ/0X
1、Statement .'=-@W*
Statement sm = cn.createStatement(); w!
':Ws
sm.addBatch(sql1); BD&AtOj[,
sm.addBatch(sql2); 0oo*F
... u~\ NL{
sm.executeBatch() 6yhRcvJ}
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 V*1-wg5>
2、PreparedStatement *M+ CA_I(
PreparedStatement ps = cn.preparedStatement(sql); ?<D1]Xv
{ s|-g)
ps.setXXX(1,xxx); Jb]22]
... ]vq=~x
ps.addBatch(); "In$|A\?E
} s
Vg89I&
ps.executeBatch(); -59;Zn/
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 G[\3)@I
.oz(,$CS"
事务的处理 ?tf<AZ=+^L
1、关闭Connection的自动提交 {z7kW@c
cn.setAutoCommit(false); iS}~e{TP/
2、执行一系列sql语句 <*5` TE0J
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close Z~HLa
Statement sm ; ^1`T_+#[s
sm = cn.createStatement(insert into user...); I8LoXY
sm.executeUpdate(); !k=~a]
sm.close(); UszR. Z
sm = cn.createStatement("insert into corp...); +3k#M[Bn}
sm.executeUpdate(); ){xMMQ5
sm.close(); *","u;&
3、提交 uG7ll5Yy
cn.commit(); 6Y/TqI[
4、如果发生异常,那么回滚 8M7pc{
cn.rollback();