java 数据库基本操作 Vt$ $ceu
1、java数据库操作基本流程 [8om9 Z3
2、几个常用的重要技巧: Ri%Of:zZ
可滚动、更新的记录集 s]V{}bY`
批量更新 k^vmRe<lk
事务处理 *(XgUJq+
XQJV.SVS
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 *SAcH_I2$>
1、取得数据库连接 G1n>@Y'j''
1)用DriverManager取数据库连接 6=[ PJM
例子 aV92.Z_Ku
String className,url,uid,pwd; 'KW+Rr~tZn
className = "oracle.jdbc.driver.OracleDriver"; %Tm'aY"
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; oeU+?-y/b
uid = "system"; _tg3%X]
pwd = "manager"; R.n`R|NOd
Class.forName(className); :;gwdZ
Connection cn = DriverManager.getConnection(url,uid,pwd); )I0g&e^Tzy
2)用jndi(java的命名和目录服务)方式
=}1~~
例子 Snvj9Nr
String jndi = "jdbc/db"; ='l6&3X
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); :fMM-?s]
DataSource ds = (DataSource) ctx.lookup(jndi); >+W?!9[p:2
Connection cn = ds.getConnection(); }e;p8)]Wl
多用于jsp中 uma9yIk
2、执行sql语句 *Sp O|*'
1)用Statement来执行sql语句 4h2bk\z-
String sql; ~m"M#1,ln3
Statement sm = cn.createStatement(); hc~#l #
sm.executeQuery(sql); // 执行数据查询语句(select) l>Oe ,`9O
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); \?Oa}&k$F8
2)用PreparedStatement来执行sql语句 @%okaj#IO
String sql; Xwn|.
sql = "insert into user (id,name) values (?,?)"; (>/Dw|,m
PreparedStatement ps = cn.prepareStatement(sql); <H(AS'
ps.setInt(1,xxx); Z_TbM^N
ps.setString(2,xxx); z@40g)R2A
... _a02#
ResultSet rs = ps.executeQuery(); // 查询 ;Q%19f3,6
int c = ps.executeUpdate(); // 更新 ,@j&q
vskM;
3、处理执行结果 ?_`P;}4#
查询语句,返回记录集ResultSet $[9V'K
更新语句,返回数字,表示该更新影响的记录数 Ymh2qGcj]8
ResultSet的方法 |x~ei_x7.p
1、next(),将游标往后移动一行,如果成功返回true;否则返回false kKTED1MW&W
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 So0,)
~8qFM
4、释放连接 >w'?DV>u|
cn.close(); GVPEene
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection !N2 n@bo
4rCqN.J
可滚动、更新的记录集 v6(l#,
1、创建可滚动、更新的Statement {d5ur@G1
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); AZm)$@e)
该Statement取得的ResultSet就是可滚动的 t7&
GCZ
2、创建PreparedStatement时指定参数 yvnrZ&x:
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); c;fyUi
ResultSet.absolute(9000); o]k]pNO
批量更新 [aVJYr2
1、Statement G?X,Y\Lp
Statement sm = cn.createStatement(); BJ;c F"Kp
sm.addBatch(sql1); #pxet
sm.addBatch(sql2); 9(\N+
... X|0`$f
sm.executeBatch() jT_Tx\k
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 gf8U &;
2、PreparedStatement )=y6s^}
PreparedStatement ps = cn.preparedStatement(sql); 8J@OMW&[l
{ IOsDVIXL\
ps.setXXX(1,xxx); 7o%|R2mL}
... [\y>&"uk
ps.addBatch(); (4gQe6tA
} Aba%Gh
ps.executeBatch(); >LZ)<-Mk
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 `9NnL.w!
" ~hj B
事务的处理 mAERZ<I
1、关闭Connection的自动提交 i(#c
Yb
cn.setAutoCommit(false); b-gVRf#F
2、执行一系列sql语句 Q>Q}/{8!
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close .EELR]`y7I
Statement sm ; Fi}rv[`XY[
sm = cn.createStatement(insert into user...); n Fn`>kQ
sm.executeUpdate(); 9E*K44L/V
sm.close(); %HS!^j3C%
sm = cn.createStatement("insert into corp...); '%7]xp
sm.executeUpdate(); &xT~;R^
sm.close(); c.> (/
3、提交 $+N^ s^
cn.commit(); T`G"2|ISS
4、如果发生异常,那么回滚 M- A}(r +J
cn.rollback();