java 数据库基本操作 WRq:xDRn0
1、java数据库操作基本流程 h6yXW!8
2、几个常用的重要技巧: <;O-N=
可滚动、更新的记录集 TIs~?wb$
批量更新 TpHvZ]c
事务处理 DaA9fJ7a
d~G, *
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 D.Q9fa&P
1、取得数据库连接 !vaS fL*]
1)用DriverManager取数据库连接 p}b:(QN~m
例子 c Nhy.Z~D
String className,url,uid,pwd; P
,%IZ.
className = "oracle.jdbc.driver.OracleDriver"; fAW(
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; *FINNNARB
uid = "system"; efc<lSUR
pwd = "manager"; ?)Psf/
Class.forName(className); -w[j`}([P9
Connection cn = DriverManager.getConnection(url,uid,pwd); eaG _)y
2)用jndi(java的命名和目录服务)方式 \1[=t+/
例子 i42M.M6D $
String jndi = "jdbc/db"; @1`!}.Tk
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); o~aK[
DataSource ds = (DataSource) ctx.lookup(jndi); ZQ%4]=w
Connection cn = ds.getConnection(); oCCTRLb02
多用于jsp中 #|ppW fZQ
2、执行sql语句 <l:c O$ m
1)用Statement来执行sql语句 (O&R-5m
String sql; s>RtCw3,
Statement sm = cn.createStatement(); ^:Mal[IR
sm.executeQuery(sql); // 执行数据查询语句(select) JQo"<<[
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); bv NXA*0
2)用PreparedStatement来执行sql语句 V!|:rwG2
String sql; PNSV?RT*pG
sql = "insert into user (id,name) values (?,?)"; n^a&@?(+
PreparedStatement ps = cn.prepareStatement(sql); g`2DJi&)
ps.setInt(1,xxx); Ojh\H
ps.setString(2,xxx); L.E6~Rv
... a/k0(
ResultSet rs = ps.executeQuery(); // 查询 csEF^T-
int c = ps.executeUpdate(); // 更新 w_>SxSS7
}o'WR'LX
3、处理执行结果 ]12ypcf
查询语句,返回记录集ResultSet DE $HF*WY
更新语句,返回数字,表示该更新影响的记录数 Pl>BTo>p'
ResultSet的方法 BE#s@-zR=p
1、next(),将游标往后移动一行,如果成功返回true;否则返回false o \#C#NiT
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 75^U<Hz-3{
9{A[n}
4、释放连接 ^|P/D
cn.close(); R#n!1~ (
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection prdlV)LTpY
]]EOCGZ"
可滚动、更新的记录集 $=IJ-_'o
1、创建可滚动、更新的Statement 6*{sZMG
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 3eg)O34
该Statement取得的ResultSet就是可滚动的 Wubvvm8U
2、创建PreparedStatement时指定参数 "-WEUz
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); Bb~Q]V=x;
ResultSet.absolute(9000); h@^d
Vg
批量更新
w~3~:w$
1、Statement ^#V7\;v$G
Statement sm = cn.createStatement(); JKXb$
sm.addBatch(sql1); mh4<.6>5
sm.addBatch(sql2); 8iB}gHe9
... N084k}io
sm.executeBatch() Xf"B\%,(`
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 THOXs;
k0
2、PreparedStatement ~ ~"qT
PreparedStatement ps = cn.preparedStatement(sql); [?=Vqd
{ vmY 88Kx&S
ps.setXXX(1,xxx); 0sQt+_Dl%L
... S260h,(,
ps.addBatch(); ;RElG>#$
} Wv4x^nJ
ps.executeBatch(); 2fa1jl
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 .8v[ss6:
iE}Lw&x
事务的处理 fH>I/%
1、关闭Connection的自动提交 g5\EVcHkz
cn.setAutoCommit(false); %mO.ur>21
2、执行一系列sql语句 v
J_1VW
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close =B/Ac0Y
Statement sm ; )R- e^Cb
sm = cn.createStatement(insert into user...); ) ]y^RrD
sm.executeUpdate(); JM&:dzyIP
sm.close(); CY4ntd4M
sm = cn.createStatement("insert into corp...); $ YPU(y
sm.executeUpdate(); HQ7
sm.close(); wH<'*>/
3、提交 8iIz!l%O
cn.commit(); 4D4Y.g_x
4、如果发生异常,那么回滚 .*x |TPv{
cn.rollback();