java 数据库基本操作 .(.<
1、java数据库操作基本流程 qy)~OBY
2、几个常用的重要技巧:
Owi/e
可滚动、更新的记录集 ujSoWs
批量更新 n=C"pH#
事务处理 m,!SDCq
i,a"5DR8
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 Iia.`"S
1、取得数据库连接 A;RV~!xx
1)用DriverManager取数据库连接 ^bfZd
例子 P/|1,Sk
String className,url,uid,pwd; c$71~|-[
className = "oracle.jdbc.driver.OracleDriver"; K)~a H
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; {vCtp
uid = "system"; 1^X)vck
pwd = "manager"; ;l0dx$w
Class.forName(className); Z%:>nDZV
Connection cn = DriverManager.getConnection(url,uid,pwd); S6JXi>n
2)用jndi(java的命名和目录服务)方式 &0qpgl|
例子 L/exR6M7
String jndi = "jdbc/db"; /*,_\ ;
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ktx| c19
DataSource ds = (DataSource) ctx.lookup(jndi); D_0Vu/v
Connection cn = ds.getConnection(); ~"#HHaBO#
多用于jsp中 H(K
PU1lDw
2、执行sql语句 Cd"{7<OyM4
1)用Statement来执行sql语句 wN4#j}C
String sql; ]lBCK
Statement sm = cn.createStatement(); dp'[I:X
sm.executeQuery(sql); // 执行数据查询语句(select) ceJi|`F
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ?X6}+
2)用PreparedStatement来执行sql语句 ]4en|Aq
String sql; 4,c6VCw3+
sql = "insert into user (id,name) values (?,?)"; Z%B6J>;u M
PreparedStatement ps = cn.prepareStatement(sql); WEif&<Y
ps.setInt(1,xxx); T!KwRxJ23
ps.setString(2,xxx); CCe>*tdf
... |&rCXfC
ResultSet rs = ps.executeQuery(); // 查询 BB(6[V"SV
int c = ps.executeUpdate(); // 更新 LrbD%2U$j5
A8Q^y
AP^
3、处理执行结果 {#k[-\|;
查询语句,返回记录集ResultSet 79W^;\3
更新语句,返回数字,表示该更新影响的记录数 ~~h#2SX
ResultSet的方法 ~8u *sy
1、next(),将游标往后移动一行,如果成功返回true;否则返回false U>f'j;5
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ($[+dR
@:9Gs!!
4、释放连接 %csrNf
cn.close(); Dz6xx?
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 3yKmuu!
m\0_1 #(
可滚动、更新的记录集 /~ {`!30
1、创建可滚动、更新的Statement +)"Rv%.
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); U\tx{CsSz
该Statement取得的ResultSet就是可滚动的 l9&k!kF`
2、创建PreparedStatement时指定参数 {XmCG%%L
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 4F6aPo2
ResultSet.absolute(9000); WJnGF3G>
批量更新 @CmKF
1、Statement :1>?:3,`
Statement sm = cn.createStatement(); @
gWd
sm.addBatch(sql1); 7<]
EH:9
sm.addBatch(sql2); p|ink):
... Pa{
sm.executeBatch() V9BW@G@9
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 z m$Sw0#(
2、PreparedStatement V+O,y9
PreparedStatement ps = cn.preparedStatement(sql); 6~x'~T
{ MkPQ@so
ps.setXXX(1,xxx); KddCR&
... KaNs>[a8
ps.addBatch(); ^x: lB>
} C'#)mo_@t
ps.executeBatch(); bPU
i44P
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。
r_#dh
zR^Gy"
事务的处理 gYc]z5`
1、关闭Connection的自动提交 Oti*"dV\::
cn.setAutoCommit(false); \MOwp@|y
2、执行一系列sql语句 j,+]tHC-
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close *c94'T cl
Statement sm ; *kl :/#
sm = cn.createStatement(insert into user...); V^5d5Ao
sm.executeUpdate(); k_=yb^6[U
sm.close(); Ptv'.<-
sm = cn.createStatement("insert into corp...); T+F]hv'
sm.executeUpdate(); Qw}1q!89
sm.close(); TB!I
3、提交 !B}9gT
cn.commit(); 7t:RQ`$:
4、如果发生异常,那么回滚 Ww2@!ng
cn.rollback();