java 数据库基本操作 I/jr`3Mj
1、java数据库操作基本流程 KCE-6T
2、几个常用的重要技巧: dAl<'~g
可滚动、更新的记录集 Zd ,=
批量更新 V bOLTc
事务处理 RfG$Px '
+hgCk87%#
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ,r;d {
1、取得数据库连接 ]H~,K ]@.
1)用DriverManager取数据库连接 /H@")je
例子 XH$|DeAFM
String className,url,uid,pwd; q&T'x> /
className = "oracle.jdbc.driver.OracleDriver"; f*}E\,V"&
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; Q0\5j<'e
uid = "system"; RJ4mlW
pwd = "manager"; /8\&f%E
Class.forName(className); +Uq:sfj,
Connection cn = DriverManager.getConnection(url,uid,pwd); 1C=P #MU`
2)用jndi(java的命名和目录服务)方式 /ASI0h
例子 P'9io!Z-s
String jndi = "jdbc/db"; 3G|fo4g
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); Y26l,XIV
DataSource ds = (DataSource) ctx.lookup(jndi); +lJ]-U|P
Connection cn = ds.getConnection(); 8T
)ELhTj
多用于jsp中 Eo&qc 17)`
2、执行sql语句 ,D,f9
1)用Statement来执行sql语句 \|`Pul$
String sql; `+c9m^
Statement sm = cn.createStatement(); #`0z=w/)
sm.executeQuery(sql); // 执行数据查询语句(select) Z8 %\v(L
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); TR_oI<xB2
2)用PreparedStatement来执行sql语句 ItE~MJ5p
String sql; .WyX/E$I^!
sql = "insert into user (id,name) values (?,?)"; =[os<+
PreparedStatement ps = cn.prepareStatement(sql); h\\2r>
ps.setInt(1,xxx); Q$/F gS
ps.setString(2,xxx); os^SD&hL
... M|e
n>P
ResultSet rs = ps.executeQuery(); // 查询 (Gc`3jJ
int c = ps.executeUpdate(); // 更新 l zPS
RT
<|Eby!KXR
3、处理执行结果 |S`yXsg
查询语句,返回记录集ResultSet 'xoE
[0!
更新语句,返回数字,表示该更新影响的记录数 <L/vNP
ResultSet的方法 sNmC#,
1、next(),将游标往后移动一行,如果成功返回true;否则返回false \'tz|
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 <JM%Kn )
^Jl!WH=20}
4、释放连接 T)f_W
cn.close(); Prz+kPP
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection :k(t/*Nl3
E/$@ud|l"
可滚动、更新的记录集 {<4?o?
1g
1、创建可滚动、更新的Statement 6@;L$QYY-V
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); _|wY[YJ[
该Statement取得的ResultSet就是可滚动的 x~Ly$A2p
2、创建PreparedStatement时指定参数 4eL54).1O
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 1"B9Z6jf
ResultSet.absolute(9000); @ZR4%A"X4
批量更新 8!Mzr1:
1、Statement ,xe@G)a
Statement sm = cn.createStatement(); %aE7id>v6
sm.addBatch(sql1); x][9ptrh
sm.addBatch(sql2); ^1yTL5#:Vw
... <&EO=A
sm.executeBatch() 3nC#$L-
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 #r^@*<{^
2、PreparedStatement pjs9b%.
PreparedStatement ps = cn.preparedStatement(sql); \If!5N
{ u+'@>%7
ps.setXXX(1,xxx); -L3
|9k
... pXj/6+^
ps.addBatch(); Q*&aC|b&
} ^'53]b:
ps.executeBatch(); xc<eU`-'b
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 G[<[#$(
Sb9=$0%\
事务的处理 f(s3TLM
1、关闭Connection的自动提交 K-k.=6mS
cn.setAutoCommit(false); ],}afa!A
2、执行一系列sql语句 wt=>{JM
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close E(3+o\w
Statement sm ; &G|jzXE
sm = cn.createStatement(insert into user...); YEPG[W<kg
sm.executeUpdate(); 5OW8G][
sm.close(); b|8>eY
sm = cn.createStatement("insert into corp...); ,#jhKnk2e
sm.executeUpdate(); ~muIi#4
sm.close(); &c?hJ8"
3、提交 vWi.[]
cn.commit(); Z0 IxYEp
4、如果发生异常,那么回滚 vV\F^
cn.rollback();