java 数据库基本操作 Plb}dID"
1、java数据库操作基本流程 N JXa_&_
2、几个常用的重要技巧: $e>/?Ss
可滚动、更新的记录集 Cv0&prt
批量更新 QZ?O;K1|y
事务处理 '+tKvTU;
HqB|SWyK
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 VVgsLQd
1、取得数据库连接 yW[L,N7d
1)用DriverManager取数据库连接 Jm%mm SYK
例子 *ZX!EjICk
String className,url,uid,pwd; OA!R5sOz"
className = "oracle.jdbc.driver.OracleDriver"; P4i3y{$V
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; KU*`f{|
uid = "system"; ^P]?3U\nj
pwd = "manager"; 7:#
Class.forName(className); (/('nY
Connection cn = DriverManager.getConnection(url,uid,pwd); 2B5A!?~>
2)用jndi(java的命名和目录服务)方式 S3b|wUf
例子 umqLKf=x!
String jndi = "jdbc/db"; N\c&PS
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 9/FG,9
DataSource ds = (DataSource) ctx.lookup(jndi); keq r%:E8
Connection cn = ds.getConnection(); =rtS#u
Y
多用于jsp中 yi sF5`+
2、执行sql语句 4c
1)用Statement来执行sql语句 -*rHB&e
String sql; b{zAJ`|#[n
Statement sm = cn.createStatement(); -3u@hp_
sm.executeQuery(sql); // 执行数据查询语句(select) ]Jja
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); vU ?b"n
2)用PreparedStatement来执行sql语句 GJ.kkTMT
String sql; Ng?apaIi@~
sql = "insert into user (id,name) values (?,?)"; u,:CJ[3
PreparedStatement ps = cn.prepareStatement(sql); j
l}!T[5
ps.setInt(1,xxx); 2O$95M
ps.setString(2,xxx); q;CayN'I
... w 9/nVu
ResultSet rs = ps.executeQuery(); // 查询 =U=e?AOG2
int c = ps.executeUpdate(); // 更新 [0h* &
vYYS.ve
3、处理执行结果 dK[*
查询语句,返回记录集ResultSet ?s1u#'aO
更新语句,返回数字,表示该更新影响的记录数 s*aH`M7^0
ResultSet的方法 +Gk!
t]dy
1、next(),将游标往后移动一行,如果成功返回true;否则返回false =X)Q7u".7
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ,Le&I9*%
Y;'VosTD
4、释放连接 -08&&H
cn.close(); (Nm}3 p
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection aJEbAs}
tniPEmeS
可滚动、更新的记录集 eo>/
1、创建可滚动、更新的Statement dCa}ITg
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); [q|?f?Zl
该Statement取得的ResultSet就是可滚动的 cWgbd^J
2、创建PreparedStatement时指定参数 unC t4uX^
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); TS\9<L9S
ResultSet.absolute(9000); Uc_'3|e
批量更新 LDT'FwMjy
1、Statement z0\;m{TH
Statement sm = cn.createStatement(); Y1#-^,qg
sm.addBatch(sql1); c-[Q,c
sm.addBatch(sql2); aQl?d<|+lk
... 7( yXsVq
sm.executeBatch() }f<fgY
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 [?Mc4uT{
2、PreparedStatement C/{nr-V3u
PreparedStatement ps = cn.preparedStatement(sql); *p" "YEN
{ Wv6z%r<
ps.setXXX(1,xxx); CP c"
... ,`ZPtnH+
ps.addBatch(); X_vI0YX9
} 3*CzXK>`M&
ps.executeBatch(); 2$o2.$i81
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 &>&dhdTQ
R59e&
事务的处理 g4~X#}:z$O
1、关闭Connection的自动提交 ,:0Q1~8
cn.setAutoCommit(false); 2neF<H?^o
2、执行一系列sql语句 >P<k[vF
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close Ymwx(Pm
Statement sm ; Sf+(1_^`t
sm = cn.createStatement(insert into user...); zF[3%qZE:T
sm.executeUpdate(); 4]Un=?)I
sm.close(); Paae-EmC
sm = cn.createStatement("insert into corp...); )ZS:gD
sm.executeUpdate(); K*([9VZ
sm.close(); _7-"VoX
3、提交 WHlD%u
cn.commit(); |#DC.Ga!
4、如果发生异常,那么回滚 7bgnZ]r8t
cn.rollback();