java 数据库基本操作 H=OKm
1、java数据库操作基本流程 -t, .A/?
2、几个常用的重要技巧: "Ldi<xq%xl
可滚动、更新的记录集 Jb'M/iG
批量更新 `CP}1W>
事务处理 z}vgp\cuT
_h4{Sx
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 G'/36M@
1、取得数据库连接 E4^zW_|xE
1)用DriverManager取数据库连接 oe$Y=`
例子 $2=-Q/lM
String className,url,uid,pwd; Nb2]}; O
className = "oracle.jdbc.driver.OracleDriver"; ssv4#8p3
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; f)p c$~B
uid = "system"; ho#]i$b}f2
pwd = "manager"; MXWCYi
Class.forName(className); -z]v"gF?Px
Connection cn = DriverManager.getConnection(url,uid,pwd); o7N3:)
2)用jndi(java的命名和目录服务)方式 [:geDk9O#'
例子 Tti]H9g_
String jndi = "jdbc/db"; N'nI
^=
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); =FkU:q$
DataSource ds = (DataSource) ctx.lookup(jndi); $*ujX,}xG
Connection cn = ds.getConnection(); vDgf}
多用于jsp中 :^+ aJ]
2、执行sql语句 &[*F!=%8
1)用Statement来执行sql语句 tkBp?Wl
String sql; LHjGlBy
Statement sm = cn.createStatement(); Y4]USU!PA
sm.executeQuery(sql); // 执行数据查询语句(select) zmH 8#
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); kK]JN
2)用PreparedStatement来执行sql语句 ;6g &_6
String sql; <QGf9{m
sql = "insert into user (id,name) values (?,?)"; $~xY6"_}!!
PreparedStatement ps = cn.prepareStatement(sql); w:l/B
'%]Y
ps.setInt(1,xxx); &BnK[Q8X
ps.setString(2,xxx); X8uVet]D~
... x4jn45]x@
ResultSet rs = ps.executeQuery(); // 查询 {umdW
x.*
int c = ps.executeUpdate(); // 更新 u?[dy
n
JHpaDy*
3、处理执行结果 T!.6@g`x>
查询语句,返回记录集ResultSet R=jIVw'
更新语句,返回数字,表示该更新影响的记录数 u9Wi@sO#
ResultSet的方法 :jB8Q$s
1、next(),将游标往后移动一行,如果成功返回true;否则返回false Z `FqC
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 m&xyw9a
LMchNTL
4、释放连接 ZzA4iT=KO
cn.close(); >'4Bq*5>
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection %xE\IRlR
Vk/CV2
可滚动、更新的记录集 mAkR<\?iTF
1、创建可滚动、更新的Statement .!T]sX_P
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); R9X*R3nB
该Statement取得的ResultSet就是可滚动的 ^&iUC&8W
2、创建PreparedStatement时指定参数 +Z0@z^6\
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ,/n<Qg"`
ResultSet.absolute(9000); <X}@afS
批量更新 L4I1n l
1、Statement f)x^s$H
Statement sm = cn.createStatement(); ;h>s=D,r
sm.addBatch(sql1); W)I)QinOH
sm.addBatch(sql2); x/Pi#X m
... v=15pW
sm.executeBatch() nlaJ
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 {64od0:T
2、PreparedStatement /an$4?":~
PreparedStatement ps = cn.preparedStatement(sql); ~GJJ{Bm_
{ GQXN1R
ps.setXXX(1,xxx); 3-4' x2
... o:u *E
ps.addBatch(); ^v.~FFK
} X(F2 5
ps.executeBatch(); H~1&hF"d
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 qSh^|;2?R
+qsNz*@p"
事务的处理 ]r;-Lx{F
1、关闭Connection的自动提交 ydOJ^Yty
cn.setAutoCommit(false); j,")c'r&dD
2、执行一系列sql语句 y=) Cid
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close B`,4M&
Statement sm ; Rckqr7q
sm = cn.createStatement(insert into user...); .b*%c?e
sm.executeUpdate(); a= *&OW
sm.close(); #% PnZ
/
sm = cn.createStatement("insert into corp...); V=}AFGC85
sm.executeUpdate(); cx?t C#t
sm.close(); +~lZ]a7k
3、提交 i9?$BZQ[R
cn.commit(); (rV#EA+6[`
4、如果发生异常,那么回滚 aW-'Jg=@H^
cn.rollback();