java 数据库基本操作 ;{q7rsE
1、java数据库操作基本流程 -q(,}/Xf
2、几个常用的重要技巧: A:p7\Kp;5}
可滚动、更新的记录集 5^GUuFt5m
批量更新 `8xe2=Ub
事务处理 2y
~]Uo
WsJ3zZc
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 #R305
1、取得数据库连接 q'3=
1)用DriverManager取数据库连接 )f(#Fn
例子 -:a
9'dT
String className,url,uid,pwd; 4rwfY<G
className = "oracle.jdbc.driver.OracleDriver"; @ L% 3}
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; I@+dE V`Lf
uid = "system"; /Kwo^Q{
pwd = "manager"; S=krF yFw
Class.forName(className); `"zX<
Connection cn = DriverManager.getConnection(url,uid,pwd); X dLB1H
2)用jndi(java的命名和目录服务)方式 aMZ6C <N
例子 F{]dq/{
String jndi = "jdbc/db"; T9RR.
ng
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); Tp)-L0kD_k
DataSource ds = (DataSource) ctx.lookup(jndi);
YmB
z$
Connection cn = ds.getConnection(); 2ztP'
多用于jsp中 bzk@6jR1
2、执行sql语句 2Ev~[Hb.
1)用Statement来执行sql语句 rbO9NRg>
String sql; Cj_cu
Statement sm = cn.createStatement(); UR1U; k
sm.executeQuery(sql); // 执行数据查询语句(select) j@ UIN3
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); RA>xol~xy
2)用PreparedStatement来执行sql语句 IA$:r@QNx8
String sql; opte)=]J
sql = "insert into user (id,name) values (?,?)"; *;Hvx32I
PreparedStatement ps = cn.prepareStatement(sql); vs7Hg)F
ps.setInt(1,xxx); <3O>
ps.setString(2,xxx); EtcAU}9
... _;v4]MU
ResultSet rs = ps.executeQuery(); // 查询 b0PF7PEEQ
int c = ps.executeUpdate(); // 更新 QI=",vmau
SD8Q_[rY
3、处理执行结果 _9Iz'-LgB
查询语句,返回记录集ResultSet oq^#mJL
更新语句,返回数字,表示该更新影响的记录数 /XS}<!)%
ResultSet的方法 P3on4c
1、next(),将游标往后移动一行,如果成功返回true;否则返回false Rl.3p<sX
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 E2LpQNvN%g
<[ 8at6;
4、释放连接 ?bmP<(N5/
cn.close(); T.`E DluG
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection Pqo"~&Y|~
XlV#)JX
可滚动、更新的记录集 lDCoYX_
1、创建可滚动、更新的Statement LUHj3H
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); #If}P$!
该Statement取得的ResultSet就是可滚动的 dF5EIPl;J
2、创建PreparedStatement时指定参数 hG
uRV|`
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); (pREo/ T
ResultSet.absolute(9000); [Sg1\UTl
批量更新 XBF#ILJ
1、Statement owmV7E1
Statement sm = cn.createStatement(); |@sUN:G4k
sm.addBatch(sql1); 2?z3s|+[
sm.addBatch(sql2); L'H'E,
... 1bYc^(z0
sm.executeBatch() ]
RN&s
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 wta\C{{
2、PreparedStatement VI74{='=
PreparedStatement ps = cn.preparedStatement(sql); )0j^Fq5[+
{ ">v76%>Z7
ps.setXXX(1,xxx); g&`e2|[7
... #[qmhU{s
ps.addBatch(); =n
cu#T]
} !L2R0Y:a
ps.executeBatch(); L1VUfEG-
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 l"f.eo0@7
d2Z5HFtY
事务的处理 4sP0oe[h
1、关闭Connection的自动提交 PL@hsZty~c
cn.setAutoCommit(false); vCb3Ra~L`
2、执行一系列sql语句 X#Y0g`muW
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close =XzrmPu
Statement sm ; GXr9J rs.e
sm = cn.createStatement(insert into user...); 4;<?ec(dc
sm.executeUpdate(); W.r0W2))(
sm.close(); z4HIDb
sm = cn.createStatement("insert into corp...); ,5mK_iUw3
sm.executeUpdate(); K9njD#/
sm.close(); ?S~HnIn
3、提交 O6pswMhAc
cn.commit(); }JeGjpAcV
4、如果发生异常,那么回滚 ]e$mTRi*
cn.rollback();