java 数据库基本操作 eQ8t.~5;-
1、java数据库操作基本流程 wik<#ke
2、几个常用的重要技巧: oS9Od8
可滚动、更新的记录集 hf2bM
`d
批量更新 Avi_]h&
事务处理 c6c@XdV
R0tT4V+
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 .f-=gZ* *
1、取得数据库连接 #Mk:4
1)用DriverManager取数据库连接 2=8PA/
例子 Q25VG5G
String className,url,uid,pwd; u)o-H!a
className = "oracle.jdbc.driver.OracleDriver"; QQV8Vlv"
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; =MJB:
uid = "system"; ~XuV:K3
pwd = "manager"; YCxwIzIR
Class.forName(className); V|sV U
Connection cn = DriverManager.getConnection(url,uid,pwd); Q{950$)L
2)用jndi(java的命名和目录服务)方式 gSw<C+
例子 L;j++^p
String jndi = "jdbc/db"; KT<$E!@
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); C5TV}Bq\
DataSource ds = (DataSource) ctx.lookup(jndi); '&Y_,-i
Connection cn = ds.getConnection(); Fc \]*
多用于jsp中 FE,mUpHIR
2、执行sql语句 ?jlz:Z4
1)用Statement来执行sql语句 OM\1TD/-
String sql; S-gO
Statement sm = cn.createStatement(); {dpDQP +!
sm.executeQuery(sql); // 执行数据查询语句(select) sHk>ek]2I
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); P3|s}&
2)用PreparedStatement来执行sql语句 h
ka_Fo
String sql; a <?~1pWtc
sql = "insert into user (id,name) values (?,?)"; vFntzN>#
PreparedStatement ps = cn.prepareStatement(sql); a oU"
ps.setInt(1,xxx); W~D_+[P|_
ps.setString(2,xxx); u|Mx}
... u4SL:IH{D
ResultSet rs = ps.executeQuery(); // 查询 AzXLlQ
int c = ps.executeUpdate(); // 更新 YJ"D"QD
JVy|SA&R
3、处理执行结果 0<~~0US
查询语句,返回记录集ResultSet ?-mOAHW0q
更新语句,返回数字,表示该更新影响的记录数 \DZ.#=d
ResultSet的方法 MSvZ3[5Io
1、next(),将游标往后移动一行,如果成功返回true;否则返回false s*yl&El/
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 +#BOWz
^ `Ozw^~
4、释放连接 t&{;6MiE
cn.close(); \-;f<%+
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection GVnDN~[
3lpxh_
可滚动、更新的记录集 0`c{9gY.
1、创建可滚动、更新的Statement x@rQ7K>
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ,
%z HykP
该Statement取得的ResultSet就是可滚动的 sV%DX5@
2、创建PreparedStatement时指定参数 -#;xfJE
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); Z*mbhod
ResultSet.absolute(9000);
&Q?@VNi
批量更新 |R@T`dW
1、Statement UiH7
Statement sm = cn.createStatement(); @g5y_G{SP
sm.addBatch(sql1); ]&Y^
sm.addBatch(sql2); 5{V"!M+<
... ;j1E 6
sm.executeBatch() `<se&IZE
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 KU` *LB:
2、PreparedStatement T&]-p:mg^
PreparedStatement ps = cn.preparedStatement(sql); |JYb4J4Ni
{ LiT%d
ps.setXXX(1,xxx); A2M(
ad
... =#W:z.w
ps.addBatch(); ySO\9#Ho
} f2IH2^)P
ps.executeBatch(); #vV]nI<MF.
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 _(h=@cv
A[;deHg=
事务的处理 MYy58N
1、关闭Connection的自动提交 4mo/MK&M:
cn.setAutoCommit(false); PZ8,E{V
2、执行一系列sql语句 LPt9+sauf1
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close oHx:["F
Statement sm ; bGeIb-|(
sm = cn.createStatement(insert into user...); <L qJg
sm.executeUpdate(); BK%B[f*[OA
sm.close(); Dbn344s
sm = cn.createStatement("insert into corp...); #'s$6gT=
sm.executeUpdate(); kpn|C 9r
sm.close(); 9Tt%~m^
3、提交 pK3A/ry<
cn.commit(); @y;VV*
4、如果发生异常,那么回滚 .@OQ$D <
cn.rollback();