java 数据库基本操作 d:ajD
1、java数据库操作基本流程 P =Gb
2、几个常用的重要技巧: ]nGA1 S{
可滚动、更新的记录集 2]KPW*V
批量更新 J*k=|+[
事务处理 LA3,e (e
IWd*"\L
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ?n~j2-[<
1、取得数据库连接 lJ2/xE ]
1)用DriverManager取数据库连接 atnbM:t
例子 :H k4i%hGk
String className,url,uid,pwd; 66;O 3g'
className = "oracle.jdbc.driver.OracleDriver"; 4&WzGnK
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; En%o7^W++
uid = "system"; X0L{#U
pwd = "manager";
$VNn`0^gF
Class.forName(className); 2o}FB\4^i
Connection cn = DriverManager.getConnection(url,uid,pwd); X~b+LG/
2)用jndi(java的命名和目录服务)方式 ;hp; Rd
例子 p{GDW_
String jndi = "jdbc/db"; .;Yei6H
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); iIRigW
DataSource ds = (DataSource) ctx.lookup(jndi); #J9XcD{1
Connection cn = ds.getConnection(); Jx7^|A
多用于jsp中 T!$HVHh&,}
2、执行sql语句 LZ$!=vg4
1)用Statement来执行sql语句 Qk?Jy<Ra
String sql; =v;@w$#
Statement sm = cn.createStatement(); 9&jNdB
sm.executeQuery(sql); // 执行数据查询语句(select) Z k_&Kw|
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 1 .CYs<
2)用PreparedStatement来执行sql语句 CKx}.<_
String sql; 6d6SP)|j
sql = "insert into user (id,name) values (?,?)"; zh#uwT1u
PreparedStatement ps = cn.prepareStatement(sql); )]Rr:i9n
ps.setInt(1,xxx); *GnO&&m'B
ps.setString(2,xxx); &KwtvUN{
... XS@6jbLE
ResultSet rs = ps.executeQuery(); // 查询 A}O9e
int c = ps.executeUpdate(); // 更新 +[qy HTcG
#{PNdINoU
3、处理执行结果 cFo-NI2
查询语句,返回记录集ResultSet Nzt1JHRS
更新语句,返回数字,表示该更新影响的记录数 SesO$=y
ResultSet的方法 Ml
^Tb#
1、next(),将游标往后移动一行,如果成功返回true;否则返回false w Nnb@
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 s)=7tHoqB)
6jA Q
4、释放连接 4Yk(ldR~
cn.close(); OC.@C}u
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 1NJ|%+I
' JVvL
可滚动、更新的记录集 3Q;l*xu
1、创建可滚动、更新的Statement Er`PYE
J
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); gE#,QOy
该Statement取得的ResultSet就是可滚动的 =0|evC
2、创建PreparedStatement时指定参数 nIT=/{oyi
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); *O2j<3CHf
ResultSet.absolute(9000); uLht;-`{n
批量更新 r6<}S(
1、Statement $tJJ
>"
Statement sm = cn.createStatement(); %hh8\5l.:
sm.addBatch(sql1); ~CscctD{;
sm.addBatch(sql2); ?U[AE -*
... w0SgF/"@
sm.executeBatch() z9ZAY!Zhq]
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ;E_{Zji_e
2、PreparedStatement -0Ek&"=Z^
PreparedStatement ps = cn.preparedStatement(sql); 6cvm\opH
{ 9 R1]2U$|
ps.setXXX(1,xxx); ^~$
o-IX
... .Dz /MSl
ps.addBatch(); 8X5XwFf}
} #(G&%I A|;
ps.executeBatch(); ml2HA4X&$Y
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 8V=o%[t
D\JYa@*?.h
事务的处理 ~1oD7=WN
1、关闭Connection的自动提交 C_/oORvK
cn.setAutoCommit(false); a6OT2B
2、执行一系列sql语句 g*uO
IF
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 1d6pQ9 N
Statement sm ; |ouk;r24V
sm = cn.createStatement(insert into user...); Uw!v=n3#!
sm.executeUpdate(); WF7RMQ51j
sm.close(); 8jk*N
sm = cn.createStatement("insert into corp...); J\BdC];
sm.executeUpdate(); =W=%!A\g
sm.close(); _!ed.h.r:
3、提交 ;K!Or
cn.commit(); Z:{Z&HQC
4、如果发生异常,那么回滚 ;f?bb*1
cn.rollback();