java 数据库基本操作 I~&*8)xM
1、java数据库操作基本流程 lbj_if;
2、几个常用的重要技巧: 4vMjVbr
可滚动、更新的记录集 4Jk[X>I~
批量更新 qpX`ZY^
事务处理 X_ (n
jMP;$w
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 IQyw>_~]
1、取得数据库连接 ~mvD|$1z
1)用DriverManager取数据库连接 a\xf\$Ym
例子 DoFF<LXBt
String className,url,uid,pwd; W0LJXp-v
className = "oracle.jdbc.driver.OracleDriver"; |5(un/-C
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; )P#xny2
uid = "system"; xsRu~'f
pwd = "manager"; uC5W1LyI
Class.forName(className); Z"d21D~h9`
Connection cn = DriverManager.getConnection(url,uid,pwd); a/gr1
2)用jndi(java的命名和目录服务)方式 ,F?O} ijk
例子 X8 x:/]/0
String jndi = "jdbc/db"; E.4 X,
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); (BZd%!
DataSource ds = (DataSource) ctx.lookup(jndi); ;BW-ag \9
Connection cn = ds.getConnection(); ,L;%-}#$
多用于jsp中 L[. )!c8k
2、执行sql语句 zC WN,K`
1)用Statement来执行sql语句 _YA;Nd#%k
String sql; Bi`m +ob
Statement sm = cn.createStatement(); K{`3,U2Wx
sm.executeQuery(sql); // 执行数据查询语句(select) <xwaFZ
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); +|.6xC7U
2)用PreparedStatement来执行sql语句 q j*77
String sql; b/&{:g!B
sql = "insert into user (id,name) values (?,?)"; nzl3<Ar
PreparedStatement ps = cn.prepareStatement(sql); :Y[?@/m4
ps.setInt(1,xxx); {TC_
4Y|8
ps.setString(2,xxx); w!/|aZ~*
... x-HR [{C
ResultSet rs = ps.executeQuery(); // 查询 %!V =noo
int c = ps.executeUpdate(); // 更新 g*$yUt
jWGX:XB
3、处理执行结果 r^ +n06[
查询语句,返回记录集ResultSet wyUfmk_}
更新语句,返回数字,表示该更新影响的记录数 AxiCpAS;J
ResultSet的方法 ^03M~SNCj
1、next(),将游标往后移动一行,如果成功返回true;否则返回false RO8]R2A
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ;s w3MRJ
7s2e>6Q[
4、释放连接 @iaz_;
cn.close(); ke5_lr(
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection WbHI>tt
f4+}k GJN
可滚动、更新的记录集 Yp6%
@c6\
1、创建可滚动、更新的Statement 86ml.VOR
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); )"&\S6*!
该Statement取得的ResultSet就是可滚动的 M%N_4j.
2、创建PreparedStatement时指定参数 "/zDcZbL;
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); Kc{~Q
ResultSet.absolute(9000); )B5(V5-!|
批量更新 e%v0EJ},
1、Statement 3.D|xE]g
Statement sm = cn.createStatement(); j?s+#t
sm.addBatch(sql1); !kWx'tJ$
sm.addBatch(sql2); q Qc-;|8
... 0r ilg
sm.executeBatch() 8@BN6
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 6a*OQ{8
2、PreparedStatement fXB64MNo
PreparedStatement ps = cn.preparedStatement(sql); \j~LxV
{ SkMBdkS9z[
ps.setXXX(1,xxx); $6yr:2Xvt
... XV0t
8#T2
ps.addBatch(); #brV{dHV,
} %^<A`Q_
ps.executeBatch(); S0mF%"
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 Yc~c(1VRz
*egAx
事务的处理 U?yKwH^{
1、关闭Connection的自动提交 FW!1 0K?
cn.setAutoCommit(false); ARa9Ia{@
2、执行一系列sql语句 OojQG
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close mx")cGGQ
Statement sm ; `I)ftj%
sm = cn.createStatement(insert into user...); uf}Q{@Ab
sm.executeUpdate(); = ms
o1
sm.close(); Czt>?8x`
sm = cn.createStatement("insert into corp...); ~0ZLaiJ
sm.executeUpdate(); ,?>:Cdz4
sm.close(); te8lF{R
3、提交 ]x`I@vSf7R
cn.commit(); XCku[?Ix
4、如果发生异常,那么回滚 jBnvu@K "
cn.rollback();