java 数据库基本操作 OGl>i
1、java数据库操作基本流程 M.DU^-7
2、几个常用的重要技巧: a#i85su
可滚动、更新的记录集 Mn)>G36(
批量更新 cZ8lRVaWW
事务处理 bxxazsj^
|aAu4
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 1yFVF
1、取得数据库连接 (~59}lu~
1)用DriverManager取数据库连接 \VL_
例子 )7X+T'?%
String className,url,uid,pwd; 8`\^wG$W
className = "oracle.jdbc.driver.OracleDriver"; N3M:|D
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; R,Gr{"H
uid = "system"; *HT)Au"5
pwd = "manager"; !@6P>HzY$
Class.forName(className); gzHMZ/31
Connection cn = DriverManager.getConnection(url,uid,pwd); M lv
2)用jndi(java的命名和目录服务)方式 y#Cp Vm#!>
例子 tVAWc$3T
String jndi = "jdbc/db"; B~%'YQk
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 6}V)\"u&
DataSource ds = (DataSource) ctx.lookup(jndi); q5Bj0r[/o
Connection cn = ds.getConnection(); ZQL4<fy'E
多用于jsp中 B #[URZ9S
2、执行sql语句 Y 6NoNc]h
1)用Statement来执行sql语句 0n FEPMO
String sql; jb~W(8cj
Statement sm = cn.createStatement(); |iGfX,C|
sm.executeQuery(sql); // 执行数据查询语句(select) s!lLdR[g
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ;8|D4+
2)用PreparedStatement来执行sql语句 k!&G; 6O-
String sql; S_Tv Ix/7&
sql = "insert into user (id,name) values (?,?)"; 9+z5$
PreparedStatement ps = cn.prepareStatement(sql); ]q,5'[=~4h
ps.setInt(1,xxx); {2A| F{7>
ps.setString(2,xxx); p"xti+2,
... `.MY"g9
ResultSet rs = ps.executeQuery(); // 查询 .o27uB.
int c = ps.executeUpdate(); // 更新 S":55YQev!
U@;W^Mt
3、处理执行结果 xJ-(]cO'
查询语句,返回记录集ResultSet u~uR:E%'C
更新语句,返回数字,表示该更新影响的记录数 |b
BA0.yS
ResultSet的方法 8fG$><@
1、next(),将游标往后移动一行,如果成功返回true;否则返回false N5ph70#y3
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 qD/GYqvm
g6s&nH`Z2
4、释放连接 !=)R+g6b
cn.close(); _f"HUKGN
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection P!6v0ezN
4R c_C0O
可滚动、更新的记录集 B%]yLJ
1、创建可滚动、更新的Statement [!g$|
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 9_$i.@L1
该Statement取得的ResultSet就是可滚动的 bNH72gX2Yh
2、创建PreparedStatement时指定参数 g9T9TQ-O
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); "k;j@
ResultSet.absolute(9000); vU4Gw4
批量更新 xr;:gz!h
1、Statement ?(t{VdZSzQ
Statement sm = cn.createStatement(); / LH#
3
sm.addBatch(sql1); /k$H"'`j4
sm.addBatch(sql2); a>05Yxw
... @4O;dFOQ)
sm.executeBatch() _,"?R]MO
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ;Dw6pmZ
2、PreparedStatement LR(Q.x
PreparedStatement ps = cn.preparedStatement(sql); #`g..3ey
{ C;m,{MD
ps.setXXX(1,xxx); tx+KxOt9Y
... 4lb(qKea
ps.addBatch(); Ar;uq7c,G
} Juhi#&`T
ps.executeBatch(); F0D7+-9[
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 w !5@PJ)~U
fQ[&
^S$
事务的处理 9 rMP"td
1、关闭Connection的自动提交 zXEu3h
cn.setAutoCommit(false); ~xp(k
2、执行一系列sql语句 g?9IS,Gp
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close K> rZJ[a
Statement sm ; ^xNs^wC.
sm = cn.createStatement(insert into user...); hx5oTJR
sm.executeUpdate(); I,nW~;OV0
sm.close(); L@&(>
sm = cn.createStatement("insert into corp...); cn3F3@_"\
sm.executeUpdate(); +=N!37+G
sm.close(); @)IHd6 R
3、提交 qH8d3?1XO
cn.commit(); TwaK>t96[
4、如果发生异常,那么回滚 ,Fv8&tR
cn.rollback();