java 数据库基本操作 1JS2SxF
1、java数据库操作基本流程 OKue" p
2、几个常用的重要技巧: J\co1kO9/
可滚动、更新的记录集 L K7Xw3
批量更新 Q\_{d0
0
事务处理 mw$Y
D0bnN1VP
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ROAI9sW0
1、取得数据库连接 b Y8GA
1)用DriverManager取数据库连接 gSi5u#}J
例子 I}0_nge
String className,url,uid,pwd; +++pI.>(*Q
className = "oracle.jdbc.driver.OracleDriver"; 0{rx.C7|
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; t8J/\f=
uid = "system"; i.a _C'<$
pwd = "manager"; {[OwMk
Class.forName(className); IM(u<c$
Connection cn = DriverManager.getConnection(url,uid,pwd); aq>?vti1D
2)用jndi(java的命名和目录服务)方式 ~1 ZD[@
例子 8n)WW$
String jndi = "jdbc/db"; yXfMzG
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); %vqT#+x
DataSource ds = (DataSource) ctx.lookup(jndi); z/|BH^Vw
Connection cn = ds.getConnection(); D guB
多用于jsp中 2<W&\D o@
2、执行sql语句 !$xu(D.
1)用Statement来执行sql语句 05e>\}{0
String sql; pdz'!I
Statement sm = cn.createStatement(); wyQb5n2`;~
sm.executeQuery(sql); // 执行数据查询语句(select) I0w%8bs
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 00<{:
2)用PreparedStatement来执行sql语句 ej[S u
String sql; Xa,&ef&q
sql = "insert into user (id,name) values (?,?)";
z1j|E
:
PreparedStatement ps = cn.prepareStatement(sql); g:~+Pe
ps.setInt(1,xxx); X>,A
ps.setString(2,xxx); 78Y@OL_$
...
9YKDguG
ResultSet rs = ps.executeQuery(); // 查询 JeQ[qQ
int c = ps.executeUpdate(); // 更新 9D_wG\g
$G";2(-k
3、处理执行结果 5P+YK\~
查询语句,返回记录集ResultSet tbur$00
更新语句,返回数字,表示该更新影响的记录数 h_ ZX/k
ResultSet的方法 rz
1、next(),将游标往后移动一行,如果成功返回true;否则返回false |rPAC![=
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 I,P!@
&L3#:jSk
4、释放连接 Q"}s>]k3_
cn.close(); &HF]\`RNr
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection L|67f4
(V9h2g&8L
可滚动、更新的记录集 g [L
1、创建可滚动、更新的Statement }~zO+Wf2
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); *x,HnHT
该Statement取得的ResultSet就是可滚动的 3M*Y= ?pI
2、创建PreparedStatement时指定参数 K2|7%
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 9q|7<raS
ResultSet.absolute(9000); {nRUH*(d9
批量更新 iZ Ta>@
1、Statement Oxa5Kfpa
Statement sm = cn.createStatement(); M,..Kw/ }~
sm.addBatch(sql1); \R Z3Hh
sm.addBatch(sql2); 2Ow<`[7
... VkXn8J
sm.executeBatch() \(u@F<s-
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ~e^)q>Lb7(
2、PreparedStatement Xw(3j)xQ
PreparedStatement ps = cn.preparedStatement(sql); z93nYY$`Y
{ NbDda/7ki
ps.setXXX(1,xxx); h AAU ecx
... ZKQo#!}
ps.addBatch(); %EIUAG
} .zwVCW,u
ps.executeBatch(); 5"2@NL
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。
FV8\+ep
T{HfP
事务的处理 )@$
&FFIu
1、关闭Connection的自动提交 1.dX)^\
cn.setAutoCommit(false); 'FxYMSZS$
2、执行一系列sql语句 ULu O0\W
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close f?m5pax|
Statement sm ; T#N80BH[
sm = cn.createStatement(insert into user...); X|)Il8
sm.executeUpdate(); jrcc
sm.close(); _UIgRkl.
sm = cn.createStatement("insert into corp...); JU2P%3
sm.executeUpdate(); d~/xGB`<
sm.close(); K*:Im#Q
3、提交 4w9F+*-
cn.commit(); 2<m
Q,,j
4、如果发生异常,那么回滚 ChVY
Vx(
cn.rollback();