java 数据库基本操作 F@z%y'5 Z*
1、java数据库操作基本流程 'rXf
2、几个常用的重要技巧: e|SNb*_
可滚动、更新的记录集 'G[G;?F
批量更新 H{_D#It
事务处理 ~U7Bo(EJp
O)R}|
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 Y]~-S
1、取得数据库连接 b'FTyi
1)用DriverManager取数据库连接 m0W3pf
例子 TSJeS`I
String className,url,uid,pwd; EGFP$nvq
className = "oracle.jdbc.driver.OracleDriver"; wYFkGih
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; zNGUll$
uid = "system"; }#~E-N3x
pwd = "manager"; VNz?e&>
Class.forName(className); _ZJQE>]nWu
Connection cn = DriverManager.getConnection(url,uid,pwd); v}5YUM0H `
2)用jndi(java的命名和目录服务)方式 m' j1
例子 g"!cO^GkT
String jndi = "jdbc/db"; "tOm
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); %Y/;jCY
DataSource ds = (DataSource) ctx.lookup(jndi); $M,Q"QL
Connection cn = ds.getConnection(); {[bpvK
多用于jsp中 pi70^`@ 'B
2、执行sql语句 9I5AYa?
1)用Statement来执行sql语句 L|D9+u L
String sql; npytb*[|c
Statement sm = cn.createStatement(); :
maBec)
sm.executeQuery(sql); // 执行数据查询语句(select) n<)A5UB5-
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 39[ylR|\
2)用PreparedStatement来执行sql语句 9%R"(X)
String sql; nT~XctwF
sql = "insert into user (id,name) values (?,?)"; ?|NsaW
PreparedStatement ps = cn.prepareStatement(sql); A3HNMz
ps.setInt(1,xxx); j,%i.[8S
ps.setString(2,xxx); [SKDsJRPP
... O\oRM2^u}
ResultSet rs = ps.executeQuery(); // 查询 1f"}]MbLR
int c = ps.executeUpdate(); // 更新 [".94(qs
5Uhxl^c
3、处理执行结果 8.%wnH
查询语句,返回记录集ResultSet VqD_FS;E
更新语句,返回数字,表示该更新影响的记录数 f]sR4mhO
ResultSet的方法 iz [IK%K
1、next(),将游标往后移动一行,如果成功返回true;否则返回false U![$7k>,pr
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 Dbx zqd
n0K+/}m
4、释放连接 xe.f]a
cn.close(); 1NTx?JJfW
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection [(3 %$?[
03 iy[~Y2
可滚动、更新的记录集
@qWClr{`
1、创建可滚动、更新的Statement ~ e<,GUx(]
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); V3|"
v4
该Statement取得的ResultSet就是可滚动的 Zy)iNNtn
2、创建PreparedStatement时指定参数 T1?9E{bC8A
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); Cnc=GTRi
ResultSet.absolute(9000); G^;]]Ji"
批量更新 [P6A$HC<
1、Statement BTOl`U
Statement sm = cn.createStatement(); >pol'=
sm.addBatch(sql1); cN2Pl%7
sm.addBatch(sql2); n Jz* }=
... uHZjpMoM
sm.executeBatch() ~U ]%>Zf
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 (Xzq(QV
2、PreparedStatement Gw6Odj
PreparedStatement ps = cn.preparedStatement(sql); SEu:31k{o
{ SN}3
ps.setXXX(1,xxx); %k"hzjXAw
... wT3D9N.
ps.addBatch(); 1Qjc*+JzO.
} K0@bh/i/^
ps.executeBatch(); :YLYCVi|
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 F7=\*U
b;vVlIG
事务的处理 2>J;P C[;
1、关闭Connection的自动提交 XfEp_.~JM
cn.setAutoCommit(false); )\W}&9 >
2、执行一系列sql语句 6Y.k<oem
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close LF(S"Of
Statement sm ; /7a3*a
sm = cn.createStatement(insert into user...); /L]@k`.q@
sm.executeUpdate(); %rl<%%T#.M
sm.close(); KAT"!b
sm = cn.createStatement("insert into corp...); =:TQ_>$Nc2
sm.executeUpdate(); KZ=5"a
sm.close(); V.+a}J=Cw
3、提交 Fy>g*3
cn.commit(); gId
:IR
4、如果发生异常,那么回滚 'Vhnio;qC
cn.rollback();