java 数据库基本操作 ^/`:o}7K7
1、java数据库操作基本流程 o"D`_ER
2、几个常用的重要技巧: 5fi6>>
可滚动、更新的记录集 K|$Dnma^n
批量更新 ^)=c74;;
事务处理 ]UyIp`nV;
Qo+_:N
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 z#*M}RR
1、取得数据库连接 >xu}eWSz
1)用DriverManager取数据库连接 0JTDJZOz@#
例子 "(j.:jayd
String className,url,uid,pwd; h_6QVab@
className = "oracle.jdbc.driver.OracleDriver"; #iD5&
klo\
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; UKyOkuY:w
uid = "system"; rQT@:$)
pwd = "manager"; Hb5^+.xur
Class.forName(className); V#jFjObTN
Connection cn = DriverManager.getConnection(url,uid,pwd); C$`z23E
2)用jndi(java的命名和目录服务)方式 l{wHu(1
例子 P1DYjm[+D
String jndi = "jdbc/db"; R o :/J
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); .um]1_= \
DataSource ds = (DataSource) ctx.lookup(jndi); dA-ik
Connection cn = ds.getConnection(); < V) T_
多用于jsp中 R?3^Kx
2、执行sql语句 ^SnGcr|a'
1)用Statement来执行sql语句 0]
e=
String sql; 3XY;g{`=q
Statement sm = cn.createStatement(); #mY*H^jI]~
sm.executeQuery(sql); // 执行数据查询语句(select) UP=0>jjbn:
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); @2Xw17[f35
2)用PreparedStatement来执行sql语句 `btw*{ .[
String sql; vH_QSx;C#
sql = "insert into user (id,name) values (?,?)"; nW2fB8yq
PreparedStatement ps = cn.prepareStatement(sql); _U)BOE0o
ps.setInt(1,xxx); K~**. NF-n
ps.setString(2,xxx); !J
")TP=
... clK3kBh~&
ResultSet rs = ps.executeQuery(); // 查询 C!xq p
int c = ps.executeUpdate(); // 更新 w^tNYN,i
lC&U9=7W
3、处理执行结果 un|+YqLf
查询语句,返回记录集ResultSet )@)wcf!b
更新语句,返回数字,表示该更新影响的记录数 FNlzpCT~L
ResultSet的方法 ? _36uJo}
1、next(),将游标往后移动一行,如果成功返回true;否则返回false "e62g
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 +@D [%l|
*njdqr2c~
4、释放连接 ,lSt}Lml
cn.close(); W 0^.Dx
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection A `\2]t$z
J$6tCFD
可滚动、更新的记录集 td-2[Sy
1、创建可滚动、更新的Statement @dE|UZ=(
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 9d{iq"*R
该Statement取得的ResultSet就是可滚动的 FyYD7E
2、创建PreparedStatement时指定参数 {>[,i`)
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); cE[B
(e
ResultSet.absolute(9000); 3~H_UGw
批量更新 vum6O3
1、Statement z7'3d7r?
Statement sm = cn.createStatement(); y
BF3Lms
sm.addBatch(sql1); K(RG:e~R0i
sm.addBatch(sql2); ]~~PD?jh
... FC<aX[~&3
sm.executeBatch() ;taTdzR_
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 1iBOf8
2、PreparedStatement 5Z{i't0CQ
PreparedStatement ps = cn.preparedStatement(sql); .Ymoh>JRL
{ +')\,m "z
ps.setXXX(1,xxx); Sz4YPl
... {8D`A;KD
ps.addBatch(); I]N?}]uZ
} uPbvN[~t
ps.executeBatch(); Ut4cli&cC
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 5{cbcuG
<i34;`)b
事务的处理 4Z>KrFO
1、关闭Connection的自动提交 --E_s/
cn.setAutoCommit(false); Dp|y&x!
2、执行一系列sql语句
=$3]% b}
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close u50 o1^<X
Statement sm ; yVd}1bX
sm = cn.createStatement(insert into user...); z
zL@3/<j
sm.executeUpdate(); +O
P8U]~
sm.close(); B-`d7c5
sm = cn.createStatement("insert into corp...); Dd8*1,
sm.executeUpdate(); (xw) pR
sm.close(); 6|gC##T
3、提交 @,0W(
cn.commit(); W/COrgbW
4、如果发生异常,那么回滚 LwIl2u*
cn.rollback();