java 数据库基本操作 gT.sjd
1、java数据库操作基本流程 CO/]wS
2、几个常用的重要技巧: u,ho7ht3(
可滚动、更新的记录集 qz_7%c]K[
批量更新 P\tB~SZ*
事务处理 u[;\y|75
>NV@R&
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 K8|r&`X0
1、取得数据库连接 bW427B0
1)用DriverManager取数据库连接 n`_{9R
例子 b#%hY{$j
String className,url,uid,pwd; Qp5VP@t
className = "oracle.jdbc.driver.OracleDriver"; <d Wv?<o
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; g/d<Zfq<{
uid = "system"; UW={[h{.|@
pwd = "manager"; QE+g
j8
Class.forName(className); Evq IcZ
Connection cn = DriverManager.getConnection(url,uid,pwd); QO:!p5^:
2)用jndi(java的命名和目录服务)方式 VBlYvZ;$*
例子 nF]W,@u"h
String jndi = "jdbc/db"; C[AqFo
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); "S]0
DataSource ds = (DataSource) ctx.lookup(jndi); )r?}P1J7
Connection cn = ds.getConnection(); xj)F55e?
多用于jsp中 ($MlX BI
2、执行sql语句 }"H,h)T
1)用Statement来执行sql语句 m])y.T
String sql; k
.;j
Statement sm = cn.createStatement(); @i_FTN
sm.executeQuery(sql); // 执行数据查询语句(select) ~vhE|f
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); $rBq"u=,0+
2)用PreparedStatement来执行sql语句 Et_bH%0
String sql; 6Pnjmw.HV
sql = "insert into user (id,name) values (?,?)"; qA7>vi%
PreparedStatement ps = cn.prepareStatement(sql); !-x$L>1$
ps.setInt(1,xxx); :pY/-Cgv
ps.setString(2,xxx); \:'/'^=#|
... #Vt%@*
i
ResultSet rs = ps.executeQuery(); // 查询 O63<AY@
int c = ps.executeUpdate(); // 更新 | j`@eF/"
nHAS(
3、处理执行结果 9L?.m&
查询语句,返回记录集ResultSet OZF
rtc+
更新语句,返回数字,表示该更新影响的记录数 f*% D$Mqg
ResultSet的方法 [!uG1 GJ>
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 4B1v4g8}
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 rU:`*b<
xrz,\eTb
4、释放连接 nNV'O(x}
cn.close(); )9G[dDeC
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection
(N6i4
g6
~$cV:O7
可滚动、更新的记录集 6vo;!V6
1、创建可滚动、更新的Statement /4V#C-
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); xC:L)7#aw
该Statement取得的ResultSet就是可滚动的 A RuA<vQ
2、创建PreparedStatement时指定参数 33x{CY15
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); N,AQsloL7
ResultSet.absolute(9000); 6:5I26
批量更新 dr}`H,X"3
1、Statement L.2^`mZs
Statement sm = cn.createStatement(); {SPq$B_VR
sm.addBatch(sql1); 6Q@j
sm.addBatch(sql2); CS5?Ti6
... &X ):4
sm.executeBatch() K`WywH3-
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 OA1uY83"
2、PreparedStatement Jb@V}Ul$
PreparedStatement ps = cn.preparedStatement(sql); U^%Q}'UYym
{ Jy:Qlx`
ps.setXXX(1,xxx); RDi]2
... t;Sb/ 3
ps.addBatch(); )gIKH{JYL
} e0zq1XcZ
ps.executeBatch(); ;>yxNGV`
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 X,_2FJv
2DtM20<>
事务的处理 Y@vTaE^w3
1、关闭Connection的自动提交 *boR`[Ond
cn.setAutoCommit(false); ay
;S4c/_
2、执行一系列sql语句 ["93~[[^
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close ?k&Vy
Statement sm ; ,t?B+$E
sm = cn.createStatement(insert into user...); Tod&&T'UW
sm.executeUpdate(); ci.+pF
sm.close(); +H-6e P
sm = cn.createStatement("insert into corp...); XbKYiy
sm.executeUpdate(); TH&U
j1
sm.close(); 2j88<Yh]H
3、提交 !qh]6%l
cn.commit(); KNvZm;Q6
4、如果发生异常,那么回滚 ,+DG2u
cn.rollback();