java 数据库基本操作 aeg5ij-]u@
1、java数据库操作基本流程 fXL$CgXG\x
2、几个常用的重要技巧: {E@@14]g
可滚动、更新的记录集 b@,w/Uw[*
批量更新 y_a~>S
事务处理 v1;`.PWD
S__ o#nf`%
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 'av
OQj]`K
1、取得数据库连接 ";xG[ne$Be
1)用DriverManager取数据库连接 esxU44
例子 e+2!)w)[
String className,url,uid,pwd; J]Y." hi
className = "oracle.jdbc.driver.OracleDriver"; Gd"lB*^Ht
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; AR)&W/S)7,
uid = "system"; f)*}L?
pwd = "manager"; S"fnT*:.%
Class.forName(className); gmrjCLj
Connection cn = DriverManager.getConnection(url,uid,pwd); in%+)`'nH7
2)用jndi(java的命名和目录服务)方式 @P)GDB7A
例子 #opFUX-
String jndi = "jdbc/db"; >yT:eG
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); =WN6Fj`
DataSource ds = (DataSource) ctx.lookup(jndi); [5:F
Connection cn = ds.getConnection(); CjIkRa@!x
多用于jsp中 -
5A"TNU
2、执行sql语句 |~'{ [?a*
1)用Statement来执行sql语句 `oq
3G }
String sql; /(vT49(]
Statement sm = cn.createStatement(); ]1gt|M^
sm.executeQuery(sql); // 执行数据查询语句(select) :vc[ iZ
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 2< ^B]N
2)用PreparedStatement来执行sql语句 xOZ?zN
String sql; /X8b=:h
sql = "insert into user (id,name) values (?,?)"; }!B<MGBd
PreparedStatement ps = cn.prepareStatement(sql); C[wnor!
ps.setInt(1,xxx); iT
IW;Cv
ps.setString(2,xxx); V_0e/7}Ya
... Tqm9><!r
ResultSet rs = ps.executeQuery(); // 查询 M a_! 1Y
int c = ps.executeUpdate(); // 更新 ^@jOS{f l
Oq|pd7fcgm
3、处理执行结果 cITQ,ah
查询语句,返回记录集ResultSet )D(XDN
更新语句,返回数字,表示该更新影响的记录数 AEEy49e
ResultSet的方法 |f`!{=?
1、next(),将游标往后移动一行,如果成功返回true;否则返回false I_N"mnn@Nr
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 lOYwYMi
dpTap<Noby
4、释放连接 I'J=I{p*
cn.close(); 9;q@;)'5
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection u\>Ed9^
^${-^w@,%V
可滚动、更新的记录集 011 _(v
1、创建可滚动、更新的Statement O4(
Z%YBe
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); t t#M4n@
该Statement取得的ResultSet就是可滚动的 g_.BJ>Uv
2、创建PreparedStatement时指定参数 hC~lH eH
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); {Uu7 @1@n
ResultSet.absolute(9000); tpA7"JD
批量更新 u5%.T0
P
1、Statement Jw9|I)H
Statement sm = cn.createStatement(); i1u &-#k
sm.addBatch(sql1); d(R3![:
sm.addBatch(sql2); K2)),_,@5+
... XPb7gd"%W
sm.executeBatch() :*@=px
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 } fSbH
2、PreparedStatement e,8C}
2
PreparedStatement ps = cn.preparedStatement(sql); #y2="$V
{ UB?a-jGZK
ps.setXXX(1,xxx); :aco$ZNH5
... Qp%kX@Z'
ps.addBatch(); llQDZ}T
} kg+"Ta[9
ps.executeBatch(); >m%\SuXq
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 YdIV_&-W
;J2=6np
事务的处理 ^'[Rb!Q8
1、关闭Connection的自动提交 Ma wio5
cn.setAutoCommit(false); R '"J{oR
2、执行一系列sql语句 Vk8:;Hj
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close K*p^Gs,
Statement sm ; [+>$'Du
sm = cn.createStatement(insert into user...); v;{s@CM m
sm.executeUpdate(); oZP:}= F
sm.close(); HL*jRl
sm = cn.createStatement("insert into corp...); R6CxNPRJ
sm.executeUpdate(); JF!!)6!2#
sm.close(); O:#t>
;
3、提交 hA)3Ah*
cn.commit(); Xg#Dbf4
4、如果发生异常,那么回滚 e6#^4Y/+`
cn.rollback();