java 数据库基本操作 4
[R8(U[g
1、java数据库操作基本流程 %sO Wg.0_
2、几个常用的重要技巧: :X'*8,]KHH
可滚动、更新的记录集 z+3<$Z
批量更新 LJRg>8
事务处理 ZNzR`6}
_'!aj+{
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 1s{ISWm
1、取得数据库连接 u @{E{
1)用DriverManager取数据库连接 pY+.SuM
例子 7ei>L]gm%
String className,url,uid,pwd; L.C
^E7;Z_
className = "oracle.jdbc.driver.OracleDriver"; zY7*[!c2
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; (v|r'B9b
uid = "system"; BA~a?"HS
pwd = "manager"; T"L0Iy!k;
Class.forName(className); CCbkxHMf|!
Connection cn = DriverManager.getConnection(url,uid,pwd); .dD9&n;#^
2)用jndi(java的命名和目录服务)方式 B<|:K\MA
例子 g\ErJ+i
String jndi = "jdbc/db"; XIr{U5$<6
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 2Pbe~[
DataSource ds = (DataSource) ctx.lookup(jndi); xN#bzma
Connection cn = ds.getConnection(); vOos*&
多用于jsp中 RL?u n}Qa
2、执行sql语句 G{@C"H[$<
1)用Statement来执行sql语句 :7 qqjs
String sql; Jt##rVN
Statement sm = cn.createStatement(); DJmoW
sm.executeQuery(sql); // 执行数据查询语句(select) ayV6m
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ;;ER"N
2)用PreparedStatement来执行sql语句 "KMLk
String sql; DRH'A!r!
sql = "insert into user (id,name) values (?,?)"; 7%{R#$F
PreparedStatement ps = cn.prepareStatement(sql); ^y:FjQC:
ps.setInt(1,xxx); T?W[Z_D
ps.setString(2,xxx); nqZA|-}
... W3 ^z Ij
ResultSet rs = ps.executeQuery(); // 查询 `d75@0:
int c = ps.executeUpdate(); // 更新 c5X`_
q:vz?G
3、处理执行结果 1*Sr5N[=
查询语句,返回记录集ResultSet .
_1jk
更新语句,返回数字,表示该更新影响的记录数 g d z
ResultSet的方法 aRbx
1、next(),将游标往后移动一行,如果成功返回true;否则返回false lkV6qIj
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ,VPbUo@
S3SV.C:z>
4、释放连接 'I&|1I^
cn.close(); ,`;jvY~Ec
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection ./#e1m?.
'dkXYtKCB
可滚动、更新的记录集 #2h+dk$1
1、创建可滚动、更新的Statement >R( 8/#|E
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); zoP%u,XL
该Statement取得的ResultSet就是可滚动的 Sdd9Dv?!
2、创建PreparedStatement时指定参数 !gH9 ay
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ~O;y?]U
ResultSet.absolute(9000); hazq#J!
批量更新 Pl+xH%U+?
1、Statement 6:?rlh
Statement sm = cn.createStatement(); )"`!AerJ
sm.addBatch(sql1); ~|lIC !q
sm.addBatch(sql2); kIvvEh<L=
... <\@1Zz@ms
sm.executeBatch() }B q^3?,#{
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 9`"DFFSMS
2、PreparedStatement '{f=hE_/
PreparedStatement ps = cn.preparedStatement(sql); S#8>ZwQ
{ F9H~k"_ZJR
ps.setXXX(1,xxx); (][LQ6Pc
... d~*TIN8Ke~
ps.addBatch(); {8@\Ij
} N[Sb#w`[/
ps.executeBatch(); LdTdQ,s<
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 wAYB RY[
C+%K6/J(
事务的处理 lIf(6nm@
1、关闭Connection的自动提交 ^0tw%6:
cn.setAutoCommit(false); @Bs0Avj.
2、执行一系列sql语句 4h|dHXYZ
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close _+w/
pS`M
Statement sm ; %f&< wC
sm = cn.createStatement(insert into user...); fSA)G$b]
sm.executeUpdate(); nl1-kB)$e|
sm.close(); 61_f3S(u
sm = cn.createStatement("insert into corp...); Vq ^]s$'
sm.executeUpdate(); !gP0ndRJ=
sm.close(); Yck~xt&]
3、提交 q\$6F)ha3
cn.commit(); cxP6-tV%
4、如果发生异常,那么回滚 c
~Fdx
cn.rollback();