java 数据库基本操作 :a{dWgN
1、java数据库操作基本流程 kl]V_ 7[
2、几个常用的重要技巧: 1'/
[x(/]d
可滚动、更新的记录集 93*d:W8Vr
批量更新 G_1r&[N3
事务处理 {^1O
{m*lt3$k
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 bD{tsxm[9
1、取得数据库连接 q0}u%Yz
1)用DriverManager取数据库连接 =@d#@
例子 CcUF)$kz
String className,url,uid,pwd; w1I07 (
className = "oracle.jdbc.driver.OracleDriver"; FO/cEu
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; z%E(o%l8
uid = "system"; Tw';;euw
pwd = "manager"; ZbC$Fk,,I&
Class.forName(className); lG-B)
F
Connection cn = DriverManager.getConnection(url,uid,pwd); <}lah%4F
2)用jndi(java的命名和目录服务)方式 ?1L<VL=b
例子 _GkLspSaU
String jndi = "jdbc/db"; }K?b2 6`
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ;t*SG*Vi
DataSource ds = (DataSource) ctx.lookup(jndi); Gy\]j
Connection cn = ds.getConnection(); (l%?YME
多用于jsp中 68j1svz9
2、执行sql语句 ,<
g%}P/
1)用Statement来执行sql语句 HN7tIz@Frc
String sql; /k/X[/WO
Statement sm = cn.createStatement(); m}z6Bbis 0
sm.executeQuery(sql); // 执行数据查询语句(select) |fKT@2(
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ^# #j
{h7
2)用PreparedStatement来执行sql语句 a]*{!V{$i
String sql; x_~_/&X5
sql = "insert into user (id,name) values (?,?)"; WOn<JCh]
PreparedStatement ps = cn.prepareStatement(sql); curYD~7
ps.setInt(1,xxx); x'0_lf</#
ps.setString(2,xxx); '!A}.wF0
... {Fwvuk
ResultSet rs = ps.executeQuery(); // 查询 F^/KD<cgK
int c = ps.executeUpdate(); // 更新 ^B1Ft5F`b
i!%WEHPe
3、处理执行结果 w)ki<Dudg
查询语句,返回记录集ResultSet ulzX$
更新语句,返回数字,表示该更新影响的记录数 Q~(Qh_Ff
ResultSet的方法 7C'@g)@^/
1、next(),将游标往后移动一行,如果成功返回true;否则返回false __eB 7]#E
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 wb9(aS4
dDA8IW![S
4、释放连接 @&G}'6vF!
cn.close(); - BWf.
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection )Wle
CS_
R]yce2w" z
可滚动、更新的记录集 R ?s;L
r
1、创建可滚动、更新的Statement D SX%SE)
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); }>M\iPO.]*
该Statement取得的ResultSet就是可滚动的 ^1~lnD~0
2、创建PreparedStatement时指定参数 b_`h2dUq
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); r^6@Zwox]
ResultSet.absolute(9000); ?#GTD?3d
批量更新 9ye!kYF,
1、Statement \FfqIc9;
Statement sm = cn.createStatement(); +@]k[9
sm.addBatch(sql1); \ n2MP
sm.addBatch(sql2); :rM2G@{
... ,Z
@I"&H
sm.executeBatch() AS]8rH
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ;`/a. /bc
2、PreparedStatement
2OpA1$n6
PreparedStatement ps = cn.preparedStatement(sql); )PvnB=wy
{ 7 q!==P=
ps.setXXX(1,xxx); f/c&Ya(D~
... C$0u-Nx8
ps.addBatch(); tm/>H
} AmC9qk8Q
ps.executeBatch(); 3\4e{3$
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 vv&< 7[
2H w7V3q
事务的处理 e|:\Ps `8
1、关闭Connection的自动提交 ]d[e
cn.setAutoCommit(false); Ce-=
-
2、执行一系列sql语句 }' tJc $!
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close Ms +ekY)
Statement sm ; OIj.K@Kr
sm = cn.createStatement(insert into user...); V'#R1 x"3
sm.executeUpdate(); 7k,BE2]"
sm.close(); q)9n%- YgP
sm = cn.createStatement("insert into corp...); %\HE1d5;
sm.executeUpdate(); fZpi+I
sm.close(); ^[.}DNR95(
3、提交 Q>Klkd5(
cn.commit(); .`~?w+ ~
4、如果发生异常,那么回滚 tl /i
cn.rollback();