java 数据库基本操作 z\fk?Tj<ro
1、java数据库操作基本流程 {C
7=
2、几个常用的重要技巧: $
\jly
可滚动、更新的记录集 &98qAO]Z
批量更新 F
M`pPx
事务处理 n6oVx5/
|ek*wo
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 )m?oQ#`m
1、取得数据库连接 $WdZAv\_S
1)用DriverManager取数据库连接 lVMAab
例子 B} &C
h
String className,url,uid,pwd; h$lY,7
className = "oracle.jdbc.driver.OracleDriver"; \2W( >_z
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; T
`N(=T^*
uid = "system"; wd u>3Ch"y
pwd = "manager"; SJw0y[IL6(
Class.forName(className); |]Ockg[
Connection cn = DriverManager.getConnection(url,uid,pwd); vhT9#) HI
2)用jndi(java的命名和目录服务)方式 4iDo.1B"
例子 !zD| @sX{
String jndi = "jdbc/db"; _w)0r}{
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); XxV]U{i!
DataSource ds = (DataSource) ctx.lookup(jndi); qbB.Z#w
Connection cn = ds.getConnection(); 3fpX
多用于jsp中 GJ!usv u
2、执行sql语句 G.L4l|%W
1)用Statement来执行sql语句 {Ke3
String sql; i^j{l_-JE
Statement sm = cn.createStatement(); W&GDE
sm.executeQuery(sql); // 执行数据查询语句(select) 594$X@!v
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); \,~gA
2)用PreparedStatement来执行sql语句 0\u_\%[
String sql; ; <3w ,r
sql = "insert into user (id,name) values (?,?)"; CKj3-rcF(
PreparedStatement ps = cn.prepareStatement(sql); A*W QdY
ps.setInt(1,xxx); IhUuL0
ps.setString(2,xxx); (Iu5QLE
... E|#'u^`yv
ResultSet rs = ps.executeQuery(); // 查询 'tF<7\!
int c = ps.executeUpdate(); // 更新 K&Zdk (l)
8iq~ha$]|
3、处理执行结果 gm4-w 9M[p
查询语句,返回记录集ResultSet :s*&_y
更新语句,返回数字,表示该更新影响的记录数 )\p@E3Uxf
ResultSet的方法
T<P4+#JK
1、next(),将游标往后移动一行,如果成功返回true;否则返回false _)lK.5
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 DAJh9I
owQLAV
4、释放连接 2Ask]
cn.close(); -0lpsF
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection <PXA`]x~
g`\Vy4w
可滚动、更新的记录集 NeUpl./b
1、创建可滚动、更新的Statement %$Mvq&ZZ
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); rY88xh^
该Statement取得的ResultSet就是可滚动的 julAN$2
2、创建PreparedStatement时指定参数 {_PV~8u
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); VAV@Qn
ResultSet.absolute(9000); IC7n;n9
批量更新 Wu%;{y~#}
1、Statement G| ^tqI
Statement sm = cn.createStatement(); Xo }w$q5
sm.addBatch(sql1); yU&A[DZQ
sm.addBatch(sql2); B-JgXW.\0
... CfA
F.H
sm.executeBatch() ePB=aCZ
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 wXfy,W
2、PreparedStatement 4{*K%pv\
PreparedStatement ps = cn.preparedStatement(sql); UIbVtJ
{ (Z
sdj
ps.setXXX(1,xxx); to+jQ9q8
... 0G;RMR ':5
ps.addBatch(); ai#0ZgO
} [96|xe\s
ps.executeBatch(); 7?b'"X"
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 K@%. T#
6<FJ`l]U9
事务的处理 E9QNx62
1、关闭Connection的自动提交 7vgz=-
MZ#
cn.setAutoCommit(false); aZ#c_Q#gZ
2、执行一系列sql语句 =OTwP
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close }4\>q$8'
Statement sm ; m &c8@-T
sm = cn.createStatement(insert into user...); ;\(wJ{u?Y
sm.executeUpdate(); ,c}Q;eYc3
sm.close();
`<q{8
sm = cn.createStatement("insert into corp...); fytgS(?I'
sm.executeUpdate(); (~,Q-w"
sm.close(); r's4-\
3、提交 7RTp+FC]
cn.commit(); dAohj
QH:
4、如果发生异常,那么回滚 (8k3z`
cn.rollback();