java 数据库基本操作 paUyS 1i
1、java数据库操作基本流程 2@OBeR
2、几个常用的重要技巧: 3 pHn_R
可滚动、更新的记录集 ]
+sSg=N7i
批量更新 >dcqPNDg1^
事务处理 1_XO3P\
nN!vgn
j
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ^S:cNRSW"
1、取得数据库连接 <(ubZ
1)用DriverManager取数据库连接 sd]0Hx[
例子 {m>~`
String className,url,uid,pwd; /:Rn"0
className = "oracle.jdbc.driver.OracleDriver"; v^57j:sD
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; `=PB2'
uid = "system"; KX$qM g1j
pwd = "manager"; j `w;z: G
Class.forName(className); vC s6#PR$
Connection cn = DriverManager.getConnection(url,uid,pwd); p}cd}@cQ6
2)用jndi(java的命名和目录服务)方式 QJniM"8v
例子 [k}dES#
String jndi = "jdbc/db"; ,OFq'}q
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); w@4t$bd7
DataSource ds = (DataSource) ctx.lookup(jndi); oT$(<$&<
Connection cn = ds.getConnection(); jw2_!D
多用于jsp中 lsN/$M|}
2、执行sql语句 ]Sk#a-^~
1)用Statement来执行sql语句 {: Am9B
String sql; R'jUS7]Y
Statement sm = cn.createStatement(); KLj 4LOs
sm.executeQuery(sql); // 执行数据查询语句(select) Q;d+]xj
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); j
P{:A9T\
2)用PreparedStatement来执行sql语句 dY4 8S{
String sql; uVoF<={
sql = "insert into user (id,name) values (?,?)"; e@6RC bj
PreparedStatement ps = cn.prepareStatement(sql); 8b8e^\l(
ps.setInt(1,xxx); z|taa;iM
ps.setString(2,xxx); M^!C?(Hx^x
... A?^A*e
ResultSet rs = ps.executeQuery(); // 查询 f/$-Nl.
int c = ps.executeUpdate(); // 更新 3W%f#d$`
`bBfNI?3d*
3、处理执行结果 /7!_un9
查询语句,返回记录集ResultSet V!j K3vc
更新语句,返回数字,表示该更新影响的记录数 _3-RoA'UZr
ResultSet的方法 5( mCBH
1、next(),将游标往后移动一行,如果成功返回true;否则返回false .`i'gPLkn2
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 7<Z~\3x
g]oc(RM
4、释放连接 $X{B*
WF
cn.close(); QYODmeu
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection v ^ FV
t
O?+tY
y?
可滚动、更新的记录集 mgJ]@s}9
1、创建可滚动、更新的Statement ;C7BoHB9
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Rh05W_?Js
该Statement取得的ResultSet就是可滚动的 2^k^"<h5j
2、创建PreparedStatement时指定参数 Dohl,d
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); jpPdjQ
ResultSet.absolute(9000); oho AUT
批量更新 S|O%h}AH;
1、Statement *Xf[b)FR
Statement sm = cn.createStatement(); QSl:=Q'
sm.addBatch(sql1); _>Pe]3
sm.addBatch(sql2); 8iII)+
... 5yO#N2jY\
sm.executeBatch() 3> n2
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 pGZl.OI
2、PreparedStatement |e.3FjTH
PreparedStatement ps = cn.preparedStatement(sql); T7WZ(y
3C
{ )- Wn'C'Z
ps.setXXX(1,xxx); !=k*hl0h
... k *zc5ev}
ps.addBatch(); >F
LdI
} 5 O{Ip-
ps.executeBatch(); \ _-kOS
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 CrQA :_Z(7
f<$K.i
事务的处理 Dn{19V.L
1、关闭Connection的自动提交 TA-(_jm
cn.setAutoCommit(false); p:
Q%Lg_I
2、执行一系列sql语句 TV[6+i*#
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close &)fhlp5
Statement sm ; Sl+jduc
sm = cn.createStatement(insert into user...); a3(7{,Ew
sm.executeUpdate(); "`V"2zZlj
sm.close(); ^bY^x+d
sm = cn.createStatement("insert into corp...); K"t:B
sm.executeUpdate(); 0|wKR|zW
sm.close(); 8) ebXc
3、提交 l{D,O?`Av
cn.commit(); G*{ u(x(
4、如果发生异常,那么回滚 f"Vm'0r
cn.rollback();