java 数据库基本操作 1pcSfN :"1
1、java数据库操作基本流程 ma-|L3 #
2、几个常用的重要技巧: F`Pu$>8C
可滚动、更新的记录集 ka]n+"~==\
批量更新 Ir]b.6B
事务处理 FCI38?`%
|=7%Edkd
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 t);5Cw_
1、取得数据库连接 RI%*5lM8;
1)用DriverManager取数据库连接 }}ogdq
例子 #?aR,@n
String className,url,uid,pwd; 8o~\L=
l
className = "oracle.jdbc.driver.OracleDriver"; F.O2;M|x
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; T nPC\.x
uid = "system"; |>[w$
pwd = "manager"; ytJ |jgp'
Class.forName(className); GF
k?Qf{u
Connection cn = DriverManager.getConnection(url,uid,pwd); [J:vSt
2)用jndi(java的命名和目录服务)方式 lMP|$C
例子 0{Tf;a<
String jndi = "jdbc/db"; 7\jH?Zi
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); OD*DHC2rN]
DataSource ds = (DataSource) ctx.lookup(jndi); b"x:IDW qG
Connection cn = ds.getConnection(); M`"2;
多用于jsp中 +LrW#K;
2、执行sql语句 {\ .2h
1)用Statement来执行sql语句 B{zIW'Ld
String sql; /ZD/!YD&R
Statement sm = cn.createStatement(); 1f~_# EIC
sm.executeQuery(sql); // 执行数据查询语句(select) ^GL0|G=(1
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); \)r#?qn4z;
2)用PreparedStatement来执行sql语句 k
9s3@S
String sql; ,$CZ(GQ
sql = "insert into user (id,name) values (?,?)"; }LE.kd&
PreparedStatement ps = cn.prepareStatement(sql); \*_qP*vq@
ps.setInt(1,xxx); S$V'_
ps.setString(2,xxx); i++ F&r[
... W/J3sAYv
ResultSet rs = ps.executeQuery(); // 查询 xXLKL6F(\
int c = ps.executeUpdate(); // 更新 Ph-3,cC
f *)t<1f
3、处理执行结果 t6LTGWs/_o
查询语句,返回记录集ResultSet .o
fYFK
更新语句,返回数字,表示该更新影响的记录数 Kz 'W
|
ResultSet的方法 &4DvZq=
1、next(),将游标往后移动一行,如果成功返回true;否则返回false M~3(4,
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 y5l4H8{h}
tXfB.[U
4、释放连接 k
\]@
cn.close(); 5% +T~ E*
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection +>/Q+nh
MJ>(HJY6?%
可滚动、更新的记录集 4?8GK
1、创建可滚动、更新的Statement k%uRG_
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ,![C8il,
该Statement取得的ResultSet就是可滚动的 VRMlr.T+
2、创建PreparedStatement时指定参数 !$Mv)c/_u
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); $YL}rM
ResultSet.absolute(9000); @-Gf+*GZys
批量更新 8CMI\yk
1、Statement NW^}u~-f
Statement sm = cn.createStatement(); {jr>Z"/q
sm.addBatch(sql1); l$PO!JRD
sm.addBatch(sql2); OhIUm4=|$
... Br-bUoua
sm.executeBatch()
{T.$xiR
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 T*LbZ"A
2、PreparedStatement x4fLe5xv
PreparedStatement ps = cn.preparedStatement(sql); [gD02a:u
{ L P.-
ps.setXXX(1,xxx); @bS>XWI>
... gl00$}C
ps.addBatch(); gM_Z/$
} vR#A7y @!
ps.executeBatch(); )W uuU [(
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 h]G}E9\l
-08Ys c
事务的处理 W~R_-
]k@g
1、关闭Connection的自动提交 DR^mT$
cn.setAutoCommit(false); 4W$53LP8
2、执行一系列sql语句 @$Z5Ag!
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close yBq4~b~[
Statement sm ; p5>TL!4M
sm = cn.createStatement(insert into user...); ^> ZQ:xs@(
sm.executeUpdate(); 3^wJ4=^
sm.close(); o"TEmZUP
sm = cn.createStatement("insert into corp...); x4Eq5"F7}
sm.executeUpdate(); #_4L/LV
sm.close(); rcNM,!dZ
3、提交 hF!yp7l;
cn.commit(); 21G]d
4、如果发生异常,那么回滚 JA())0a
cn.rollback();