java 数据库基本操作 sKVN*8ia
1、java数据库操作基本流程 jCa%(2~iQ7
2、几个常用的重要技巧: /7/d
u[P6
可滚动、更新的记录集 o{f|==<t3#
批量更新 ACxOC 2\n
事务处理 q|;_G#4
61L
vT"
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 MF)Xc\}0p
1、取得数据库连接 UE3(L
^
1)用DriverManager取数据库连接 # -e
例子 WvQK$}Ax4N
String className,url,uid,pwd; * $~H=4t
className = "oracle.jdbc.driver.OracleDriver"; N}HQvlLkF9
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; $w4%JBZr
uid = "system"; Cp` [0v~0
pwd = "manager"; W ZdEfY{
Class.forName(className); %5Hsd
Connection cn = DriverManager.getConnection(url,uid,pwd); \
'G%%%;4
2)用jndi(java的命名和目录服务)方式 N3nFE:`u]
例子 mrX 2w
String jndi = "jdbc/db"; Cgq/#2BM
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); C8 9c2
DataSource ds = (DataSource) ctx.lookup(jndi); 1BO$xq
Connection cn = ds.getConnection(); =
_X#JP79
多用于jsp中 Q\|72NWS
2、执行sql语句 2#:/C:
1)用Statement来执行sql语句 (C>FM8$J
String sql; 4=!SG4~o
Statement sm = cn.createStatement(); yr?*{;
sm.executeQuery(sql); // 执行数据查询语句(select) a+sHW<QeS
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close();
AV{3f`
2)用PreparedStatement来执行sql语句 7N9~nEU
String sql; #-*7<wN
sql = "insert into user (id,name) values (?,?)"; sLrSi
PreparedStatement ps = cn.prepareStatement(sql); Z
M_
6A1
ps.setInt(1,xxx); ywWF+kR_
ps.setString(2,xxx); qKNX^n;
... VO r*YB&
ResultSet rs = ps.executeQuery(); // 查询 K(@QKRZ7[
int c = ps.executeUpdate(); // 更新 g S xK9P
booth}M
3、处理执行结果 HxCq6Y_m<
查询语句,返回记录集ResultSet t>.1,'zb
更新语句,返回数字,表示该更新影响的记录数 [!1z;
/
ResultSet的方法 29]-s Utqv
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 3
r4QB
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 k]?M^jrm
)NAC9:8!
4、释放连接 GG%X1c8K
cn.close(); {uH
4j4)2
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection `2`Nu:r^
m} /L MY
可滚动、更新的记录集 Au3>=x`
1、创建可滚动、更新的Statement 9DcUx-
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 3yg22y&l
该Statement取得的ResultSet就是可滚动的 O92a*)
2、创建PreparedStatement时指定参数 jm9J-%?
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ]AkHNgW
ResultSet.absolute(9000); ]4~-
z3=y
批量更新 ."b=dkx
1、Statement $Lg%CY
Statement sm = cn.createStatement(); %{qJkjG
sm.addBatch(sql1); NJK?5{H'
sm.addBatch(sql2); hpp>+=
... hDaI@_86
sm.executeBatch() *%<Ku&C
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ;ELQIHnD"
2、PreparedStatement DwM4/m
PreparedStatement ps = cn.preparedStatement(sql); (}E-+:vFU
{ U U!M/QJ
ps.setXXX(1,xxx); vQf'lEFk
... FD>j\
ps.addBatch(); Zkl:^!*
} u=^0n2ez
ps.executeBatch(); ER,,K._?B
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 +W|MAJtg
KY'"Mg^!
事务的处理 /LMb~Hy,
1、关闭Connection的自动提交 k<W n
cn.setAutoCommit(false); $mFsf)1]]?
2、执行一系列sql语句 Jg#L8>p1
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 09?n5x!6
Statement sm ; Yas! w'
sm = cn.createStatement(insert into user...); 6ExUNp @U>
sm.executeUpdate(); a,X=!oJ
sm.close(); lOp/kGmn+
sm = cn.createStatement("insert into corp...); Z-[nHSf
sm.executeUpdate(); cy)b/4h@
sm.close(); 2y;
|6`
3、提交 FkJa+ZA
cn.commit(); Kp,}7%hDw!
4、如果发生异常,那么回滚 #k? Rl
cn.rollback();