java 数据库基本操作 B@@j-
1、java数据库操作基本流程 "}'Sk(
2、几个常用的重要技巧: Q]NGd 0 J
可滚动、更新的记录集 <=7N2t)s4
批量更新 K`% I!Br
事务处理 @!zT+W&
cA]Ch>]A%
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 >(:b\*C
1、取得数据库连接 Pu7cL
1)用DriverManager取数据库连接 At=l>
例子 2W]y9)<c
String className,url,uid,pwd; qtLXdSc
className = "oracle.jdbc.driver.OracleDriver"; jYi{[**
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; iJD_qhd7
uid = "system";
}j /r
pwd = "manager"; Q($aN-
Class.forName(className); 2lm{: tS
Connection cn = DriverManager.getConnection(url,uid,pwd); *N|s+
2)用jndi(java的命名和目录服务)方式 Gaxa~?ek
例子
a{%]X(';
String jndi = "jdbc/db"; Y^P'slY{%
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); oHI/tS4
_
DataSource ds = (DataSource) ctx.lookup(jndi); ]psx\ZMa
Connection cn = ds.getConnection(); e:H9!
多用于jsp中 ?=X_a{}/
2、执行sql语句 maopr$r
1)用Statement来执行sql语句 &$
/}HND
String sql; z`Cq,Sz/
Statement sm = cn.createStatement(); 1=X"|`<!
sm.executeQuery(sql); // 执行数据查询语句(select) B{+ Ra
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 70&]nb6f
2)用PreparedStatement来执行sql语句 ]\_T
String sql; K9+C3"*I
sql = "insert into user (id,name) values (?,?)"; ,BCo/j
PreparedStatement ps = cn.prepareStatement(sql); +m8gS;'R4
ps.setInt(1,xxx); N>J"^ GX
ps.setString(2,xxx); ={a_?l%
... m;]glAtt
ResultSet rs = ps.executeQuery(); // 查询 ,J0BG0jB^u
int c = ps.executeUpdate(); // 更新 wRi` L7
xHMbtY
3、处理执行结果 K@PQLL#yJp
查询语句,返回记录集ResultSet :x<'>)6
更新语句,返回数字,表示该更新影响的记录数 kW=GFj)L
ResultSet的方法 r+WY7'c
1、next(),将游标往后移动一行,如果成功返回true;否则返回false >S:>_&I`I
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 o>' 1ct
]{<`W5b/
4、释放连接 ]2Q:&T
cn.close(); yHL5gz@k
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection }7H8Y}m
3h|:ew[
可滚动、更新的记录集 bkgJz+u
1、创建可滚动、更新的Statement P5*~Wi`
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Ydr/ T/1
该Statement取得的ResultSet就是可滚动的 \dz@hJl:
2、创建PreparedStatement时指定参数 eHjn<@
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ~yvOR`2Gg
ResultSet.absolute(9000); i@C$O.m(
批量更新 D/&^Y'|T
1、Statement <
<vE .
Statement sm = cn.createStatement(); lV0\UySH
sm.addBatch(sql1); NHCdf*
sm.addBatch(sql2); -OS&(7
... k'K&GF1B
sm.executeBatch() '`*{ig
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 Pkbx/\
2、PreparedStatement oe:@7stG
PreparedStatement ps = cn.preparedStatement(sql); @!:~gQ
{ 2AAZZx +$
ps.setXXX(1,xxx); De(\<H#
... Hi 1@
ps.addBatch(); domaD"C
} -K_p?
l
ps.executeBatch(); <6s?M1J
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 BWct0=
>7VOytc
事务的处理 W5_:Q@
1、关闭Connection的自动提交 xjOj1Hv
cn.setAutoCommit(false); rK%A=Q
2、执行一系列sql语句 '$3]U5KOwK
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close exqFwmhh
Statement sm ; %Hk9.1hn5
sm = cn.createStatement(insert into user...); x}W,B,q
sm.executeUpdate(); %\
i 7
sm.close(); ZgcJxWC<
sm = cn.createStatement("insert into corp...); lKd+,<
sm.executeUpdate(); \P;%fN
sm.close(); aF9p%HPDw
3、提交 ?_L)|:WL
cn.commit(); {/C
\GxH+
4、如果发生异常,那么回滚 5xm^[o2#y
cn.rollback();