java 数据库基本操作 yeW|Ux:
1、java数据库操作基本流程 >- :U
2、几个常用的重要技巧: 6h5*b8LxA
可滚动、更新的记录集 *zmbo >{(
批量更新 2;q6~Y,
事务处理 D6 M:pIN*
f[X>?{q
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 c~>M7e(
1、取得数据库连接 ^x4gUT-Wy
1)用DriverManager取数据库连接 SmRU!C$A
例子 ;A|6&~E0G
String className,url,uid,pwd; +xWT)h/
className = "oracle.jdbc.driver.OracleDriver";
Gjzhgz--
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; j\W+wnAgk
uid = "system"; L-MpdC
pwd = "manager"; |#S!qnXB
Class.forName(className); f+)F-3
Connection cn = DriverManager.getConnection(url,uid,pwd); SQEXC*08
2)用jndi(java的命名和目录服务)方式 `;`34t_)
例子 Hiq9Jn uv(
String jndi = "jdbc/db"; mxXQBmW
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); pa.W-qyu
DataSource ds = (DataSource) ctx.lookup(jndi); r^]0LJ
Connection cn = ds.getConnection(); &^z~wJ,]
多用于jsp中 (g
2、执行sql语句 YAO.Cc z
1)用Statement来执行sql语句 44n^21k
String sql; t4,6`d?C
Statement sm = cn.createStatement(); zJ#q*2A(Z
sm.executeQuery(sql); // 执行数据查询语句(select) 643 O(0a
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); Qz
$ 1_vO
2)用PreparedStatement来执行sql语句 QK;A>]
String sql; Zaq:l[%
sql = "insert into user (id,name) values (?,?)"; @ws3X\`<C
PreparedStatement ps = cn.prepareStatement(sql); Haturg
ps.setInt(1,xxx); yvVs9"|0
ps.setString(2,xxx); 9<xe%V=ki
... QjRVdb>
ResultSet rs = ps.executeQuery(); // 查询 4u"O/rt
int c = ps.executeUpdate(); // 更新 YHE7`\l
H1q>UU:
3、处理执行结果 AN^;~m ^
查询语句,返回记录集ResultSet K}Aaflq
更新语句,返回数字,表示该更新影响的记录数 (=7e~'DC
ResultSet的方法 ZZ4W?);;
1、next(),将游标往后移动一行,如果成功返回true;否则返回false cnI!}Bu
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 _7 n+j
>WDb89kC=
4、释放连接 q~a6ES_lA
cn.close(); c.NAUe_3
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection '!Q[+@$
5<&<61[A
可滚动、更新的记录集 8pPAEf
1、创建可滚动、更新的Statement qG~O]($
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); c1Dhx,]ad
该Statement取得的ResultSet就是可滚动的 7|H !( a'
2、创建PreparedStatement时指定参数 UP#]n
69y
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); dGZVWEaPfx
ResultSet.absolute(9000); rU(N@i%
批量更新 &L+u]&!6C
1、Statement vk{dL'
Statement sm = cn.createStatement(); IUI>/87u
sm.addBatch(sql1); 8_W<BXW
sm.addBatch(sql2);
_ 57m] ;&
... I2D<~xP~2+
sm.executeBatch() ]W]Vkkg]
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 sgFpZk
2、PreparedStatement E@t^IGDr
PreparedStatement ps = cn.preparedStatement(sql); TVYO`9:CW
{ Kh3*\x T
ps.setXXX(1,xxx); aQkgkV;~
... CkIICx
ps.addBatch(); KeY)%{
} Nqy',N
ps.executeBatch(); $Nnz|y
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 :Bda]]Y=
(5VP*67
事务的处理 ;clF\K>
1、关闭Connection的自动提交 ]yA|
m3^2
cn.setAutoCommit(false); (l9U7^S"{K
2、执行一系列sql语句 !*N#}6Jd
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close L;>tuJY1
Statement sm ; oE)tK1>;H
sm = cn.createStatement(insert into user...); BpRQG]L
sm.executeUpdate(); 389T6sP]
sm.close(); &yWl8O
sm = cn.createStatement("insert into corp...); X+Xjf(
sm.executeUpdate(); pX|\J>u)
sm.close(); 6i, d|
3、提交 6Kg
lp\2
cn.commit(); ;PGC9v%i
4、如果发生异常,那么回滚 j2g#t
cn.rollback();