java 数据库基本操作 <+oh\y16
1、java数据库操作基本流程 XB7Aa)
2、几个常用的重要技巧: kGYpJg9=
可滚动、更新的记录集 k&ci5MpN
批量更新 &zdS9e-fF
事务处理 ""0Y^M2I
Rql/@j`JX
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ga5Q
1、取得数据库连接 9\_AB.Z:
1)用DriverManager取数据库连接 /?'~`4!(
例子 ("2X8(3z
String className,url,uid,pwd; M:/NW-:
className = "oracle.jdbc.driver.OracleDriver"; {EoYU\x
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; nK1eh@a9Qv
uid = "system"; 0K%okq|n
pwd = "manager"; N PT-d
Class.forName(className); DM^0[3XuV5
Connection cn = DriverManager.getConnection(url,uid,pwd); R| ?Q&F_$
2)用jndi(java的命名和目录服务)方式 ~~W.]>f
例子 djdTh
+>28
String jndi = "jdbc/db"; WNGX`V,d
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); WHdM P
DataSource ds = (DataSource) ctx.lookup(jndi); :?6HG_9X
Connection cn = ds.getConnection(); ~)U50.CH
多用于jsp中 &Hb%Q! ^Kb
2、执行sql语句 "lh4Vg\7n
1)用Statement来执行sql语句
J=`
8
String sql; NN*L3yx
Statement sm = cn.createStatement(); jIubJQR~
sm.executeQuery(sql); // 执行数据查询语句(select) }?s-$@$R
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 23gN;eD+m6
2)用PreparedStatement来执行sql语句 FEjO}lTK
String sql; *7xcwjeP
sql = "insert into user (id,name) values (?,?)"; V~*Gk! +f
PreparedStatement ps = cn.prepareStatement(sql); l=CAr
ps.setInt(1,xxx); XV]N}~h o`
ps.setString(2,xxx); sgfqIe1
... %R0 Wq4}
ResultSet rs = ps.executeQuery(); // 查询 GW,EyOE+~
int c = ps.executeUpdate(); // 更新 NUV">i.(
{rc3`<%
3、处理执行结果 *D?=Ts
查询语句,返回记录集ResultSet hIe .Mv-I)
更新语句,返回数字,表示该更新影响的记录数 .-Lrrk)R+
ResultSet的方法 >v+1v
1、next(),将游标往后移动一行,如果成功返回true;否则返回false a
!VWWUTm?
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 0/R;g~q@
f .O^R~,
4、释放连接 Kb%Y%j
cn.close(); ;ElCWs->\
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection W=+n|1
@xWWN
可滚动、更新的记录集 Bb/if:XS
1、创建可滚动、更新的Statement ?'> .>
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); [c,V=:Cq
该Statement取得的ResultSet就是可滚动的 ;'S,JGpvT
2、创建PreparedStatement时指定参数 /~NX<Ye&
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); A6z,6v6
ResultSet.absolute(9000);
d$$5&a
批量更新 q} e#L6cM
1、Statement >(RkoExO/
Statement sm = cn.createStatement(); _
$F=A
sm.addBatch(sql1);
:^)?AO#J
sm.addBatch(sql2); aopPv&jY
... 5P!ZGbG
sm.executeBatch() +e{ui +
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 fd'kv
2、PreparedStatement +``vnC
PreparedStatement ps = cn.preparedStatement(sql); rCPIz<
{ %'KRbY
ps.setXXX(1,xxx); \?n6l7*t>
... ]Y[N=G
ps.addBatch(); *Jsb~wta
} XDPR$u8hM
ps.executeBatch(); !n-Sh<8
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 %~Yo{4mHs
;Nn(
事务的处理 v9f+ {Y%-
1、关闭Connection的自动提交 jEBn"]\D
cn.setAutoCommit(false); dmF=8nff
2、执行一系列sql语句 q;eb
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close #/YS
Statement sm ; kLgkUck8]
sm = cn.createStatement(insert into user...); >?^oxB"<Gc
sm.executeUpdate(); 5M5Bm[X
sm.close(); |S8$NI2
sm = cn.createStatement("insert into corp...); :!aLa}`@
sm.executeUpdate(); ;%n'k
sm.close();
~@'wqGTp
3、提交 +xYu@r%R
cn.commit(); YS|Dw'%g /
4、如果发生异常,那么回滚 $Tbsre\MJ
cn.rollback();