java 数据库基本操作 Br}h/!NU/
1、java数据库操作基本流程 9:5:`'b
2、几个常用的重要技巧: 6SVqRD<`
可滚动、更新的记录集
6xoq;=o
批量更新 'n0 .#E_
事务处理 d6`OXTD
3\AM=`
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 2jl)mL
1、取得数据库连接
bLqy!QE
1)用DriverManager取数据库连接
B$^7h!
例子 R[LsE^
String className,url,uid,pwd; )t:7_M3
className = "oracle.jdbc.driver.OracleDriver"; sc W'AJJq
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; _d@=nK)
uid = "system"; Bn?:w\%Ue
pwd = "manager"; YzAFC11,
Class.forName(className); Po(]rQbE
Connection cn = DriverManager.getConnection(url,uid,pwd); 9GgA 6#
2)用jndi(java的命名和目录服务)方式 q_ %cbAcD
例子 $+cAg>
String jndi = "jdbc/db"; lv]quloT
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); f6!D L<
DataSource ds = (DataSource) ctx.lookup(jndi); 6 {}JbRNf
Connection cn = ds.getConnection(); MxOD8TDF4
多用于jsp中 2| B[tt1Z
2、执行sql语句 >E:<E'L
1)用Statement来执行sql语句 eWvo,4
String sql; MAqLIf<G
Statement sm = cn.createStatement(); QV qK
sm.executeQuery(sql); // 执行数据查询语句(select) oE?QnH3R
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 3xNMPm
2)用PreparedStatement来执行sql语句 Q$ri=uB;+
String sql; >`'O7.R
sql = "insert into user (id,name) values (?,?)"; /RT%0!
PreparedStatement ps = cn.prepareStatement(sql); p_{("zQ
ps.setInt(1,xxx); O oSb>Y/4
ps.setString(2,xxx); B&Y_2)v
... 2 -Xdoxw
ResultSet rs = ps.executeQuery(); // 查询 wvMW|
int c = ps.executeUpdate(); // 更新 cu&,J#r%
]JE TeZ^/
3、处理执行结果 Z{R[Wx
查询语句,返回记录集ResultSet kS :\Oz\
更新语句,返回数字,表示该更新影响的记录数 JN'cXZJPn
ResultSet的方法 G^wtE90
1、next(),将游标往后移动一行,如果成功返回true;否则返回false @ {#mpDX
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 &<5+!cV=
pI;NL
[
4、释放连接 8i}<
k$S
cn.close(); GX&b;N
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection U47}QDh
vyI%3+N@
可滚动、更新的记录集 ,RxYd6
1、创建可滚动、更新的Statement pFsc}R/0/8
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ir16
该Statement取得的ResultSet就是可滚动的 }LP!)|E
2、创建PreparedStatement时指定参数 zf [`~g
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 8FkFM^\1L
ResultSet.absolute(9000); a%BeqSZh
批量更新 -n5
B)uw=
1、Statement }-@4vl
x$
Statement sm = cn.createStatement(); '
GG=Ebt
sm.addBatch(sql1); G{9X)|d
sm.addBatch(sql2); l4y{m#/
... pS[KBQ"F
sm.executeBatch() {/<6v. v
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 7=XL!:P
2、PreparedStatement %7hB&[ 5
PreparedStatement ps = cn.preparedStatement(sql); J*fBZ.NO
{ ILwn&[A0
ps.setXXX(1,xxx); otJ!UfpR8
... ($nrqAv4
ps.addBatch(); ~8T(>!hE1h
} ,8MLoZ_
ps.executeBatch(); BZv+H=b
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 v"^~&q0x
oU6y4yO
事务的处理 gEQNs\Jn
L
1、关闭Connection的自动提交 ]bi)$j.9s
cn.setAutoCommit(false); F^k.is
2、执行一系列sql语句 SP]IUdE\
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close p4K.NdUH
Statement sm ; o4b~4h{%
sm = cn.createStatement(insert into user...); ;z~n.0'
sm.executeUpdate(); >q~l21dUi
sm.close(); ,Gk}"w
sm = cn.createStatement("insert into corp...); mTNVU@TY=
sm.executeUpdate(); `Y=WMNy
sm.close(); *i{Y 9f8
3、提交 f.B>&%JRZ
cn.commit(); 6
sxffJt
4、如果发生异常,那么回滚 ^! 8P<y
cn.rollback();