java 数据库基本操作 =(2y$,6g?
1、java数据库操作基本流程 H=RzY-\a%
2、几个常用的重要技巧: X'Q?Mh
可滚动、更新的记录集 ]Wr2I M
批量更新 <`rmQ`(}s
事务处理 %A64AJZ
P{fT5K|
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ~"|MwR!0
1、取得数据库连接 q!iTDg*$
1)用DriverManager取数据库连接 js;p7wi
例子 o@:${>jw
String className,url,uid,pwd; Heh.CD)Q
className = "oracle.jdbc.driver.OracleDriver"; @6h,#8#
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; nsn
uid = "system"; gR1vUad7
pwd = "manager"; 8?LsV<
Class.forName(className); >M~1{
Connection cn = DriverManager.getConnection(url,uid,pwd); )Q= EmZbJz
2)用jndi(java的命名和目录服务)方式 diHK
例子 9^;Cz>6s
String jndi = "jdbc/db"; G5*"P!@6
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 2^ uP[
DataSource ds = (DataSource) ctx.lookup(jndi); jV{?.0/h|
Connection cn = ds.getConnection(); |?v(?
多用于jsp中 E+z),"QA
2、执行sql语句 + OKk~GYf
1)用Statement来执行sql语句 k;/K']4y
String sql; TWE>"8]
Statement sm = cn.createStatement(); J;HYGu:
sm.executeQuery(sql); // 执行数据查询语句(select) I\e/
Bv^
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); =r|e]4
2)用PreparedStatement来执行sql语句 @7UZ{+67*C
String sql; !ZNirvk
sql = "insert into user (id,name) values (?,?)"; J([Y4Em5
PreparedStatement ps = cn.prepareStatement(sql); X1*f#3cm#
ps.setInt(1,xxx); :m.6a4vx
ps.setString(2,xxx); 7[=\bL
... =z>d GIT1
ResultSet rs = ps.executeQuery(); // 查询 +FomAs1*f
int c = ps.executeUpdate(); // 更新 )qSjI_qt5
]31>0yj[Q
3、处理执行结果 %#t*3[
查询语句,返回记录集ResultSet 9*~bAgkWI
更新语句,返回数字,表示该更新影响的记录数 I]GGmN
ResultSet的方法 ^^,cnDlm
1、next(),将游标往后移动一行,如果成功返回true;否则返回false u00w'=pe)
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 5 EhOvt8
3JYhF)G
4、释放连接 :1asY:)vNP
cn.close(); VAW:h5j2@
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection r&%TKm^/
M(
w'TE@
可滚动、更新的记录集 O06 2c)vIY
1、创建可滚动、更新的Statement /U$5'BoS
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Nk63F&J7e
该Statement取得的ResultSet就是可滚动的 *^y,Gg/
2、创建PreparedStatement时指定参数 `D/<*e,#
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); W&~\@j]!D
ResultSet.absolute(9000); =[JstiT?E
批量更新 ycq+C8J+Ep
1、Statement n(uzqd
Statement sm = cn.createStatement(); b~$8<\
sm.addBatch(sql1); [>$?/DM
sm.addBatch(sql2); 35Ro85j
... N\l|3~
sm.executeBatch() \LG0
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 IA%|OVAfF
2、PreparedStatement :o3>
PreparedStatement ps = cn.preparedStatement(sql); P2Jo^WS
{ RGgePeaw
ps.setXXX(1,xxx); 8Z|A'M
... ^F)t>K$0m
ps.addBatch(); Mz7qC3Z
} ^[x6p}$
ps.executeBatch(); Ab
#}BHI
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 v6U Gr4
g^l~AR
事务的处理 E3hXs6P
1、关闭Connection的自动提交 o75l&`
cn.setAutoCommit(false); _V`F_C\\#
2、执行一系列sql语句 HPMj+xH
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close *iX PG9XZ
Statement sm ; 4A0v>G`E*#
sm = cn.createStatement(insert into user...); >sjvE4s
sm.executeUpdate(); j>8S,b=%
sm.close(); sU(<L0
sm = cn.createStatement("insert into corp...); a B$x(8pP@
sm.executeUpdate(); DD5cUlOSu
sm.close(); LpK? C<?x
3、提交 >P+oNY
cn.commit(); %i6/=
'u
4、如果发生异常,那么回滚 uc{s\_
cn.rollback();