java 数据库基本操作 EMW6'
1、java数据库操作基本流程 neDXzMxF
2、几个常用的重要技巧: kW g.-$pp
可滚动、更新的记录集 (8JU!lin
批量更新 lS.Adl^k
事务处理 c[dzO.~
;hX( /T
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 vjGQ! xF
1、取得数据库连接 0Z9DewwP
1)用DriverManager取数据库连接 Z .6dL
例子 hi0HEm\
String className,url,uid,pwd; 8vY-bm,e
className = "oracle.jdbc.driver.OracleDriver"; >d 2Fa4u3
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; 5~JT*Ny
uid = "system"; H$(bSw$
pwd = "manager"; zN4OrG0
Class.forName(className); Ic#xz;elM
Connection cn = DriverManager.getConnection(url,uid,pwd); JQ&t"`\k
2)用jndi(java的命名和目录服务)方式 u]J@65~'b
例子 @!#e\tx
String jndi = "jdbc/db"; e<L@QNX
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); afEa@et'
DataSource ds = (DataSource) ctx.lookup(jndi); ^/2I)y]W0
Connection cn = ds.getConnection(); 9oWU]A\k>
多用于jsp中 Dm>"c;2
2、执行sql语句 Tu#< {'1$
1)用Statement来执行sql语句 RdTM5ANT
String sql; yGZsNd {a&
Statement sm = cn.createStatement(); {m.$EoS
sm.executeQuery(sql); // 执行数据查询语句(select) +2~kHrv
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); e3?=1ZB
2)用PreparedStatement来执行sql语句 %BqaVOKJ"f
String sql; %qP[+N&
sql = "insert into user (id,name) values (?,?)"; tgK
I
PreparedStatement ps = cn.prepareStatement(sql); }SN( ^3N
ps.setInt(1,xxx); #o.e
(C
ps.setString(2,xxx); ^:eZpQ [,
... gE-y`2SU
ResultSet rs = ps.executeQuery(); // 查询 }]?Si6_ZZ
int c = ps.executeUpdate(); // 更新 mPV<a&U
~GaGDS\V
3、处理执行结果 kI{DxuTad
查询语句,返回记录集ResultSet rH+OXGoB
更新语句,返回数字,表示该更新影响的记录数
l] nt@0+
ResultSet的方法 |?` 5 ~f
1、next(),将游标往后移动一行,如果成功返回true;否则返回false c?p^!zG
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 S&op|Z)1
5,RUPaE
4、释放连接 2ej7Ql_@c
cn.close(); dhl[=Y`
Q
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection -EjXVn! vQ
pm&THd
可滚动、更新的记录集 @=Kq99=\U
1、创建可滚动、更新的Statement IUcL*
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); IP~!E_e}\
该Statement取得的ResultSet就是可滚动的 ] $ew 5%
2、创建PreparedStatement时指定参数 )
nfoDG#O
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); AKNx~!%2
ResultSet.absolute(9000); v\0 G`&^1
批量更新 v0^9"V:y
1、Statement LSo!_tY
Statement sm = cn.createStatement(); G1"iu89d
sm.addBatch(sql1); ::L2zVq5V
sm.addBatch(sql2); E_HB[9
... Qy,^'fSN
sm.executeBatch() B~Q-V&@o
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 f0Q6sV ZHa
2、PreparedStatement
PJnC
PreparedStatement ps = cn.preparedStatement(sql); B[vj X"yg
{
^?69|,
ps.setXXX(1,xxx); e_vsiT
... %B3~t>
ps.addBatch(); [}X|&`'i
} _B4&Fb.
ps.executeBatch(); GN.Oa$
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 |Lq8cA)|y
3P>gDQP
事务的处理 _`$LdqgE
1、关闭Connection的自动提交 )vr@:PE
cn.setAutoCommit(false); 9N]Xa
2、执行一系列sql语句 ^6 6!f 5^W
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close k_=SDm a
Statement sm ; tiK?VwaKI
sm = cn.createStatement(insert into user...); )n/%P4l
sm.executeUpdate(); CU$khz"
sm.close(); MatXhP] Fi
sm = cn.createStatement("insert into corp...); z(PUoV:?
sm.executeUpdate(); mp|pz%U
sm.close(); JFq
wC=-
3、提交 NOz3_k
cn.commit(); 8WP>u8&
4、如果发生异常,那么回滚 $o6/dEKQ
cn.rollback();