java 数据库基本操作 1aKYxjYM
1、java数据库操作基本流程 4HlOv%8
2、几个常用的重要技巧: 8[LwG&
可滚动、更新的记录集 ;+]9KIa_Pq
批量更新 Dt,b\6
事务处理 P 3uAS
?29zcuRaru
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 @xR7>-$0p
1、取得数据库连接 gd'#K~?
1)用DriverManager取数据库连接 BCB"&:}
例子 wH1E7LY|R
String className,url,uid,pwd; `<ITLT
className = "oracle.jdbc.driver.OracleDriver"; 9"_JiX~3
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; Ws?BAfP
uid = "system"; i:`ur
pwd = "manager"; ? lC.
Pq
Class.forName(className); XQ.czj
Connection cn = DriverManager.getConnection(url,uid,pwd); $Gb] K{e
2)用jndi(java的命名和目录服务)方式 _+0l+a*D
例子 |+Z,
7~!
String jndi = "jdbc/db"; l c)*HYqU
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ^.Cfa
DataSource ds = (DataSource) ctx.lookup(jndi); 03?TT,y$
Connection cn = ds.getConnection(); =jdO2MgSg*
多用于jsp中 ^,zE Nqg7
2、执行sql语句 xB{0lI
1)用Statement来执行sql语句 }OO(uC2
String sql; vlCjh! x
Statement sm = cn.createStatement(); fLK*rK^{"
sm.executeQuery(sql); // 执行数据查询语句(select) KZO!
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); <mlQn?u
2)用PreparedStatement来执行sql语句 ]bO{001y,
String sql; 9_'xq.uP
sql = "insert into user (id,name) values (?,?)"; b u%p,u!
PreparedStatement ps = cn.prepareStatement(sql); QC0^G,9.
ps.setInt(1,xxx); T[M?:~
ps.setString(2,xxx); r{qM!(T
... SeAokz>
ResultSet rs = ps.executeQuery(); // 查询 >T{9-_#P
int c = ps.executeUpdate(); // 更新 Tz .!
$Tu%dE(OF
3、处理执行结果 wVk2Fr(
查询语句,返回记录集ResultSet ,Iq+ v
更新语句,返回数字,表示该更新影响的记录数 :$d3}TjsA+
ResultSet的方法 \&]M \
1、next(),将游标往后移动一行,如果成功返回true;否则返回false Db\.D/76
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 NL&(/72V
Hno@
4、释放连接 N'R^S98x
cn.close(); ~/1kCZB
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection Z"#ysC
tr"iluwGc
可滚动、更新的记录集 >XP]NY}Po[
1、创建可滚动、更新的Statement i' J.c4
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); [7B:{sH
该Statement取得的ResultSet就是可滚动的 $wU.GM$t~
2、创建PreparedStatement时指定参数 c38RE,4U
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); p,}-8#K[
ResultSet.absolute(9000); ^_3idLE
批量更新 zsA6(?)u
1、Statement %cG6=`vR
Statement sm = cn.createStatement(); `),7*gn*)
sm.addBatch(sql1); N;tUrdgQ
sm.addBatch(sql2); [P)'LY6F
... =-jkp
sm.executeBatch() (V@g?|LZ
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 qgrRH'
2、PreparedStatement I_.(&hMn
PreparedStatement ps = cn.preparedStatement(sql); x{<WJ|'B
{ $7gzu4f
ps.setXXX(1,xxx); !%J;dOcU
... SQ5SvYH
ps.addBatch(); / _v5B>
} YIb5jK`
ps.executeBatch(); *%(8z~(\
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 v=nq P{
]]@jvU_?kS
事务的处理 ])}{GW
1、关闭Connection的自动提交 9'3%%o
cn.setAutoCommit(false); qa#Fa)g*
2、执行一系列sql语句 'vj45b
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close OQaM4 7"
Statement sm ; kHd_q.
sm = cn.createStatement(insert into user...); wl2rw93
sm.executeUpdate(); dgpo4'c}
sm.close(); I<|)uK7
sm = cn.createStatement("insert into corp...); (:2:_FL
sm.executeUpdate(); VaQ>g*(I
sm.close(); ;%2/
3、提交 ,@%1q)S?A
cn.commit(); EiWy`H;
4、如果发生异常,那么回滚
S%uH*&`
cn.rollback();