java 数据库基本操作 S"joXmJ/-C
1、java数据库操作基本流程 J*'#!
xIa
2、几个常用的重要技巧: "( P-VX
可滚动、更新的记录集 D4CiB"g3*
批量更新 :k.C|V!W
事务处理 Nm=\~LP90
UZRCJ
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 C{Er%
1、取得数据库连接 O'<cEv'B*
1)用DriverManager取数据库连接 g_t1(g*s
例子 roG f
&
String className,url,uid,pwd; n g?kl|VG
className = "oracle.jdbc.driver.OracleDriver"; ZzV%+n7<Vx
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; :f58JLX
uid = "system"; M%Dv-D{
pwd = "manager"; ZA/:\6gm
Class.forName(className); xp"5L8:C
Connection cn = DriverManager.getConnection(url,uid,pwd); JRl`evTS
2)用jndi(java的命名和目录服务)方式 mg7Q~SLL{
例子 9-?[%8
String jndi = "jdbc/db"; 4XL]~3 c
Context ctx = (Context) new InitialContext().lookup("java:comp/env");
MfNguh
DataSource ds = (DataSource) ctx.lookup(jndi); X`FFI6pb
Connection cn = ds.getConnection(); v %fRq!~
多用于jsp中 Qk.:b
2、执行sql语句 #}{1>g{sXt
1)用Statement来执行sql语句 DU%j;`3
String sql; V:8ph`1
Statement sm = cn.createStatement(); yzQ^KqLH
sm.executeQuery(sql); // 执行数据查询语句(select) %?[H=v(b
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); Yhkn(k2
2)用PreparedStatement来执行sql语句 u|a+:r)*4
String sql; <[mvfw
sql = "insert into user (id,name) values (?,?)"; i=G.{.
PreparedStatement ps = cn.prepareStatement(sql); $f^ \fa[
ps.setInt(1,xxx); 6S2v3
ps.setString(2,xxx); v"dj%75O?e
... !F&Ss|(}
ResultSet rs = ps.executeQuery(); // 查询 Ohmi(s
int c = ps.executeUpdate(); // 更新 nXuoRZ
27!9LU
3、处理执行结果 #=B~}
_
查询语句,返回记录集ResultSet w$5#jJX\
更新语句,返回数字,表示该更新影响的记录数 3d|n\!1r
ResultSet的方法 }TS4D={1
1、next(),将游标往后移动一行,如果成功返回true;否则返回false <MH| <hP
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ?YO$NYwE
zg=F;^oZ<
4、释放连接 SXx2
cn.close(); 7VQk$im399
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection WhHnF*I
a D,(mw-7r
可滚动、更新的记录集 f}1R,N_fC
1、创建可滚动、更新的Statement +u:Q+PkM
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); _jW}p-j
该Statement取得的ResultSet就是可滚动的 ch%-Cg~%
2、创建PreparedStatement时指定参数 ~~_!&
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); DxLN{g]B
ResultSet.absolute(9000); [j:]YR
批量更新 ?u9JRXj%
1、Statement >=_Z\ wA
Statement sm = cn.createStatement(); ZzuEw
sm.addBatch(sql1); bQ"w%!
sm.addBatch(sql2); MQv2C@K9F
... Ux Yb[Nbc
sm.executeBatch() M)oy3y^&
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 62X;gb
2、PreparedStatement _lE0_X|d
PreparedStatement ps = cn.preparedStatement(sql); xN +j]LC
{ dm&vLQVS
ps.setXXX(1,xxx); ~#b&UR
... .WR+)^&zz
ps.addBatch(); Z+< zKn}
} T*%Q s&x;
ps.executeBatch(); A:3:Cr
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 "c6(=FFq
OBY
事务的处理 Q( C\X
1、关闭Connection的自动提交 prC1<rm
cn.setAutoCommit(false); JPX5Jm()
2、执行一系列sql语句 *@|EaH/
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close :Sx!jx>W
Statement sm ; P2S$Dk_<\X
sm = cn.createStatement(insert into user...); #UcqKq
sm.executeUpdate(); K0i[D"
sm.close(); D4x~Vk%H
sm = cn.createStatement("insert into corp...); x*A_1_A
sm.executeUpdate(); $~V,.RD
sm.close(); ' ju{j`b
3、提交 0!c^pOq6
cn.commit(); >!vb ;a!
4、如果发生异常,那么回滚 B!=JRfT
cn.rollback();