java 数据库基本操作 5Ug.J{d
1、java数据库操作基本流程 2QwdDKMS_
2、几个常用的重要技巧: L{y%\:]
可滚动、更新的记录集 u0M[B7Q
批量更新 ?+-uF}
事务处理 nNNs3h(Ss
<SeK3@Gi
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 =0,:w(Sb!
1、取得数据库连接 v'`VyXetl
1)用DriverManager取数据库连接 hM~9p{O
例子 2pR+2p`
String className,url,uid,pwd; :o$k(X7a
className = "oracle.jdbc.driver.OracleDriver"; eSvS<\p
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; b77Iw%x7
uid = "system"; &NbhQY`k
pwd = "manager"; |F)BKo D
Class.forName(className);
ismx evD
Connection cn = DriverManager.getConnection(url,uid,pwd); E^kB|; Ki
2)用jndi(java的命名和目录服务)方式 0XV8B
例子 ,PH ;j_
String jndi = "jdbc/db"; OwXw9
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ``*iK
DataSource ds = (DataSource) ctx.lookup(jndi); S<do.{|p[
Connection cn = ds.getConnection(); =6FA(R|QU
多用于jsp中 .U.Knn
2、执行sql语句 &''lOS|
1)用Statement来执行sql语句 3^m0 k
E
String sql; Pf`HF|NI
Statement sm = cn.createStatement(); o6L eC*
sm.executeQuery(sql); // 执行数据查询语句(select) ~DYUI#x
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); i("ok
2)用PreparedStatement来执行sql语句 f'
|JLhs
String sql; TEQs\d
sql = "insert into user (id,name) values (?,?)"; O$d z=)
PreparedStatement ps = cn.prepareStatement(sql); VF8pH<
ps.setInt(1,xxx); {%g]Ym=
ps.setString(2,xxx); tkT:5O6
... zN2CI6
ResultSet rs = ps.executeQuery(); // 查询 ~qFuS933
int c = ps.executeUpdate(); // 更新 gaFOm9y.e
?N*m2rv
3、处理执行结果 M7U:UV)
查询语句,返回记录集ResultSet BYj Eo
更新语句,返回数字,表示该更新影响的记录数 | Q0Wv8/
ResultSet的方法 DIrQ5C
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 3 !W
M'i
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 %K0
H?^.
F@ Sw
4、释放连接 FbH
1yz
cn.close();
DZPg|*KT
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection \NE~k)`4j%
^{f^%)X
可滚动、更新的记录集 3d<Z##`{4
1、创建可滚动、更新的Statement *F:f\9
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 7p"4rL
该Statement取得的ResultSet就是可滚动的 '3B"@^]
2、创建PreparedStatement时指定参数 ft |W
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); p6)Jzh_/
ResultSet.absolute(9000); ]70V
批量更新 )4h4ql W
1、Statement Jz"Yb
Statement sm = cn.createStatement(); Rr>nka)U
sm.addBatch(sql1); [ PXv8K%]p
sm.addBatch(sql2); Uwj|To&QR
... Y!!w*G9b
sm.executeBatch() :SBB3G)|
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 h=<x%sie
2、PreparedStatement mdzUL
d5J
PreparedStatement ps = cn.preparedStatement(sql); W(~7e?fO
{ C/34K(
ps.setXXX(1,xxx); bU$4"_eA
B
... eK8y'VY
ps.addBatch(); "{TVd>9_
} ~`Uil=
ps.executeBatch(); IR_&dWHyc
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 cp| q
/6Bm
<k%
事务的处理 r}?uZ"]=?
1、关闭Connection的自动提交 PBkTI2 v
cn.setAutoCommit(false); i
n$~(+
2、执行一系列sql语句 pNt,RRoR
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close "rHcsuSEw
Statement sm ; 4i]h0_]
sm = cn.createStatement(insert into user...); t4Q&^AC
sm.executeUpdate(); &YiUhK
sm.close(); SM?rss.=
sm = cn.createStatement("insert into corp...); c&>S
sm.executeUpdate(); l$1
]
sm.close(); 5/w4[d
3、提交 86 $88`/2
cn.commit(); T?lp:~d
4、如果发生异常,那么回滚 <m"fzT<"
cn.rollback();