java 数据库基本操作 x: Tm4V{
1、java数据库操作基本流程 tdRnRoB
2、几个常用的重要技巧: 8J7<7Sx
可滚动、更新的记录集 d 'wWj
批量更新 T xwZ3E
事务处理 s2+s1%^Ll
H"g
p
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ,e>N9\*
1、取得数据库连接 (OK;*ZH+T@
1)用DriverManager取数据库连接 k!,&L$sG
例子 \\Huk*Jn{
String className,url,uid,pwd; xqzdXL}
className = "oracle.jdbc.driver.OracleDriver"; PAXdIh[]
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; UG9 Ha
uid = "system"; ^RS`q+g
pwd = "manager"; |N>TPK&Xt
Class.forName(className); ?G!DYUK
Connection cn = DriverManager.getConnection(url,uid,pwd); VJ(#FA2
2)用jndi(java的命名和目录服务)方式 w+owx(mN@
例子 =:=uV0jX\
String jndi = "jdbc/db"; Ih0kdi
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); bjJ212J
DataSource ds = (DataSource) ctx.lookup(jndi); $'VFb=?XrK
Connection cn = ds.getConnection(); wg,w;Gle
多用于jsp中 Q|o~\h<
2、执行sql语句 wN! 5[N"
1)用Statement来执行sql语句 !n/"39KT
String sql; Y;XEC;PXD
Statement sm = cn.createStatement(); S(*SUH
sm.executeQuery(sql); // 执行数据查询语句(select) )b AcU
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); Xn3Ph!\Z5e
2)用PreparedStatement来执行sql语句 gg%OOvaj5
String sql; O}#h^AU-BS
sql = "insert into user (id,name) values (?,?)"; f~? MNJ2
PreparedStatement ps = cn.prepareStatement(sql); 4h~o>(Sq
ps.setInt(1,xxx); .qBf`T;
ps.setString(2,xxx); m;nT ?kv
... `H6kC$^Ofx
ResultSet rs = ps.executeQuery(); // 查询 F&lvofy23
int c = ps.executeUpdate(); // 更新 t1YVE%`w
/g!', r,
3、处理执行结果 'e>0*hF[
查询语句,返回记录集ResultSet 9rmOf Jo:
更新语句,返回数字,表示该更新影响的记录数 It@.U|
ResultSet的方法 $/Q*@4t
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 7.l[tKh
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 g k[8'
"V;M,/Q|
4、释放连接 TM|ycS'
cn.close(); u>.qhtm[
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection w+~s}ta2^
%A dE5HI-
可滚动、更新的记录集 R"=pAO.4l
1、创建可滚动、更新的Statement ^i^/d#
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 0Y9\,y_
该Statement取得的ResultSet就是可滚动的 *1KrI9i
2、创建PreparedStatement时指定参数 XaV h.
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); bgjo_!J+Pp
ResultSet.absolute(9000); 3X&}{M:Qo
批量更新 3R[5prE<
1、Statement O?9&6x
Statement sm = cn.createStatement(); {\L /?#
sm.addBatch(sql1); ZLJfSnB
sm.addBatch(sql2); b}9Ry"
... m. G}#/
sm.executeBatch() -Ug
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 =:zmF]j9
2、PreparedStatement vo[Zuv?<h
PreparedStatement ps = cn.preparedStatement(sql); M38QA
{ _s
Z9p4]
ps.setXXX(1,xxx); <o";?^0Q
... ^{GnEqml&
ps.addBatch(); c?{&=,u2
} {`vF4@
ps.executeBatch(); >c>f6
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 hp]T ^
&AI/;zru
事务的处理 54w..8'
1、关闭Connection的自动提交 DUxj^,mf,
cn.setAutoCommit(false); ;_GS<[A3
2、执行一系列sql语句 ^xO
CT=V
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close K_4}N%P/))
Statement sm ; 7p(^I*|
sm = cn.createStatement(insert into user...); "3A.x1uQ
sm.executeUpdate(); DDT)l+: XP
sm.close(); $e7dE$eH
sm = cn.createStatement("insert into corp...); !PI& y
sm.executeUpdate(); Bg*Oj)NM
sm.close(); bBBW7',[a
3、提交 #]'#\d#i
cn.commit(); 3PLv;@!#j}
4、如果发生异常,那么回滚 "]81+
D
cn.rollback();