java 数据库基本操作 }s.\B
1、java数据库操作基本流程 H:mcex
2、几个常用的重要技巧: "P$')uwE
可滚动、更新的记录集
va!fJ
批量更新 \\Nt^j3qR
事务处理 0RN 7hpf&`
J5}?<Dd:
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 Z*.rv t
1、取得数据库连接 a@#<qf8g
1)用DriverManager取数据库连接 +#6f)H(P]
例子 R xc
String className,url,uid,pwd; G9CL}=lJ,
className = "oracle.jdbc.driver.OracleDriver"; 6dYa07
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; iAXF;'|W
uid = "system"; 0<nW
nD,z
pwd = "manager"; tZ:fh p
Class.forName(className); z\Z+>A
Connection cn = DriverManager.getConnection(url,uid,pwd); 2c3/iYCKP
2)用jndi(java的命名和目录服务)方式 =27Z Y Z
例子 '
?EG+o8
String jndi = "jdbc/db"; (i-L:
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); srH.$Y;~
DataSource ds = (DataSource) ctx.lookup(jndi); Bd[H@oKru
Connection cn = ds.getConnection(); ZpZoOdjslV
多用于jsp中 NFI~vkk'G
2、执行sql语句 7Kti&T
1)用Statement来执行sql语句 '<AE%i,
String sql; (mx}6A
Statement sm = cn.createStatement(); F /"lJ/I
sm.executeQuery(sql); // 执行数据查询语句(select) 2]H?q!l!O
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close();
hAD gi^
2)用PreparedStatement来执行sql语句 T^Hq 5Oy
String sql; ?]>;Wr
sql = "insert into user (id,name) values (?,?)"; ^%qQ)>I=j
PreparedStatement ps = cn.prepareStatement(sql); O)`ye5>v
ps.setInt(1,xxx); \4uj!LgTb
ps.setString(2,xxx); 8cj}9}k
... ngzQVaB9
ResultSet rs = ps.executeQuery(); // 查询 GZ.KL!,R!
int c = ps.executeUpdate(); // 更新 cpx:4R,
U \jFB*U
3、处理执行结果 +l<;?yk:;
查询语句,返回记录集ResultSet |C7=$DgwY
更新语句,返回数字,表示该更新影响的记录数 q[c^`5
ResultSet的方法 F`o"t]AD-a
1、next(),将游标往后移动一行,如果成功返回true;否则返回false MgHO WoF
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 LqS_%6^
z/i&Lpr:
4、释放连接 }L>0}H
cn.close(); Q1x=@lXR
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 3&B- w
IC-W[~
可滚动、更新的记录集 BuS[(
1、创建可滚动、更新的Statement _"82W^W i
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Nk?/vMaw
该Statement取得的ResultSet就是可滚动的 ]F"@+_E
2、创建PreparedStatement时指定参数 v5*JBW+c*
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 2D"aAI<P
ResultSet.absolute(9000); 8>(/:u_x
批量更新 aF.fd2k
1、Statement I %CrsEo
Statement sm = cn.createStatement(); (1%A@4
sm.addBatch(sql1); H~W=#Cx
sm.addBatch(sql2); PsN_c[+
... nsu RG
sm.executeBatch() JC7:0A^
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 l)Mi?B~N
2、PreparedStatement Oo9'
PreparedStatement ps = cn.preparedStatement(sql); l$C
Y
gm
{ *Q;?p
hr
ps.setXXX(1,xxx); Y\E7nll:.
... Pe`jNiI
ps.addBatch(); `Yyi;!+0
} |zOwC9-6
ps.executeBatch(); aX.//T:':?
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 {%6g6?=j
,jeC7-tX
事务的处理 <,Jx3yq
1、关闭Connection的自动提交 RHmT$^=
cn.setAutoCommit(false); &cy<"y
2、执行一系列sql语句 Dc0CQGx9b
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close \
F)}brPc
Statement sm ; P3TM5
sm = cn.createStatement(insert into user...); TmJXkR.5
sm.executeUpdate(); fj[Kbo 7!h
sm.close(); H_w?+Rig
sm = cn.createStatement("insert into corp...); ZN!<!"~
sm.executeUpdate(); {}BAQ9|q
sm.close(); S4
s#EDs
3、提交 </_.+c [
cn.commit(); |q
Pu*vR
4、如果发生异常,那么回滚 2 e&M/{
cn.rollback();