java 数据库基本操作 o|b[(t$;O
1、java数据库操作基本流程 ="'rH.n #
2、几个常用的重要技巧: F&nMI:h7
可滚动、更新的记录集 ~Q.8 U3"
批量更新 /j=DC9_
事务处理 ,}xpYq_/
f 4
Sw,A
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 1FXzAc(c!
1、取得数据库连接 XcJ'm{=
1)用DriverManager取数据库连接 ,6cbD
例子 J
pCZq
#
String className,url,uid,pwd; ` $QzTv
className = "oracle.jdbc.driver.OracleDriver"; ~/]\iOL
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; GlV-}5W
uid = "system"; ;%b <uV
pwd = "manager"; -.+KCt G$+
Class.forName(className); jL>I5f
Connection cn = DriverManager.getConnection(url,uid,pwd); h&:Q$*A>
2)用jndi(java的命名和目录服务)方式 sqMNon`5
例子 ?,+C!R?
String jndi = "jdbc/db"; 0pZ.; /<{
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); s)`1Rf
DataSource ds = (DataSource) ctx.lookup(jndi); g4.'T51
Connection cn = ds.getConnection(); {Q#Fen
;y|
多用于jsp中 iuH8g
2、执行sql语句 qxg7cj2
1)用Statement来执行sql语句 7 ~%
String sql; Uy_}@50"l
Statement sm = cn.createStatement(); I;kUG_c(4
sm.executeQuery(sql); // 执行数据查询语句(select) P?3YHa^up
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); V5(tf'
2)用PreparedStatement来执行sql语句 TQbFI;\
String sql; / ut~jf`
sql = "insert into user (id,name) values (?,?)"; UG^?a
PreparedStatement ps = cn.prepareStatement(sql); *x#&[>
ps.setInt(1,xxx); N('S2yfDR
ps.setString(2,xxx); )N%1%bg^-
... FS]+s>
ResultSet rs = ps.executeQuery(); // 查询 MK!]y8+Z
int c = ps.executeUpdate(); // 更新 Ztpm_P6
c9cphZ(z
3、处理执行结果 5@r_<J<>
查询语句,返回记录集ResultSet yv#c=v|
更新语句,返回数字,表示该更新影响的记录数 J _[e9
ResultSet的方法 R"\ub"]
1、next(),将游标往后移动一行,如果成功返回true;否则返回false C&d"#I
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 B'lxlYV1
.9[8H:Fe
4、释放连接 xTksF?u)
cn.close(); dg'CHxU
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection %gne%9nn
E=tx.h4xG~
可滚动、更新的记录集 \3js}
1、创建可滚动、更新的Statement 4LKs'$:A=
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); %RT6~0z
该Statement取得的ResultSet就是可滚动的 J!TK*\a2
2、创建PreparedStatement时指定参数 B3g82dm
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 9-Nq[i"
ResultSet.absolute(9000); ,P; a/{U
批量更新 JK'_P}[]I
1、Statement HLyFyv\
Statement sm = cn.createStatement(); hAxuZb7 ?
sm.addBatch(sql1); ^&Rxui
sm.addBatch(sql2); T$N08aju#
... _QOOx+%*5
sm.executeBatch() Ymk4Cu.s
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 <>5:u
2、PreparedStatement OV@h$fg
PreparedStatement ps = cn.preparedStatement(sql); l]58P
{ Z+h70,|
ps.setXXX(1,xxx); ja,L)b:
... p#8LQP~0$
ps.addBatch(); P20]>Hg
} 0F0(]7g^
ps.executeBatch(); %]:vT&M
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 ^?S@v1~7d
>I66R;
事务的处理 pg& ]F
1、关闭Connection的自动提交 ]Buk9LTe
cn.setAutoCommit(false); *l'$pJ X
2、执行一系列sql语句 /cg]wG!n8
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close $et
:
Statement sm ; @,>=X:7
sm = cn.createStatement(insert into user...); p TV@nP
sm.executeUpdate(); &T{B~i3w8
sm.close(); R82Zr@_
sm = cn.createStatement("insert into corp...); *O}'2Ht6\
sm.executeUpdate(); e5/DCz
sm.close(); V]S06>P
3、提交 ??e#E[bI
cn.commit(); JjTzq2'%
4、如果发生异常,那么回滚 pi l*/&pB
cn.rollback();