java 数据库基本操作 <9?`zo$y
1、java数据库操作基本流程 vslN([@JR
2、几个常用的重要技巧: L$f:D2Ei
可滚动、更新的记录集 rE.z.r"O
批量更新 2iWxx:e
事务处理 g0RfvR
>zv}59M
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 luO4ap]*
1、取得数据库连接 .A<n2-
1)用DriverManager取数据库连接 ==~
lc;
例子 a]R1Fi0n
String className,url,uid,pwd; 0S>U_#-
className = "oracle.jdbc.driver.OracleDriver"; h)yAge
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; :FI4GR*?
uid = "system"; xA"7a
pwd = "manager"; n)>nfnh
Class.forName(className); 8x<; AL|`
Connection cn = DriverManager.getConnection(url,uid,pwd); irzWk3@:
2)用jndi(java的命名和目录服务)方式 VXu1Y xY
例子 v
iM6q<Ht
String jndi = "jdbc/db"; BO-=X
78f@
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); hjY)W;
DataSource ds = (DataSource) ctx.lookup(jndi); :8Jn?E (36
Connection cn = ds.getConnection(); jX{t/8v/s4
多用于jsp中 4[m4u6z=
2、执行sql语句 ;=?KQq f
1)用Statement来执行sql语句 `n~bDG>
String sql; Klk[h
Statement sm = cn.createStatement(); [ncOtDE
sm.executeQuery(sql); // 执行数据查询语句(select) G+f@m,
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); (]p,Z<f
2)用PreparedStatement来执行sql语句 ]abox%U=%
String sql; l+i9)Fc<i
sql = "insert into user (id,name) values (?,?)"; \^rAH@
PreparedStatement ps = cn.prepareStatement(sql); iKuSk~
ps.setInt(1,xxx); IH0qx_;P&
ps.setString(2,xxx); Z3
$3zyi
... S,TK;g
ResultSet rs = ps.executeQuery(); // 查询 tV,Y38e
int c = ps.executeUpdate(); // 更新 fu?Y'Qet
Z'L}x6
3、处理执行结果 EBPm7{&0|
查询语句,返回记录集ResultSet 3xGk@ 333
更新语句,返回数字,表示该更新影响的记录数 Wo+'j $k
ResultSet的方法 :If1zB)
1、next(),将游标往后移动一行,如果成功返回true;否则返回false X(ZouyD<
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 Jd>"g9
C@i4[g){
4、释放连接 nWAx!0G
cn.close(); i0-zGEMB.
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection @ \(*pa
~&Gw[Nd1
可滚动、更新的记录集 PI0[
1、创建可滚动、更新的Statement %XieKL
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Jr4^@]78o<
该Statement取得的ResultSet就是可滚动的 }+8w
2、创建PreparedStatement时指定参数 C!8XFf8e
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); "##Ylq( "
ResultSet.absolute(9000); E#=slj@
批量更新 y84=Q
1、Statement ^gpswhp
5
Statement sm = cn.createStatement(); b{o%`B*
sm.addBatch(sql1); x!o>zT\
sm.addBatch(sql2); '8 ~E
... D|[~Py
sm.executeBatch() P]4C/UDS-~
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 H1FSN6'
2、PreparedStatement SDTX3A1
PreparedStatement ps = cn.preparedStatement(sql); 6R+m;'
{ +)4_1i4"x
ps.setXXX(1,xxx); 4EiEE{9V
... PKhH0O\_U
ps.addBatch(); ?6gC;B
} OJUH".o
ps.executeBatch(); &?=UP4[oif
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 >d&_e[j
'W/E*O6BY
事务的处理 _T 5ZL
1、关闭Connection的自动提交 8%s_~Yc
cn.setAutoCommit(false); "+2Hde1
2、执行一系列sql语句 OE(Z)|LF
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close {[
j+y
Statement sm ; '1[}PmhD
sm = cn.createStatement(insert into user...); 5__8+R
sm.executeUpdate(); i6p0(OS&D
sm.close(); 8lo /BGxS>
sm = cn.createStatement("insert into corp...); %Bo/vB'
sm.executeUpdate(); h5-<2B|
sm.close(); 5sD\4 g)HK
3、提交 XAV|xlfm
cn.commit(); =X?jId{
4、如果发生异常,那么回滚 MX-(;H
cn.rollback();