java 数据库基本操作 {uFO/
1、java数据库操作基本流程 "{xrL4BtC
2、几个常用的重要技巧: m7V/zne
可滚动、更新的记录集 w.o@7|B1N
批量更新 W
i.&e
事务处理 VGN5<?PrN
B-Hrex]
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 e>OoyDZ@R
1、取得数据库连接 UDFDJm$
1)用DriverManager取数据库连接 ;;t yoh~t
例子 (,2SXV
String className,url,uid,pwd; `(;m?<%
className = "oracle.jdbc.driver.OracleDriver"; /}Axf"OE
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; |-ALklXr
uid = "system"; Rv>-4@fMJ
pwd = "manager"; t}4,]ms
Class.forName(className); Yh7t"=o
Connection cn = DriverManager.getConnection(url,uid,pwd); ,qwuLBW
2)用jndi(java的命名和目录服务)方式 Dy&i&5E.-l
例子 = svN#q5s
String jndi = "jdbc/db"; q<<v,ihh
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); wJqMa9|
DataSource ds = (DataSource) ctx.lookup(jndi); {Xy5pfW
Q
Connection cn = ds.getConnection(); JR|ck=tq
多用于jsp中 >y>5#[M!
2、执行sql语句 r;2^#6/Z
1)用Statement来执行sql语句 .Hm>i
String sql; >:!5*E5?
Statement sm = cn.createStatement(); /N.b%M]!
sm.executeQuery(sql); // 执行数据查询语句(select) M_f:A
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 6@!`]tSCK
2)用PreparedStatement来执行sql语句 T>Z<]s
String sql; 0mVNQxHI
sql = "insert into user (id,name) values (?,?)"; |r/"
|`
PreparedStatement ps = cn.prepareStatement(sql); V0YZp
ps.setInt(1,xxx); Fo_sgv8O<
ps.setString(2,xxx); H?Wya.7
... gQuw1
ResultSet rs = ps.executeQuery(); // 查询 [|L<_.8
int c = ps.executeUpdate(); // 更新 B6 ;|f'e!
0+ '&`Q!u
3、处理执行结果 j (d~aqW
查询语句,返回记录集ResultSet =qIp2c}Rx
更新语句,返回数字,表示该更新影响的记录数 B$K=\6o
ResultSet的方法 Q&;9x? e
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ?V=ZIGj
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ru%y
EZGIf/ 3
4、释放连接 *^4"5X@
cn.close(); eByz-,{P
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection e*C(q~PQ
JQI: sj
可滚动、更新的记录集 q;CiV
1、创建可滚动、更新的Statement A)!*]o>U
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); x,-75
该Statement取得的ResultSet就是可滚动的 J@'wf8Ub
2、创建PreparedStatement时指定参数 "S]TP$O D
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); jr."I+
ResultSet.absolute(9000); G` A4|+W"
批量更新 BWrxunHO
1、Statement BU_nh+dF
Statement sm = cn.createStatement(); AT3Mlz~7#
sm.addBatch(sql1); tNI^@xdim1
sm.addBatch(sql2); X_h}J=33Q
... cT,sh~-x,
sm.executeBatch() m(!FHPvN
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 4$<JHo
@.
2、PreparedStatement cq]6XK-W
PreparedStatement ps = cn.preparedStatement(sql); ~
7s!VR
{ q9_OGd|P
ps.setXXX(1,xxx); * u>\57W
... o.!Dq7R
ps.addBatch(); \b x$i*
} CCx&7f
ps.executeBatch(); Hn"RH1Zy
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 9A=,E&
4HlQ&2O%#
事务的处理 M2Qr(K|
1、关闭Connection的自动提交 >bW#Zs,6
cn.setAutoCommit(false); `^&OF uee
2、执行一系列sql语句 eauF~md,
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 0h_|t-9j
Statement sm ; KRzAy)8
sm = cn.createStatement(insert into user...); +0Y&`{#Z
sm.executeUpdate(); 6&x@.1('z
sm.close(); /4Gt{ygSr
sm = cn.createStatement("insert into corp...); 5j(k:a+!H
sm.executeUpdate(); ICQKP1WFp
sm.close(); .q>iXE_c
3、提交 Lf&kv7Wj
cn.commit(); bAMdI 5Zk?
4、如果发生异常,那么回滚 +e``OeXog
cn.rollback();