java 数据库基本操作 /yOd]N;$
1、java数据库操作基本流程 -8o8lz
2、几个常用的重要技巧: =y4g. J\
可滚动、更新的记录集 kSJWQ
批量更新 fT@#S}t
事务处理 k`&mHSk-
(;n|>l?*
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 @M,_mX
1、取得数据库连接 87HVD Di
1)用DriverManager取数据库连接 15zL,yo
例子 mrJQB I+
String className,url,uid,pwd; o#T,vu0s
className = "oracle.jdbc.driver.OracleDriver"; |9%>R*
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; "[8](3\v
uid = "system"; $nVTN.k
pwd = "manager"; V^0*S=N
Class.forName(className); $'&5gFr9
Connection cn = DriverManager.getConnection(url,uid,pwd); 55;xAsG
2)用jndi(java的命名和目录服务)方式 _zOzHc? Q
例子 /Ly%-py-$
String jndi = "jdbc/db"; ctCfLlK
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); )~5`A*Ku
DataSource ds = (DataSource) ctx.lookup(jndi); $DMeUA\av
Connection cn = ds.getConnection(); a"v D+r7Ol
多用于jsp中 dFUsQ_]<
2、执行sql语句 IOJ fv8
1)用Statement来执行sql语句 s<5t}{x
String sql; prwyP
Statement sm = cn.createStatement(); C*KRu`t
sm.executeQuery(sql); // 执行数据查询语句(select) _Y0o\0B
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); >Z3}WMgBN
2)用PreparedStatement来执行sql语句 uwIZzz
String sql; 1xx-}AIH#
sql = "insert into user (id,name) values (?,?)"; T.{I~_
PreparedStatement ps = cn.prepareStatement(sql); tVe*J@i\$
ps.setInt(1,xxx); +(<CE#bb[
ps.setString(2,xxx); 9(iJ=ao (
... pymT-
ResultSet rs = ps.executeQuery(); // 查询 :l6sESr
int c = ps.executeUpdate(); // 更新 rdC(+2+Ay
Q!"Li
3、处理执行结果 nc3 1X
查询语句,返回记录集ResultSet :;JJvYIs
更新语句,返回数字,表示该更新影响的记录数 +28FB[W
ResultSet的方法 <y!BO
1、next(),将游标往后移动一行,如果成功返回true;否则返回false QQ?` 1W
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 8kqxr&,[
*</;:?
4、释放连接 b\^.5SEw
cn.close(); /fD)/x
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection r)b`3=
nyMA%9,B
可滚动、更新的记录集 >#kzPYsp
1、创建可滚动、更新的Statement eAl&[_o|S
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); #fFEo)YG
该Statement取得的ResultSet就是可滚动的 6IvLr+I
2、创建PreparedStatement时指定参数 ^+P]_< 43
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ]v lQNd?
ResultSet.absolute(9000); 2V
批量更新 I*24%z9
1、Statement :H?p^d
e
Statement sm = cn.createStatement(); p?!]sO1l
sm.addBatch(sql1); r3KV.##u,
sm.addBatch(sql2); *mBEF"
... PM_q"}-
sm.executeBatch() ,+q5e^P
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 r67 3+
2、PreparedStatement xWV_Do)z
PreparedStatement ps = cn.preparedStatement(sql); xi.;`Q^#
{ Bz24U wcZ
ps.setXXX(1,xxx); N.VzA
6C
... un\"1RdO
ps.addBatch(); \Q3m?)X=Gd
} 5-+Y2tp}
ps.executeBatch(); x
&\~4,TN
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 lh5k@\X
2S/^"IM["
事务的处理 8Mp
1、关闭Connection的自动提交 \"f}Fx
cn.setAutoCommit(false); Bd7A-T)q!
2、执行一系列sql语句 ;z[yNW8
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close mMa7Eyaf
Statement sm ; CjO/q)vV
sm = cn.createStatement(insert into user...); f[%iRfUFw
sm.executeUpdate(); Ya>cGaLq
sm.close(); 2 1;n0E
sm = cn.createStatement("insert into corp...); $D45X<
sm.executeUpdate(); k1%Ek#5
sm.close(); (57x5qP
X
3、提交 `HHbQXB
cn.commit(); fygy#&}~
4、如果发生异常,那么回滚 eR3!P8t
cn.rollback();