java 数据库基本操作 (&F}/s gbi
1、java数据库操作基本流程 x:NY\._
2、几个常用的重要技巧: S]e|"n~@
可滚动、更新的记录集 mP~QWx![N
批量更新 ; ; OAQ`
事务处理 O>bC2;+s
X1x#6
oi
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 h6D<go-b56
1、取得数据库连接 TCwFPlF|
1)用DriverManager取数据库连接 o4F2%0gJ
例子 +s,=lL
String className,url,uid,pwd; 3=P]x;[ba
className = "oracle.jdbc.driver.OracleDriver"; 6
6EV$*dRL
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; NqazpB*
uid = "system"; w7.V6S$Ga
pwd = "manager"; +K:Dx!9
Class.forName(className); D09Sg%w
Connection cn = DriverManager.getConnection(url,uid,pwd); Ha0M)0Anv
2)用jndi(java的命名和目录服务)方式 #C74z$
例子 T= y}y
String jndi = "jdbc/db"; OhQgF
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); %op**@4/t\
DataSource ds = (DataSource) ctx.lookup(jndi); Q^9_'t}X
Connection cn = ds.getConnection(); / |;RV"
多用于jsp中 ah4N|zJ>v
2、执行sql语句 {Qf=G|Ah
1)用Statement来执行sql语句 H7&8\FNa
String sql; FF`T\&u
Statement sm = cn.createStatement(); 9X+V4xux
sm.executeQuery(sql); // 执行数据查询语句(select) wj$<t'MN
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ~rqCN,=d
2)用PreparedStatement来执行sql语句 urs,34h
String sql; .LnGL]/
sql = "insert into user (id,name) values (?,?)"; q.^;!f1
PreparedStatement ps = cn.prepareStatement(sql); 8?#/o c
ps.setInt(1,xxx); rK6l8)o
ps.setString(2,xxx); i4Q@K,$
... O'p9u@kc
ResultSet rs = ps.executeQuery(); // 查询 Uou1mZz/
int c = ps.executeUpdate(); // 更新 E1aHKjLQ
O_muD\
3、处理执行结果 a8e6H30Sm
查询语句,返回记录集ResultSet oQ/E}Zk@
更新语句,返回数字,表示该更新影响的记录数 ]KKS"0a
ResultSet的方法 c(f
1、next(),将游标往后移动一行,如果成功返回true;否则返回false T?CdZc.
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 F`9xVnK=
%ufN8w!p
4、释放连接 Af~$TyX
cn.close(); -e"H ^:
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 6xx<Y2@
~~/|dh5
可滚动、更新的记录集 9IdA%RM~mH
1、创建可滚动、更新的Statement \$~|ZwV{
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); \g&,@'uh
该Statement取得的ResultSet就是可滚动的 FJGlP&v<
2、创建PreparedStatement时指定参数 7FP*oN?
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); $D~0~gn~
ResultSet.absolute(9000); jE.N ev/
批量更新 Ws3)gvpPA
1、Statement 1Z/(G1
Statement sm = cn.createStatement(); 13$%,q)
sm.addBatch(sql1); u
OmtyX
sm.addBatch(sql2); R3)~?X1n
... i(rL|d+'
sm.executeBatch() t9GR69v:?
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 z3{G9Np
2、PreparedStatement n:I,PS0H<
PreparedStatement ps = cn.preparedStatement(sql); Q",t3i4
{ ^KnU4sD
ps.setXXX(1,xxx); Y!aSs3c
... kUL'1!j7
ps.addBatch(); RtkEGxw*^
} r!|6:G+Q
ps.executeBatch(); WH#1zv
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 > ym,{EHK
P[G)sA_"
事务的处理 kf\PioD8
1、关闭Connection的自动提交 Hp|kQJ[L E
cn.setAutoCommit(false); b"<liGh"n-
2、执行一系列sql语句 #X+JHl
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close W@M:a
Statement sm ; 5 Aw"B
sm = cn.createStatement(insert into user...); ^lnK$i
sm.executeUpdate(); sg^zH8,3
sm.close(); P8OaoPj
sm = cn.createStatement("insert into corp...); KC*e/J
sm.executeUpdate(); yM6pd U]i
sm.close(); <VMGTBVQ
3、提交 TNT4<5Ol6
cn.commit(); XAD- 'i
4、如果发生异常,那么回滚 wyH[x!QX
cn.rollback();