java 数据库基本操作 Z2k5qs7g
1、java数据库操作基本流程 P?iQ{x}w~
2、几个常用的重要技巧: 42DB0+_wz
可滚动、更新的记录集 ob(~4H-
批量更新 k@2@%02o9C
事务处理 ]5eZLXM
yfe4}0}
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 0:>C v<N
1、取得数据库连接 Yp9%u9tNq
1)用DriverManager取数据库连接 _qS4Ns/4s
例子 .OF2O}
String className,url,uid,pwd; uF-Rl##
>
className = "oracle.jdbc.driver.OracleDriver"; UTuOean ]'
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; 62/tg*)
uid = "system"; )7N$lY<
pwd = "manager"; B]cV|S|
Class.forName(className); ]-u>HO g\
Connection cn = DriverManager.getConnection(url,uid,pwd); <d3N2
2)用jndi(java的命名和目录服务)方式 (_~Dyvo
例子 "eKM<S
String jndi = "jdbc/db"; BH?fFe&J:`
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); K%>3ev=y.s
DataSource ds = (DataSource) ctx.lookup(jndi); 1f5;^T
I
Connection cn = ds.getConnection(); th|TwD&mO
多用于jsp中 ebB8.(k9G3
2、执行sql语句 0J9Ub
1)用Statement来执行sql语句 GG`;c?d@
String sql; =xHzhh
Statement sm = cn.createStatement(); 7C^W <SUo
sm.executeQuery(sql); // 执行数据查询语句(select) %@[ ~s,6<
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ~2U5Wt
2)用PreparedStatement来执行sql语句 )%(H'omvl
String sql; TZ@S?r>^
sql = "insert into user (id,name) values (?,?)"; Tn\59 (
PreparedStatement ps = cn.prepareStatement(sql); TZS:(MJ9M
ps.setInt(1,xxx); N< 7
ps.setString(2,xxx); \EeK<)4:
... mF]8
ResultSet rs = ps.executeQuery(); // 查询 ~C ;gEE-
int c = ps.executeUpdate(); // 更新 2lBfc
Y>'t)PK
3、处理执行结果 iJ~e8l0CA
查询语句,返回记录集ResultSet =doOt 7Rj
更新语句,返回数字,表示该更新影响的记录数 j2,w1f}T
ResultSet的方法 NpxND0
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ~-2q3U Py
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 -D,kL
JAcNjzL
4、释放连接 e!O:z
cn.close(); i@spd5.
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection Gw}b8N6E
Yu9.0A_) :
可滚动、更新的记录集 "Bbd[ZI8
1、创建可滚动、更新的Statement {}v<2bS
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); }VXZM7@u
该Statement取得的ResultSet就是可滚动的 2o9IP>#u
2、创建PreparedStatement时指定参数 D,;6$Pvg^
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); G_n~1?
ResultSet.absolute(9000); }h`ddo
批量更新 bjGQ04da
1、Statement _^u^@.Q'i<
Statement sm = cn.createStatement(); {'eF;!!Dy
sm.addBatch(sql1); 7W\aX*]
sm.addBatch(sql2); m^ [VM&%
... S?LUSb
sm.executeBatch() iQ_^MzA
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 }{m.\O
2、PreparedStatement g|V0[Hnq6
PreparedStatement ps = cn.preparedStatement(sql); wDS(zG
{ (
G# W6
ps.setXXX(1,xxx); ^6I8 a"
... Q?TXM1Bp
ps.addBatch(); c ,RY
j
} @c#M^:9Dc
ps.executeBatch(); \KPwh]0
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 j+>&~
?;)F_aHp
事务的处理
.</.(7
1、关闭Connection的自动提交 7`Bwo*Y
cn.setAutoCommit(false); kv'gs+,e
2、执行一系列sql语句 d<B=p&~
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close K_E- Hgg_
Statement sm ; F
{T\UX
sm = cn.createStatement(insert into user...); Pi:=0,"XOp
sm.executeUpdate(); xSoXf0zq:
sm.close(); `tZ`a
sm = cn.createStatement("insert into corp...); /QCyA%y
sm.executeUpdate(); 2w? 5vSv
sm.close(); Qp]-4%^Vz
3、提交 1brKs-z
cn.commit(); ZRo-=/1
4、如果发生异常,那么回滚 2k3yf_N
cn.rollback();