java 数据库基本操作 )21yD1"6
1、java数据库操作基本流程 _VvXE572
2、几个常用的重要技巧: vz{Z
tE"
可滚动、更新的记录集 ]Ak/:pu
批量更新 Zt3Y<3o
事务处理 }iOFB&)w
3rRN~$
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 +;@p'af!9
1、取得数据库连接 1$A7BP
1)用DriverManager取数据库连接 5;:P^[cH9
例子 eyUhMjd
String className,url,uid,pwd; P&3Z,f0
className = "oracle.jdbc.driver.OracleDriver"; ^seb8o7
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr;
OhNEt>
uid = "system"; OE{PP9eh
pwd = "manager"; ;|a,1#x
Class.forName(className); fWutB5?P
Connection cn = DriverManager.getConnection(url,uid,pwd); #.Q8q
2)用jndi(java的命名和目录服务)方式 kim qm
例子 %d%$jF`
String jndi = "jdbc/db"; Ug2^cgL
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ?G|*=-8
DataSource ds = (DataSource) ctx.lookup(jndi); v; =|-y
Connection cn = ds.getConnection(); hoJ{C 0
多用于jsp中 @'D ,T^I
2、执行sql语句 -D?-ctFYj^
1)用Statement来执行sql语句 u)NmjW
String sql; :h(r2?=7
Statement sm = cn.createStatement(); =zetZJg
sm.executeQuery(sql); // 执行数据查询语句(select) 0vi)my;!
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); =Su~iOa
2)用PreparedStatement来执行sql语句 0P?\eoB@8
String sql; N51g<K
sql = "insert into user (id,name) values (?,?)"; xoT|fgb
PreparedStatement ps = cn.prepareStatement(sql); e7# B?
ps.setInt(1,xxx); [H-r0Ah
ps.setString(2,xxx); G/y@`A)
... Y\Grf$e
ResultSet rs = ps.executeQuery(); // 查询 -n>JlfCd2
int c = ps.executeUpdate(); // 更新 B '@a36
{Xj2c]A1
3、处理执行结果 EKr#i}(x<
查询语句,返回记录集ResultSet FF} A_ZFY
更新语句,返回数字,表示该更新影响的记录数 j1Ng[
ResultSet的方法 xllk hD4F
1、next(),将游标往后移动一行,如果成功返回true;否则返回false <aScA`\B#
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 M@TXzn!&o
et-<ib<lY
4、释放连接 r=S6yq}
cn.close(); _--kK+rU
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection Gdi8Al]\Nl
koTb{U L
可滚动、更新的记录集 ~[wh
1、创建可滚动、更新的Statement JGZxNUr^
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); +DpiX&^h
该Statement取得的ResultSet就是可滚动的 6`V2-zv$
2、创建PreparedStatement时指定参数 li`4&<WGC
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 3Mlwq'pzD
ResultSet.absolute(9000); vwc)d{ND
批量更新 7y/Pch
1、Statement )|Il@unp/
Statement sm = cn.createStatement(); 8Ev,9
sm.addBatch(sql1); "&@v[O)!xu
sm.addBatch(sql2); &OXnZT3P
... )9PP3" I
sm.executeBatch() eG
F{.]
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 0}:wM':G
2、PreparedStatement |K7zN\
Wq
PreparedStatement ps = cn.preparedStatement(sql); }BR@vY'd
{ bAd$
>DI[
ps.setXXX(1,xxx); "c'K8,+?
... MT?;9ZV}
ps.addBatch(); ^o|Gx
} vz^w%67&
ps.executeBatch();
)ld !(d=
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 (mvzGXNz4
/8s+eHn&%
事务的处理 /4 Q^L>a
1、关闭Connection的自动提交 S,'y
L7s
cn.setAutoCommit(false); =Y-ZI
2、执行一系列sql语句 N8-!}\,
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close bq}hj Cy
Statement sm ; ^kF-mM=
sm = cn.createStatement(insert into user...); ?)2&LVrf
sm.executeUpdate(); D{Rk9MKkE
sm.close(); >&`S$1 o
sm = cn.createStatement("insert into corp...); m:sT)
sm.executeUpdate(); f(}AdW}?
sm.close(); FK:Tni
3、提交 -$Ad#Eu]M
cn.commit(); }ag
-J."5M
4、如果发生异常,那么回滚 "j]85
cn.rollback();