java 数据库基本操作 B(7oHj.i2
1、java数据库操作基本流程 X]8(_[Y
2、几个常用的重要技巧: Q^prHn*@
可滚动、更新的记录集 aUa.!,_dh
批量更新 a$r-
U_?
事务处理 $nF|n+m
< aJl
i
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 qq.M]?Z
1、取得数据库连接 S[J eW
1)用DriverManager取数据库连接 WHeyE3}p
例子 !iA3\Ai"
String className,url,uid,pwd; CuC1s>
className = "oracle.jdbc.driver.OracleDriver"; a?S5 =
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; E-IV v
uid = "system"; N;4bEcWjp
pwd = "manager"; nF>41 K
Class.forName(className); kH~ z07:
Connection cn = DriverManager.getConnection(url,uid,pwd); m0QE
S
2)用jndi(java的命名和目录服务)方式 6!zBLIYFI
例子 )12.W=p
String jndi = "jdbc/db"; vT~ey
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); i)y8MlC{
DataSource ds = (DataSource) ctx.lookup(jndi); g xY6 M4
Connection cn = ds.getConnection(); 3}dTbr4y
多用于jsp中 i0Ejo;dB
2、执行sql语句 waI?X2
1)用Statement来执行sql语句 [p3{d\=*?
String sql; .a2b&}/.d
Statement sm = cn.createStatement(); (
m/ujz
sm.executeQuery(sql); // 执行数据查询语句(select) :B{Wf 2<z
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); lC/1,Z/M
2)用PreparedStatement来执行sql语句 |_."U9!Z^
String sql; 8C]K36q
sql = "insert into user (id,name) values (?,?)"; ze2%#<
PreparedStatement ps = cn.prepareStatement(sql); *N>n5B2
ps.setInt(1,xxx); b.I_
ps.setString(2,xxx); >*s_)IH2
... EP,j+^RVf
ResultSet rs = ps.executeQuery(); // 查询 X3e&c
int c = ps.executeUpdate(); // 更新 EyR~VKbJ'
W[c[ulY&
3、处理执行结果 c?5?TJpm
查询语句,返回记录集ResultSet %O6r
更新语句,返回数字,表示该更新影响的记录数 ! yqez
ResultSet的方法 "Vh3hnS~
1、next(),将游标往后移动一行,如果成功返回true;否则返回false p3r("\Za,
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 GsIVx!
6_|iXs(&
4、释放连接 R !g'zS'
cn.close(); yq. <,b=87
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection f~Y;ZvB
4`yE'%6.}
可滚动、更新的记录集 mi[t1cN)=
1、创建可滚动、更新的Statement OT0%p)
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); )5T82=[h<
该Statement取得的ResultSet就是可滚动的 wcH,!;3z+
2、创建PreparedStatement时指定参数 }uZ/^_U.
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); @$}Ct
ResultSet.absolute(9000); 4>^LEp
批量更新 `%QXaKO-
1、Statement M~%P1@%
Statement sm = cn.createStatement(); m`i_O0T
sm.addBatch(sql1); 88Nx/:#Y*
sm.addBatch(sql2); @)#EZQi x
... 5aj%<r
sm.executeBatch() I3gl+)Q
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 hL4T7`
2、PreparedStatement Hg&.U;n
PreparedStatement ps = cn.preparedStatement(sql); L0l'4RRm\
{
zh{,.c
ps.setXXX(1,xxx); {wy{L-X
... U#V&=~-
ps.addBatch(); cWtuI(.
} ES-V'[+jDy
ps.executeBatch(); T:T`M:C.
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 K|pg'VT"
[ Y+Ta,
事务的处理 !3F3E8%
1、关闭Connection的自动提交 Su/8P[q_
cn.setAutoCommit(false); {W+IUvn
2、执行一系列sql语句 vf&_
N
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close XHU\;TF
Statement sm ; vA3wn><
sm = cn.createStatement(insert into user...); dx@|M{jz'
sm.executeUpdate(); Mj&G5R~_
sm.close(); s$% t2UaV
sm = cn.createStatement("insert into corp...); Hr_5N,
sm.executeUpdate(); `j1oxJm
sm.close(); azz=,^U#
3、提交 \sMe2OL#z
cn.commit(); *\.8*6*$!
4、如果发生异常,那么回滚 rJZR8bo
cn.rollback();