java 数据库基本操作 Xbm\"g \
1、java数据库操作基本流程 q-3,p.
2、几个常用的重要技巧: @@&([f
可滚动、更新的记录集 n\l$R!zr
批量更新 C7|zDJ_
事务处理 EX]LH({?+L
5~AK+6Za
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 r-Nv<oH;
1、取得数据库连接 RtE2%d$JT
1)用DriverManager取数据库连接 })zYo 7
例子 lwY2zX&%)/
String className,url,uid,pwd; t-, =sV
className = "oracle.jdbc.driver.OracleDriver"; }3{ x G+,
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; )FF3|dZ";K
uid = "system"; S"*M9*8
pwd = "manager"; *U[Nn5#?
Class.forName(className); Q/JX8<7K
Connection cn = DriverManager.getConnection(url,uid,pwd); v61'fQ1Qg!
2)用jndi(java的命名和目录服务)方式 q6xm#Fd'.
例子 3_AVJv
;N
String jndi = "jdbc/db"; d&z^u.SY
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); xy/B<.M1
DataSource ds = (DataSource) ctx.lookup(jndi); p>GTFXEi6
Connection cn = ds.getConnection(); zjuU*$A4
多用于jsp中 Tc{n]TV
2、执行sql语句 "JHdF&
1)用Statement来执行sql语句 rD7L==Ld
String sql; ]z^*1^u^ig
Statement sm = cn.createStatement(); {w,g~ew
`
sm.executeQuery(sql); // 执行数据查询语句(select) D7|=ev
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); @qszwQav$
2)用PreparedStatement来执行sql语句 U64WTS@
String sql; hcQky/c\#b
sql = "insert into user (id,name) values (?,?)"; ,5tW|=0@
PreparedStatement ps = cn.prepareStatement(sql); m^6& !`CD
ps.setInt(1,xxx); -Fl;;jeX
ps.setString(2,xxx); ?b}d"QsmU
... zcn> 4E)
ResultSet rs = ps.executeQuery(); // 查询 =TTk5(m
int c = ps.executeUpdate(); // 更新 38I .1p9
@U~i<kt
3、处理执行结果 Wr3).m52}P
查询语句,返回记录集ResultSet >= G{.H
更新语句,返回数字,表示该更新影响的记录数 Zx%ib8|j
ResultSet的方法 $i:wS=
w'
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 2YU-iipdOq
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 -F7GUB6B
WAzYnl'p
4、释放连接 =.*+c\
cn.close(); |H!kU.f]
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection mBp3_E.t
PNjZbOmzS
可滚动、更新的记录集 }"V$li
1、创建可滚动、更新的Statement J.R|Xd
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); "s:eH"_s
该Statement取得的ResultSet就是可滚动的 e@Cv')]B
2、创建PreparedStatement时指定参数 o~
v
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); Jp'XZ]o\
ResultSet.absolute(9000); +Wr"c
批量更新 I UMt^z
1、Statement ^rHG#^hA
Statement sm = cn.createStatement(); `|{6U"n
sm.addBatch(sql1); {giKC)!
sm.addBatch(sql2); zc}qAy'<
... \.@fAgv
sm.executeBatch() ^oL43#Nlo
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 `{1&*4!
2、PreparedStatement
PT`];C(he
PreparedStatement ps = cn.preparedStatement(sql); X^2Txm d
{ E3p3DM0F$
ps.setXXX(1,xxx); u]D>O$_ s
... Sqc
r
-
ps.addBatch(); ?Aewp$Bj
} Ezvm5~<
ps.executeBatch(); xaM?
B7
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 o@p(8=x
PYOU=R%o`8
事务的处理
zK*zT$<l
1、关闭Connection的自动提交 `|t X[':
cn.setAutoCommit(false); a!_vd B
2、执行一系列sql语句 b1("(,r/`
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close <c,/+
lQ^
Statement sm ; .e^AS~4pl
sm = cn.createStatement(insert into user...); -G!W6$Y
sm.executeUpdate(); @[:JQ'R=
sm.close(); u{H'evv0O
sm = cn.createStatement("insert into corp...); =p1aF/1$I
sm.executeUpdate(); zF%'~S0{
sm.close(); 0:,8Ce
3、提交 BW`)q/
cn.commit(); (|{b ZW}
4、如果发生异常,那么回滚 '1$#onx
cn.rollback();