java 数据库基本操作 wHEt;rc(
1、java数据库操作基本流程 ;SagN
2、几个常用的重要技巧: MOJKz!%
可滚动、更新的记录集 ?WKFDL'_0j
批量更新 OtBVfA:[
事务处理 [K9l>O
J)"2^?!&B
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ;vy" i
1、取得数据库连接 7:)=
1)用DriverManager取数据库连接 OT+=H)/
例子 &&nvv &a
String className,url,uid,pwd; [h
{zT)[
className = "oracle.jdbc.driver.OracleDriver"; l#Ipo5=
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; RplLU7
uid = "system"; }i ^]uW*h
pwd = "manager"; ;%0$3a
Class.forName(className); 1~zzQ:jAZ
Connection cn = DriverManager.getConnection(url,uid,pwd); 6k|o<`~,
2)用jndi(java的命名和目录服务)方式 wa\Yc,R
例子 <v>^#/.0
String jndi = "jdbc/db"; +vIpt{733
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); |A0BYzlVc
DataSource ds = (DataSource) ctx.lookup(jndi); FAX|.!US*p
Connection cn = ds.getConnection(); G3
rTzMO
多用于jsp中 #^|y0:
2、执行sql语句 P<ElH3J`
1)用Statement来执行sql语句 k Pi%RvuQ
String sql; jhgS@g=@ZC
Statement sm = cn.createStatement(); A<fKO <d
sm.executeQuery(sql); // 执行数据查询语句(select) ikX"f?Q;S2
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); DvB!-|ek
2)用PreparedStatement来执行sql语句 _~/F-
String sql; (~q.YJ'
sql = "insert into user (id,name) values (?,?)"; ,R#pQ
4
PreparedStatement ps = cn.prepareStatement(sql); Yd'Fhvo8
ps.setInt(1,xxx); ~_8Dv<"a
ps.setString(2,xxx); ' ^E7T'v%
... [
R
ResultSet rs = ps.executeQuery(); // 查询 3`.*~qW
int c = ps.executeUpdate(); // 更新 c!*yxzs\
<:/Lap#D^
3、处理执行结果 = >CADTU
查询语句,返回记录集ResultSet BbsgZ4
更新语句,返回数字,表示该更新影响的记录数 Zgy~Y0Di
ResultSet的方法 v3O+ ;4
1、next(),将游标往后移动一行,如果成功返回true;否则返回false IJa6W`}
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 u_H=Xm)9
Pt5"q3ec{T
4、释放连接 )l?1dR:sP
cn.close(); 6Cw+
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection x3DUz
E+z),"QA
可滚动、更新的记录集 /JsA[}.6
1、创建可滚动、更新的Statement bpP-wA^Hd
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); I\e/
Bv^
该Statement取得的ResultSet就是可滚动的 cD.afy
2、创建PreparedStatement时指定参数 Z5/*iun
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ,5V w^@F
ResultSet.absolute(9000); )R6h
1
批量更新 5"sd
1、Statement K g6hySb
Statement sm = cn.createStatement(); izDfpr}s4
sm.addBatch(sql1); &u`EYxT
sm.addBatch(sql2); YCl&}/.pA
... '4KN
sm.executeBatch()
5ENU}0W
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 e"#QUc(
2、PreparedStatement [KQ#b
PreparedStatement ps = cn.preparedStatement(sql); W Og pDs
{ Y`N w E
ps.setXXX(1,xxx); knn9s0'Q
... 'VpzB
s#
ps.addBatch(); zMke}2
} k"3@G?JY
ps.executeBatch(); B>}B{qi|
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 *iX PG9XZ
9dVHh?E
事务的处理 o 9rZ&Q<
1、关闭Connection的自动提交 %W}YtDf\
cn.setAutoCommit(false); &=*sN`
2、执行一系列sql语句 T)MX]T
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close )O],$\u
Statement sm ; A$g'/QM
sm = cn.createStatement(insert into user...); IayF<y,8
sm.executeUpdate(); Wr3z%1
sm.close(); |.z4 VJi4
sm = cn.createStatement("insert into corp...); a[V X)w_W{
sm.executeUpdate(); (`&SV$m
sm.close(); 0"}=A,o(w
3、提交 /HH_Zi0?N|
cn.commit(); QE|x[?7e,!
4、如果发生异常,那么回滚 8e5imei
cn.rollback();