java 数据库基本操作 aoS]Qp
1、java数据库操作基本流程 O7\)C]A
2、几个常用的重要技巧: Z|a\rNv
可滚动、更新的记录集 parC~)b_
批量更新 9{5 c}bX
事务处理 /'0,cJnm
dM3V2TT
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 0B[eG49
1、取得数据库连接 sTGe=}T8
1)用DriverManager取数据库连接 /yj-^u\R
例子 7Om)uUjU4
String className,url,uid,pwd; P;!4 VK
className = "oracle.jdbc.driver.OracleDriver"; QprzlxB
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; <jRs/?1R
uid = "system"; G q
r(.
pwd = "manager"; ]qk/V:H:
Class.forName(className); 4 4kb
Connection cn = DriverManager.getConnection(url,uid,pwd); P1mPC
2)用jndi(java的命名和目录服务)方式 _G5MQ%z
例子 yy-\$<j
String jndi = "jdbc/db"; +qEvz<kch
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); #]5|Qhrr+
DataSource ds = (DataSource) ctx.lookup(jndi); WS)u{
or
Connection cn = ds.getConnection(); yi/jZX
多用于jsp中 U[8Cg
2、执行sql语句 ps6c>AN`A&
1)用Statement来执行sql语句 Ctxx.MM
String sql; DeTZl+qm1E
Statement sm = cn.createStatement(); e/h7x\Z
sm.executeQuery(sql); // 执行数据查询语句(select) [{B1~D-
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); C&ivjFf
2)用PreparedStatement来执行sql语句 v`$9;9
String sql; WtTwY8HC
sql = "insert into user (id,name) values (?,?)"; P'6(HT>F?
PreparedStatement ps = cn.prepareStatement(sql); ~ ]q^Akq
ps.setInt(1,xxx); 'E,Bl]8C5
ps.setString(2,xxx); kM\O2ay
... tEl4 !vA
ResultSet rs = ps.executeQuery(); // 查询 lYu1m
int c = ps.executeUpdate(); // 更新 GX
lFS#`
'yM )>]u"
3、处理执行结果 -j_J1P0,
查询语句,返回记录集ResultSet 8}W06k>)%
更新语句,返回数字,表示该更新影响的记录数 :1wMGk
ResultSet的方法 #YSUPO%F
1、next(),将游标往后移动一行,如果成功返回true;否则返回false s:/.:e_PU
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 :22IY>p
2;`"B|-T
4、释放连接 1H_#5hd
cn.close(); 9{bzxM
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection U{>eE8l
3rZ" T
可滚动、更新的记录集 otO6<%/m
1、创建可滚动、更新的Statement ]Zim8^n?`.
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); hexq]' R
该Statement取得的ResultSet就是可滚动的 +mT}};-TS
2、创建PreparedStatement时指定参数 xW,(d5RtZ
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); )Cz^Xp)#
ResultSet.absolute(9000); >cD+&h34
批量更新 'gojP
1、Statement _ QM
Statement sm = cn.createStatement();
l%A~3
sm.addBatch(sql1); }x1mpPND
sm.addBatch(sql2); Sn/~R|3XA7
... G JItGq`)
sm.executeBatch() '.@R_sj
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 j]<T\O>t>
2、PreparedStatement 0\jOg
PreparedStatement ps = cn.preparedStatement(sql); t?]6>J_V
{ %Ys>PzM
ps.setXXX(1,xxx); ]Nvtiw 6
... 0n,5"B
ps.addBatch(); ^>ca*g
} v}]x>f
ps.executeBatch(); v[6 BESu
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 b~b(Ed{r
<5(8LMF
事务的处理 0{Kl5>Z9M
1、关闭Connection的自动提交 ,\DB8v6l\A
cn.setAutoCommit(false); tGd<{nF% 2
2、执行一系列sql语句 |b/J$.R
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 38Z"9
Statement sm ; =3oz74O[
sm = cn.createStatement(insert into user...); 7-ba-[t#A
sm.executeUpdate(); 9VN@M
sm.close(); h ;5
-X7
sm = cn.createStatement("insert into corp...); +c\s%Gzrh
sm.executeUpdate(); "ngYh]Git$
sm.close(); KW&&AuPb}
3、提交 WytCc>oL
cn.commit(); n a2"Sy=Yi
4、如果发生异常,那么回滚 -H`G6oMOO
cn.rollback();