java 数据库基本操作 !1H# 6
1、java数据库操作基本流程 ( !fKNia@S
2、几个常用的重要技巧: EF}\brD1
可滚动、更新的记录集 O$j7i:G'5
批量更新 vJc- 6EO
事务处理 PB`Y
g
F]]]y5t
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 n QZwC
1、取得数据库连接 `l){!rg8IC
1)用DriverManager取数据库连接 `yXg{lk
例子 {|_M
#w~&
String className,url,uid,pwd; < ?}-$
className = "oracle.jdbc.driver.OracleDriver"; j8{i#;s!"
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; s;Z\Io
uid = "system"; 6J6BF%
pwd = "manager"; (G4at2YLd
Class.forName(className); {e9@-
Connection cn = DriverManager.getConnection(url,uid,pwd); 1&evG-#<:
2)用jndi(java的命名和目录服务)方式 MvHm)h
例子 9gEwh<
String jndi = "jdbc/db"; KNpl:g3{<Q
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); JNYFD8J~
DataSource ds = (DataSource) ctx.lookup(jndi); =eXU@B
Connection cn = ds.getConnection(); cr?Q[8%t1
多用于jsp中 OXSmt
DvJ
2、执行sql语句 q#ClnG*
1)用Statement来执行sql语句 u#;7<.D
String sql; {V$|3m>:*
Statement sm = cn.createStatement(); ?2;&O`x*
sm.executeQuery(sql); // 执行数据查询语句(select) Cc' 37~6~P
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); mD0f<gJ1
2)用PreparedStatement来执行sql语句 Ug t.&IA
String sql; A8fOQ
sql = "insert into user (id,name) values (?,?)"; I{9QeRI
PreparedStatement ps = cn.prepareStatement(sql); aS{n8P6vW
ps.setInt(1,xxx); st3l2Q
ps.setString(2,xxx); y'~U%,ki6
... l7259Ro~
ResultSet rs = ps.executeQuery(); // 查询 gG:Vt}N
int c = ps.executeUpdate(); // 更新 _jI,)sr4ic
T/Gz94c
3、处理执行结果 v/0QOp
查询语句,返回记录集ResultSet %C'?@,7C
更新语句,返回数字,表示该更新影响的记录数 E$:*NSXj
ResultSet的方法 V2?=4mb
1、next(),将游标往后移动一行,如果成功返回true;否则返回false R{3N&C
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 '(VJ&UlS2
KRLQ #,9
4、释放连接 a 3b/e8c
cn.close(); nntuLuW
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection be{H$9'
tl4V7!U@^z
可滚动、更新的记录集 m
)zUU
1、创建可滚动、更新的Statement `* ["UER
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); |vwVghC
该Statement取得的ResultSet就是可滚动的 *_{j=sd
2、创建PreparedStatement时指定参数 !t%j?\f
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); c9'vDTE%~
ResultSet.absolute(9000); Xy&A~F
批量更新 zh`<WN&H
1、Statement M~#g RAUJ
Statement sm = cn.createStatement(); gJXq^~-hd
sm.addBatch(sql1); n Fg~< $d
sm.addBatch(sql2); Ae^~Cz1qz
... JEwa
&
sm.executeBatch() [0[i5'K:
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 A*R^n}sh
2、PreparedStatement VimE@ Hz
PreparedStatement ps = cn.preparedStatement(sql); }wjw:M
{ D|L9Vs`
ps.setXXX(1,xxx); 2dcV"lY
... 9:[ 9v
ps.addBatch(); c|B('3h
} B6As,)RjD:
ps.executeBatch(); R)(T^V`{
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 V-2(?auZd
Rz:]\jcIT/
事务的处理 \0I_<
1、关闭Connection的自动提交 gNrjo=
cn.setAutoCommit(false); 8f4b&ah
2、执行一系列sql语句 \?ZB]*Fu
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close #s(BuVU
Statement sm ; Y%aCMP9j~9
sm = cn.createStatement(insert into user...); #PW9:_BE
sm.executeUpdate(); >d*@_kJM
sm.close(); Jk11fn;\>
sm = cn.createStatement("insert into corp...); (ejvF):|
sm.executeUpdate(); rjAn@!|:+
sm.close(); l
-m fFN
3、提交 I)6+6pm
cn.commit(); 7\[@m3s
4、如果发生异常,那么回滚 *3FKt&v 0
cn.rollback();