java 数据库基本操作 f9?f!k
1、java数据库操作基本流程 ?0'db
2、几个常用的重要技巧: ,<]~/5-f
可滚动、更新的记录集 =~'{2gsB
批量更新 o=I.i>c
事务处理 q#P@,|nc:
[Qn$i/`J
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 Bx ru7E"
1、取得数据库连接 &>3AL,
1)用DriverManager取数据库连接 Og9:MFI
例子 vptBDfzz
String className,url,uid,pwd; _"S1>s)X?j
className = "oracle.jdbc.driver.OracleDriver"; fO 6Jug
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; [D<"qT^*z6
uid = "system"; '\/|K
pwd = "manager"; Ag0)> PD^
Class.forName(className); &Q[|FO;[
Connection cn = DriverManager.getConnection(url,uid,pwd); :o}LJc)|
2)用jndi(java的命名和目录服务)方式 I+']av8e
例子 tZ_D.syBAc
String jndi = "jdbc/db"; B1(T-pr
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); xcE<|0N
:
DataSource ds = (DataSource) ctx.lookup(jndi); LAU\.d
Connection cn = ds.getConnection(); ,2Q5'!o
多用于jsp中 "4/J4'-
2、执行sql语句 ,O1/|Y
1)用Statement来执行sql语句 b'
fcWp0
String sql; 2#xz,RM.
Statement sm = cn.createStatement(); xA]}/*
sm.executeQuery(sql); // 执行数据查询语句(select) O
<"\G!y~
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); N:&EFfg3
2)用PreparedStatement来执行sql语句 {9<c*0l
String sql; +L|-W9"@3
sql = "insert into user (id,name) values (?,?)"; %p8#pt\$7
PreparedStatement ps = cn.prepareStatement(sql); w)xfP^M#
ps.setInt(1,xxx); i
3i
ps.setString(2,xxx); {6gY6X-R
... Ql{:H5
ResultSet rs = ps.executeQuery(); // 查询 h0;R*c
int c = ps.executeUpdate(); // 更新 Hm
17El68
0{!+N6MiR
3、处理执行结果 uxsi+vkI
查询语句,返回记录集ResultSet L_Lhmtm}m
更新语句,返回数字,表示该更新影响的记录数 @agxu-Y
ResultSet的方法 KU*XRZu)
1、next(),将游标往后移动一行,如果成功返回true;否则返回false Q;y)6+VU4
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 3u~V&jl
%v,a3^Qu
4、释放连接 $`6Q\=*R/
cn.close(); cOvdC4
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection s1%th"e
[
O("13cU
可滚动、更新的记录集 8>a%L?BY
1、创建可滚动、更新的Statement {P!1VYs5
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 4O:y
?D/e
该Statement取得的ResultSet就是可滚动的 F8d:7`lO@/
2、创建PreparedStatement时指定参数 (KnU-E]L
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); _tR?WmNH=
ResultSet.absolute(9000); *`~]XM@H
批量更新 pMLTXqL
1、Statement .1A/hAdU
Statement sm = cn.createStatement(); QpiA~4
sm.addBatch(sql1); Oe"nNvu/
sm.addBatch(sql2); (svKq(X
... .r\|9 *j<
sm.executeBatch() /xw}]Fa5
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有
G:i>MJbxT
2、PreparedStatement nr- 32u
PreparedStatement ps = cn.preparedStatement(sql); A Y_GD ^
{ D&!c7_ ^
ps.setXXX(1,xxx); hK 1 H'~c
... K2!GpGZu
ps.addBatch(); qw6i|JM%
} _DLELcH
Y
ps.executeBatch(); 0rCQz3gh1
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 uG=~kO
~+CEek
事务的处理 fRomP-S
1、关闭Connection的自动提交 bO+]1nZ.
cn.setAutoCommit(false); <KBS ;t="1
2、执行一系列sql语句 a9g~(#?a
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close (qDPGd*1
Statement sm ; k]9+/$
sm = cn.createStatement(insert into user...); XS=f>e1<W
sm.executeUpdate(); XWag+K
sm.close(); \%|%C
sm = cn.createStatement("insert into corp...); sMgRpem;
sm.executeUpdate(); O 4'/C]B2
sm.close(); ky@ZEp=
3、提交 =[nuesP'
cn.commit(); 8'#L+$O &N
4、如果发生异常,那么回滚 ErxvGB(2
cn.rollback();