java 数据库基本操作 j83? m
1、java数据库操作基本流程 gIWrlIV{9
2、几个常用的重要技巧: mAgF73,3
可滚动、更新的记录集 J`M&{UP
批量更新 |XYEn7^r
事务处理 4Ph0:^i_
vP%tk s+.
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ~jU/<~s
1、取得数据库连接
\u-0v.+|
1)用DriverManager取数据库连接 ] U@o0
例子 Op.8a`XLt&
String className,url,uid,pwd; S-+"@>{HJ
className = "oracle.jdbc.driver.OracleDriver"; s6*ilq1
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; + j+5ud`
uid = "system"; uxn)R#?
pwd = "manager"; kEeo5XN
Class.forName(className); e;bYaM4UX
Connection cn = DriverManager.getConnection(url,uid,pwd); Mpue
2)用jndi(java的命名和目录服务)方式 Mvj;ic6iK
例子 H?1xjY9sl
String jndi = "jdbc/db"; <mA'X V,
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); *F^wtH`
DataSource ds = (DataSource) ctx.lookup(jndi); 9L0GLmLk1u
Connection cn = ds.getConnection(); 4rK{-jvh>m
多用于jsp中 D(W,yq~7uY
2、执行sql语句 `Ycf]2.,$
1)用Statement来执行sql语句 R9We/FhOY
String sql; FQ%c~N
Statement sm = cn.createStatement(); @K223?c8l
sm.executeQuery(sql); // 执行数据查询语句(select) [$(%dV6O
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); h-a!q7]l
2)用PreparedStatement来执行sql语句 rj]F87"
String sql; PupM/?57
sql = "insert into user (id,name) values (?,?)"; .D,p@4
PreparedStatement ps = cn.prepareStatement(sql); g]@(E
ps.setInt(1,xxx); iO/XhSD
ps.setString(2,xxx); |LG4=j.l
... k;PAh>8
ResultSet rs = ps.executeQuery(); // 查询 2A`A\19t
int c = ps.executeUpdate(); // 更新 ^Jp&H\gI.
(;x3} ]
3、处理执行结果 @tohNO>
查询语句,返回记录集ResultSet "|Fy+'5}
更新语句,返回数字,表示该更新影响的记录数 0Q,g7K<d
ResultSet的方法 }uHrto3M
1、next(),将游标往后移动一行,如果成功返回true;否则返回false iF5'ygR-Z
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 c:S] R"
W+wA_s2&D
4、释放连接 zQ?!f#f
cn.close(); 'mCe=Y
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 2=0DCF;Bv
A,-6|&F
可滚动、更新的记录集 @[<nQZw:
1、创建可滚动、更新的Statement hDP/JN8y
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); d4:`@*
该Statement取得的ResultSet就是可滚动的 CQ7{1,?2
2、创建PreparedStatement时指定参数 G2 ]H6G$M
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); !J1rRPV
ResultSet.absolute(9000); _cTh#t ^
批量更新 :Eh\NOc_O
1、Statement onCKI,"
Statement sm = cn.createStatement(); [AH6~-\ x
sm.addBatch(sql1); ( m\$hX
sm.addBatch(sql2); v$~QCtc
... L$'[5"ma
;
sm.executeBatch() Tm^89I]L
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 y4Z&@,_{
2、PreparedStatement $CTSnlPq
PreparedStatement ps = cn.preparedStatement(sql); *b *G2f^
{ 682Z}"I0
ps.setXXX(1,xxx); eg<bi@C1|
... \}6;Kf}\
ps.addBatch(); V6$xcAE"</
} c0c|z
Ym
ps.executeBatch(); m42T9wSsx
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 ^2d!*W|
AT2v!mNyCw
事务的处理 %:>3n8n
1、关闭Connection的自动提交 Sw^X2$h
cn.setAutoCommit(false); 65z"
2、执行一系列sql语句 ^
&E}r{?
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close kp?w2+rz
Statement sm ; :.(;<b<\
sm = cn.createStatement(insert into user...); OJT1d-5p
sm.executeUpdate(); YzosZ! L!<
sm.close(); dpQG[vXe
sm = cn.createStatement("insert into corp...); { pu85'DV
sm.executeUpdate(); ERwHLA
sm.close(); V^y^
;0I}[
3、提交 ')a(.f
cn.commit(); 5vo.[^ty
4、如果发生异常,那么回滚 j.a`N2]WE
cn.rollback();