java 数据库基本操作 0Ux<16#
1、java数据库操作基本流程 'xsbm^n6a&
2、几个常用的重要技巧: .B6`OX&k
可滚动、更新的记录集 'qdg:_L"
批量更新 |GuKU!
事务处理 6GY32\Ac
z;ULQ
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 1Jl{1;c
1、取得数据库连接 @uoT{E[
1)用DriverManager取数据库连接 HRj7n<>L=
例子 WBy[m ?d
String className,url,uid,pwd; <8g=BWA
className = "oracle.jdbc.driver.OracleDriver";
!8we8)7
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; L#`7 FaM?
uid = "system"; >kt~vJI
pwd = "manager"; {ip=iiW2
Class.forName(className); #>@<n3rq
Connection cn = DriverManager.getConnection(url,uid,pwd); <Kh?Ad>N
2)用jndi(java的命名和目录服务)方式 ?_8%h`z
例子 T.J`S(oI
String jndi = "jdbc/db"; pn|p(6
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); DL
%S(l
DataSource ds = (DataSource) ctx.lookup(jndi); xQX<w\s
Connection cn = ds.getConnection(); +O&RBEa[
多用于jsp中 DakLD~H;
2、执行sql语句 i^/
eN
1)用Statement来执行sql语句 L7s>su|c(
String sql; r>E\Cco
Statement sm = cn.createStatement(); hx*HY%\P
sm.executeQuery(sql); // 执行数据查询语句(select) `i=JjgG@
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); h -Tsi:%b
2)用PreparedStatement来执行sql语句 aMBL1d7
String sql; S^|$23}
sql = "insert into user (id,name) values (?,?)"; ,Y$F7&
PreparedStatement ps = cn.prepareStatement(sql); } /[_
ps.setInt(1,xxx); z~BD(FDI
ps.setString(2,xxx); W]Y@WKeT
... ]cn/(U`
ResultSet rs = ps.executeQuery(); // 查询 Fq vQk
int c = ps.executeUpdate(); // 更新 t8t}7XD
~5FS|[1L
3、处理执行结果 1NuR/DO
查询语句,返回记录集ResultSet fS5GICx8R
更新语句,返回数字,表示该更新影响的记录数 hyJ
ded&D
ResultSet的方法 79TPg
1、next(),将游标往后移动一行,如果成功返回true;否则返回false +.S#=
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 wTB)v !
CEbzJ
4、释放连接 y>>vGU;
cn.close(); qUifw @
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection _{lx*dq
;,<r|.6U
可滚动、更新的记录集 ".Lhte R?
1、创建可滚动、更新的Statement ay=KfY5
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); g Cg4;b6g
该Statement取得的ResultSet就是可滚动的 i:V0fBR[>
2、创建PreparedStatement时指定参数 rn5"o8|
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); : :F!
ResultSet.absolute(9000); 8$2l^
批量更新 kX@bv"i
1、Statement K~`n}_:
Statement sm = cn.createStatement(); #DQX<:u
sm.addBatch(sql1); ?(fQ<i n
sm.addBatch(sql2); >]:N?[Y_~}
... \Y51KB\
sm.executeBatch() I~d#p ]>
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 F9Ifw><XM
2、PreparedStatement mGt\7&`
PreparedStatement ps = cn.preparedStatement(sql); [u/zrpTk
{ kyy0&L
ps.setXXX(1,xxx); }l,T~Pjb
... }5fU7&jA;3
ps.addBatch(); 0|.7Kz^
} C<r(-qO{5
ps.executeBatch(); B*-ToXQQr
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 mY$nI -P
u^}7Vs
.
事务的处理 @PT`CK}
1、关闭Connection的自动提交 qgwv=5|
cn.setAutoCommit(false); TrSN00
2、执行一系列sql语句 J!=](s5|
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close !T<z'zZU
Statement sm ; `
(7N^@
sm = cn.createStatement(insert into user...); "}S9`-Wd|
sm.executeUpdate(); [54@i rH
sm.close(); IW5*9)N?
sm = cn.createStatement("insert into corp...); A6{t%k~F
sm.executeUpdate(); Xy[4f=X}z
sm.close(); {D;Xa`:O
3、提交 fQ=&@ >e
cn.commit(); &Pmc"9Rl
4、如果发生异常,那么回滚 )p^m}N 6M]
cn.rollback();