java 数据库基本操作 =L
wX+c
1、java数据库操作基本流程 zXf+ie o
2、几个常用的重要技巧: =nL*/
可滚动、更新的记录集 %Z5k8
批量更新 ?RzT0HRd
事务处理 X9gC2iSs]
~D=@4(f8|
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 dO//
1、取得数据库连接 yEqmB4^-
1)用DriverManager取数据库连接 7ER 2h*
例子 f}'gg
String className,url,uid,pwd; }Voh5*$E`
className = "oracle.jdbc.driver.OracleDriver"; qL+y8*
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; (Mm{"J3uv
uid = "system"; A7RX2
pwd = "manager"; 8k`zMT
Class.forName(className); d,+n,;6Cf
Connection cn = DriverManager.getConnection(url,uid,pwd); jb![ Lp
2)用jndi(java的命名和目录服务)方式 i
}gxq
例子 g^4FzJ
String jndi = "jdbc/db"; *f#4S_ws`
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 9iy|=
DataSource ds = (DataSource) ctx.lookup(jndi); @YB\PVhW
Connection cn = ds.getConnection(); +e:ZN
tr9
多用于jsp中 2!3&Ub#FO
2、执行sql语句 jgo@~,5R
1)用Statement来执行sql语句 #rr-4$w+
String sql; `pMI[pLZe
Statement sm = cn.createStatement(); @ty|HXW
sm.executeQuery(sql); // 执行数据查询语句(select) fBOPd=
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); RZtL<2.@
2)用PreparedStatement来执行sql语句 Z%{f[|h9}
String sql; %UJ4wm
sql = "insert into user (id,name) values (?,?)"; +=k|(8Js#
PreparedStatement ps = cn.prepareStatement(sql); l.W:6",w
ps.setInt(1,xxx); F`Y<(]+
ps.setString(2,xxx); KUyJ"q<W
... 5#o,]tP
ResultSet rs = ps.executeQuery(); // 查询 (*x"6)`
int c = ps.executeUpdate(); // 更新 k0IU~y%
] zY
3、处理执行结果 WO9/rF_
查询语句,返回记录集ResultSet bC{8yV=)
更新语句,返回数字,表示该更新影响的记录数 M<srJ8|'
ResultSet的方法 w1_Ux<RF
1、next(),将游标往后移动一行,如果成功返回true;否则返回false K)@}Ok"#\4
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 WLl9>v^1
pzr-}>xrZ
4、释放连接 !~l%6Z5
cn.close(); w$ {
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection cj#q7
%$xFnGb
可滚动、更新的记录集 y)E2=JQA/
1、创建可滚动、更新的Statement ) :@%xoF5
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); %nh'F6bNgv
该Statement取得的ResultSet就是可滚动的 R4(8]oUW
2、创建PreparedStatement时指定参数 /6c10}f
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); P[K=']c
ResultSet.absolute(9000); m^.C(}
批量更新 fdG.=7`
1、Statement ?$c
Statement sm = cn.createStatement(); @GtZK
sm.addBatch(sql1); kwR@oVR^
sm.addBatch(sql2); vNSf:5H$
... TMCA?r%Y\
sm.executeBatch() w0Y%}7
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 wS0bk<(
2、PreparedStatement 8Q -F
PreparedStatement ps = cn.preparedStatement(sql); \Agg6tYr
{ Ohag%<1#
ps.setXXX(1,xxx); #Vigu,zY
... y}HC\A77uD
ps.addBatch(); KgWT&^t
} p ri{vveN@
ps.executeBatch(); =3C)sz}
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 Zwns|23n
r![JPhei
事务的处理 ~(/HgFLLu
1、关闭Connection的自动提交 Ds_
"m,
cn.setAutoCommit(false); Z|%2495\
2、执行一系列sql语句 Y`?X Fy:
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close [Mc5N
Statement sm ; ]!aa#?Fc
sm = cn.createStatement(insert into user...); QJM!Wx+
sm.executeUpdate(); 5qSZ>DZ
sm.close(); 9nS!
sm = cn.createStatement("insert into corp...); %:?QE
;
sm.executeUpdate(); xN8JrZE&
sm.close(); SqF.DB~
3、提交 !gHWYWu)!
cn.commit(); :[f`HY&
4、如果发生异常,那么回滚 =Zy!',,d,9
cn.rollback();