java 数据库基本操作 L
R\LC6kM
1、java数据库操作基本流程 }jUsv8`}8R
2、几个常用的重要技巧: {zWR)o .=
可滚动、更新的记录集 2E?!Q I\O
批量更新 ESNI$[`
事务处理 @ 5^nrB
a}uYv:
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 \ )=WA!
1、取得数据库连接 xorafL
1)用DriverManager取数据库连接 {fnx=BaG
例子 c:.~%AJx
String className,url,uid,pwd; ^nK<t?KS
className = "oracle.jdbc.driver.OracleDriver"; fd4C8>*7G
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; #1/~eIEY
uid = "system"; V^,eW!
pwd = "manager"; BZ=I/L
Class.forName(className); \"1>NJn&k)
Connection cn = DriverManager.getConnection(url,uid,pwd); 8Z0x*Ssk
2)用jndi(java的命名和目录服务)方式 @zC6`
例子 {nbT$3=Zt
String jndi = "jdbc/db"; D8<C7
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 37$
^ie)
DataSource ds = (DataSource) ctx.lookup(jndi); }b1FB<e]
Connection cn = ds.getConnection(); ":_II[FPY
多用于jsp中 IH;sVT$M
2、执行sql语句
p"#\E0GM
1)用Statement来执行sql语句 %rMCiz
String sql; =KUmvV*\
Statement sm = cn.createStatement(); ]'`E
sm.executeQuery(sql); // 执行数据查询语句(select) m/1FVC@*
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); b?l>vUgAg
2)用PreparedStatement来执行sql语句 UWF
\Vx*)b
String sql; [Q0V 5P~Q'
sql = "insert into user (id,name) values (?,?)"; v !8=B21
PreparedStatement ps = cn.prepareStatement(sql); {u/1ph-
ps.setInt(1,xxx); Y@`uBB[
ps.setString(2,xxx); >Jmla~A
... c3 O/#*
ResultSet rs = ps.executeQuery(); // 查询 F?|Efpzow?
int c = ps.executeUpdate(); // 更新 2}A)5P*K
HMCLJ/
3、处理执行结果 ;U|(rM;
查询语句,返回记录集ResultSet $uZmIu9Bi+
更新语句,返回数字,表示该更新影响的记录数 `R$i|,9)
ResultSet的方法 CtXbAcN2B
1、next(),将游标往后移动一行,如果成功返回true;否则返回false V6X )L>!xx
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 @^<odmM
HbegdbTJ
4、释放连接 !1G
KpL
cn.close(); W!wof-1
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection J(l\VvK
${MzOi
可滚动、更新的记录集 :Ln)j%&
1、创建可滚动、更新的Statement T@tsM|pI
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ~= *o
该Statement取得的ResultSet就是可滚动的 3uocAmY
2、创建PreparedStatement时指定参数 z.Ic?Wz7
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); bGCC?}\
ResultSet.absolute(9000); ==OUd6e}
批量更新 >jX"
1、Statement c|k_[8L
Statement sm = cn.createStatement(); Cgx:6TRS
sm.addBatch(sql1); k1<^Ept
sm.addBatch(sql2); nwU],{(Hgr
... |Dn Zk3M,
sm.executeBatch() ZC N}iQu4
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ]~aj
2、PreparedStatement 1ysfpX{=
PreparedStatement ps = cn.preparedStatement(sql); -Cs( 3[
{ AH#mL
ps.setXXX(1,xxx); %):_
... $6a9<&LP_
ps.addBatch(); Y"H`+UV
} 1zPS#K/3
ps.executeBatch(); 8>9Mh!t}(I
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 w.q`E@ T*
hzsQK_;S
事务的处理 2iG+Ek-?"
1、关闭Connection的自动提交 )X0=z1$
cn.setAutoCommit(false); MY,~leP&
2、执行一系列sql语句 ~HB#7+b
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 1.du#w
Statement sm ; dd
sm = cn.createStatement(insert into user...); lxyTh'
sm.executeUpdate(); )8A.Wg4S;c
sm.close(); +]eG=.
u
sm = cn.createStatement("insert into corp...); '2.ey33V
sm.executeUpdate(); 0]4X/u#N
sm.close(); Wx:v~/r
3、提交 I=kqkuW
cn.commit(); ZaYiby@Ci
4、如果发生异常,那么回滚 g8Ex$,\,
cn.rollback();