java 数据库基本操作 j#,M@CE
1、java数据库操作基本流程 d;SRK @
2、几个常用的重要技巧: 6wB>-/'Y
可滚动、更新的记录集 0NtsFPO
批量更新 ]&U| d
事务处理 Noxz kpMF
&t/<yq}{
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 9yo[T(8
1、取得数据库连接 %`QsX {?,
1)用DriverManager取数据库连接 ;lH,bX~5
例子 ,R}KcZG)
String className,url,uid,pwd; "IG$VjgcB
className = "oracle.jdbc.driver.OracleDriver"; wmE,k1G
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; R0mT/h2
uid = "system"; &H1D!N
pwd = "manager"; ' 1'1T5x~
Class.forName(className); 9!HMQ
Connection cn = DriverManager.getConnection(url,uid,pwd); .eNwC .8i
2)用jndi(java的命名和目录服务)方式 s66XdM
例子 ~cBc&u:"
String jndi = "jdbc/db"; Z034wn\N
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ]8>UII ,US
DataSource ds = (DataSource) ctx.lookup(jndi); 'uACoME@
Connection cn = ds.getConnection(); hav?mnVJ
多用于jsp中 N#['fg'
2、执行sql语句 ~_db<!a
1)用Statement来执行sql语句 P .4b+9Tx
String sql; L*01l"5
Statement sm = cn.createStatement(); wT~;tOw~
sm.executeQuery(sql); // 执行数据查询语句(select) jfPJ5]Z
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); bNjaCK<
2)用PreparedStatement来执行sql语句 fC GDL6E
String sql; J5p!-N`NS
sql = "insert into user (id,name) values (?,?)"; ,35:Srf|
PreparedStatement ps = cn.prepareStatement(sql); mUyv+n,
ps.setInt(1,xxx); $v<hW
A]>
ps.setString(2,xxx); }t
D!xI;
... 8N*
-2/P&
ResultSet rs = ps.executeQuery(); // 查询 06 Esc^D
int c = ps.executeUpdate(); // 更新 &tz%WW%D8
gVA}?t;
3、处理执行结果 tD7C7m
查询语句,返回记录集ResultSet ws2j:B
更新语句,返回数字,表示该更新影响的记录数 ENXW#{N.v
ResultSet的方法 6a]f&={E
1、next(),将游标往后移动一行,如果成功返回true;否则返回false cw]>a&d
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 K'5sn|)
#X@<U <R
4、释放连接 v#%>uLl
cn.close(); {9.~]dI|L
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection <fsn2[V:B%
iC|6roO!jk
可滚动、更新的记录集 QjjJtKz
1、创建可滚动、更新的Statement Na 9l#
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); $
lsRg:J
该Statement取得的ResultSet就是可滚动的 Hv gK_'
2、创建PreparedStatement时指定参数 zHoO?tGf
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); {iIg 4PzrU
ResultSet.absolute(9000); #D LT-G0
批量更新 h[je _^5
1、Statement g1 Wtu*K3
Statement sm = cn.createStatement(); yp2 'KES>
sm.addBatch(sql1); TQ\wHJ
sm.addBatch(sql2); y)^CDe2xU
... 4R*<WdT(
sm.executeBatch() m wEVEx24
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 BRU9LS
2、PreparedStatement z@l!\m-
PreparedStatement ps = cn.preparedStatement(sql); C+(Gg^ w
{ Z>Kcz^a#
ps.setXXX(1,xxx); \LoSUl
i
... <W=[
sWJ
ps.addBatch(); QV'3O|
} a[P>SqT4`
ps.executeBatch(); _2gT1B
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 jU4)zN/`r
G9'YgW+$7
事务的处理 +ersP@G
1、关闭Connection的自动提交 ksOANLRN
cn.setAutoCommit(false); w] 5U
2、执行一系列sql语句 fv j5[Q
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close =O3I[
Statement sm ; MY?O/,6
sm = cn.createStatement(insert into user...); i5E:FS^!I
sm.executeUpdate(); }Cmj (k`~
sm.close(); |+;K hC
sm = cn.createStatement("insert into corp...); 0(U3~k6
sm.executeUpdate(); V>>) 7E:Q
sm.close(); Ca5Sc, no
3、提交 kJ#[UCqzM
cn.commit(); WrHgF*[
4、如果发生异常,那么回滚 [Z5}2gB&
cn.rollback();