java 数据库基本操作 G!3d!$t
1、java数据库操作基本流程 0N19R 5NN8
2、几个常用的重要技巧: 5cE?>
可滚动、更新的记录集 U#U nM,3%
批量更新 and)>$)|
事务处理 L.) 0!1
+$H`/^a.
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 J)leRR&
1、取得数据库连接 )Y}8)/Pud
1)用DriverManager取数据库连接 GV T[)jS
例子 PK<+tIm\
String className,url,uid,pwd; Z/hgr|&}
className = "oracle.jdbc.driver.OracleDriver"; \,5OPSB
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; { |[n>k
uid = "system"; aZ{]t:]
pwd = "manager"; #0;ULZ99aH
Class.forName(className); yxz"9PE/P
Connection cn = DriverManager.getConnection(url,uid,pwd); f]Q`8nU
2)用jndi(java的命名和目录服务)方式 sHQ82uX
例子 %\2w
1
String jndi = "jdbc/db"; 26Jb{o9Z<
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); .y~vn[q N
DataSource ds = (DataSource) ctx.lookup(jndi); ;VAHgIpx;
Connection cn = ds.getConnection(); zwa%$U
多用于jsp中 (+ibT;!]
2、执行sql语句 >2w^dI2
1)用Statement来执行sql语句 :7-2^7z)
String sql; xLmgr72D
Statement sm = cn.createStatement(); 5g(`U+,*(
sm.executeQuery(sql); // 执行数据查询语句(select) &?xZHr`
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ]1(G:h\
2)用PreparedStatement来执行sql语句 j6_tFJT
String sql; d`+@
_)ea
sql = "insert into user (id,name) values (?,?)"; n^2p jTkl
PreparedStatement ps = cn.prepareStatement(sql); M$0-!$RY
ps.setInt(1,xxx); _#]/d3*Z}
ps.setString(2,xxx); lEe<!B$d"
... +__PT4ps
ResultSet rs = ps.executeQuery(); // 查询 ^<VJ8jk<
int c = ps.executeUpdate(); // 更新 [|!A3o
K7CrRT3>6
3、处理执行结果 IDIok~B=e
查询语句,返回记录集ResultSet M'D l_dx-
更新语句,返回数字,表示该更新影响的记录数 J@vL,C)E6
ResultSet的方法 t5Oeb<REz
1、next(),将游标往后移动一行,如果成功返回true;否则返回false O.% $oV
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 :]hNw1e
#7}1W[y9}l
4、释放连接 y:R!E *.L'
cn.close(); 86AZ)UP2D
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection BrO" _
,s9gGCA
可滚动、更新的记录集 A3|hFk
1、创建可滚动、更新的Statement
:ENdF `nC
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); KtO|14R:
该Statement取得的ResultSet就是可滚动的 (L3Etan4RE
2、创建PreparedStatement时指定参数 ,'f^K!iA
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); E kvTl-
ResultSet.absolute(9000); DZ7<-SFU
批量更新 @z-%:J/$
1、Statement ^L@2%}6b`
Statement sm = cn.createStatement(); e: aa
sm.addBatch(sql1); d~F4
sm.addBatch(sql2); .*(xkJI3
... %H AforH
sm.executeBatch() V6ICR{y<3
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 4fyds< f
2、PreparedStatement PV\aQO.mo
PreparedStatement ps = cn.preparedStatement(sql); 8$TSQ~
{ ;qN;oSK
ps.setXXX(1,xxx); cfP9b8JG
... QU;bDNq,c
ps.addBatch(); qG<3H!Z!ky
} Lq6R_udp
ps.executeBatch(); UqwU3
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 CVy\']
nde_%d$
事务的处理 W Y]
1、关闭Connection的自动提交 +\_c*'K>
cn.setAutoCommit(false); 6B=: P3Y
2、执行一系列sql语句 h7"c_=w+
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close -/'_XR@1
Statement sm ; <(c_[o/
sm = cn.createStatement(insert into user...); L
HW\A8
sm.executeUpdate(); Qu;cl/&
sm.close(); 'OTQiI^t=
sm = cn.createStatement("insert into corp...); *
",/7(
sm.executeUpdate(); fR$_=WWN>h
sm.close(); (& UQ^
3、提交 F!_8?=|
cn.commit(); ``?79 MJ5
4、如果发生异常,那么回滚 Nm7YH@x*o
cn.rollback();