java 数据库基本操作 B/u0^!
1、java数据库操作基本流程 ASME~]]?
2、几个常用的重要技巧: :I*G tq
可滚动、更新的记录集 T5(]/v,UT
批量更新 oVk*G
事务处理 uSh!A
hqOy*!8'@
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接
c]3% wL
1、取得数据库连接 Y?G\@6
1)用DriverManager取数据库连接 $ J}d6%
例子 @y?<Kv}s
String className,url,uid,pwd; 2~[f<N
className = "oracle.jdbc.driver.OracleDriver"; z=C'qF`
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ,5`pe%W7
uid = "system";
KKpO<TO
pwd = "manager"; xrb %-vT
Class.forName(className); Rrh?0qWs
Connection cn = DriverManager.getConnection(url,uid,pwd); \l)<NZ\
2)用jndi(java的命名和目录服务)方式 ODa+s>a`^
例子 g$+u;ER5
String jndi = "jdbc/db"; k1Cx~Q)XC
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); M| r6"~i
DataSource ds = (DataSource) ctx.lookup(jndi); M\\t)=q
Connection cn = ds.getConnection(); i
Lr*W#E
多用于jsp中 *9V;;bY#
2、执行sql语句 &-^|n*=g6
1)用Statement来执行sql语句 >b9nc\~
String sql; ]*b}^PQM^
Statement sm = cn.createStatement(); hwgLJY?
sm.executeQuery(sql); // 执行数据查询语句(select) ~a@O1MB
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 1 ?X(q
2)用PreparedStatement来执行sql语句 @n<y[WA
String sql; L,G{ t^j
sql = "insert into user (id,name) values (?,?)"; Ucnj7>+"
PreparedStatement ps = cn.prepareStatement(sql); Hjl{M>z
ps.setInt(1,xxx); qIE e7;DO
ps.setString(2,xxx); N0APX4j
... zGKDH=Yy ;
ResultSet rs = ps.executeQuery(); // 查询 ;:(kVdb
int c = ps.executeUpdate(); // 更新 2ZHeOKJ-
pe(31%(h
3、处理执行结果 \GA6;6%Oo
查询语句,返回记录集ResultSet %J)n#\
更新语句,返回数字,表示该更新影响的记录数 d#~^)r
ResultSet的方法 Oa7x(wS
1、next(),将游标往后移动一行,如果成功返回true;否则返回false =~;SUO
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 R1.No_`PHq
n27df9L
4、释放连接 :5 XNV6^|
cn.close(); v4_p3&aj
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection (Uk1Rt*h
eteq Mg}M
可滚动、更新的记录集 xDtq@Rb}
1、创建可滚动、更新的Statement zQY|=4NP
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Ph[P$: 9
该Statement取得的ResultSet就是可滚动的 rHhn)m
2、创建PreparedStatement时指定参数 ]WZ_~8
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); oq00)I1
ResultSet.absolute(9000); 8&?kr/_Vr
批量更新 Vq[L4
1、Statement GJlkEWs
Statement sm = cn.createStatement(); %4X#|22n
sm.addBatch(sql1); ;uw`6 KJ
sm.addBatch(sql2); wk
@-O}W
... eK]g FXk
sm.executeBatch() M#v#3:&5
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 gcLwQ-
2、PreparedStatement ;O8Uc&:P
PreparedStatement ps = cn.preparedStatement(sql); m e\S:
{ G)qNu }
ps.setXXX(1,xxx); V?KACYd@O
... ziFg+i%s
ps.addBatch(); M9mC\Iz[
} %3v:c|r
ps.executeBatch(); $@
/K/"
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 'k|?M
v9Kx`{1L
事务的处理 '2`MT-
1、关闭Connection的自动提交 \;"$Z9W
cn.setAutoCommit(false); Bvbv~7g(
2、执行一系列sql语句 i1ph{;C
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close &V.ps1
Statement sm ; F_8<
tA6
sm = cn.createStatement(insert into user...); .}KY*y
sm.executeUpdate(); 8J60+2Wa
sm.close();
5p9zl=mT
sm = cn.createStatement("insert into corp...); 8<cD+Jtj
sm.executeUpdate(); fBgW0o.Bu
sm.close(); V*an0@
3、提交 e_Cns&
cn.commit(); 8<z]rLQw?%
4、如果发生异常,那么回滚 ^4jIT1
cn.rollback();