java 数据库基本操作 gBd@4{y6C.
1、java数据库操作基本流程 lSK<LytB
2、几个常用的重要技巧: m>&:)K}m
可滚动、更新的记录集 rfHAz
批量更新 1|/-Ff"1@
事务处理 F|!
ib5
F7lzc)
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 0*F<tg,+]
1、取得数据库连接 k@Mt8Ln
1)用DriverManager取数据库连接 \I+#M-V
例子 =PAsyj
String className,url,uid,pwd; \wM8I-f!
className = "oracle.jdbc.driver.OracleDriver"; fA" VLQE
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; -v &
uid = "system"; MYMg/>f[
pwd = "manager"; :=e"D;5
Class.forName(className); ZMGthI}~-
Connection cn = DriverManager.getConnection(url,uid,pwd); y\@INA^
2)用jndi(java的命名和目录服务)方式 1T/ 72+R0
例子 r"bV{v
String jndi = "jdbc/db"; 4ztU) 1
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); kH" >(f
DataSource ds = (DataSource) ctx.lookup(jndi); -&QTy
Connection cn = ds.getConnection(); pWOK~=t
多用于jsp中 ;:Q&Rf"@%
2、执行sql语句 =niT]xf
1)用Statement来执行sql语句 mT&?DZ9<
String sql; 5"mH6%d :8
Statement sm = cn.createStatement(); Un^3%=;
sm.executeQuery(sql); // 执行数据查询语句(select) /M5R<rl
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); C|-QU
2)用PreparedStatement来执行sql语句 ^j *H
String sql; xjH({(/B>a
sql = "insert into user (id,name) values (?,?)"; H-/w8_} KG
PreparedStatement ps = cn.prepareStatement(sql); [I2vg<my
ps.setInt(1,xxx); +(/' b'*
ps.setString(2,xxx); N"-U)d-.
... K6G+sBw[
ResultSet rs = ps.executeQuery(); // 查询 !.@F,wZvY
int c = ps.executeUpdate(); // 更新 x03@} M1
DTo P|P
3、处理执行结果 2 i97
查询语句,返回记录集ResultSet <}('w/
更新语句,返回数字,表示该更新影响的记录数 b/6!>qMMk%
ResultSet的方法 4o,G[Cf_
1、next(),将游标往后移动一行,如果成功返回true;否则返回false vTq
[Xe"
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值
kAnK1W>
.~7:o.BE`n
4、释放连接 qLa6c2o,
cn.close(); yP0XA=,Y
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 0+ 3{fD/
6)[gF1
可滚动、更新的记录集 (Q F-=o
1、创建可滚动、更新的Statement A#Ne07d
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); RI&V:1
该Statement取得的ResultSet就是可滚动的 K %.>o
2、创建PreparedStatement时指定参数 ~U+W4%f8
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ]*TW%mY
ResultSet.absolute(9000); xV>sc;PEb
批量更新 {pz7ADK<
1、Statement J?_-Dg(=
Statement sm = cn.createStatement(); mIah[~G
sm.addBatch(sql1); cxpG6c
sm.addBatch(sql2); -s&7zqW
... ^k5# {?I
sm.executeBatch() fx*Q,}t
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 O\q-Ai
2、PreparedStatement Tu&W7aoX5
PreparedStatement ps = cn.preparedStatement(sql); ufvjW]
{ !eA6Ejf
ps.setXXX(1,xxx); g[ O6WZ!F_
... <m0m8p"G
ps.addBatch(); 6oy[0hj
} /0(c-Dv
ps.executeBatch(); 5Mz6/&`
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 vEC#W43l
7_CX6:
事务的处理 1HBWOV7z.?
1、关闭Connection的自动提交 fir#5,*q|
cn.setAutoCommit(false); S t;@ZV
2、执行一系列sql语句 SdNxSD$Q
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close RW|Xh8.O
Statement sm ;
, )PpE&
sm = cn.createStatement(insert into user...); ;uN&yj<}a
sm.executeUpdate(); Zy=DY
sm.close(); d:JP935
sm = cn.createStatement("insert into corp...); wj 15Og?
sm.executeUpdate(); m_h$fT8
_
sm.close(); 0 LQ%tn
3、提交 <|1Kh ygv
cn.commit(); L|Bjw3K&D
4、如果发生异常,那么回滚 ",P?jgs^g5
cn.rollback();