java 数据库基本操作 D"$Y, d
1、java数据库操作基本流程 3*2~#dh=
2、几个常用的重要技巧: :r hB=
可滚动、更新的记录集 <I
tS_/z
批量更新 LQ4:SV'3
事务处理 N{Z+
9X=<uS
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 `y^\c#k
1、取得数据库连接 z,x
)Xx
1)用DriverManager取数据库连接 Ao}<a1f
例子 dVj2x-R)
String className,url,uid,pwd; Nr `R3(X
className = "oracle.jdbc.driver.OracleDriver"; LO)!Fj4|
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; Ui
(nMEon
uid = "system"; Fj~suZ`
pwd = "manager"; %aMC[i
Class.forName(className); =<p=?16
x
Connection cn = DriverManager.getConnection(url,uid,pwd); BO7HJF)a
2)用jndi(java的命名和目录服务)方式 c1s&
例子 1.3dy]vG
String jndi = "jdbc/db"; 43B0ynagN
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); /7Pqy2sgE
DataSource ds = (DataSource) ctx.lookup(jndi); xatq
Connection cn = ds.getConnection(); lGWz
多用于jsp中 @0P4pt;(
2、执行sql语句 9t)Hi qj
1)用Statement来执行sql语句 EYj~Xj8_
String sql; g`S;xs
Statement sm = cn.createStatement(); G"J
nQ
sm.executeQuery(sql); // 执行数据查询语句(select) iJ^}{-
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ?{aJ#w
2)用PreparedStatement来执行sql语句 rC_1f3A
String sql; ou~$XZ7oi
sql = "insert into user (id,name) values (?,?)"; >4Tk#+%Jj
PreparedStatement ps = cn.prepareStatement(sql); _v 0iH
ps.setInt(1,xxx); E] /2u3p
ps.setString(2,xxx); .x,y[/[[)
... IJ2'
ResultSet rs = ps.executeQuery(); // 查询 {TpbUj0
int c = ps.executeUpdate(); // 更新 76@W:L*J$J
CZu=/8?
3、处理执行结果 BQ Vro;#Jc
查询语句,返回记录集ResultSet XF)N_}X^
更新语句,返回数字,表示该更新影响的记录数 6d;}mhH
ResultSet的方法 Bt}90#
1、next(),将游标往后移动一行,如果成功返回true;否则返回false cpP}NJb0;%
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ~ E6e~
y.D+M$f
4、释放连接 N WF h<
cn.close(); =KOi#;1
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection v/rBjUc+X
dt"/4wCO
可滚动、更新的记录集 lqmQQ*Z
1、创建可滚动、更新的Statement 2{~`q
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); $ MH;v_'a
该Statement取得的ResultSet就是可滚动的 Y`]P&y
2、创建PreparedStatement时指定参数 s)]T"87H'_
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); Y=G`~2Pr=
ResultSet.absolute(9000); x
cAs}y}
批量更新 {!wW,3|Pu
1、Statement 7AT8QC`u
Statement sm = cn.createStatement(); }#ta3 x
sm.addBatch(sql1); [.xY>\e
sm.addBatch(sql2); qm><}N7f
... s) U1U6O
sm.executeBatch() P8By~f32_
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ;xz_H$g
2、PreparedStatement 4>V@+#Ec5
PreparedStatement ps = cn.preparedStatement(sql); 5wx~QV=Hh
{ 1 mJUlx
ps.setXXX(1,xxx); JZ-@za6u
... sYDav)L.
ps.addBatch(); c:0n/DC
} !;*flr`/
ps.executeBatch(); b_F1?:#
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 ,:L^vG@*
v5a\}S<(
事务的处理 Ly8=SIZ
1、关闭Connection的自动提交 z/4<x?}+hE
cn.setAutoCommit(false); Uvm.|p_V
2、执行一系列sql语句 3 5.&!4}
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close G-9i
Statement sm ; $%DoLpE>
sm = cn.createStatement(insert into user...); N ~=PecQ
sm.executeUpdate(); 0*5Jq#5
sm.close(); -F `GZ
sm = cn.createStatement("insert into corp...); 2yn"K|
sm.executeUpdate(); |\uj(|
sm.close(); NO[A00m|OL
3、提交 rD <T
cn.commit(); H%Vf$1/TF
4、如果发生异常,那么回滚 vA_,TS#Bo
cn.rollback();