java 数据库基本操作 /0X0#+kn
1、java数据库操作基本流程 'JJ1#kKa
2、几个常用的重要技巧: z2"2tFK
可滚动、更新的记录集 W8\PCXnsfl
批量更新 3T Yo
事务处理 xuw//F
<x.]OZgO
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 F%Ro98?{
1、取得数据库连接 _+0uju?o}
1)用DriverManager取数据库连接 eimA *0Cq
例子 pqRO[XEp2
String className,url,uid,pwd; "`y W]v
className = "oracle.jdbc.driver.OracleDriver";
m,xy4
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; *S,v$ VX
uid = "system"; ,S7~=S
pwd = "manager"; :qt82tbn
Class.forName(className); 6:8EZ'y
Connection cn = DriverManager.getConnection(url,uid,pwd); }UJdE#4
2)用jndi(java的命名和目录服务)方式 }7f 1(#{7
例子 S"I#>^
String jndi = "jdbc/db"; H@ 1[SKBl
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); kG_&-b
DataSource ds = (DataSource) ctx.lookup(jndi); e2,<,~_K6
Connection cn = ds.getConnection(); \emT:Frb
多用于jsp中 ;D%5 nnr
2、执行sql语句 [)T$91
6I
1)用Statement来执行sql语句 7 UB8N vo
String sql; i2`.#YJ&v
Statement sm = cn.createStatement(); 2_B;
sm.executeQuery(sql); // 执行数据查询语句(select) PprQq_j
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); /zDSlj<c
2)用PreparedStatement来执行sql语句 ,3g]=f
String sql; q(w1VcLZ
sql = "insert into user (id,name) values (?,?)"; q[Sp|C6x
PreparedStatement ps = cn.prepareStatement(sql); N6-2*ES
ps.setInt(1,xxx); Ae,2Xi
ps.setString(2,xxx); ?];~N5<'
... )w3XN A_V
ResultSet rs = ps.executeQuery(); // 查询 i2\\!s
int c = ps.executeUpdate(); // 更新 &km d<
+dPE!:
3、处理执行结果 2-
|j
查询语句,返回记录集ResultSet zEA{%)W
更新语句,返回数字,表示该更新影响的记录数
FCjYTGA
ResultSet的方法 h|$zHm
1、next(),将游标往后移动一行,如果成功返回true;否则返回false & y 2GQJE
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 >Gw%r1)
CU}
q&6h
4、释放连接 [hvig$L
cn.close(); K!$\REs
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection y.TdWnXx
PHE;
可滚动、更新的记录集 O23]!S<;
1、创建可滚动、更新的Statement 3XYIb Xnk
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 2={K-s20
该Statement取得的ResultSet就是可滚动的 V2<k0@y
2、创建PreparedStatement时指定参数 _bvtJZ3i
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); SIyS.!k>
ResultSet.absolute(9000); HY%6eUhj
批量更新 PN)TX~}
1、Statement 4w3V!K8
Statement sm = cn.createStatement(); ]h`E4B
sm.addBatch(sql1); .D M1Knj
sm.addBatch(sql2); A~%g"
... : \ON+LQr
sm.executeBatch() 8B% O%*5`
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 k(w9vt0?
2、PreparedStatement RvgAI`T7$
PreparedStatement ps = cn.preparedStatement(sql); =*U%j
{ mF$jC:Tb
ps.setXXX(1,xxx); d/-0B<ts
... @)!1#^(}%
ps.addBatch(); #L)4|
} {f6A[ZO; J
ps.executeBatch(); ^LQ lfd
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 gIf+.^/m1
IhFw {=2*
事务的处理 NnSI)*%'
1、关闭Connection的自动提交 "S:NU.c?
cn.setAutoCommit(false); LTlC}3c28f
2、执行一系列sql语句 u9y-zhj_$
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close SE7 (+r
Statement sm ; d}6AHS[
sm = cn.createStatement(insert into user...); nk?xNe4
sm.executeUpdate(); XxrO:$
sm.close(); NVM2\fs
sm = cn.createStatement("insert into corp...); @'G ( k;
sm.executeUpdate(); ysw6hVb
sm.close(); ?X5glDZ$
3、提交 $SD@D6`lL
cn.commit(); ~{]m8a/ `6
4、如果发生异常,那么回滚 28ov+s~1+-
cn.rollback();