java 数据库基本操作 5aa}FdUq
1、java数据库操作基本流程 N|bPhssFw
2、几个常用的重要技巧: q/A/3/
可滚动、更新的记录集 "0!~g/X`rK
批量更新 dBsRm{aS
事务处理 *sjj"^'=
?.]o_L_K
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 i-|/2I9 %
1、取得数据库连接 ,xm;JXJ
1)用DriverManager取数据库连接 M?QQr~a
例子 7YoofI
String className,url,uid,pwd; ~ W2:NQ>i
className = "oracle.jdbc.driver.OracleDriver"; 9yO{JgKA
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; tq2-.]Y@U
uid = "system"; `\Uc4lRS
pwd = "manager"; Iq^~
Class.forName(className); >fW+AEt\JB
Connection cn = DriverManager.getConnection(url,uid,pwd); JHnk%h0
2)用jndi(java的命名和目录服务)方式 #(m`2Z`H
例子 [Od>NO,n+]
String jndi = "jdbc/db"; vx({N?
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 4x=V|"
DataSource ds = (DataSource) ctx.lookup(jndi); Pn~pej5'K
Connection cn = ds.getConnection(); p7%0hLW
多用于jsp中 nh _DEPMq
2、执行sql语句 Ry3+/]
1)用Statement来执行sql语句 :!r9 =N9
String sql; Bu*W1w\
Statement sm = cn.createStatement(); AGw1Pl8]K
sm.executeQuery(sql); // 执行数据查询语句(select) EGp~Vo-
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); )6O\WB|
2)用PreparedStatement来执行sql语句 nXx6L!H J#
String sql;
{JCSR2BB
sql = "insert into user (id,name) values (?,?)"; v!WU |=u
PreparedStatement ps = cn.prepareStatement(sql); QC$=Fs5+
ps.setInt(1,xxx); W;xW:
-
ps.setString(2,xxx); SSl8
... "`gf y
ResultSet rs = ps.executeQuery(); // 查询 )$2%&9b
int c = ps.executeUpdate(); // 更新 Zkwy.Hq^
2+c>O%L
3、处理执行结果 M Ak-=?t
查询语句,返回记录集ResultSet .=.yZ
更新语句,返回数字,表示该更新影响的记录数 {hkM*:U
ResultSet的方法 z^gDbXS
1、next(),将游标往后移动一行,如果成功返回true;否则返回false "Nk=g~|
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 F'$9en2I:
M="WUe_
4、释放连接 >
gA %MT
cn.close(); )R
[@G.
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 9}K(Q=
xiOv$.@q
可滚动、更新的记录集 |G`4"``]k
1、创建可滚动、更新的Statement ]be0I)
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); gJ)h9e*m^
该Statement取得的ResultSet就是可滚动的 4~]8N@Bii
2、创建PreparedStatement时指定参数 $@+p~ )r(l
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); &0;{lS[N:L
ResultSet.absolute(9000); 3{N p 9y.
批量更新 pIU#c&%<9
1、Statement Zztt)/6*
Statement sm = cn.createStatement(); pq/FLYiv
sm.addBatch(sql1); Thht_3_C,f
sm.addBatch(sql2); v*C+U$_3\1
... lx A<iQia
sm.executeBatch() S0Rf>Eo4
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 7?n*t
2、PreparedStatement (hRgYwUa<
PreparedStatement ps = cn.preparedStatement(sql); 89:?.'
{ mVc'%cPaw
ps.setXXX(1,xxx); {2'74
... j.
ks UJ
ps.addBatch(); ims=-1,
} &vJ(P!2f<
ps.executeBatch(); fl5UY$a2-
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 YW4bm
_{2Fx[m%
事务的处理 D@sx`H(
1、关闭Connection的自动提交 `JY>v io
cn.setAutoCommit(false); bJG!)3cx
2、执行一系列sql语句 b]tA2~e
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close n]6}yJJo
Statement sm ; @4 Os?_gJ\
sm = cn.createStatement(insert into user...); *_"c!eW
sm.executeUpdate(); &kXGWp
sm.close(); ei|*s+OZu
sm = cn.createStatement("insert into corp...);
8;+Hou
sm.executeUpdate(); _!$Up
sm.close(); Z;"4$@|qE
3、提交 '
q=NTP
cn.commit(); x3Dg%=R
4、如果发生异常,那么回滚 Pi"tQyw39$
cn.rollback();