java 数据库基本操作 g(7rTyp4)
1、java数据库操作基本流程 3<f}nfB%r?
2、几个常用的重要技巧: u(F_oZ~
可滚动、更新的记录集 9ZsVy
批量更新 w4{<n/"
事务处理 paE[rS\
3J|F?M"N7
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 U}rU~3N
1、取得数据库连接 \aUC(K~o\;
1)用DriverManager取数据库连接 V1`o%;j
例子 w(3G&11N?
String className,url,uid,pwd; K+K#+RBK
className = "oracle.jdbc.driver.OracleDriver"; (Y? gn)*t
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; &>W$6>@
uid = "system"; j[G
pwd = "manager"; $2M$?4S/T
Class.forName(className); Y0dEH^I
Connection cn = DriverManager.getConnection(url,uid,pwd); x,@B(9No
2)用jndi(java的命名和目录服务)方式 Zbt.t]N
例子 V]e 8a"/[{
String jndi = "jdbc/db"; Eib5
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); /cQueUME`
DataSource ds = (DataSource) ctx.lookup(jndi); _P 3G
Connection cn = ds.getConnection(); ND#Yenye
多用于jsp中 i0kak`x0
2、执行sql语句 }t=!(GOb}
1)用Statement来执行sql语句 }9# r0Vja
String sql; pis`$_kmwV
Statement sm = cn.createStatement(); 1N#|
}ad
sm.executeQuery(sql); // 执行数据查询语句(select)
}Gm>`cw-
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); S8wLmd>
2)用PreparedStatement来执行sql语句 N&+x+;Kx
String sql; $)ijN^hV
sql = "insert into user (id,name) values (?,?)"; :tB1D@Cb6
PreparedStatement ps = cn.prepareStatement(sql); c&?m>2^6
ps.setInt(1,xxx); /}fHt^2H
ps.setString(2,xxx); gpvYb7Of0
... kY|utoAP
ResultSet rs = ps.executeQuery(); // 查询 H.|#c^I
int c = ps.executeUpdate(); // 更新 (Ag16
FF(#]vz '
3、处理执行结果 %G/hD
查询语句,返回记录集ResultSet /hH
更新语句,返回数字,表示该更新影响的记录数 +-U- D?-
ResultSet的方法
Rn(ec
1、next(),将游标往后移动一行,如果成功返回true;否则返回false s_OF( o
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ~IfJwBn-i
tGh~!|P
4、释放连接 aFb==73aLw
cn.close(); .B]MpmpK
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection bz2ztH9 n
pnowy;
可滚动、更新的记录集 #@9/g
1、创建可滚动、更新的Statement *K6g\f]b #
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); FaQe_;
该Statement取得的ResultSet就是可滚动的 b_#m}yZ6
2、创建PreparedStatement时指定参数 gmO!
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ll<Xz((o
ResultSet.absolute(9000); oim9<_
批量更新 t?x<g <PJ4
1、Statement wOEj)fp.
Statement sm = cn.createStatement(); DJXmGt]
sm.addBatch(sql1); +ocol6G7W
sm.addBatch(sql2); fF$<7O)+]
... L_uVL#To
sm.executeBatch() NMa} {*sQ
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 :Ij{s
2、PreparedStatement ,]ma+(|
PreparedStatement ps = cn.preparedStatement(sql); tqvN0vY5
{ D9CaFu
ps.setXXX(1,xxx); 6ryak!|[
... u~M
q*
ps.addBatch(); Pw7]r<Q
} .9 on@S
ps.executeBatch(); J!v3i*j\
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 iwZPpl";
F3v!AvA|
事务的处理 x=hiQ>BIO0
1、关闭Connection的自动提交 Qcq`libK
cn.setAutoCommit(false);
nJG U-Z
2、执行一系列sql语句 ~q@|l3?$
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 7a=gH2]&
Statement sm ; \:# L)
sm = cn.createStatement(insert into user...); av}k)ZT_
sm.executeUpdate(); <
Mn ;
sm.close(); SO|NaqWa
sm = cn.createStatement("insert into corp...); \Xt7`I<
sm.executeUpdate(); !N\@'F!
sm.close(); '8RsN-w
3、提交 Bw)/DM]
cn.commit(); F#,90F'
4、如果发生异常,那么回滚 55nlg>j
cn.rollback();