java 数据库基本操作 kk6
!krZ
1、java数据库操作基本流程 l5Ko9CG
2、几个常用的重要技巧: GdNhEv
可滚动、更新的记录集 rf4f'cUa
批量更新 y&5
O)
事务处理 cnQ2/ZZp~
3~Fag1Hp
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 .Y]0gi8z
1、取得数据库连接 UE"v+GH
1)用DriverManager取数据库连接 ksOsJ~3)
例子 OZe&p
String className,url,uid,pwd; La9}JvQoX
className = "oracle.jdbc.driver.OracleDriver"; u*P@Nuy6
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; BlU&=;#r5>
uid = "system"; e1h7~ j
pwd = "manager"; g=Xy{Vm
Class.forName(className); }EkL[H!
Connection cn = DriverManager.getConnection(url,uid,pwd); W}TP(~x'N
2)用jndi(java的命名和目录服务)方式 (?R!y -
例子 M(K7xx+G
String jndi = "jdbc/db"; .\ fpjQW
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); -sKtT 9o
DataSource ds = (DataSource) ctx.lookup(jndi); *nJ,|T
Connection cn = ds.getConnection(); ou~$XZ7oi
多用于jsp中 >| ,`E
2、执行sql语句 _v 0iH
1)用Statement来执行sql语句 k89N}MA
String sql; abUO3
Y{
Statement sm = cn.createStatement(); IJ2'
sm.executeQuery(sql); // 执行数据查询语句(select) y,|2hrj/0E
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); s9CmR]C
2)用PreparedStatement来执行sql语句 W-#DEU 7_
String sql; wzju)q S
sql = "insert into user (id,name) values (?,?)"; XF)N_}X^
PreparedStatement ps = cn.prepareStatement(sql); 1~K'r&
ps.setInt(1,xxx); Bt}90#
ps.setString(2,xxx); cpP}NJb0;%
... ~ E6e~
ResultSet rs = ps.executeQuery(); // 查询 y.D+M$f
int c = ps.executeUpdate(); // 更新 N WF h<
=KOi#;1
3、处理执行结果 hIV]ZYbH
查询语句,返回记录集ResultSet dt"/4wCO
更新语句,返回数字,表示该更新影响的记录数 \L~^c1s3r
ResultSet的方法 v9*+@
1、next(),将游标往后移动一行,如果成功返回true;否则返回false $ MH;v_'a
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 r[}nr H&8
Y=G`~2Pr=
4、释放连接 x
cAs}y}
cn.close(); `b8nz 7
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection W g7
eY'FE
|rk.t g9
可滚动、更新的记录集 06 %-tAq:
1、创建可滚动、更新的Statement \UZGXk
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 99ZWB
该Statement取得的ResultSet就是可滚动的 :qbU@)p*
2、创建PreparedStatement时指定参数 $RY-yKmi
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
b7\> =
ResultSet.absolute(9000); 9AhA"+?
批量更新 m=@xZw<
1、Statement "Ux(nt
Statement sm = cn.createStatement(); i@?|vu
sm.addBatch(sql1); n5UUoBv
sm.addBatch(sql2); /fb}]e]N
... mJ<`/p?:
sm.executeBatch() P:.jb!ZU
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 Ya\:C]
2、PreparedStatement dGOFSH
PreparedStatement ps = cn.preparedStatement(sql); tmS2%1o
{ ( `bb1gz
ps.setXXX(1,xxx); $%DoLpE>
... N ~=PecQ
ps.addBatch(); 0*5Jq#5
} "o`?-bQ:
ps.executeBatch(); iQ:eR]7X
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 %?].(
Lc
%M1l[\N
事务的处理 P7=`P
1、关闭Connection的自动提交 (["kbPma
cn.setAutoCommit(false); pu/5#[MC)^
2、执行一系列sql语句 ;.sYE/ZVi
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close ^_@[1'^
Statement sm ; ~8nR3ki
sm = cn.createStatement(insert into user...); duEXp]f!
sm.executeUpdate(); J?m/u6
sm.close(); KMy"DVqE
sm = cn.createStatement("insert into corp...); ynM~&]fk#k
sm.executeUpdate(); ohKoX$|p~
sm.close(); JYw?
3、提交 _"Ym]y28li
cn.commit(); lG'D/#
4、如果发生异常,那么回滚 5|~g2Zz{;
cn.rollback();