java 数据库基本操作 5~%,u2
1、java数据库操作基本流程 KW7?: x
2、几个常用的重要技巧: .A!0.M|
可滚动、更新的记录集 ?(ls<&s{w
批量更新 SP?U@w%}
事务处理 h k!,
dJ%Rk#?;A
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 +=~%S)9F
1、取得数据库连接 O][Nl^dl
1)用DriverManager取数据库连接 {+6D-rDw
例子 }wOpPN[4
String className,url,uid,pwd; -llx:
className = "oracle.jdbc.driver.OracleDriver"; d
O46~
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; 'tu@`7*
uid = "system"; YaNH.$.:
pwd = "manager"; zIm_7\e
Class.forName(className); 1S(\2{Ylo
Connection cn = DriverManager.getConnection(url,uid,pwd); d1TdH s\
2)用jndi(java的命名和目录服务)方式 Ph+X{|
例子 E_D ^O
String jndi = "jdbc/db"; :IR9=nhS]
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); KW|\)83$
DataSource ds = (DataSource) ctx.lookup(jndi); MYhx'[4[3
Connection cn = ds.getConnection(); +fd@K
多用于jsp中 8hK P
2、执行sql语句 Gkv~e?Kc~^
1)用Statement来执行sql语句 T4~`e_
String sql; E<<p_hX8R
Statement sm = cn.createStatement(); oO#xx)b
sm.executeQuery(sql); // 执行数据查询语句(select) C3\E.u?
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); K4k~r!&OU
2)用PreparedStatement来执行sql语句 z{@R.'BD
String sql; *K,hrpYR
sql = "insert into user (id,name) values (?,?)"; a%T -Z.rd
PreparedStatement ps = cn.prepareStatement(sql); {;&B^uz
]
ps.setInt(1,xxx); sCF40AoY&
ps.setString(2,xxx); ;;?vgrz
... .5Knb c
ResultSet rs = ps.executeQuery(); // 查询 AUxM)H
int c = ps.executeUpdate(); // 更新 HUJ|-)"dw
%0yS98']g
3、处理执行结果 Oz&+{ c
查询语句,返回记录集ResultSet (rr}Pv%yb
更新语句,返回数字,表示该更新影响的记录数 #`La|a.-
ResultSet的方法 .~q)eV
1、next(),将游标往后移动一行,如果成功返回true;否则返回false `k(u:yGK
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 bR`rT4.F
wy{ \/?~c
4、释放连接 }3f
BY@
cn.close(); -]Q(~'a
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection d/B'[Ur
#M5_em4kN
可滚动、更新的记录集 ?0rOcaTY
1、创建可滚动、更新的Statement 2yln7[a
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 'ySljo*It
该Statement取得的ResultSet就是可滚动的 l#D-q/k?
2、创建PreparedStatement时指定参数 }iilzE4oH#
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); v@8S5KJ
ResultSet.absolute(9000); >1x7UXs~:
批量更新 ch@x]@-;A3
1、Statement G HD^%)T5^
Statement sm = cn.createStatement(); |l|_dn
sm.addBatch(sql1); $ph0ag+
sm.addBatch(sql2); K8?zgRG3~N
... b'velj3A
sm.executeBatch() Y4mC_4EU
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 n6b3E*
2、PreparedStatement ~~PgF"v
PreparedStatement ps = cn.preparedStatement(sql); F:%^&%\
{ [tUv*jw %
ps.setXXX(1,xxx); ' _B_&is
... [2Iau1<@
ps.addBatch(); Zta$R,[9h
} JE0?@PI$
ps.executeBatch(); z|ves&lRa
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 Nd`HB=ShJ
_N98 vf0o
事务的处理 hwiKOP
1、关闭Connection的自动提交 6wPeb~{
cn.setAutoCommit(false); vXephR'
2、执行一系列sql语句 wGPotPdE2
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close q"S(7xWS
Statement sm ; MDk*j,5V
sm = cn.createStatement(insert into user...); +p3 Z#KoC
sm.executeUpdate(); |K%}}g[<e;
sm.close(); sf`PV}a1
sm = cn.createStatement("insert into corp...); a\=-D:
sm.executeUpdate(); d7* CwY9"
sm.close(); ! ,@ZQS
3、提交 G*B$%?n
cn.commit(); AM'gnP>
4、如果发生异常,那么回滚 jo)6
%w]
cn.rollback();