java 数据库基本操作 my/KsB
1、java数据库操作基本流程 j3H_g^
2、几个常用的重要技巧: z]KJ4
可滚动、更新的记录集 @6Lp$w
批量更新 W)'*Dcd
事务处理 xm5?C>vu(
g W_E
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 t/_\w"
1、取得数据库连接 +Jm vB6s
1)用DriverManager取数据库连接 JTObyAoW
例子 ex^9 l b
String className,url,uid,pwd; ~0[(-4MA
className = "oracle.jdbc.driver.OracleDriver"; (BngwLVDK
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; )CHXfO w
uid = "system"; jT/P+2hMW
pwd = "manager"; p2< 927z
Class.forName(className); 4>HaKJ-c#
Connection cn = DriverManager.getConnection(url,uid,pwd); 5<e{)$C
2)用jndi(java的命名和目录服务)方式 U ^nv)
例子 /r2S1"(q
String jndi = "jdbc/db"; ZpMv16
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); YQtq?&0Ct
DataSource ds = (DataSource) ctx.lookup(jndi); f96`n+>xi
Connection cn = ds.getConnection(); aXzb]">
多用于jsp中 7yXJ\(6R_
2、执行sql语句 lMG+,?<uK&
1)用Statement来执行sql语句 1GIBqs~-
String sql; X&h?1lMJ /
Statement sm = cn.createStatement(); n).*=YLN
sm.executeQuery(sql); // 执行数据查询语句(select) KUq7O a!
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); )wXE\$
2)用PreparedStatement来执行sql语句 cLRzm9
String sql; u+
hRaI;v
sql = "insert into user (id,name) values (?,?)"; .C&kWM&j
PreparedStatement ps = cn.prepareStatement(sql); <lNNT6[/r
ps.setInt(1,xxx); hS*&p0YV~M
ps.setString(2,xxx); ]Yf^O @<<>
... cMCM>*X
ResultSet rs = ps.executeQuery(); // 查询 *&\6x}.I4
int c = ps.executeUpdate(); // 更新 !* KQ2#e
Jw#7b[a
3、处理执行结果 ,0ilNi>
查询语句,返回记录集ResultSet gz~ug35
更新语句,返回数字,表示该更新影响的记录数 Jt#HbAY
ResultSet的方法 +0j{$MPZ
1、next(),将游标往后移动一行,如果成功返回true;否则返回false Zy.A9Bh~
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 h_\(
$"
wt;`_}g
4、释放连接 p Q!lY
cn.close(); Q2)(tB= )
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection sdiWQv
_sZ&=-FR
可滚动、更新的记录集 w\UAKN60
1、创建可滚动、更新的Statement =,C]d~
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ` AD}6O+x
该Statement取得的ResultSet就是可滚动的 edCVIY'1
2、创建PreparedStatement时指定参数 %IE;'aa
}
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); B2* 7H
ResultSet.absolute(9000); ; yE.R[I
批量更新 WPrBK{B`o
1、Statement o3eaNYa
Statement sm = cn.createStatement(); )MLbE-@
sm.addBatch(sql1); FCOa|IKsN
sm.addBatch(sql2); %W$b2N{l
... .o5K X*
sm.executeBatch() BTYYp1
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 hOkn@F.
2、PreparedStatement ,grx'to(X
PreparedStatement ps = cn.preparedStatement(sql); ^^*L;b>I
{ |(2#KMEWa
ps.setXXX(1,xxx); b:r8r}49
... e@;'# t
ps.addBatch(); 3$Vx8:Rhdn
} -ah)/5j
ps.executeBatch(); S:Jg#1rww-
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 !`4ie
1RX-`"^+
事务的处理 ,3c25.,*
1、关闭Connection的自动提交 /er{sKVX<
cn.setAutoCommit(false); Q[aF"5h%
2、执行一系列sql语句 k3e6y
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 6Vncr}
Statement sm ; G<k.d"<
sm = cn.createStatement(insert into user...); m+:JNgX6
sm.executeUpdate(); :-<30LS$
sm.close(); nqx0#_K-E
sm = cn.createStatement("insert into corp...); 63_#*6Pv28
sm.executeUpdate(); Ayv:Pv@
sm.close(); 5''k|B>
3、提交 cH$(*k9%M
cn.commit(); dtTfV.y4w
4、如果发生异常,那么回滚 ]Hq,Pr_+
cn.rollback();