java 数据库基本操作 QQT G9s
1、java数据库操作基本流程 Gxo#
!
2、几个常用的重要技巧: u2\+?`Ox
可滚动、更新的记录集 s><IykIi
批量更新 ?LR"hZ>
事务处理 6 1L7
-~
VkWO}
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ]u;GNz}?
1、取得数据库连接 90?,-6
1)用DriverManager取数据库连接 V8\$`NEP
例子 u\:rY)V
String className,url,uid,pwd; @c0n2 Xcr
className = "oracle.jdbc.driver.OracleDriver"; (lieiye^
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; mZ~mf->%
uid = "system"; W\'Nv/L
pwd = "manager"; 7F=2t_2O
Class.forName(className); P&,hiGTDi
Connection cn = DriverManager.getConnection(url,uid,pwd); >/8ru*Oc
2)用jndi(java的命名和目录服务)方式 I'xC+nL@
例子 R04.K!
String jndi = "jdbc/db"; c1PViko,>
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); Q6eN+i2 ;
DataSource ds = (DataSource) ctx.lookup(jndi); y{YXf!AS
Connection cn = ds.getConnection(); }Z"28?
多用于jsp中 hTDV!B-_(
2、执行sql语句 m**0rpA
1)用Statement来执行sql语句 gH5CB%)
String sql; vJ~4D*(]l
Statement sm = cn.createStatement(); s c5\( b
sm.executeQuery(sql); // 执行数据查询语句(select) Sy4
mZ}:
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); a5X`jo
2)用PreparedStatement来执行sql语句 W^003*m~~K
String sql; Q^[e/U,
sql = "insert into user (id,name) values (?,?)"; p}96uaC1
PreparedStatement ps = cn.prepareStatement(sql); 1!X1wCT
ps.setInt(1,xxx); .4Iw=T_
ps.setString(2,xxx); 2]2{&b u
... W)|c[Q\
ResultSet rs = ps.executeQuery(); // 查询 t3pZjdLJd
int c = ps.executeUpdate(); // 更新 HE*7\"9
_yiRh:
3、处理执行结果 1% asx'^
查询语句,返回记录集ResultSet ,tcP=fdk]
更新语句,返回数字,表示该更新影响的记录数 "3\oQvi.
ResultSet的方法 |
A3U@>6
1、next(),将游标往后移动一行,如果成功返回true;否则返回false MRjH40"2
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 +{5JDyh0
1XqIPiXJ
4、释放连接 -)4uYK*
cn.close(); U~oBNsU"
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 1d/NZJ9
Po'-z<}wS
可滚动、更新的记录集 >_&~!Y.Z=
1、创建可滚动、更新的Statement O~$ {&(
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); P/C&R-{')
该Statement取得的ResultSet就是可滚动的 j?Cr31
2、创建PreparedStatement时指定参数 RP,A!pa@
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); c!tvG*{
ResultSet.absolute(9000); gTqeJWX9wP
批量更新 ;,<r|.6U
1、Statement ".Lhte R?
Statement sm = cn.createStatement(); ay=KfY5
sm.addBatch(sql1); g Cg4;b6g
sm.addBatch(sql2); i:V0fBR[>
... rn5"o8|
sm.executeBatch() : :F!
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 8.*\+nH
2、PreparedStatement "|(rVj=
PreparedStatement ps = cn.preparedStatement(sql); aUKh})B
{ UedvA9$&;
ps.setXXX(1,xxx); 7bA4P*
... <Gn8B^~$
ps.addBatch(); dNOX&$/=
} A
Z4|&iT
ps.executeBatch(); BO?mQu~
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 ;[FW!
KYnW7|*
事务的处理 Sg/:n,68
1、关闭Connection的自动提交 !S~,>,yd
cn.setAutoCommit(false); O3_D~O
."
2、执行一系列sql语句 _7r qXkp%
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close &=v/VRan[
Statement sm ; <^CYxy
sm = cn.createStatement(insert into user...); R#"U/8b>z
sm.executeUpdate(); xIS\4]F?r
sm.close(); gV<0Hj
sm = cn.createStatement("insert into corp...); ]]\)=F`n77
sm.executeUpdate(); .tZjdNE(h
sm.close(); TrSN00
3、提交 J!=](s5|
cn.commit(); !T<z'zZU
4、如果发生异常,那么回滚 `
(7N^@
cn.rollback();