java 数据库基本操作 @16y%]Q-E#
1、java数据库操作基本流程 Oi?Q^ISxP
2、几个常用的重要技巧: 26~rEOgJ
可滚动、更新的记录集 m@nGXl'!
批量更新 fyUW;dj
事务处理 qF3S\
C
gS(JgN
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 _$*-?*V&
1、取得数据库连接 'tTlBf7#
1)用DriverManager取数据库连接 Db2#QQ
例子 ?Ho$fGz
String className,url,uid,pwd; fXevr `
className = "oracle.jdbc.driver.OracleDriver"; h`fZ8|yw
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; "Io-%Su+
uid = "system"; NTJ,U2
pwd = "manager"; S?t
`/"O
Class.forName(className); vasw@Uto)
Connection cn = DriverManager.getConnection(url,uid,pwd); toF6 Z
2)用jndi(java的命名和目录服务)方式 'NWvQR<X
例子 BfCib]V9C
String jndi = "jdbc/db"; =SJ[)|
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); |QzJHP @
DataSource ds = (DataSource) ctx.lookup(jndi); '
Sd&I:?
Connection cn = ds.getConnection(); h%:wIkZ/
多用于jsp中 a:|]F|
2、执行sql语句 b c
.Vy
1)用Statement来执行sql语句 iP7KM*ks
String sql; e7G>'K
Statement sm = cn.createStatement(); /_fZ2$/
sm.executeQuery(sql); // 执行数据查询语句(select) h<m>S,@g
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); :%Z)u:~':
2)用PreparedStatement来执行sql语句 9F,XjPK=
String sql; yMNOjs'c {
sql = "insert into user (id,name) values (?,?)"; j+<!4 0#
PreparedStatement ps = cn.prepareStatement(sql); 1slt[&4N
ps.setInt(1,xxx); Y\!:/h]E&
ps.setString(2,xxx); "~C\Z} ;
... |RpZr!3V
ResultSet rs = ps.executeQuery(); // 查询 qyyLU@hd
int c = ps.executeUpdate(); // 更新 i_6 wD
8Pom^QopK
3、处理执行结果 (`n*d3
查询语句,返回记录集ResultSet tSDp>0yZ3
更新语句,返回数字,表示该更新影响的记录数 E3Z>R=s
ResultSet的方法 P)TeF1~T
1、next(),将游标往后移动一行,如果成功返回true;否则返回false dkEnc
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ]H:K$nmX
i\36 s$\
4、释放连接 [u3^R]
cn.close(); UIQ=b;J9
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection *|+ ~V/#
kGq<Zmy|
可滚动、更新的记录集 VAxk?P0j6
1、创建可滚动、更新的Statement _}Gs9sHr0K
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); RkdAzv!Y7
该Statement取得的ResultSet就是可滚动的 :Z
]E:f0P
2、创建PreparedStatement时指定参数 7Ph+Vs+h
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); jM@@N.
ResultSet.absolute(9000); d\z':d.Tt
批量更新 43J8PMY
1、Statement }=3W(1cu-
Statement sm = cn.createStatement(); p|Fhh\,*`X
sm.addBatch(sql1); G`!;RX
sm.addBatch(sql2); _ )^n[_E
... OQX ek@~2
sm.executeBatch() ;+qPV7Z
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 WY~}sE
2、PreparedStatement yC=vTzzp
PreparedStatement ps = cn.preparedStatement(sql); 7L:R&W6
{
qf]OSd
ps.setXXX(1,xxx); `|JQ)!Agx
... OaxE3bDT
ps.addBatch(); tX*L_
} CtDS lJ
ps.executeBatch(); PzTTL=G +
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 EZiGi[t7
&4MVk3SLx#
事务的处理 : [vp.vw}/
1、关闭Connection的自动提交 h$zPQ""8
cn.setAutoCommit(false);
K[TMTn
2、执行一系列sql语句 &9] [~$
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close .J\U|r
Statement sm ; >-y&k^a=
sm = cn.createStatement(insert into user...); <Q-ufF85)
sm.executeUpdate(); zT+yZA.L
sm.close(); :S7yM8b`
sm = cn.createStatement("insert into corp...); =Jl1D*B*
sm.executeUpdate(); Pq7tNM E
sm.close(); {78*SR
3、提交 { K0T%.G
cn.commit(); uJp}9B60_
4、如果发生异常,那么回滚 g9"_ BG
cn.rollback();