java 数据库基本操作 SOhM6/ID2/
1、java数据库操作基本流程 QM F
2、几个常用的重要技巧: L"|Bm{Run
可滚动、更新的记录集 Q2VF+g,
批量更新 P[WkW#
事务处理 ={)85N
<ToBVGX
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 l,7&
z
1、取得数据库连接 p0bWzIH
1)用DriverManager取数据库连接 kun/KY
例子 &rBe -52
String className,url,uid,pwd; &.,K@OFE}
className = "oracle.jdbc.driver.OracleDriver"; zHb[.ry~
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; t1adS:)s
uid = "system"; e4tIO
pwd = "manager"; ki9&AFs2X
Class.forName(className); n" Ie>
Connection cn = DriverManager.getConnection(url,uid,pwd); +:.Jl:fx4
2)用jndi(java的命名和目录服务)方式 z#GZb
例子 </{Zb.
String jndi = "jdbc/db"; TwPQ8}pj?
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); jr4xh{Z`
DataSource ds = (DataSource) ctx.lookup(jndi); :3n@].
Connection cn = ds.getConnection(); y("WnVI
多用于jsp中 ;>v.(0FE6
2、执行sql语句 %":3xj'EEI
1)用Statement来执行sql语句 @V%\Gspv
String sql; qT$k%(
Statement sm = cn.createStatement(); :\OSHs<M
sm.executeQuery(sql); // 执行数据查询语句(select) +`HMl;0m
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); &kg^g%%
2)用PreparedStatement来执行sql语句 _!03;zrO
String sql; kv:9Fm\$
sql = "insert into user (id,name) values (?,?)"; ,n/]ALz>~
PreparedStatement ps = cn.prepareStatement(sql);
,&hv x
ps.setInt(1,xxx); V.GM$
ps.setString(2,xxx); !=dz^f.{
... G?W:O{n3
ResultSet rs = ps.executeQuery(); // 查询 0|P=S|%~
int c = ps.executeUpdate(); // 更新 PJ.\)oP
E]@&<TFq
3、处理执行结果 +F;2FD$
查询语句,返回记录集ResultSet Cr5ND\
更新语句,返回数字,表示该更新影响的记录数 #rlgeHG!fs
ResultSet的方法 +0pI}a\
1、next(),将游标往后移动一行,如果成功返回true;否则返回false BsQ;`2
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 [3m\~JtS
68tyWd}
4、释放连接 4D?h}U /
cn.close(); o<Zlm)"%1
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection {"ST
hTZ
)eyzHB,H
可滚动、更新的记录集 yLa@27T\A
1、创建可滚动、更新的Statement Y
Zj-%5
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); L`+[mX&2B
该Statement取得的ResultSet就是可滚动的 }_D .Hy5
2、创建PreparedStatement时指定参数 rnIjpc F
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); KL&/Yt
ResultSet.absolute(9000); 2*NPK}
批量更新 Rt8[P6e"q
1、Statement ]Z!Y*v
Statement sm = cn.createStatement(); V\L;EHtc$
sm.addBatch(sql1); is<:}z
sm.addBatch(sql2); .vu7$~7
... \o>-L\`O
sm.executeBatch() C]ss'
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 gu
k,GF9p]
2、PreparedStatement .|,LBc!
PreparedStatement ps = cn.preparedStatement(sql); V[tebv!
{ YdhTjvx
ps.setXXX(1,xxx); r[L.TX3Ah=
... 9Dx~!(
ps.addBatch(); P#O"{+`
} Cj0r2^`
ps.executeBatch(); hG1$YE
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 KdEvu?
o*KAS@&
事务的处理 OgF[=
1、关闭Connection的自动提交 CD`a-]6qA
cn.setAutoCommit(false); 8+'}`
2、执行一系列sql语句 T)! }Wvv
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close dSGdK
$ XA
Statement sm ; ]\39#
sm = cn.createStatement(insert into user...); 8~'cP?
sm.executeUpdate(); Ng#psN
sm.close(); B"4 3o7C
sm = cn.createStatement("insert into corp...); iuV4xyp
sm.executeUpdate(); i 8sv,P
sm.close(); @M'k/jl
3、提交 9)!Ksg(h
cn.commit(); AwJg/VBo)
4、如果发生异常,那么回滚 xQFRM aQE
cn.rollback();