java 数据库基本操作 Of[XKFn_
1、java数据库操作基本流程 l0PZ`m+;j
2、几个常用的重要技巧: ujR_"r|l
可滚动、更新的记录集 JNt^ (z
批量更新 r0+6evU2
事务处理 6/r)y+H
+#lM
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ^h~x)@=
1、取得数据库连接 `lO[x.[
1)用DriverManager取数据库连接 kT"Kyd
例子 +'I+o5*
String className,url,uid,pwd; 3L_\`Ia9
className = "oracle.jdbc.driver.OracleDriver"; GzI yP(U
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; {MCi<7j<?
uid = "system"; #xQr<p$L6
pwd = "manager"; iS
WU'K
Class.forName(className); R3;Tk^5A
Connection cn = DriverManager.getConnection(url,uid,pwd); CohDO
2)用jndi(java的命名和目录服务)方式 smRE!f*q
例子 clL2k8VS
String jndi = "jdbc/db"; qB0E_y)a
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); O4cr*MCb5
DataSource ds = (DataSource) ctx.lookup(jndi); d4>Z8FF|1B
Connection cn = ds.getConnection(); Ay5i+)MD
多用于jsp中
19Mu61
2、执行sql语句 ER5gmmVP@p
1)用Statement来执行sql语句 !Wy6/F@Z
String sql; |:xYE{*)H
Statement sm = cn.createStatement(); $JJrSwR<h
sm.executeQuery(sql); // 执行数据查询语句(select) $Q96,rb}k;
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); <`B,R*H{
2)用PreparedStatement来执行sql语句 :D%"EJ
String sql; M<.d8?p )
sql = "insert into user (id,name) values (?,?)"; QS` PpyBkd
PreparedStatement ps = cn.prepareStatement(sql); G~2jUyv
ps.setInt(1,xxx); E_])E`BJ
ps.setString(2,xxx); 4E]l{"k<
... aWWU4xe
ResultSet rs = ps.executeQuery(); // 查询 mKL<<L[
int c = ps.executeUpdate(); // 更新 Li/O
rV R1wsaL
3、处理执行结果
A: 5x|
查询语句,返回记录集ResultSet .TND a&
更新语句,返回数字,表示该更新影响的记录数 K]s[5
ResultSet的方法 C":32_q
1、next(),将游标往后移动一行,如果成功返回true;否则返回false Gb#Cm]
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 >L;eO'D
*W0y: 3dB3
4、释放连接 b[t> te
cn.close(); OWjk=u2Lz
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection @eD):Y
aqRhh=iS
可滚动、更新的记录集 yp KUkH/
1、创建可滚动、更新的Statement hb zC#@q
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); wKZ$iGMbz
该Statement取得的ResultSet就是可滚动的 `\T]ej}zvI
2、创建PreparedStatement时指定参数 \>:CvTzF
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); x(etb<!jd
ResultSet.absolute(9000); #{?PbBE}
批量更新 P9^-6;'Y
1、Statement trPAYa}W
Statement sm = cn.createStatement(); FbaEB RM
sm.addBatch(sql1); }=gx#
sm.addBatch(sql2); \O*-#} ~\
... TcjEcMw,
sm.executeBatch() Hfwq/Is
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 .S(TxksCz
2、PreparedStatement h]+C.Eqnt#
PreparedStatement ps = cn.preparedStatement(sql); P7nc7a
{ h{HF8>u[
ps.setXXX(1,xxx); =(NB%}
... -+ SF
ps.addBatch(); - }7e:!.
} ej4W{IN~:
ps.executeBatch(); {QHVo#
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 l6YtEHNG
/^X/ 8
事务的处理 y#Fv+`YDl
1、关闭Connection的自动提交 Xu<k3oD7
cn.setAutoCommit(false); f&eK|7J_Yf
2、执行一系列sql语句 WG6FQAo^8
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close W-x?:X<}
Statement sm ; \
e\?I9
sm = cn.createStatement(insert into user...); @R/07&lBR
sm.executeUpdate(); gVq;m>\|F
sm.close(); -=)+dCyB^
sm = cn.createStatement("insert into corp...); tBq
nfv
sm.executeUpdate(); pm*xb]8y
sm.close(); #MX'^RZ>2
3、提交 =|M>l
cn.commit(); ,Sq/y~
4、如果发生异常,那么回滚 ohF JZ'
cn.rollback();