java 数据库基本操作 !{s$V2_
1、java数据库操作基本流程 .,,?[TI
2、几个常用的重要技巧: 5%?La`C9[
可滚动、更新的记录集 P,iLqat
批量更新 )X\.Xr-6q
事务处理 *@G4i
5G){7]P+r"
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 #X"\:yN
1、取得数据库连接 [ZURs3q
1)用DriverManager取数据库连接 /^uvY
例子 =Gd[Qn83.%
String className,url,uid,pwd; ]Nt97eD)
className = "oracle.jdbc.driver.OracleDriver"; 2{p`"xX
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; p/lMv\`5
uid = "system"; jXi<ZJ
pwd = "manager"; ynM{hN.+ H
Class.forName(className); o^&;
`XOd
Connection cn = DriverManager.getConnection(url,uid,pwd); N,'JQch},8
2)用jndi(java的命名和目录服务)方式 I2j;9Qcz
例子 "MC&!AMv
String jndi = "jdbc/db"; h%+8}uywZ
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); Z6>:k,-Ot
DataSource ds = (DataSource) ctx.lookup(jndi); )\^o<x2S
Connection cn = ds.getConnection(); :v{$]wg
多用于jsp中 1a4QWGpq
2、执行sql语句 +@%9pbM"z
1)用Statement来执行sql语句 0 nWV1)Q0=
String sql; rxa"ji!)
Statement sm = cn.createStatement(); v_c'npC
sm.executeQuery(sql); // 执行数据查询语句(select) <mY`<(bc
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); <?qmB}Y
2)用PreparedStatement来执行sql语句 J-?\,N1R7
String sql; N>ct`a)BD/
sql = "insert into user (id,name) values (?,?)"; z8Dn<h
PreparedStatement ps = cn.prepareStatement(sql); @aCg1Rm
ps.setInt(1,xxx); ^#3$C?d
ps.setString(2,xxx); YXIDqTA+
... ^ ?tAt3dMI
ResultSet rs = ps.executeQuery(); // 查询 ).oqlA!
int c = ps.executeUpdate(); // 更新
XN=<s;U
5\=9&{WjND
3、处理执行结果 ts?b[v
查询语句,返回记录集ResultSet ,C&h~uRi#f
更新语句,返回数字,表示该更新影响的记录数 6^{ hY^Z
ResultSet的方法 lBG*P>;
1、next(),将游标往后移动一行,如果成功返回true;否则返回false <u2*(BM4
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 fy_'K}i3k
#Z$6>
Xt
4、释放连接 #(aROTV5a
cn.close(); p6Z]oL q
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection i $I|JJJ
:-"J)^V
可滚动、更新的记录集 sWavxh8A
1、创建可滚动、更新的Statement ziH2<@
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); j~Gu;%tq
该Statement取得的ResultSet就是可滚动的 E=QL4*?
2、创建PreparedStatement时指定参数 g=U?{<8.m
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); X'?v8\mPK
ResultSet.absolute(9000); -'}iK6
批量更新 /WHhwMc!
1、Statement mH{cGu?
Statement sm = cn.createStatement(); lf|^^2'*2<
sm.addBatch(sql1); uhc0,V;S
sm.addBatch(sql2); G=nFs)z
... M\v4{\2l0
sm.executeBatch() /$eEj
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 E0O{5YF^T
2、PreparedStatement oQyG
PreparedStatement ps = cn.preparedStatement(sql); .k*2T<p$rC
{ )D[xY0Y~
ps.setXXX(1,xxx); }7.q[ ^oF
... akCl05YW
ps.addBatch(); M;iaNL(
} l?FNYvL
ps.executeBatch(); C>K/C!5?
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 _ZS<zQ'
t9`NCng
5
事务的处理 dhVwS$O )
1、关闭Connection的自动提交 E?9_i
:IX
cn.setAutoCommit(false); 1MahFeQ[
2、执行一系列sql语句 8OFrW.>[
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close vq5I 2
Statement sm ; Y}?@Pm drz
sm = cn.createStatement(insert into user...); n/|/Womr
sm.executeUpdate(); epG;=\f}m`
sm.close(); w5*18L=O\
sm = cn.createStatement("insert into corp...); ^U`q1Pg5
sm.executeUpdate(); <=7)t.
sm.close(); X^.r@tT
3、提交 s lI)"+6
cn.commit(); &pba~X.u
4、如果发生异常,那么回滚 rSJ}qRXwU
cn.rollback();