java 数据库基本操作 2'@m'4-N
1、java数据库操作基本流程 96^aI1:
2、几个常用的重要技巧: $!_
X9)e
可滚动、更新的记录集 6&x\!+]F8
批量更新 '<o3x$6
*
事务处理 4SI~y;c)
W,@F!8
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 V#oz~GMB
1、取得数据库连接 x{:U$[_
1)用DriverManager取数据库连接 wGti|7Tu*
例子 vntJe^IaFd
String className,url,uid,pwd; FY'0?CT$
className = "oracle.jdbc.driver.OracleDriver"; Q~]oN
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; x1eC r_
uid = "system"; s-IE}I?;
pwd = "manager"; ts~VO`
Class.forName(className); {\(G^B*\
Connection cn = DriverManager.getConnection(url,uid,pwd); C*2%Ix18+N
2)用jndi(java的命名和目录服务)方式
^f,4=-
例子 K} CgFBk
String jndi = "jdbc/db"; ,LA'^I?
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); <uuumi-!%G
DataSource ds = (DataSource) ctx.lookup(jndi); `a&L
Connection cn = ds.getConnection(); <2)AbI+3
多用于jsp中 .~o{i_JH
2、执行sql语句 eaFkDl
1)用Statement来执行sql语句 2V@5:tf
String sql; *5PQ>d
G
Statement sm = cn.createStatement(); =v<w29P(g
sm.executeQuery(sql); // 执行数据查询语句(select) WkuCnT
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); jOV6%
2)用PreparedStatement来执行sql语句 XKTDBaON
String sql; DKS1Sm6d0
sql = "insert into user (id,name) values (?,?)"; 3 ZOD2:(
PreparedStatement ps = cn.prepareStatement(sql); H=BI%Z
ps.setInt(1,xxx); s^zlBvr|.
ps.setString(2,xxx); I#MPJ@*WT
... :Tpf8
ResultSet rs = ps.executeQuery(); // 查询 z[f]mU
int c = ps.executeUpdate(); // 更新 H7'42J@
\$_02:#
3、处理执行结果 "zcAYg^U
查询语句,返回记录集ResultSet 6!]@S|vDX
更新语句,返回数字,表示该更新影响的记录数 -4x! #|]
ResultSet的方法 &`qYe)1Eo
1、next(),将游标往后移动一行,如果成功返回true;否则返回false <~dfp
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 QG*hQh
Bb=r?;zjO
4、释放连接 lf`ULY4{
cn.close(); E.*hY+kGZ
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection J920A^)j!
0HWSdf|w
可滚动、更新的记录集 3g;Y
1、创建可滚动、更新的Statement pl>b 6 |
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); {O>Td9
该Statement取得的ResultSet就是可滚动的 9^!.!%6O$
2、创建PreparedStatement时指定参数 'b.jKkW7
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ]ePg6
ResultSet.absolute(9000); N 8[rWJ#
批量更新 IIAp-Y~B
1、Statement 1vo3aF
Statement sm = cn.createStatement(); (n k g
sm.addBatch(sql1); Wq3PN^
sm.addBatch(sql2); KRxJ2
... G|jHic!
sm.executeBatch() ={xRNNUj_
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 "#E
Z
2、PreparedStatement !ldEy#"X
PreparedStatement ps = cn.preparedStatement(sql); _qE9]mU
{ F qJ`d2E
ps.setXXX(1,xxx); V30w`\1A
... o*204BGB
ps.addBatch(); uM$b/3%s
} j(y<oxh
ps.executeBatch(); #MYoy7=
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 i]<@
m u9,vH
事务的处理 fL|9/sojz
1、关闭Connection的自动提交 Ct `)R
cn.setAutoCommit(false); O h
e^{:
2、执行一系列sql语句 (.$$U3\
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close {qHQ_ _Bl
Statement sm ; YQD`4ND
sm = cn.createStatement(insert into user...); X}'rPz\Lu
sm.executeUpdate(); `pfgx^qG
sm.close(); _kBmKE
sm = cn.createStatement("insert into corp...); 0dwD ?GG2
sm.executeUpdate(); 2(!W
9#]
sm.close(); #q:j~4)h
3、提交 eY`z\I
cn.commit(); 7a_8007$l
4、如果发生异常,那么回滚 9%kO%j,3
cn.rollback();