java 数据库基本操作 X?$Eb
1、java数据库操作基本流程 G\h8j*o
2、几个常用的重要技巧: bj`cYL%
可滚动、更新的记录集 ]!H*oP8a*
批量更新 ,
6\i
事务处理 THQW8 V
oMda)5 &
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 {B|U8j[
1、取得数据库连接 S4<@ji
1)用DriverManager取数据库连接 &:L8; m
例子 P,AS`=z
String className,url,uid,pwd; <Xw 6m$fr:
className = "oracle.jdbc.driver.OracleDriver"; z2t;!]"'l
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; 18w[T=7)
uid = "system"; ?zUV3Qgzj
pwd = "manager"; mh44
Class.forName(className); bf3LNV|
Connection cn = DriverManager.getConnection(url,uid,pwd); `u:U{m
2)用jndi(java的命名和目录服务)方式 [K13Jy+
例子 `{I,!to
String jndi = "jdbc/db"; .^#{rk
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 'N=' B<^;%
DataSource ds = (DataSource) ctx.lookup(jndi); hX)r%v:
Connection cn = ds.getConnection(); =pWpHbB.
多用于jsp中 /0SG
2、执行sql语句 &{&lCBN
1)用Statement来执行sql语句 a[s%2>e
String sql; =YA%=
d_
Statement sm = cn.createStatement(); 'DsfKR^s
sm.executeQuery(sql); // 执行数据查询语句(select) &0f7>.y
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); [k-7Kq
2)用PreparedStatement来执行sql语句 8q7KqYu
String sql; <t]c'
sql = "insert into user (id,name) values (?,?)"; %H<w.]>
PreparedStatement ps = cn.prepareStatement(sql); _KmpC>J+
ps.setInt(1,xxx); eJ{"\c(
ps.setString(2,xxx); K *vNv4
... /Re1QS
ResultSet rs = ps.executeQuery(); // 查询 UkNC|#l)
int c = ps.executeUpdate(); // 更新 G+[>or}
aC3\Hs
3、处理执行结果 ThWZ>hyJ
查询语句,返回记录集ResultSet ?O4Dhu
更新语句,返回数字,表示该更新影响的记录数 ~\<ZWU<BE
ResultSet的方法 ^.kas7<
1、next(),将游标往后移动一行,如果成功返回true;否则返回false qa^x4xZM
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ;~~Oc
spO?5#
4、释放连接 o~P8=1t
cn.close(); b{sE#m%r
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 1:YDN.*
s>~&:GUwR
可滚动、更新的记录集 9[T#uh!DC
1、创建可滚动、更新的Statement JPQ02&e
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Xki/5roCQ|
该Statement取得的ResultSet就是可滚动的 (/"T=`3t
2、创建PreparedStatement时指定参数 q*{"6"4(
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); UMhM8m!=o
ResultSet.absolute(9000); &[*<>
批量更新 08k1 w,6W
1、Statement *B:{g>0
Statement sm = cn.createStatement(); 7M;Y#=sR
sm.addBatch(sql1); 8x,;B_Zu
sm.addBatch(sql2); 9U}EVpD
... (-dJ0!
sm.executeBatch() qwFn(pK[
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 m$LZ3=v%8
2、PreparedStatement W\~ZmA.
PreparedStatement ps = cn.preparedStatement(sql); "r"]NyM
{ T>f-b3dk
ps.setXXX(1,xxx); )STt3.
... Z/-%Eb]L1
ps.addBatch(); \
vJ*3H6
} ^"buF\3L
ps.executeBatch(); Bl`e+&b
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 6w1:3~a
#i2q}/w5`C
事务的处理 :L`z~/6
1、关闭Connection的自动提交 2~J|x+
cn.setAutoCommit(false); :+Dn]:\
2、执行一系列sql语句 KAsS= `
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close KMbBow3o*~
Statement sm ; 1~7y]d?%
sm = cn.createStatement(insert into user...); *"zE,Bp"
sm.executeUpdate();
iI
^{OD
sm.close(); +Z;0"'K'e
sm = cn.createStatement("insert into corp...); +'#d*r91@
sm.executeUpdate(); STOE=TC>
sm.close(); Q ^ 39Wk@
3、提交 IwH
,g^0\
cn.commit(); Be]o2N;J
4、如果发生异常,那么回滚 GtGToI
cn.rollback();