java 数据库基本操作 "q]r{0
1、java数据库操作基本流程 1"fbQ^4`
2、几个常用的重要技巧: 4Q?3gA1
可滚动、更新的记录集 ?.~hex#M@
批量更新 = lMs1}S9
事务处理 ,3,(/%=k
7i##g,
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 LDgGVl
1、取得数据库连接 K^Ixu~
1)用DriverManager取数据库连接 6V&HlJH
例子 c?t,,\o(}
String className,url,uid,pwd; rYfN
className = "oracle.jdbc.driver.OracleDriver"; +#RqQ8\
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; K)&oDwk
uid = "system"; L3J .Oh
pwd = "manager"; YcdT/
Class.forName(className); }1BpIqee
Connection cn = DriverManager.getConnection(url,uid,pwd); 2PDU(R
2)用jndi(java的命名和目录服务)方式 d8Sr,t+
例子 y3Q2d7G
String jndi = "jdbc/db"; n1Fp$9%
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ;Ob`B@!=b
DataSource ds = (DataSource) ctx.lookup(jndi); qZB}}pM#
Connection cn = ds.getConnection(); grZ?F~P8
多用于jsp中 I=c}6
2、执行sql语句 !)//b]
1)用Statement来执行sql语句 TD^w|U.
String sql; !WgVk7aP`
Statement sm = cn.createStatement(); C#oH7o+_.
sm.executeQuery(sql); // 执行数据查询语句(select) P+gYLX8
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); N6<G`k,
2)用PreparedStatement来执行sql语句 \ sc's7
String sql; >mCS`D8
sql = "insert into user (id,name) values (?,?)"; egn9O
PreparedStatement ps = cn.prepareStatement(sql); i7jI(VvB^
ps.setInt(1,xxx); "bmWr)
ps.setString(2,xxx); V6a+VfH
... @A1Ohl
ResultSet rs = ps.executeQuery(); // 查询 f2,\B6+
int c = ps.executeUpdate(); // 更新 H6V!W\:s
+AkMU|6
3、处理执行结果 bPMkBm
查询语句,返回记录集ResultSet h7
c
更新语句,返回数字,表示该更新影响的记录数 .[:2M9Rx
ResultSet的方法 bKac?y~S_
1、next(),将游标往后移动一行,如果成功返回true;否则返回false v[!ZRwk4w3
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 #Nv)SCc
BW{&A&j
4、释放连接 ) mh,F#"L
cn.close(); jr3FDd]
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 3v,Bg4[i
?L(y8b}F(
可滚动、更新的记录集 YJqbA?i
1、创建可滚动、更新的Statement .]y"04@]
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ){FXonVP
该Statement取得的ResultSet就是可滚动的 u0i;vO)MNt
2、创建PreparedStatement时指定参数 w<$0n#5
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); v?<Tkw ^F
ResultSet.absolute(9000); "3e1 7dsY
批量更新 *<#$B}!{
1、Statement IRY/0v
Statement sm = cn.createStatement();
.H7xG'$
sm.addBatch(sql1); p`T,VU&.
sm.addBatch(sql2); P+(q38f[
... jImw_Q
sm.executeBatch() N}X7g0>hV
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 %WO4uOi:@
2、PreparedStatement pUm|e5
PreparedStatement ps = cn.preparedStatement(sql); ]]!&>tOlI
{ !J k|ha~r
ps.setXXX(1,xxx); Wo,"$Z6B
... y%@C-:
ps.addBatch(); ;pVnBi
} _2wH4^Vb
ps.executeBatch(); Cw,;>>Y_b<
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 4u+4LB*
9 6j*F,{
事务的处理 M 0Vs9K=
1、关闭Connection的自动提交 Ns5'K^
cn.setAutoCommit(false); Q/y"W,H#
2、执行一系列sql语句 ]v|n'D-?
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close V4tObZP3Ff
Statement sm ; AB[#
sm = cn.createStatement(insert into user...); ^7-l<R[T
sm.executeUpdate(); @*"H{xo.U
sm.close(); "Wn8}T*
sm = cn.createStatement("insert into corp...); V)#rP?Y
sm.executeUpdate(); L3|~
i&k
sm.close(); #:M <<gk
3、提交 D?`|`Mu
cn.commit(); !6pE0(V^+4
4、如果发生异常,那么回滚 1qN+AT
cn.rollback();