java 数据库基本操作 %AJdtJ@0H
1、java数据库操作基本流程 i7p3GBXh[
2、几个常用的重要技巧: HS2)vd@)
可滚动、更新的记录集 )oNomsn
批量更新 &oR&NKk
事务处理 'J\%JAR@
@B[V'|
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 59)PJ0E
1、取得数据库连接 g,1\Gj%y
1)用DriverManager取数据库连接 _7;#0B
例子 Q'rG' |
String className,url,uid,pwd; BvYJ!Vj
className = "oracle.jdbc.driver.OracleDriver"; 3Y8%5/D5
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; UR\*KR;yM
uid = "system"; jjwY{jV
pwd = "manager"; `,|7X]%b
Class.forName(className); 5H5<ft,
Connection cn = DriverManager.getConnection(url,uid,pwd); e5AiIVlv
2)用jndi(java的命名和目录服务)方式 I7}[%(~Sf/
例子 &2g1Oy~
String jndi = "jdbc/db"; D]0#A|nF
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 7_|zMk.J*
DataSource ds = (DataSource) ctx.lookup(jndi); 1,/oS&?E
Connection cn = ds.getConnection(); p'R}z|d)
多用于jsp中 Rk'pymap
2、执行sql语句 Coyop#q#"{
1)用Statement来执行sql语句 c~Ha68
String sql; 18`?t_8g
Statement sm = cn.createStatement(); E0*81PS
sm.executeQuery(sql); // 执行数据查询语句(select) *AJW8tIP
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ?>w%Lg{L}
2)用PreparedStatement来执行sql语句 >y az
String sql; sQ_{zOUPh
sql = "insert into user (id,name) values (?,?)"; zi5;>Iv0}
PreparedStatement ps = cn.prepareStatement(sql); mO\6B7V!
ps.setInt(1,xxx); avT>0b:
ps.setString(2,xxx); U_!6pqFc
... UrtN3icph
ResultSet rs = ps.executeQuery(); // 查询 S |B7HS5
int c = ps.executeUpdate(); // 更新 NTn-4iJy
ed617J
3、处理执行结果 cLXMq"?C
查询语句,返回记录集ResultSet 3cs'Oz<w
更新语句,返回数字,表示该更新影响的记录数 X2EC+<
ResultSet的方法 lT%o6qgT
1、next(),将游标往后移动一行,如果成功返回true;否则返回false /6f$%:q
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 Gz
kf
f-3lJ?6
4、释放连接 P ^D\znvc
cn.close(); 9iGJYMWf
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection <8'}H`w%
l.&6|
可滚动、更新的记录集 `?La
1、创建可滚动、更新的Statement pV1~REk$&
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 9_&.G4%V
该Statement取得的ResultSet就是可滚动的 QYg2'`(
2、创建PreparedStatement时指定参数 :V >Z|?[*H
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); Q.!D2RZc
ResultSet.absolute(9000); f>Ij:b`Z2
批量更新 =i `o+H
1、Statement oo/#]a
Statement sm = cn.createStatement(); n}YRE`>D
sm.addBatch(sql1); r% qgLP{v
sm.addBatch(sql2); []'BrG)!
... >y2gfD
sm.executeBatch() O>}aK.H
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 3Hr ZN+D
2、PreparedStatement jy6%
CSWQ
PreparedStatement ps = cn.preparedStatement(sql); \# #~Tq
{ eM{+R^8
ps.setXXX(1,xxx); @C?RbTHy
... ?a(ApD\
ps.addBatch(); 4D0"Y#&G
} $_NVy>\&
ps.executeBatch(); Z~v.!j0
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 pWeKN`
l].dOso$`
事务的处理 QKe=/;
1、关闭Connection的自动提交 HD$W\P
cn.setAutoCommit(false); 2x t
8F
2、执行一系列sql语句 \|Us/_h
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close xMU4Av[{
Statement sm ; =r#of|`Q
sm = cn.createStatement(insert into user...); MsfY|(/m
sm.executeUpdate(); @/7tN3O
sm.close(); eR =P
sm = cn.createStatement("insert into corp...); LG@5Z-
sm.executeUpdate(); L%Me
wU0TZ
sm.close(); /wKL"M-%
3、提交 lorjMS
cn.commit(); U+URj <)
4、如果发生异常,那么回滚 fgq#Oi}
cn.rollback();