java 数据库基本操作 lm6hFvEZ
1、java数据库操作基本流程 ~nTj't2R
2、几个常用的重要技巧: ~o>Gm>5!HH
可滚动、更新的记录集 Zwm/ c]6`
批量更新 W#%s0EN<_
事务处理 f1]zsn:
lxm/*^
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 R8cOb*D
1、取得数据库连接 D<m0G]Ht*
1)用DriverManager取数据库连接 X@"G1j >/
例子 J\Hv42
String className,url,uid,pwd; *i}X(sfe
className = "oracle.jdbc.driver.OracleDriver"; .L+XV y
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; wk ^7/B
uid = "system"; >{N}UNZ$}
pwd = "manager"; c:.~%AJx
Class.forName(className); ^nK<t?KS
Connection cn = DriverManager.getConnection(url,uid,pwd); fd4C8>*7G
2)用jndi(java的命名和目录服务)方式 #1/~eIEY
例子 F#>00b{Q
String jndi = "jdbc/db"; gfs ;?vP
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); zGFD71=#
DataSource ds = (DataSource) ctx.lookup(jndi); i84!x%|P
Connection cn = ds.getConnection(); <:V~_j6P0
多用于jsp中 tEL9hZzI
2、执行sql语句 l2LLM {B
1)用Statement来执行sql语句 1_<x%>zG
String sql; 59O-"Sc[
Statement sm = cn.createStatement(); o//h|f U@
sm.executeQuery(sql); // 执行数据查询语句(select) %uN<^`JZ
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ]q.%_
2)用PreparedStatement来执行sql语句 -?-XO<I
String sql; Z(7kwhP[`
sql = "insert into user (id,name) values (?,?)"; g_1#if&
PreparedStatement ps = cn.prepareStatement(sql); fO$){(]^
ps.setInt(1,xxx); ICb!AsL
ps.setString(2,xxx); v,S5C
... 4WJY+)
ResultSet rs = ps.executeQuery(); // 查询 ov,|`FdU^T
int c = ps.executeUpdate(); // 更新 8ix_<$%
|)+
SG>-
3、处理执行结果 t|$jgM
查询语句,返回记录集ResultSet $8)XN-%(
更新语句,返回数字,表示该更新影响的记录数 P&uSh?[ ^
ResultSet的方法 )-26(aNGT
1、next(),将游标往后移动一行,如果成功返回true;否则返回false Rh ^(91d
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 H.m]Dm,z
!JDr58
4、释放连接 ;U|(rM;
cn.close(); {2h*NFp
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection a(|6)w-
@^<odmM
可滚动、更新的记录集 -B H/)$-$
1、创建可滚动、更新的Statement *3H=t$1G}
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); _Xt/U>N
该Statement取得的ResultSet就是可滚动的 16zRe I(
2、创建PreparedStatement时指定参数 V9,<>
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); st;iGg
ResultSet.absolute(9000); b2OwLt9
批量更新 b)<WC$"
1、Statement SHX`/
Statement sm = cn.createStatement(); ~= *o
sm.addBatch(sql1); 3uocAmY
sm.addBatch(sql2); z.Ic?Wz7
... bGCC?}\
sm.executeBatch() ==OUd6e}
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 /)6T>/
2、PreparedStatement &t[[4+Qt
PreparedStatement ps = cn.preparedStatement(sql); `9co7[Z
{ WM'!|lg
ps.setXXX(1,xxx); d ItfR'$
... orFwy!
ps.addBatch(); &KjMw:l
} #NW+t|E
ps.executeBatch(); Jt=->
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 `qc"JB
~t)cbF(UO
事务的处理 ]>1Mq,!
1、关闭Connection的自动提交 +6#$6 hG
cn.setAutoCommit(false); )&@YRT\c?8
2、执行一系列sql语句 rx2)uUbR
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close y:RW:D&
Statement sm ; F
qH))2
sm = cn.createStatement(insert into user...); ENuL!H>;*
sm.executeUpdate(); C2}y#A I
sm.close(); v>]g="5}8
sm = cn.createStatement("insert into corp...); @G"nkB
sm.executeUpdate(); QN#"c
sm.close(); bzFac5n)Q
3、提交 _y~6b{T
cn.commit(); L5bq\
4、如果发生异常,那么回滚 SBreA-2
cn.rollback();