java 数据库基本操作 0R`>F">
1、java数据库操作基本流程 !Fxn1Z,
2、几个常用的重要技巧: &2[Xu4*
可滚动、更新的记录集 A-_M=\
批量更新 Kb;Pd!Q
事务处理 ;lrO?sm
!7Qj8YmS
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ycki0&n3
1、取得数据库连接 *8;<w~
1)用DriverManager取数据库连接 |O'*CCrCL
例子 FwHqID_!:l
String className,url,uid,pwd; /YU8L
className = "oracle.jdbc.driver.OracleDriver"; ? u".*!%
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ~)>.%`v&
uid = "system"; f}4A,%:1
pwd = "manager"; <RbfW'<G
Class.forName(className); 7bRfkKD
Connection cn = DriverManager.getConnection(url,uid,pwd); .f;@OqU
2)用jndi(java的命名和目录服务)方式 E4Ez)IaKyi
例子 a.JjbFL
String jndi = "jdbc/db"; +|8.ymvm
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); b\o>4T
DataSource ds = (DataSource) ctx.lookup(jndi); V*(x@pF
Connection cn = ds.getConnection(); c+T`X?.j
多用于jsp中 Uam%u
2、执行sql语句 $]}K ;
1)用Statement来执行sql语句 >=:mtcph
String sql; _/cX!/"
Statement sm = cn.createStatement(); m^m=/'<+
sm.executeQuery(sql); // 执行数据查询语句(select) (vzYgU,
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); u ysTyzx
2)用PreparedStatement来执行sql语句 <|X+T,
String sql; (a-Lx2 T
sql = "insert into user (id,name) values (?,?)"; fO^s4gWTg
PreparedStatement ps = cn.prepareStatement(sql); F0zaA
ps.setInt(1,xxx); M2d&7>N
ps.setString(2,xxx); ZU.E}Rn:
... ;V?(j3b[
ResultSet rs = ps.executeQuery(); // 查询 3$:F/H
int c = ps.executeUpdate(); // 更新 Cc`-34/%
_K'Y`w']
3、处理执行结果 Otq1CD9
查询语句,返回记录集ResultSet a j
.7t=^
更新语句,返回数字,表示该更新影响的记录数 4oryTckS
ResultSet的方法 SAf)#HXa
1、next(),将游标往后移动一行,如果成功返回true;否则返回false fZsw+PSy
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 yI07E "9
w\N\J^5,Q
4、释放连接 KC2Z@
cn.close(); c'Ibgfx%m
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 7^M$u\a)U
eX}aa0
可滚动、更新的记录集 t:P]bp^#
1、创建可滚动、更新的Statement 5A|dhw
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); }0@@_Y]CC
该Statement取得的ResultSet就是可滚动的 %_B2/~
2、创建PreparedStatement时指定参数 c>3? T^=
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); *kTp(*K/7`
ResultSet.absolute(9000); S>*i\OnI'
批量更新 q{b-2k
1、Statement V\r{6-%XiW
Statement sm = cn.createStatement(); nec}grA
sm.addBatch(sql1); )Td{}vbIh
sm.addBatch(sql2); Xc"
%-
... 5P\A++22Y
sm.executeBatch() 3K/tB1
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 %0}}Qt
2、PreparedStatement S0:Oep
PreparedStatement ps = cn.preparedStatement(sql); 2P@6Qe
?
{ w{*V8S3h9
ps.setXXX(1,xxx); l.Ev]G/5
... KiKw,@
ps.addBatch(); v+79#qWK|n
} [E6ceX0
ps.executeBatch(); uW#s;1H.)
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 NW3qs`$-(
Lz-|M?(
事务的处理 *f>\X[wN
1、关闭Connection的自动提交 D Y4!RjJ47
cn.setAutoCommit(false); gVh&c4
2、执行一系列sql语句 .q4$)8[Pg
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close A8ef=ljM?
Statement sm ; }m5()@Q}a
sm = cn.createStatement(insert into user...); (pP.*`JRv
sm.executeUpdate(); shy[>\w
sm.close(); GQd[7j[sh
sm = cn.createStatement("insert into corp...); /cUu]#h
sm.executeUpdate(); LayK&RwL
sm.close(); #G`K<%{?f
3、提交 @H~oOf
cn.commit(); _~C1M&b(X3
4、如果发生异常,那么回滚 JZ5 ";*,
cn.rollback();