java 数据库基本操作 (~(FQ:L%U
1、java数据库操作基本流程 a;(,$q3M
2、几个常用的重要技巧: h}}7_I9
可滚动、更新的记录集 @f-rS{
批量更新 yK mHTjX=
事务处理 Y"dTm;&
k1LbWR1%wB
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 hJX;/~L
1、取得数据库连接 % QaWg2Y=
1)用DriverManager取数据库连接 R^.c
例子 !_?HSDAj"n
String className,url,uid,pwd; X*e:MRw[
className = "oracle.jdbc.driver.OracleDriver";
)
urUaE
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; :]* =f].
uid = "system"; fL gHQ
pwd = "manager"; .SBN^fq
Class.forName(className); dhuIVBp!!e
Connection cn = DriverManager.getConnection(url,uid,pwd); T <RWz
2)用jndi(java的命名和目录服务)方式 Iapzh y2l
例子 >_X(rar0
String jndi = "jdbc/db"; wHQYBYKcd
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); z] |Y
DataSource ds = (DataSource) ctx.lookup(jndi); qLB(Th\&'
Connection cn = ds.getConnection(); /#}%c'
多用于jsp中 7/\SN04l
2、执行sql语句 2XeN E[
1)用Statement来执行sql语句 PG'I7)Bv
String sql; MF$NcU
Statement sm = cn.createStatement(); P[e#j
sm.executeQuery(sql); // 执行数据查询语句(select) /FcwsD\=$
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); r?`7i'
2)用PreparedStatement来执行sql语句 u;8bbv4
String sql; [VouG{
sql = "insert into user (id,name) values (?,?)"; x/ P\qI
PreparedStatement ps = cn.prepareStatement(sql); D.h <!?E%
ps.setInt(1,xxx); ]`}EOS-Q
ps.setString(2,xxx); sB01QVx47
... QFhQfn
ResultSet rs = ps.executeQuery(); // 查询 x6|QTO
int c = ps.executeUpdate(); // 更新 be.Kx< I
M|>-q
3、处理执行结果 p\xsW"=8q
查询语句,返回记录集ResultSet ,UD5>Ai
更新语句,返回数字,表示该更新影响的记录数 /ZSdY_%s
ResultSet的方法 u#Uc6? E
1、next(),将游标往后移动一行,如果成功返回true;否则返回false \BSPv]d
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 p+{*w7?8"[
@T sdgx8
4、释放连接 9(BB>o54r
cn.close(); o2LUB)=R'
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection <Q.-WV]Z
M5S<N_+Pe
可滚动、更新的记录集 ?QzN\fY;
1、创建可滚动、更新的Statement ~ o5h}OU"
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ;fv/s]X86I
该Statement取得的ResultSet就是可滚动的 =}W)%Hldr.
2、创建PreparedStatement时指定参数 ralU9MN.
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 'RCX6TKBnR
ResultSet.absolute(9000); 3[To"You
批量更新 &MP8.(u `
1、Statement ~I%JVX%
Statement sm = cn.createStatement(); }iR!uhi#
sm.addBatch(sql1); H3S u'3
sm.addBatch(sql2); *Rj*%S
... hhOrO<(
sm.executeBatch() Js!Zk\O
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 Pu!%sG jD
2、PreparedStatement ;'| t>'0_
PreparedStatement ps = cn.preparedStatement(sql); u8[jD^
{ {>#4{D00
ps.setXXX(1,xxx); GZ"J6/0-|
... sT"{ e7;F;
ps.addBatch(); N_E:?Jo
} !q*]_1
ps.executeBatch(); =/HTe&
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 Lmyw[s\U
1
BVpv7@
事务的处理 H3o Um1
1、关闭Connection的自动提交 h}P""
cn.setAutoCommit(false); bC]GL$ph9*
2、执行一系列sql语句 FDRpK5cw
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close #'kVW{
Statement sm ; YCB=RT]&`
sm = cn.createStatement(insert into user...); 3 jay V
sm.executeUpdate(); ?I#zcD)w
sm.close(); `LVX|l62
sm = cn.createStatement("insert into corp...); [Uu!:SZ
sm.executeUpdate();
*:V"C\`^n
sm.close(); 7o64|@ 'j
3、提交 ehls:)F
cn.commit(); )Y,>cg:z~
4、如果发生异常,那么回滚 ^2um.`8
cn.rollback();