java 数据库基本操作 SUIu.4Mz
1、java数据库操作基本流程 #%8)'=1+4?
2、几个常用的重要技巧: =v!Z8zk=W
可滚动、更新的记录集 wDSwcNS
批量更新 :7X{s4AU6
事务处理 mey -Bn
@HnahD
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ;CoD5F!
1、取得数据库连接 t/%[U,m
1)用DriverManager取数据库连接 _VM}]A
例子 }sJ}c}b
String className,url,uid,pwd; 9b&;4Yq!f
className = "oracle.jdbc.driver.OracleDriver"; H;@0L}Nu+}
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; >WJQxL4
uid = "system"; Os].
IL$
pwd = "manager"; I2NMn5>
Class.forName(className); lPC{R k.\C
Connection cn = DriverManager.getConnection(url,uid,pwd); ?5;wPDsK
2)用jndi(java的命名和目录服务)方式 1K)9fMr]
例子 \d:Uq5d)0
String jndi = "jdbc/db"; oK<H/76x
Context ctx = (Context) new InitialContext().lookup("java:comp/env");
Jk:ZO|'Z
DataSource ds = (DataSource) ctx.lookup(jndi); X+ybgB4(
Connection cn = ds.getConnection(); ar'VoL}
多用于jsp中 {w,<igh
2、执行sql语句 %s5(''a.
1)用Statement来执行sql语句 [H9<JdUZ
String sql; "(~fl<;
Statement sm = cn.createStatement(); nE0I [T(
sm.executeQuery(sql); // 执行数据查询语句(select) |%rRALIY
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); _5p]Arg?}&
2)用PreparedStatement来执行sql语句 .:B0(4Mj
String sql; ZEpu5`
sql = "insert into user (id,name) values (?,?)"; %,@e- &>
PreparedStatement ps = cn.prepareStatement(sql); /}%C'
ps.setInt(1,xxx); 9Uz2j$p7
ps.setString(2,xxx); :xO43z
... 7|[Dr@.S
ResultSet rs = ps.executeQuery(); // 查询 {}gL*2:EW$
int c = ps.executeUpdate(); // 更新 y1Wb/ d
Z^J)]UL/
3、处理执行结果 unnuSW#v=
查询语句,返回记录集ResultSet 4{ZVw/VP,-
更新语句,返回数字,表示该更新影响的记录数 2$2@?]|?
ResultSet的方法 j xq89x
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ;2MdvHhz1
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 >>;He7
OU^I/TU
4、释放连接 dDA&\BuS
cn.close(); gF;C% }
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection _0\wyjjU
bHTTxZ-%
可滚动、更新的记录集 V4W(>g
1、创建可滚动、更新的Statement cA]PZ*]{BN
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); {n<1uh9~$8
该Statement取得的ResultSet就是可滚动的 -
s{&_]A~
2、创建PreparedStatement时指定参数 >=1UhHFNI
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); a+9_sUq
ResultSet.absolute(9000); K!-iDaVI
批量更新 SpEu>9g&
1、Statement /CbM-jf
Statement sm = cn.createStatement(); nA=E|$1
sm.addBatch(sql1); Qi9M4Yv
sm.addBatch(sql2); N~(?g7
... lZ`@ }^&
sm.executeBatch() :&RpB^]
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 vv`53 Pbw)
2、PreparedStatement =trLL+vGw'
PreparedStatement ps = cn.preparedStatement(sql); "M %WV>
{ e4.G9(
ps.setXXX(1,xxx); nv:VX{%
... A2`Xh#o
ps.addBatch(); RNcnE1=
} Bv6~!p
ps.executeBatch(); F/df!I~
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 `2HNQiK'@
`mN5s q
事务的处理 r#6djs1
1、关闭Connection的自动提交 2 rS`ViicD
cn.setAutoCommit(false); Cg^1(dBd[9
2、执行一系列sql语句 U{9yfy
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close E/>kvs%
Statement sm ; -TNb=2en(
sm = cn.createStatement(insert into user...); rp!{QG
sm.executeUpdate(); ;\Pq
sm.close(); ~eekv5
sm = cn.createStatement("insert into corp...); Qf}}/k|)k
sm.executeUpdate(); :8lqo%5
sm.close(); .wQM_RZJ
3、提交 zf[KZ\6H
cn.commit(); !L@a;L
4、如果发生异常,那么回滚 OkQtM
nq
cn.rollback();