java 数据库基本操作 7(}'jZ
1、java数据库操作基本流程 @ki|#ro
2、几个常用的重要技巧: ps'_Y<@
可滚动、更新的记录集 V1'otQH2l
批量更新 N**)8(
事务处理 `df!-\#
O50_qu33ju
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ),yar9C
1、取得数据库连接 dFBFXy
1)用DriverManager取数据库连接 x$q} lJv_
例子 z)M#9oAM
String className,url,uid,pwd; =\lw.59
className = "oracle.jdbc.driver.OracleDriver"; sSU|N;"Y
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; 1["i,8zB
uid = "system"; rfk{$g
pwd = "manager"; j!agD_J
Class.forName(className); [gT}<W
Connection cn = DriverManager.getConnection(url,uid,pwd); 0B(s+#s
2)用jndi(java的命名和目录服务)方式 ^=eC1bQA
例子 UN'n~d@~
String jndi = "jdbc/db"; =!t;e~^8]
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ~vz%I^xW
DataSource ds = (DataSource) ctx.lookup(jndi); ;qaPK2a8
Connection cn = ds.getConnection(); PIU@}:}
多用于jsp中 ^i|R6oO_5
2、执行sql语句 4Kch=jt4#
1)用Statement来执行sql语句 Oa/zEH
String sql; ?Kgb-bXB
Statement sm = cn.createStatement(); ?#w} S%
sm.executeQuery(sql); // 执行数据查询语句(select) OTF/Pu$
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); fJlNxdVr
2)用PreparedStatement来执行sql语句 S L
5k^|
String sql; US$$ADq
sql = "insert into user (id,name) values (?,?)"; bB?E(>N;
PreparedStatement ps = cn.prepareStatement(sql); "r46Rfa
ps.setInt(1,xxx); wPM&N@Pf
ps.setString(2,xxx); Y'iI_cg
... I(^0/]'
ResultSet rs = ps.executeQuery(); // 查询 cCZp6^/<x
int c = ps.executeUpdate(); // 更新 ~yJ 2@2I
7
0?iZIK _
3、处理执行结果 ./ {79
查询语句,返回记录集ResultSet }gQ2\6o2g
更新语句,返回数字,表示该更新影响的记录数 -Fd&rq:GB(
ResultSet的方法 *,JE[M
1、next(),将游标往后移动一行,如果成功返回true;否则返回false -
]wT
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 Bh&pZcm|
0o+Yjg>\~8
4、释放连接 ;~<To9O
cn.close(); ^7yt>
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection [XY%<P3D
J-
S.m(
可滚动、更新的记录集 ;(?tlFc
1、创建可滚动、更新的Statement Dsm1@/"i|7
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY);
] :;x,$k
该Statement取得的ResultSet就是可滚动的 *#YZm>h
2、创建PreparedStatement时指定参数 y2I7Zd .
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ZMQ=D!kT
ResultSet.absolute(9000); +7b8 ye
批量更新 _nqnO8^IG4
1、Statement ?zBu`7j
Statement sm = cn.createStatement(); c9nR&m8(+
sm.addBatch(sql1); 'O(=Pz
sm.addBatch(sql2); Gt.'_hf Js
... ! $$>D"
sm.executeBatch() Fs~(>w@
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ?:wb#k)Z/
2、PreparedStatement nmU1xv_
PreparedStatement ps = cn.preparedStatement(sql); D[yyFo,z
{ Qel)%|dOn
ps.setXXX(1,xxx); gNEcE9y2
... yus3GqPI
ps.addBatch(); :$"{-n
} W q<t+E[
ps.executeBatch(); Iuxf`sd
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 '<o3x$6
*
dQ8RrD=$&
事务的处理 hty'L61\z
1、关闭Connection的自动提交 !ekByD
cn.setAutoCommit(false); {J==y;dK
2、执行一系列sql语句 Y ]([K.I=
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close (%fQhQ
Statement sm ; A5Hx$.Z
sm = cn.createStatement(insert into user...); yq-~5ui
sm.executeUpdate(); M>i(p%
sm.close(); bJ_rU35s>
sm = cn.createStatement("insert into corp...); m ~&
sm.executeUpdate(); Qbv@}[f
sm.close(); ya&=UoI
3、提交 WPRk>j
cn.commit(); iL;V5|(sb
4、如果发生异常,那么回滚 G^ GIHdo
cn.rollback();