java 数据库基本操作 OMjPC_
1、java数据库操作基本流程 &${| o@
2、几个常用的重要技巧: R|qNyNXo[
可滚动、更新的记录集 z@19gD#8
批量更新 4|\M`T
事务处理 u|$HA>F[
A~E S{Zkh
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 8irTGA
1、取得数据库连接 f&5S`}C
1)用DriverManager取数据库连接 I'{Ctc
例子 (HeSL),1
String className,url,uid,pwd; Pr%KcR ;
className = "oracle.jdbc.driver.OracleDriver"; E,?IIRg&
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; zpf<!x^
uid = "system"; Wy6a4oY
pwd = "manager"; 4`oKvL9
Class.forName(className); =(TMcu$4`
Connection cn = DriverManager.getConnection(url,uid,pwd); ckP AH E@
2)用jndi(java的命名和目录服务)方式 @Q ~;@M
例子 yG~Vvpv
String jndi = "jdbc/db"; X[<#B5
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); J#@+1 Nt
DataSource ds = (DataSource) ctx.lookup(jndi); e&ZTRgYdi
Connection cn = ds.getConnection(); a[zVC)N0
多用于jsp中 525^/d6v
2、执行sql语句 N|)e {|k
1)用Statement来执行sql语句 N&k\X]U
String sql; ea$. +
Statement sm = cn.createStatement(); ZWuNl!l>
sm.executeQuery(sql); // 执行数据查询语句(select) B!)9
>
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); Snmv
2)用PreparedStatement来执行sql语句 mhU=^/X
String sql; xp3^,x;\X
sql = "insert into user (id,name) values (?,?)"; yNwSiZE X
PreparedStatement ps = cn.prepareStatement(sql); Xs$a^zZ
ps.setInt(1,xxx); 5'{QMnfB
ps.setString(2,xxx); ^e]O
>CJ
... #>~A-k)
ResultSet rs = ps.executeQuery(); // 查询 Q8l vwip
int c = ps.executeUpdate(); // 更新 gxI/MD~!>
c(8>oeKyD
3、处理执行结果 t Jtp1$h
查询语句,返回记录集ResultSet &l-d_dh
更新语句,返回数字,表示该更新影响的记录数 HtE^7i*_
ResultSet的方法 ^a3 (QKS
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ]-X\n
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 5\JV }
y[cc<wm$
4、释放连接 "k"+qR`fH
cn.close(); /s(PFN8#Y
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection n2c(x\DA&
Ha ZV7
可滚动、更新的记录集 Eoo[H2=^H
1、创建可滚动、更新的Statement 1v3
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ?0z/i^I
该Statement取得的ResultSet就是可滚动的 M,{; xf
2、创建PreparedStatement时指定参数 0$yHO2 f
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); Ae^4
ResultSet.absolute(9000); =7: }/&
批量更新 hlc g[Qdo*
1、Statement %Y|AXxR
Statement sm = cn.createStatement(); NX;{L#lQ
sm.addBatch(sql1); BjjuZN&
sm.addBatch(sql2); SZ4@GK
... ,@N.v?p>
sm.executeBatch() 7:$dl#
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 $'#}f?
2、PreparedStatement :=q9ay
PreparedStatement ps = cn.preparedStatement(sql); @\-*aS_8>
{ MScUrW!TA
ps.setXXX(1,xxx); v33[Rk'
... Fo
,8"m
ps.addBatch(); _ qQ
} m^/>C-&C
ps.executeBatch(); *z~J ]
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 4 #lLC-k
y^{4}^u-^
事务的处理 \j
we
1、关闭Connection的自动提交 5(Q-||J
cn.setAutoCommit(false); @JP6F[d
2、执行一系列sql语句 #=m:>Q?%z
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close %A&g-4(
Statement sm ; <x$fD37
sm = cn.createStatement(insert into user...); C<^S$
sm.executeUpdate(); b3GTsX\2|
sm.close(); &s\,+d0
sm = cn.createStatement("insert into corp...); ^b.fci{1m
sm.executeUpdate(); <X97W\
sm.close(); +@@( C9
3、提交 5':j=KQE_
cn.commit(); h=NXU9n%'
4、如果发生异常,那么回滚 4dSAGLpp
cn.rollback();