java 数据库基本操作 Q`J U[nY
1、java数据库操作基本流程 & ;5f/
2、几个常用的重要技巧: e^~dx}X
可滚动、更新的记录集 9.dZA9l@g
批量更新 a>4q"IT6
事务处理 ,V]FAIJ
z"7?I$NQ
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 T;Kv<G;
1、取得数据库连接 J_&cI%.
1)用DriverManager取数据库连接 7ZAxhFC
例子 YG*<jKcX
String className,url,uid,pwd; 6v:L8t$"
className = "oracle.jdbc.driver.OracleDriver"; *wqR .n?
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; _G-6G=q
uid = "system"; VWdTnu
pwd = "manager"; Tg@G-6u0c
Class.forName(className); d=+zOF
Connection cn = DriverManager.getConnection(url,uid,pwd); YSB> WBS-<
2)用jndi(java的命名和目录服务)方式 9({ 9 r[U
例子 ;6 d-+(@
String jndi = "jdbc/db"; ={o4lFe3v(
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); {c?{M.R
DataSource ds = (DataSource) ctx.lookup(jndi); ^|h_[>
Connection cn = ds.getConnection(); 7mi=Xa:U
多用于jsp中 .XK3o .ZhW
2、执行sql语句 MTE1\,
1)用Statement来执行sql语句 1=+S'_j
String sql; I31Nu{
Statement sm = cn.createStatement(); D?Ol)aj?
sm.executeQuery(sql); // 执行数据查询语句(select) ?T%"Jgy8
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 0nI*9
2)用PreparedStatement来执行sql语句 `3[W~Cq
String sql; py~[M'p(H
sql = "insert into user (id,name) values (?,?)"; f9_Pn'"I
PreparedStatement ps = cn.prepareStatement(sql); A`vRUl,c=
ps.setInt(1,xxx); :SN? t
ps.setString(2,xxx); OBlQ
... j4@6`[n:
ResultSet rs = ps.executeQuery(); // 查询 *R4=4e2#S
int c = ps.executeUpdate(); // 更新 .u7grC C
BH}rg,]G
3、处理执行结果 G^ <m0ew|
查询语句,返回记录集ResultSet 4s>L]!
W$8
更新语句,返回数字,表示该更新影响的记录数 *}HDq(/>w
ResultSet的方法 F@t\D?
1、next(),将游标往后移动一行,如果成功返回true;否则返回false B[w.8e5
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 4M>]0%3.D
mrsN@(X0
4、释放连接 3\ )bg
R:
cn.close(); It 3@
Cd>
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection d\A7}_r*x
~Odclrs
可滚动、更新的记录集 P%[{ 'u
1、创建可滚动、更新的Statement 2^5RQl/
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); C)qG<PW.!
该Statement取得的ResultSet就是可滚动的 60|m3|0o
2、创建PreparedStatement时指定参数 ^N ;TCn
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); {KTZSs $n
ResultSet.absolute(9000); hQzT
=0
批量更新 o4rf[.z
1、Statement J~@W":v
Statement sm = cn.createStatement(); FDGzh/
sm.addBatch(sql1);
S[8nGH#m
sm.addBatch(sql2); )!zg=}V
... 4|jPr J
sm.executeBatch() 4rCw#mVtB
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 |l|$Q;
2、PreparedStatement :=quCzG
PreparedStatement ps = cn.preparedStatement(sql); Y.52`s6F
{ w1F)R^tU
ps.setXXX(1,xxx); c2gZ<[~
... .ArOZ{lKD>
ps.addBatch(); 0"sZP\<p
} qMO(j%N5
ps.executeBatch(); ffOV7Dxy
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 gz:US77
&ML-\aSal
事务的处理 s/;S2l$`
1、关闭Connection的自动提交 #cJ1Jj $
cn.setAutoCommit(false); $G/p[JG6-
2、执行一系列sql语句 {>ghX_m|
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close FV OPC:}bj
Statement sm ; Zwtz )ZII
sm = cn.createStatement(insert into user...); \H PB{
;
sm.executeUpdate(); 70R_O&f-k
sm.close(); 7}mrC@[i
sm = cn.createStatement("insert into corp...); uXGAcUx(
sm.executeUpdate(); |hvclEu,
sm.close(); a|dn3R>vX
3、提交 +9;6]4
cn.commit(); C2hB7?UGN
4、如果发生异常,那么回滚 EUPc+D3
cn.rollback();