java 数据库基本操作 DvY)n<U1qA
1、java数据库操作基本流程 H&uh$y@
2、几个常用的重要技巧: FZx.Yuv
可滚动、更新的记录集 q" @%W K
批量更新 SY$%)(c8kL
事务处理 %OJq( }
)M_|r2dDq3
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 %,f(jQfg_
1、取得数据库连接 ^c?$$Tq
1)用DriverManager取数据库连接 DsH#?h<-o
例子 CtE <9?
String className,url,uid,pwd;
J7p?9
className = "oracle.jdbc.driver.OracleDriver"; Vw+RRi(
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; X][=(l!;w7
uid = "system"; fF.sT7Az+
pwd = "manager"; +l;A L5h
Class.forName(className); b] ~
Connection cn = DriverManager.getConnection(url,uid,pwd); jPEOp#C
2)用jndi(java的命名和目录服务)方式 S^_F0</U,
例子 @waY+sqt=
String jndi = "jdbc/db"; =O>E>Q
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); :Hj #1-U
DataSource ds = (DataSource) ctx.lookup(jndi); q@XxCP]
Connection cn = ds.getConnection(); iyP0;$
多用于jsp中 ~'0W(~Q8
2、执行sql语句 7uq^TO>9f
1)用Statement来执行sql语句 Ny
G?^
String sql; 9YY*)5eyD
Statement sm = cn.createStatement(); =i>i,>bv
sm.executeQuery(sql); // 执行数据查询语句(select) `u$lSGl
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); Yz? 8n
2)用PreparedStatement来执行sql语句 zR5KC!xc
String sql; 3 uJ?;
sql = "insert into user (id,name) values (?,?)"; 6"/4@?
PreparedStatement ps = cn.prepareStatement(sql); ]}L tf,9
ps.setInt(1,xxx); Ao$|`Lgj=z
ps.setString(2,xxx); S@cKo&^
... (lt{$0
ResultSet rs = ps.executeQuery(); // 查询 |Q$9I#rv
int c = ps.executeUpdate(); // 更新 Wd?=RO`a
s^HI%mdf
3、处理执行结果 s=hao4v7z
查询语句,返回记录集ResultSet qqSFy>`P
更新语句,返回数字,表示该更新影响的记录数 OPC8fX5.
ResultSet的方法 KN".0WU
1、next(),将游标往后移动一行,如果成功返回true;否则返回false Bb.U4#
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值
liPaT
+^ `n- m
4、释放连接 <ToRPx&E
cn.close(); ;&$f~P Q
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 3`Gb;D
gbziEjRe
可滚动、更新的记录集 > *soc!# Y
1、创建可滚动、更新的Statement jbp?6GW
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); $y,tR.5.)[
该Statement取得的ResultSet就是可滚动的 Zw_'u=r
>
2、创建PreparedStatement时指定参数 \nU_UH
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ?<1~KLPMhY
ResultSet.absolute(9000);
Ww=b{lUD
批量更新 <jG[
z69)
1、Statement [" sm7yQ
Statement sm = cn.createStatement(); CvRO'
sm.addBatch(sql1); q``:[Sz
sm.addBatch(sql2); [wn!
<#~v
... hkx (r5o
sm.executeBatch() ._TN;tR~'
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 L u1pxL
2、PreparedStatement F~?|d0
PreparedStatement ps = cn.preparedStatement(sql); 5=/j
{ Fil6;R
ps.setXXX(1,xxx); nhRpb9f`1@
... U&0 RQ:B
ps.addBatch(); *vOk21z77d
} Fhga^.5U&
ps.executeBatch(); czT]XF
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 i JS7g
^xQPj6P}
事务的处理 3<_=Vyf
1、关闭Connection的自动提交 ^u> fW["[
cn.setAutoCommit(false); F$jfPy-f
2、执行一系列sql语句 AA0\C_W0p
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close z@v2t>@3k
Statement sm ; VM<$!Aaz
sm = cn.createStatement(insert into user...); qO[_8's8
sm.executeUpdate(); vGwpDu\RgX
sm.close(); + P<#6<gR
sm = cn.createStatement("insert into corp...); 8~AL+*hn
sm.executeUpdate(); !
=*k+gpF
sm.close(); t]E@AJOK
3、提交 009Q#[A
cn.commit(); 3EH7HW
4、如果发生异常,那么回滚 2yV^'o)
cn.rollback();