java 数据库基本操作 =O~ J
1、java数据库操作基本流程 )^Ha?;TS
2、几个常用的重要技巧: iTX:*$~I
可滚动、更新的记录集 1\'?.
批量更新 R1!F mZW8
事务处理
;f]p`!]
3
^A&i$RRO
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 jwP}{mi*
1、取得数据库连接 ;q=0NtCS=4
1)用DriverManager取数据库连接 q+j.)e
例子 g]fds Zv
String className,url,uid,pwd; "ITC P<+
className = "oracle.jdbc.driver.OracleDriver"; AD$$S.zoD<
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; |3Fo4K%+
uid = "system"; 0n FEPMO
pwd = "manager"; VXE85
Class.forName(className); \vH /bL
Connection cn = DriverManager.getConnection(url,uid,pwd); qcNu9Ih
2)用jndi(java的命名和目录服务)方式 Ou26QoT9XI
例子 Gky
e
String jndi = "jdbc/db"; L9lN AiOH
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); |*G$ilu
DataSource ds = (DataSource) ctx.lookup(jndi); dz3KBiq
Connection cn = ds.getConnection(); 0XkLWl|k
多用于jsp中 S]Y3nI
2、执行sql语句 TT85G
1)用Statement来执行sql语句 %VV\biO]
String sql; rNi]|)-ET
Statement sm = cn.createStatement(); t:NYsL
sm.executeQuery(sql); // 执行数据查询语句(select) jY~W*
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); |JUb 1|gi
2)用PreparedStatement来执行sql语句 :Dh\
String sql; gY\g+df-
sql = "insert into user (id,name) values (?,?)"; V`ODX>\
PreparedStatement ps = cn.prepareStatement(sql); cWNZ +Q8Y
ps.setInt(1,xxx); r8R]0\
ps.setString(2,xxx); tK
$r_*
...
A?YU:f
ResultSet rs = ps.executeQuery(); // 查询 3`Ug]<m
int c = ps.executeUpdate(); // 更新 Y)Os]<N1
t;3n
3、处理执行结果 X0QY:?
查询语句,返回记录集ResultSet }3b3^f
更新语句,返回数字,表示该更新影响的记录数 b I%Sq+"}
ResultSet的方法 pBZf=!+E
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 2qA"emUM
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 +t9$*i9`L
B%]yLJ
4、释放连接 A:-M RhE9X
cn.close(); nnzfKn:J
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection jfLkp>2E'
|D@/4B1P
可滚动、更新的记录集 fZq_]1(/uP
1、创建可滚动、更新的Statement B-R& v8F
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); "k;j@
该Statement取得的ResultSet就是可滚动的 )}Vb+
2、创建PreparedStatement时指定参数 Bql5=p
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ]j4Nl?5*x
ResultSet.absolute(9000); K)D5%?D
批量更新 t PJW|wo
1、Statement he
vM'"|4
Statement sm = cn.createStatement(); y ~PW_,
sm.addBatch(sql1); 3d1$w
sm.addBatch(sql2); @4O;dFOQ)
... ZaNZUVBh
sm.executeBatch() kVqRl%/3Tb
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 f;PPB@ :`$
2、PreparedStatement ~.:9~(2;
PreparedStatement ps = cn.preparedStatement(sql); Tz`O+fx&
{ k@[P\(a3b
ps.setXXX(1,xxx); *X_-8 ^~
... -(Zi
ps.addBatch(); #4yh-D"
} X\=m
ps.executeBatch(); <FkoWN
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 @nh*H{
O BCH%\;g
事务的处理 vqeWt[W
v
1、关闭Connection的自动提交 Np.]
W(
cn.setAutoCommit(false); F0D7+-9[
2、执行一系列sql语句 }k{h^!fV
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close .uoQ@3
Statement sm ; \{GBaMwG~
sm = cn.createStatement(insert into user...); x;w^&<hQ\
sm.executeUpdate(); G*`H2-,
sm.close(); lDWg%pI+
sm = cn.createStatement("insert into corp...); G
$F3dx.I
sm.executeUpdate(); San=E@3}v!
sm.close(); sC<
B
3、提交 }C'H@:/
cn.commit(); nt5x[xa
4、如果发生异常,那么回滚 m|CB')
cn.rollback();