java 数据库基本操作 */xI#G,O+
1、java数据库操作基本流程 K
!8+~[
2、几个常用的重要技巧: 3P Twpq1
可滚动、更新的记录集 |#R;pEn
批量更新 AoyU1MR(
事务处理 A@*P4E`xp
?@Z~i]gE[V
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 6"WR}S0o
1、取得数据库连接 d+~c$(M)
1)用DriverManager取数据库连接 {y<[1Pms
例子 ba|x?kz
String className,url,uid,pwd; N%6jZmKip
className = "oracle.jdbc.driver.OracleDriver"; @I}:HiF
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; T3Kq1
Rh
uid = "system"; DU$]e1
pwd = "manager"; 3?Y%|ZVM
Class.forName(className); K @"m0
Connection cn = DriverManager.getConnection(url,uid,pwd); n|NI]Qi*
2)用jndi(java的命名和目录服务)方式 N J:]jd
例子 mB;W9[
String jndi = "jdbc/db"; W5}.WFu
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); : Ey
DataSource ds = (DataSource) ctx.lookup(jndi); ~ $#DB@b
Connection cn = ds.getConnection(); KXcG;b[7n
多用于jsp中 N-jFA8n
2、执行sql语句 dW;{,Q
1)用Statement来执行sql语句 MdU_zY(c
String sql; #!h:w
Statement sm = cn.createStatement(); B$g!4C
`g
sm.executeQuery(sql); // 执行数据查询语句(select) al=Dy60|z
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); t-dN:1
2)用PreparedStatement来执行sql语句 00?^!';
String sql; 8gJ"7,}-'
sql = "insert into user (id,name) values (?,?)"; e`4OlM]
PreparedStatement ps = cn.prepareStatement(sql); Lcplc"C
ps.setInt(1,xxx); 65N;PH59D
ps.setString(2,xxx); 8^p/?R^bu
... e+bpbyV_#
ResultSet rs = ps.executeQuery(); // 查询 xZtA) Bp
int c = ps.executeUpdate(); // 更新 Ia)wlA02S
JoKD6Q1D
3、处理执行结果 \% &QIe;:k
查询语句,返回记录集ResultSet &of%;>$>M
更新语句,返回数字,表示该更新影响的记录数 W2tIt&{
ResultSet的方法 4a>z]&s
1、next(),将游标往后移动一行,如果成功返回true;否则返回false Y {Klwn
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 Gw!jYnU
?F*gFW_k
4、释放连接 s?=f,I
cn.close(); LGK0V!W
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection nE]R0|4h
QYVT"$=
可滚动、更新的记录集 T9{94Ra
1、创建可滚动、更新的Statement Vj0`*nC)/
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); N-3w)23*:
该Statement取得的ResultSet就是可滚动的 ]5x N^7_!j
2、创建PreparedStatement时指定参数 / !jd%,G
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ^ft_1 d[
ResultSet.absolute(9000);
?.|qRzWL
批量更新 |g> K$m^
1、Statement `iv,aQ '
Statement sm = cn.createStatement(); 93)&
sm.addBatch(sql1); )eY3[>`
sm.addBatch(sql2); S`K8e^]
... n0@e%=H)I
sm.executeBatch() nEQw6q~je
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 }_3<Q\j
2、PreparedStatement DDN#w<#
PreparedStatement ps = cn.preparedStatement(sql); %l,p />r
{ s4;SA
ps.setXXX(1,xxx); Z?G-~3]e
... 3tS~/o+]
ps.addBatch(); h<6@&yzp
} uV52ko,
ps.executeBatch(); zvdtP'&uj
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 ~k+-))pf
epW;]>
l
事务的处理 vxZvK0b620
1、关闭Connection的自动提交 o{
\cCZ"
cn.setAutoCommit(false); E>KV1P
2、执行一系列sql语句 -"\z|OQ
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close B:&/*HU
Statement sm ; fi:Z*-
sm = cn.createStatement(insert into user...); [US.n+G6
sm.executeUpdate(); op"RrZAZBT
sm.close(); 87>\wUJ
sm = cn.createStatement("insert into corp...); fHb0pp\[.
sm.executeUpdate(); -1:yqF.x
sm.close(); .^l;3*X@
3、提交 hR[Qdu6r
cn.commit();
xdXt
4、如果发生异常,那么回滚 |mc!v*O
cn.rollback();