java 数据库基本操作 D~U RY_[A
1、java数据库操作基本流程 }qhYHC
2、几个常用的重要技巧: -aS@y.z
可滚动、更新的记录集 QB!_z4UJ_;
批量更新 3\
,t_6}
事务处理 c5b}q@nH
,\c V,$
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 i$Kx@,O8t
1、取得数据库连接 / o
I 4&W
1)用DriverManager取数据库连接 /3K)$Er
例子 19c_=$mV
String className,url,uid,pwd; l|E4 7@#
className = "oracle.jdbc.driver.OracleDriver"; >]ZE<.
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; P}UxA!
uid = "system"; H9_iTGBQ
pwd = "manager"; 2f@Cy+W'[
Class.forName(className); .`5|NUhN
Connection cn = DriverManager.getConnection(url,uid,pwd); UB~-$\.
2)用jndi(java的命名和目录服务)方式 9__B!vw:
例子 N6\rjYx+7
String jndi = "jdbc/db"; hf0(!C*
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); b;5j awG
DataSource ds = (DataSource) ctx.lookup(jndi); i*m;kWu,
Connection cn = ds.getConnection(); e&U$;sS`
多用于jsp中 g,!.`[e'ex
2、执行sql语句 H.E=m0np
1)用Statement来执行sql语句 OFyy!r@?
String sql; doHE]gC2Uz
Statement sm = cn.createStatement(); qe&B$3D|
sm.executeQuery(sql); // 执行数据查询语句(select) unew
XHA
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); r|DIf28MIq
2)用PreparedStatement来执行sql语句 g?Nk-cg
String sql; #asi%&3pP
sql = "insert into user (id,name) values (?,?)"; <tZZ]Y]
PreparedStatement ps = cn.prepareStatement(sql); R=D}([pi
ps.setInt(1,xxx); oH?:(S(
ps.setString(2,xxx); u)I\R\N
... |N%
l
at
ResultSet rs = ps.executeQuery(); // 查询 F[yofRN
int c = ps.executeUpdate(); // 更新 <!XunXh
oy5K*
}
3、处理执行结果 Skg/iH"(
查询语句,返回记录集ResultSet zow8 Q6f
更新语句,返回数字,表示该更新影响的记录数 V|kN 1
A
ResultSet的方法 &]RE 5!
1、next(),将游标往后移动一行,如果成功返回true;否则返回false %=9o'Y,4
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 X'
5R4j
@KU;'th
4、释放连接 1zH?.-
cn.close(); 'N+;{8C-{
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection g3&nxZ
:q*w_*w
可滚动、更新的记录集 K8MET&
1、创建可滚动、更新的Statement o5DT1>h
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ^>Z_3{s:$
该Statement取得的ResultSet就是可滚动的 1/w8'Kf'u
2、创建PreparedStatement时指定参数 h]t v+\0
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); %<a3[TQd`\
ResultSet.absolute(9000); { +w.Z,D"
批量更新 w9VwZow
1、Statement ?O#,{ZZf=
Statement sm = cn.createStatement(); z,x
)Xx
sm.addBatch(sql1); 9?hZf$z
sm.addBatch(sql2); jS[=Zx`
... Nr `R3(X
sm.executeBatch() 'uDx$AkY
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 Ui
(nMEon
2、PreparedStatement Fj~suZ`
PreparedStatement ps = cn.preparedStatement(sql); D6Aa5&rO+
{ =<p=?16
x
ps.setXXX(1,xxx); U'(zKqC
... 'G>XI;g
ps.addBatch(); IauLT;! X
} pC,[!>0g8
ps.executeBatch(); em3+V
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 Y* rujn{
b3R(O|
事务的处理 df@N V Ld
1、关闭Connection的自动提交 eT3!"+p-F
cn.setAutoCommit(false); [>54?4{|.
2、执行一系列sql语句 @9_mk@
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close {G x=QNd
Statement sm ; IAwS39B
sm = cn.createStatement(insert into user...); a`%`9GD
sm.executeUpdate(); d/OP+yzgZ
sm.close(); Z^%a 1>`
sm = cn.createStatement("insert into corp...); saiXFM7J
sm.executeUpdate(); 3w"JzC@
sm.close(); DMG'8\5C
3、提交 .Vnb+o
cn.commit(); RIXeV*ix
4、如果发生异常,那么回滚 |6bvUFr
cn.rollback();