java 数据库基本操作 g*]/HS>e<G
1、java数据库操作基本流程 *3Qwmom
2、几个常用的重要技巧: 'h.:-1# L
可滚动、更新的记录集 m(DJ6CSa
批量更新 ;%W]b
事务处理 YkuFt>U9,
8;\
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 m]Gxep0%
1、取得数据库连接 rU!QXg]uD
1)用DriverManager取数据库连接 4#"_E:;PQ
例子 HY!R |
String className,url,uid,pwd; ]/ffA|"U`
className = "oracle.jdbc.driver.OracleDriver"; R!Lh~~@{(
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; cM 5V%w
uid = "system"; OAw- -rl
pwd = "manager"; ]o+5$L,5b
Class.forName(className); [Rxbb+,U
Connection cn = DriverManager.getConnection(url,uid,pwd); p'f8?jt
2)用jndi(java的命名和目录服务)方式 DElrY)3O.
例子 Q/zlU@
String jndi = "jdbc/db"; ;eY.4/*R
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); CyXFuk!R
DataSource ds = (DataSource) ctx.lookup(jndi); 'nRoa7v(
Connection cn = ds.getConnection(); /?*GJN#
多用于jsp中 dYxX%"J
2、执行sql语句
bo|3sN+D
1)用Statement来执行sql语句 w]O[{3"
String sql; 1Xn:B_pP
Statement sm = cn.createStatement(); UI%Z`.&
sm.executeQuery(sql); // 执行数据查询语句(select) $s]vZ(H
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); M)6iYA%$
2)用PreparedStatement来执行sql语句 B9(@.
String sql; D`NPU
sql = "insert into user (id,name) values (?,?)"; A29R5
PreparedStatement ps = cn.prepareStatement(sql); 7U647G(Sg
ps.setInt(1,xxx); OUFx M
ps.setString(2,xxx); +S6(Fvp
... `~k`m{4.a
ResultSet rs = ps.executeQuery(); // 查询 6Q*Zy[=
int c = ps.executeUpdate(); // 更新 N5d)&a
7?
r7^oqEp@B
3、处理执行结果 $H8B%rT]
查询语句,返回记录集ResultSet 1tIJ'#6
更新语句,返回数字,表示该更新影响的记录数 4^(aG7
ResultSet的方法 N}gPf
i
1、next(),将游标往后移动一行,如果成功返回true;否则返回false Q&]f9j_
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 fvBL? x
f"RS,]
4、释放连接 sXaudT
cn.close(); 'zhv#&O
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection l9t|@9
v|Y
ut~
可滚动、更新的记录集 B&L-Lc2
1、创建可滚动、更新的Statement xQ,My
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); s3sPj2e{
该Statement取得的ResultSet就是可滚动的 K;Fs5|gFU
2、创建PreparedStatement时指定参数 lW|`8ykp
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); W+Q^u7K
ResultSet.absolute(9000); SxI-pH'
批量更新 kt2W7.A5
1、Statement (Cb;=:3G
Statement sm = cn.createStatement(); \"pp-str
sm.addBatch(sql1); Ji)Ys
ebV
sm.addBatch(sql2); `n?Rxhkwp
... dt|| nF
sm.executeBatch() hN^,'O
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 .]w=+~h
2、PreparedStatement K1$
PreparedStatement ps = cn.preparedStatement(sql); lG5KZ[/Or
{ '\M]$`Et
ps.setXXX(1,xxx); 5=_bK^Am
... Tx>V$+al
ps.addBatch(); {n\Ai3F-
} f]48-X,^6
ps.executeBatch(); 43?uTnX/
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 \IaUsx"#o{
ZM16 ~k
事务的处理 $1 t
IC_
1、关闭Connection的自动提交 Vbv)C3ezD
cn.setAutoCommit(false); ub;:"ns}
2、执行一系列sql语句 v>0I=ut
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close p""\uG'
Statement sm ; +"1fr
sm = cn.createStatement(insert into user...); .XT]\'vW
sm.executeUpdate(); \q@Co42n\
sm.close(); gA}?X
sm = cn.createStatement("insert into corp...); zfw=U
\
sm.executeUpdate(); 3Fw7q"
sm.close(); :cvT/xhO
3、提交 ON9L+"vqv0
cn.commit(); !oa/\p
4、如果发生异常,那么回滚 Tq?7-_MLC$
cn.rollback();