java 数据库基本操作 $1k@O@F(4
1、java数据库操作基本流程 qga?-oz,<6
2、几个常用的重要技巧: D|'[ [=
可滚动、更新的记录集 FRayB VHL
批量更新 bE3mOml
事务处理 P5lk3Zg'
Ss\FSEN!/
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 g3(LDqB'.
1、取得数据库连接 WzBr1
ea{I
1)用DriverManager取数据库连接 SUjo%3R
例子 6S0Gjekr
String className,url,uid,pwd; XcL%0%`
className = "oracle.jdbc.driver.OracleDriver"; \(r$f!`
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; q*cEosi'F?
uid = "system"; f|~X}R
pwd = "manager"; Sar1NkD#
Class.forName(className); gq="&
Connection cn = DriverManager.getConnection(url,uid,pwd); S,vdd7Y
2)用jndi(java的命名和目录服务)方式 eK}GBBdO
例子 z:u)@>6D1
String jndi = "jdbc/db"; `Io#440;
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); Ns5P,[pBOZ
DataSource ds = (DataSource) ctx.lookup(jndi); ,
YlS
Connection cn = ds.getConnection(); tjx|;m7
多用于jsp中 eDvh3Y<D
2、执行sql语句 )RQQhB
1)用Statement来执行sql语句 _z9~\N/@[
String sql; J5Ti@(G5V
Statement sm = cn.createStatement(); vb}c)w
dp?
sm.executeQuery(sql); // 执行数据查询语句(select) :@-.whj
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); v 7%}ey[
2)用PreparedStatement来执行sql语句 ]ZNFrpq
String sql; dXsD%sG@
sql = "insert into user (id,name) values (?,?)"; DgB;6Wl
PreparedStatement ps = cn.prepareStatement(sql); :39arq
ps.setInt(1,xxx); 2IGU{&s
ps.setString(2,xxx); m7i(0jd
+
... po.QM/b
\
ResultSet rs = ps.executeQuery(); // 查询 U]g9t<jD
int c = ps.executeUpdate(); // 更新 |I{3~+E h
B![:fiR`
3、处理执行结果 *vq75k$7
查询语句,返回记录集ResultSet A;o({9VH`Z
更新语句,返回数字,表示该更新影响的记录数 y9w,Su2
ResultSet的方法 =YD<q:n4
1、next(),将游标往后移动一行,如果成功返回true;否则返回false N>1d]DrQR
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 E[4
vUnm-
a2/Mf
4、释放连接 ( GoPXh
cn.close(); O,S>6o)?
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection ?Mn~XN4F_
qk(bA/+e
可滚动、更新的记录集 4t3>`x
7
1、创建可滚动、更新的Statement /XU=l0u
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); +;M 5Sp
该Statement取得的ResultSet就是可滚动的 G5 RdytK
2、创建PreparedStatement时指定参数 iSg0X8J)
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); %5nEyZOq
ResultSet.absolute(9000); p(K^Zc
批量更新 yO,Jgn
1、Statement C[d1n#@r
Statement sm = cn.createStatement(); VL'wrgk
sm.addBatch(sql1); S4-jF D)U
sm.addBatch(sql2); zQ<;3+*
... xEeHQ7J
sm.executeBatch() .k
+>T*c{
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 {TdxsE>
2、PreparedStatement #,1z=/d.
PreparedStatement ps = cn.preparedStatement(sql); ?/-WH?1I
{ ]yL+lv
ps.setXXX(1,xxx); He}?\C
Bo
...
|=![J?
ps.addBatch(); [IAk9B.\
} >yHtGIHe-
ps.executeBatch(); rK`^A
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 J9DI(`
*c&OAL]
事务的处理 *X ;ch55\
1、关闭Connection的自动提交 lNtxM"G&
cn.setAutoCommit(false); x'..j5
2、执行一系列sql语句 K<`W>2"
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 'J5F+,\Ka
Statement sm ; @+Sr~:K
sm = cn.createStatement(insert into user...); U^% )BI
sm.executeUpdate(); $5&~gHc,
sm.close(); cMnN} '
sm = cn.createStatement("insert into corp...); 56.JBBZZ
sm.executeUpdate(); vqO#Z
sm.close(); |v5
ge3-
3、提交
N&kUTSd
cn.commit(); TW70z]B
4、如果发生异常,那么回滚 v ?}0h5
cn.rollback();