java 数据库基本操作 rqPo)AL
1、java数据库操作基本流程 2F{hg%
2、几个常用的重要技巧: JuR"J1MY
可滚动、更新的记录集 o G*5f
批量更新 G3P&{.v
事务处理 6fo3:P*O
K)tQ]P
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 "p&Y^]
1、取得数据库连接 CqMhk
1)用DriverManager取数据库连接 Cwa^"r3P1
例子 (& "su3z
String className,url,uid,pwd; hXIro
className = "oracle.jdbc.driver.OracleDriver"; H9XvO
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ~/pzxo$
uid = "system"; Qd _6)M-
pwd = "manager"; Kb#4ILA
Class.forName(className); 7,qYV}
Connection cn = DriverManager.getConnection(url,uid,pwd); :$;Fhf<5
2)用jndi(java的命名和目录服务)方式 a]17qMl
例子 7w:ef0S
String jndi = "jdbc/db"; .~A*=
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); GYxM0~:$k
DataSource ds = (DataSource) ctx.lookup(jndi); 8H,4kY?Z
Connection cn = ds.getConnection(); ]B"'}%>ez
多用于jsp中 !)"%),>}o
2、执行sql语句 GE;e]Jkjn
1)用Statement来执行sql语句 rEhX/(n#
String sql; <#=N
m0S$
Statement sm = cn.createStatement(); /@ !CKh`
sm.executeQuery(sql); // 执行数据查询语句(select) f),TO
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); Ei}/iBG@
2)用PreparedStatement来执行sql语句 |:[tNs*,O
String sql; +CH},@j
sql = "insert into user (id,name) values (?,?)"; K;?,FlH
PreparedStatement ps = cn.prepareStatement(sql); c .3ZXqpI;
ps.setInt(1,xxx); ,u }XWV
ps.setString(2,xxx); oBQ#eW aY
... p^<yj0Y
ResultSet rs = ps.executeQuery(); // 查询 ,[S+T.Cu
int c = ps.executeUpdate(); // 更新 y.5/?{GL
}VS3L_
;}/
3、处理执行结果 Ars687WB
查询语句,返回记录集ResultSet s4Sd>D7
更新语句,返回数字,表示该更新影响的记录数 ^'CPM6J
ResultSet的方法 Xp\/YJOibd
1、next(),将游标往后移动一行,如果成功返回true;否则返回false <?-YTY|
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 w{[=l6L m
f0<hE2
4、释放连接 2]GdD*
cn.close(); =ph&sn$;L
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection CTt vyr
rk+#GO{
可滚动、更新的记录集 ~7~~S*EQ
1、创建可滚动、更新的Statement ](tx<3h
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); {2/LRPT
该Statement取得的ResultSet就是可滚动的 <DKS+R
2、创建PreparedStatement时指定参数 5$DHn]
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); q"O.Cbk
ResultSet.absolute(9000); |b-9b&
批量更新 `p;eIt
1、Statement M;cO0UIwO
Statement sm = cn.createStatement(); D']ZlB'K
sm.addBatch(sql1); bwVPtu`
sm.addBatch(sql2); j?y LDLj
... 5>3}_
sm.executeBatch() '1,,)U#6E
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 5w %_$x
2、PreparedStatement t*@2OW`!
PreparedStatement ps = cn.preparedStatement(sql); rg0ma
{ swA+f
ps.setXXX(1,xxx); bCref$|
... 3iw{SEY
ps.addBatch(); /? r?it
} >AoK/(yL.
ps.executeBatch(); A+y
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 ;\EiM;Q]
CTWn2tpW
事务的处理 t+5E#!y
1、关闭Connection的自动提交 8N:owK
cn.setAutoCommit(false); &_JD)mM5
2、执行一系列sql语句 4}_O`Uxh
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close Gl1jxxd
Statement sm ; ,Jc m+Wb
sm = cn.createStatement(insert into user...); ^w ] /
sm.executeUpdate(); REZJ}%}/
sm.close(); S3L~~X/=
sm = cn.createStatement("insert into corp...); uwRr LF
sm.executeUpdate(); F+ E|r6'i
sm.close(); 91Uj}n%
3、提交 iX0iRC6f
cn.commit(); u6`=x$&
4、如果发生异常,那么回滚 xs\!$*R
cn.rollback();