java 数据库基本操作 X9ZHYlr+Q
1、java数据库操作基本流程 4:-x!lt
2、几个常用的重要技巧: 7ug"SV6Hb
可滚动、更新的记录集 HLOrDlj7
批量更新 f;AI4:#I
事务处理 7hTpjox2
Jy\0y[f*
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 R9!U _RH
1、取得数据库连接 u /]P
1)用DriverManager取数据库连接 V~p01f"J
例子 ln+.=U6Tm
String className,url,uid,pwd; KA{&NFx
className = "oracle.jdbc.driver.OracleDriver"; *<X1M~p$
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ',K:.$My
uid = "system"; `So/G
pwd = "manager"; h8X[*Wme
Class.forName(className); XwFTAaZ
Connection cn = DriverManager.getConnection(url,uid,pwd); .]s? 01Z
2)用jndi(java的命名和目录服务)方式 b$yIM
例子 -DK6(<:0
String jndi = "jdbc/db"; r8?p6E
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); }xBDyr63
DataSource ds = (DataSource) ctx.lookup(jndi); bN7m[GRO.
Connection cn = ds.getConnection(); 6VVxpDAi:
多用于jsp中 (Gw*xsn 1
2、执行sql语句 c@Br_-
1)用Statement来执行sql语句 .$7RF!p
String sql; +Gg|BTTL/
Statement sm = cn.createStatement(); ~_Fx2T:X
sm.executeQuery(sql); // 执行数据查询语句(select) _VVq&t}
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); _",<at
2)用PreparedStatement来执行sql语句 l i)6^f#
String sql; Il Qk W<
sql = "insert into user (id,name) values (?,?)"; ;S
\s&. u
PreparedStatement ps = cn.prepareStatement(sql); W@ &a
ps.setInt(1,xxx); 0KTO)K
ps.setString(2,xxx); @_?2iN?4Z
... ar#73f
ResultSet rs = ps.executeQuery(); // 查询 )z\#
int c = ps.executeUpdate(); // 更新 c BZ,"kp-
kDDC@A $
3、处理执行结果 \Oq8kJ=
查询语句,返回记录集ResultSet #4./>}G
更新语句,返回数字,表示该更新影响的记录数 ,
^K.J29
ResultSet的方法 c?e-2Dp(
1、next(),将游标往后移动一行,如果成功返回true;否则返回false x"g)pGsT
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 S3l^h4
=yz"xWH
4、释放连接 #:+F
cn.close();
ti (Hx
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 57EX#:a
w%s];EE
可滚动、更新的记录集 :L@n(buRN
1、创建可滚动、更新的Statement tcT=a@
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); '(rD8 pc
该Statement取得的ResultSet就是可滚动的 r7oFG!.?
2、创建PreparedStatement时指定参数 }8"
|q3k
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); a6j& po
ResultSet.absolute(9000); VnVBA-#r|
批量更新 ^3BPOK[*gB
1、Statement Jx~H4y=z
Statement sm = cn.createStatement(); .|^Gde
sm.addBatch(sql1); l)*(UZ"
sm.addBatch(sql2); |Q%P4S"B?
... l cHf\~
sm.executeBatch() ZnRT$ l O
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有
*Z^`H!&
2、PreparedStatement 5{oc
PreparedStatement ps = cn.preparedStatement(sql); }oA>0Nw$K
{ JRw,${W
ps.setXXX(1,xxx); KILX?Pt[7
... !p).3Kx0
ps.addBatch(); eG1V:%3
} )~)l^0X
ps.executeBatch(); hNsi
8/
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 `MCiybl,&P
*U,JQ
事务的处理 NS2vA>n8R
1、关闭Connection的自动提交 vQyY
%
cn.setAutoCommit(false); Vx2/^MiXy
2、执行一系列sql语句 JPAjOcmU/
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close g i6s+2
Statement sm ; fs 2MYat
sm = cn.createStatement(insert into user...); l=p_
sm.executeUpdate(); 4NW!{Vw ,
sm.close(); 'E9{qPLk(
sm = cn.createStatement("insert into corp...); h{iuk3G`h6
sm.executeUpdate(); wpuK?fP
sm.close(); 6ICW>#fI`
3、提交 !#_2 ![
cn.commit(); 'mbLK#q
4、如果发生异常,那么回滚 hdCd:6
cn.rollback();