java 数据库基本操作 V0P>YQq9s
1、java数据库操作基本流程
(q(~de
2、几个常用的重要技巧: F*3j.lI
可滚动、更新的记录集 p(/dBt[3k
批量更新 'a\%L:`
事务处理 G}ob<`o|"
&L,nqc\3D5
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 O8j_0
1、取得数据库连接 )'6DNa[y
1)用DriverManager取数据库连接 t+1 %RyKFB
例子 TjwBv6h
String className,url,uid,pwd; ^$'z!+QRM
className = "oracle.jdbc.driver.OracleDriver"; Nw1#M%/!r!
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; Stu4t==U
uid = "system"; /Z@tv.f
pwd = "manager"; *fn*h[pV&
Class.forName(className); W8KDX_vGJ
Connection cn = DriverManager.getConnection(url,uid,pwd); 4<lRPsvgc
2)用jndi(java的命名和目录服务)方式 Wb?8j M
例子 hKT
String jndi = "jdbc/db"; YTexv;VNb|
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); \l]DQaOEe
DataSource ds = (DataSource) ctx.lookup(jndi); tavpq.0O
Connection cn = ds.getConnection(); i03w1pSH,
多用于jsp中 'gTb A?+@5
2、执行sql语句 RF%KA[Dj
1)用Statement来执行sql语句 DUC#NZgw
String sql; !>zo_fP
Statement sm = cn.createStatement(); 4'!c*@Y
sm.executeQuery(sql); // 执行数据查询语句(select) ?C&z]f3(:
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); K0}pi+=
2)用PreparedStatement来执行sql语句 cM$P`{QrM
String sql; 8>WC5%f*
sql = "insert into user (id,name) values (?,?)"; 2&^]k`Aj6D
PreparedStatement ps = cn.prepareStatement(sql); ihP|E,L=L
ps.setInt(1,xxx); YW60q0:
ps.setString(2,xxx); A8oo@z68n>
... /7t>TYip!
ResultSet rs = ps.executeQuery(); // 查询 ](wvu(y\E
int c = ps.executeUpdate(); // 更新 Ns7(j-
Q2F+?w;,
3、处理执行结果 o'f?YZ$.
查询语句,返回记录集ResultSet {:]9Q Tq
更新语句,返回数字,表示该更新影响的记录数 e= .njMqW5
ResultSet的方法 LRb{hUt=
1、next(),将游标往后移动一行,如果成功返回true;否则返回false p%*%n3bw
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 A<qTg`gA
S/ODqL|
4、释放连接 nysUZB
cn.close(); w6{TE(]zp
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection Y[$!`);Ye
\8?Tdx=
可滚动、更新的记录集 a6WI170^1
1、创建可滚动、更新的Statement /iJ4{p
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); c%'RR?Tl
该Statement取得的ResultSet就是可滚动的 %|oJ>+
2、创建PreparedStatement时指定参数 z2QP)150
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); s1h/}
ResultSet.absolute(9000); [N#,K02mk
批量更新 49dd5ddr
1、Statement b#hDHSdZ,
Statement sm = cn.createStatement(); lMg+R<$~I
sm.addBatch(sql1); j+["JXy
sm.addBatch(sql2); @++.FEf
... 1M
781
sm.executeBatch() ZGYr$C~
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 O2f-5Y$@
2、PreparedStatement ),ma_{$N
PreparedStatement ps = cn.preparedStatement(sql); ,kF}lo)
{
1][S#H/?
ps.setXXX(1,xxx); Gr^E+#;
... hnc@
ps.addBatch(); -2 A(5B9Fq
} _;UE9S%
ps.executeBatch(); \3S8 62B7
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 lS'-xEv?
` M3w]qJ<}
事务的处理 zN:K%AiGxe
1、关闭Connection的自动提交 f^"N!f a
cn.setAutoCommit(false); LkK~%tY
2、执行一系列sql语句 Gq }U|Z
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close =aoMii
Statement sm ; viMzR(JU
sm = cn.createStatement(insert into user...); }`,t$NV`
sm.executeUpdate(); h?;T7|^
sm.close(); TG+VEL |T
sm = cn.createStatement("insert into corp...); Ndcg/d
sm.executeUpdate(); #[`:'e
sm.close(); vWf;
'j
3、提交 < VSA
cn.commit(); jhg;%+KB
4、如果发生异常,那么回滚 ?)1{)Erf8x
cn.rollback();