java 数据库基本操作 `0!%jz=
1、java数据库操作基本流程 =A$d)&
2、几个常用的重要技巧: *19a\m=>oi
可滚动、更新的记录集 q9a6s{,
批量更新 ,068IEs
事务处理 + ef>ek
nNnfcA&W
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 LB}J7yEQvj
1、取得数据库连接 xe3Jxo!U
1)用DriverManager取数据库连接 !T8sWMY
例子 1rLxF{,
String className,url,uid,pwd; NmF8BmIj
className = "oracle.jdbc.driver.OracleDriver"; .f>7a;V?}
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; {eQijW2Z3
uid = "system"; N S*Lv
pwd = "manager"; |+>U91!
Class.forName(className); ~@[<y1g?nG
Connection cn = DriverManager.getConnection(url,uid,pwd); J Rj{Q 1J
2)用jndi(java的命名和目录服务)方式 9jNh%raG|
例子 R|wS*xd ,
String jndi = "jdbc/db"; GJHJ?^%
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); f;Ijl 0d@
DataSource ds = (DataSource) ctx.lookup(jndi); p1mAoVxR
Connection cn = ds.getConnection(); >RpMw!NT
多用于jsp中 k72NXagh
2、执行sql语句 YNKvR
1)用Statement来执行sql语句 +V[;DOlll
String sql; 'Z#>K*
Statement sm = cn.createStatement(); -C!m#"PDW
sm.executeQuery(sql); // 执行数据查询语句(select) tT]mMlKJ
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 5N bq9YY
2)用PreparedStatement来执行sql语句 1\)lD(J\C
String sql; Nei i$
sql = "insert into user (id,name) values (?,?)"; _g,_G
PreparedStatement ps = cn.prepareStatement(sql); HnsLYY\
ps.setInt(1,xxx); BqdpJIr
ps.setString(2,xxx); e+>$4Jq
... $'<$:;4b3
ResultSet rs = ps.executeQuery(); // 查询 Bqb`WX[<`
int c = ps.executeUpdate(); // 更新 %P(2uesd
Py/~Q-8p
3、处理执行结果 Q]VG6x
查询语句,返回记录集ResultSet i<=2 L?[.I
更新语句,返回数字,表示该更新影响的记录数 j7NOYm5N
ResultSet的方法 Z
J1@z.
1、next(),将游标往后移动一行,如果成功返回true;否则返回false !:tr\L {
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ld 1[Usaq
<JvYCWX`
4、释放连接 cjd-B:l
cn.close(); X;#Ni}af
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 7-\wr^ll3
we@*;k@_
可滚动、更新的记录集 U!JmSP
1、创建可滚动、更新的Statement B+pLW/4l
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Wvl'O'R
该Statement取得的ResultSet就是可滚动的 =@X?$>'
2、创建PreparedStatement时指定参数 &h=f
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); fGe"1MfU
ResultSet.absolute(9000); W2M[w_~QE
批量更新 MfKru,LSh
1、Statement P:1eWP
Statement sm = cn.createStatement(); 6KPjZC<
sm.addBatch(sql1); TB84}
sm.addBatch(sql2); QA)W( 1
... ilZ5a&X;
sm.executeBatch() !0):g/2h
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 iQLP~Z>,T
2、PreparedStatement X\*H7;k,
PreparedStatement ps = cn.preparedStatement(sql); "1%k"+&
{ Kq+vAp).
ps.setXXX(1,xxx); lE8_Q *ev
... Vf=,@7
ps.addBatch(); 7vI
ROK~
} QXEZ?gx
ps.executeBatch(); ^$RpP+d
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 X?/32~\
P\z1fscnK
事务的处理 =2vZqGO30
1、关闭Connection的自动提交 {BJH}vV1)
cn.setAutoCommit(false); #Pg?T%('`
2、执行一系列sql语句 h53G$Ol.
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close ,JPDPI/a
Statement sm ; WE-+WC!!:
sm = cn.createStatement(insert into user...); -Y N(j\
sm.executeUpdate(); !vHCftKel
sm.close(); Hd
gABIuX
sm = cn.createStatement("insert into corp...); :?i,!0#"
sm.executeUpdate(); F*NHy.Y
sm.close(); %?8.UW\m
3、提交 fWDTP|DV
cn.commit(); gT,iH.
4、如果发生异常,那么回滚 (IA:4E}
cn.rollback();