java 数据库基本操作 .cS,T<$
1、java数据库操作基本流程 7]xz8t
2、几个常用的重要技巧: C.)&FW2F_
可滚动、更新的记录集 &9dr+o-(~
批量更新 06 Esc^D
事务处理 d<GG(
Gx_`|I{P
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 &iiK ZZ`_o
1、取得数据库连接 2<o[@w
1)用DriverManager取数据库连接 199hQxib:
例子 {9.~]dI|L
String className,url,uid,pwd; iC|6roO!jk
className = "oracle.jdbc.driver.OracleDriver"; m)|.:sj
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; '"]>`=R
uid = "system"; ok%a|Zz+]
pwd = "manager"; 2@m(XT
(
Class.forName(className); B,vHn2W
Connection cn = DriverManager.getConnection(url,uid,pwd); &PBWJ?@O)r
2)用jndi(java的命名和目录服务)方式 <x0uO
例子 xK),:+G(
String jndi = "jdbc/db"; .`Old{<
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); U~#^ ^
DataSource ds = (DataSource) ctx.lookup(jndi); ),p]n
Connection cn = ds.getConnection(); U??f<
多用于jsp中 ;TV'PJ
2、执行sql语句 G9'YgW+$7
1)用Statement来执行sql语句 oY2?W
String sql; Avv
Statement sm = cn.createStatement(); Ro'4/{}+
sm.executeQuery(sql); // 执行数据查询语句(select) 1_j<%1{sZ
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); g?A5'o&Yu
2)用PreparedStatement来执行sql语句 dJQ }{,+6
String sql; }OP%p/eY
sql = "insert into user (id,name) values (?,?)"; $O~F>.*
PreparedStatement ps = cn.prepareStatement(sql); 01-\:[{
ps.setInt(1,xxx); wwK~H
ps.setString(2,xxx); !|Xl 8lV`
... C?/r}ly<\
ResultSet rs = ps.executeQuery(); // 查询 iUxDEt[t*
int c = ps.executeUpdate(); // 更新 3vRLg b
vA2,&%jw
3、处理执行结果 fVA=<:
查询语句,返回记录集ResultSet e"o6C\c
更新语句,返回数字,表示该更新影响的记录数 :_fjml/
ResultSet的方法 STXqq[+Rf
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 0$f_or9T
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 qUEd
E`B
j:v~MrQ7|
4、释放连接 VNr
cn.close(); Z/NGv
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection ;9p#xW6
\N`fWh8&
可滚动、更新的记录集 cYq']$]
1、创建可滚动、更新的Statement oRT
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); F=
_uNq
该Statement取得的ResultSet就是可滚动的 @pqY9_:P1
2、创建PreparedStatement时指定参数 E'&OOEMN-
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); LY\ddI*s
ResultSet.absolute(9000); zt)p`kd D
批量更新 uKR\Xo}
1、Statement _XY`UZ
Statement sm = cn.createStatement(); =2.tu*!C
sm.addBatch(sql1); w&wA >q>&
sm.addBatch(sql2); %jbJ6c
... G|QUujl
sm.executeBatch() >0Fxyv8
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ;xW8Z<\-
2、PreparedStatement p|FlWR'mA
PreparedStatement ps = cn.preparedStatement(sql); )XmCy"xx
{ J^ +_8
ps.setXXX(1,xxx); *<`7|BH 3
... ShL1'Z}^{
ps.addBatch(); ]~j_N^oZ1X
} ~
V@xu{
ps.executeBatch(); b lRY7
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 bc3|;O
l?[{?Luq
事务的处理 rmY,v
1、关闭Connection的自动提交 k%EWkM)?
cn.setAutoCommit(false); ri/t(m^{W
2、执行一系列sql语句 wFK:Dp_^
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close $l#v/(uFa
Statement sm ; c8^+^.=pX
sm = cn.createStatement(insert into user...); -kG3k> by_
sm.executeUpdate(); O{lIs_1.Z
sm.close(); K(-G: |
sm = cn.createStatement("insert into corp...); ;Ri 3#*a=
sm.executeUpdate(); HBt|}uZ?6i
sm.close(); 07.nq;/R
3、提交 fp.!VOy
cn.commit(); C/mg46
v2W
4、如果发生异常,那么回滚 bin6i2b
cn.rollback();