java 数据库基本操作 @vC7j>*4B
1、java数据库操作基本流程 yz CQ
2、几个常用的重要技巧: jBTXs5q
可滚动、更新的记录集 J9kmIMq-C
批量更新 FHu
-';
事务处理 ;0R>D g
krw_1Mm
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 c:R`]4o
1、取得数据库连接 !2R<T/9~
1)用DriverManager取数据库连接 n8!qz:z/
例子 y$]gmg
String className,url,uid,pwd; hSO(s
className = "oracle.jdbc.driver.OracleDriver"; [CBhipoc
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; \GR M,c
uid = "system"; a*pwVn
pwd = "manager"; .!kO2/:6
Class.forName(className); } +@H&}u
Connection cn = DriverManager.getConnection(url,uid,pwd); [`_ZlC
2)用jndi(java的命名和目录服务)方式 e+!+(D
例子 D?v)Xqw=
String jndi = "jdbc/db"; Q bg,q
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); Zw)*+> +FV
DataSource ds = (DataSource) ctx.lookup(jndi); T.fmEl
Connection cn = ds.getConnection(); eu]t.Co[X
多用于jsp中 Nf#8V|
2、执行sql语句 RcASFBNpS
1)用Statement来执行sql语句 D};zPf@!p
String sql; 7^fpbrj
Statement sm = cn.createStatement(); C{i9~80n
sm.executeQuery(sql); // 执行数据查询语句(select) gm-I)z!tz
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); b&y"[1`
2)用PreparedStatement来执行sql语句 DRBRs-D
String sql; 4@qKML
sql = "insert into user (id,name) values (?,?)"; C;T:'Uws
PreparedStatement ps = cn.prepareStatement(sql); ?9_RI(a.}
ps.setInt(1,xxx); >#q2KXh
ps.setString(2,xxx); 6evW
O!
... R3G+tE/Y
ResultSet rs = ps.executeQuery(); // 查询 |HjoaN )
int c = ps.executeUpdate(); // 更新 `ehZ(H}
<O5r|
3、处理执行结果 ,Tb~+z|-[
查询语句,返回记录集ResultSet ?HP54G<{xz
更新语句,返回数字,表示该更新影响的记录数 ],fu#pi=]
ResultSet的方法 QJcaOXyMS
1、next(),将游标往后移动一行,如果成功返回true;否则返回false Tr^Egw]
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 T[z]~MJL
nTJ-1A7EP
4、释放连接 3
e19l!B
cn.close(); uG|d7LS,%
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection ,+u.FQv~
a cSm+t
可滚动、更新的记录集 _?vh#6F
1、创建可滚动、更新的Statement )wmG&"qsP
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Lv`*+;1K
该Statement取得的ResultSet就是可滚动的 B]`!L/
2、创建PreparedStatement时指定参数 CDy *8<-&
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); /D]V3|@E
ResultSet.absolute(9000); 92@/8,[
批量更新 JYY:~2
1、Statement ;{n@hM*O
Statement sm = cn.createStatement(); eb])=
sm.addBatch(sql1); NV|[.g=lg
sm.addBatch(sql2); 6z/ct|n
... %{fa
.>6
sm.executeBatch() 4k
HFfc
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 RGeM.
2、PreparedStatement :QndeUw
PreparedStatement ps = cn.preparedStatement(sql); -:hiLZJ7-
{ <K~> :4c
ps.setXXX(1,xxx); LDj'L~H
...
wknr^A
ps.addBatch(); ElAho3W
} I^M%+\
ps.executeBatch(); -/#VD&MJO=
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 SWAggW)
73-*|@6
事务的处理 -+'fn$
1、关闭Connection的自动提交 YL )epi^
cn.setAutoCommit(false); hPCt-
2、执行一系列sql语句 Bf72 .gx{0
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close Bs@!S?
Statement sm ; 6@7K\${
sm = cn.createStatement(insert into user...); hi{#HXa
sm.executeUpdate(); c)d*[OI8
sm.close(); .4M8
sm = cn.createStatement("insert into corp...); )HrFWI'Y
sm.executeUpdate(); Ub0hISA
sm.close(); !)jw o=l}J
3、提交 ^w0V{qF{
cn.commit(); 61Z#;2]
4、如果发生异常,那么回滚 (,5oqU9s@
cn.rollback();