java 数据库基本操作 ]SPB c
1、java数据库操作基本流程 J~}UG]j n
2、几个常用的重要技巧: )s8r(.W
可滚动、更新的记录集 PWmz7*/
批量更新 68!]q(!6F
事务处理 y{"E)YY
vr vzV
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 68)^i"DM<
1、取得数据库连接 Ax%BnkU
1)用DriverManager取数据库连接 K@i*Nl
例子 iWCV(!
String className,url,uid,pwd; "5YdmBy
className = "oracle.jdbc.driver.OracleDriver"; ##5/%#eZ
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; O`u! P\
uid = "system"; bPOx~ CMh
pwd = "manager"; K+}Z6_:
Class.forName(className); W"*R#:Q
Connection cn = DriverManager.getConnection(url,uid,pwd); f8 jaMn9o
2)用jndi(java的命名和目录服务)方式 -hzza1DP
例子 4
* OU
String jndi = "jdbc/db"; Gw./qu-W
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); \1!k)PZdTW
DataSource ds = (DataSource) ctx.lookup(jndi); ;1dz?'%V
Connection cn = ds.getConnection(); /'1y`j<
多用于jsp中 v<SEGv-
2、执行sql语句 IBqY$K+l
1)用Statement来执行sql语句 k$c
j|-<
String sql; gctaarB&
Statement sm = cn.createStatement(); Cm4*sN.&)
sm.executeQuery(sql); // 执行数据查询语句(select) A1q^E(}O
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); P&GZe/6Y
2)用PreparedStatement来执行sql语句 #SYWAcTkO}
String sql; M BT-L
sql = "insert into user (id,name) values (?,?)"; ^55?VQB
PreparedStatement ps = cn.prepareStatement(sql); m@@QT<
ps.setInt(1,xxx); HFr3(gNj@
ps.setString(2,xxx); Wy4^mOv
... >S!DIL
ResultSet rs = ps.executeQuery(); // 查询 E1C_d'
int c = ps.executeUpdate(); // 更新 NM@An2
)
b10%n^
3、处理执行结果 [*G2wP[$
查询语句,返回记录集ResultSet Fjzk;o
更新语句,返回数字,表示该更新影响的记录数 @>]3xHE6#=
ResultSet的方法 ~D5MAEazS
1、next(),将游标往后移动一行,如果成功返回true;否则返回false q(7D8xG;F
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 :/NN=3e
/;4MexgB%
4、释放连接 [Mz;:/
cn.close(); {H V,2-z
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection RuZ;hnE&
='0!B]<G
可滚动、更新的记录集 vR$5ItnT
1、创建可滚动、更新的Statement ? st#6=M
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 0I((UA/7Zs
该Statement取得的ResultSet就是可滚动的 kKM%
2、创建PreparedStatement时指定参数 b..$5
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); Z-|C{1}A
ResultSet.absolute(9000); \DqxS=o;
批量更新 vI'>$
1、Statement ~-`02
Statement sm = cn.createStatement(); CK(ev*@\D,
sm.addBatch(sql1); ?6d4T
sm.addBatch(sql2); V+24- QWh
... QNXxpoS#
sm.executeBatch() 8~E)gV+v
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ;#9|l=
2、PreparedStatement MPbPq3an
PreparedStatement ps = cn.preparedStatement(sql); (OB8vTRXP
{ r6JkoPMh
ps.setXXX(1,xxx); 8>q%1]X
... P@YL.'KU)
ps.addBatch(); +
nS/jW
} v{ n}%akc
ps.executeBatch(); =-LX)|x}
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 >8fH5
1omvE9
%zM
事务的处理 .4> s2
1、关闭Connection的自动提交 &.hRVW(
cn.setAutoCommit(false); |"qB2.[
2、执行一系列sql语句 ~C'nBV
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close FH8mK)
Statement sm ; #<Nvy9
sm = cn.createStatement(insert into user...); NCnId}BT
sm.executeUpdate(); hxVM]e[
sm.close(); WN+Jf
sm = cn.createStatement("insert into corp...); _|3TC1N$n
sm.executeUpdate(); ACO4u<M)
sm.close(); VtiqAh}4
3、提交
IB{ZE/
cn.commit(); WV1 Z
4、如果发生异常,那么回滚 |HGb.^f?
cn.rollback();