java 数据库基本操作 )ds]fvMW]N
1、java数据库操作基本流程 X!K> .r_Dg
2、几个常用的重要技巧: \fUX_0k9,
可滚动、更新的记录集 z4Zm%
批量更新 %jy$4qAf%
事务处理 S4`X^a}pY
`
PQQU~^
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 8T9s:/%
1、取得数据库连接 .Y{x!Q"
1)用DriverManager取数据库连接 v:/\;2
例子 \Q(a`6U
String className,url,uid,pwd; Lv]%P.=[G
className = "oracle.jdbc.driver.OracleDriver"; lYCvYe
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; 7)V"E-6h
uid = "system"; !5(DU~S*@S
pwd = "manager"; 4pf@.ra,
Class.forName(className); 0t%]z!
Connection cn = DriverManager.getConnection(url,uid,pwd); e}1Q+h\
2)用jndi(java的命名和目录服务)方式 w(&EZDe
例子 Jh 0Grq
String jndi = "jdbc/db"; " Q?~LB
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); mf$YsvPq*+
DataSource ds = (DataSource) ctx.lookup(jndi); YB7n}r23
Connection cn = ds.getConnection(); %L* EB;nK
多用于jsp中 RW+u5Y
2、执行sql语句 I51]+gEN
1)用Statement来执行sql语句 :Q> e54]'&
String sql; p$9Aadi]
Statement sm = cn.createStatement(); tRJ5IX ##L
sm.executeQuery(sql); // 执行数据查询语句(select) 6vsA8u(|V#
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); =~h b&
2)用PreparedStatement来执行sql语句 A~PR
String sql; )gdLb}
sql = "insert into user (id,name) values (?,?)"; zUL,~u
PreparedStatement ps = cn.prepareStatement(sql); =Q40]>bpx
ps.setInt(1,xxx); M%`CzCL
u
ps.setString(2,xxx); q+\<%$:u
... 2I [zV7 @t
ResultSet rs = ps.executeQuery(); // 查询 `
= O
int c = ps.executeUpdate(); // 更新 `6)Qi*Z
%S;AM\o4
3、处理执行结果 F-wAQ:
查询语句,返回记录集ResultSet rhbz|Uq
更新语句,返回数字,表示该更新影响的记录数 %rG4X
ResultSet的方法 cyJ{AS+
1、next(),将游标往后移动一行,如果成功返回true;否则返回false }+n|0xK
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 v,ZYh w
d-B+s%>D
4、释放连接 ?-<lIFFh
cn.close(); m%`YAD@2z
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection jeWv~JA%L|
f(w>(1&/B
可滚动、更新的记录集 ?'6@m86d
1、创建可滚动、更新的Statement I?}jf?!oM
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); I U"
该Statement取得的ResultSet就是可滚动的 MGm*({%
2、创建PreparedStatement时指定参数 bpwA|H%{M
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); O|,9EOrP
ResultSet.absolute(9000); p?y2j
批量更新 W+#Q>^ Q>
1、Statement cb /Q<i
Statement sm = cn.createStatement(); ]nUr E6
sm.addBatch(sql1); g~y0,0'j1\
sm.addBatch(sql2); /S"jO[n9b
... ?I6rW JcQ6
sm.executeBatch() %US&`BT!
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ;yomaAr
2、PreparedStatement n8<?<-2
PreparedStatement ps = cn.preparedStatement(sql); aNEah
{ FSA%,b;U
ps.setXXX(1,xxx); \uOM,98xS
... uVn"L:_
ps.addBatch(); Ahwi
} RH;ulAD6(~
ps.executeBatch(); \s&Mz;:
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 nUP, Yd
d=xjLbsZ
事务的处理 ^7spXfSAd
1、关闭Connection的自动提交 HXa[0VOx
cn.setAutoCommit(false); 7x6M]1F
2、执行一系列sql语句 X>[i<ei
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close (0NffM1
Statement sm ; gUru=p
sm = cn.createStatement(insert into user...); "5V;~}=S
sm.executeUpdate(); 60!%^O =
sm.close(); jG[Vp b
sm = cn.createStatement("insert into corp...); 6/8K2_UeoW
sm.executeUpdate(); \~hrS/$[$
sm.close(); PK2;Ywk`
3、提交 v;<gCzqQh
cn.commit(); 5U~KYy^v
4、如果发生异常,那么回滚 JPqd}:u3
cn.rollback();