java 数据库基本操作 5J3K3
1、java数据库操作基本流程 Vj[,o
Vt$
2、几个常用的重要技巧: Q*/jQC
可滚动、更新的记录集 }/7rA)_
批量更新 Angt=q
事务处理 3[%n@i4H|
")W5`9
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 q)tNH/
1、取得数据库连接 DF"*[]^[
1)用DriverManager取数据库连接 }]j#C
例子 Lx3`.F\mG
String className,url,uid,pwd; 8`q"] BQN
className = "oracle.jdbc.driver.OracleDriver"; }`uq:y
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; . 3xf!E*
uid = "system"; i6E~]&~.v
pwd = "manager"; YKa9]Q
Class.forName(className); x|3G}[=
Connection cn = DriverManager.getConnection(url,uid,pwd); ^i17MvT'
2)用jndi(java的命名和目录服务)方式 \~""<*Hz
例子 n5?7iU&JIo
String jndi = "jdbc/db";
=#vU$~a
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 4aG}ex-s|
DataSource ds = (DataSource) ctx.lookup(jndi); ,L8(Vo`-
Connection cn = ds.getConnection(); Qy) -gax:,
多用于jsp中 wPpern05
2、执行sql语句 [<#`@Kr
1)用Statement来执行sql语句 h ?+vH{}j
String sql; 8*(|uX
Statement sm = cn.createStatement(); E1|:t$>Ld
sm.executeQuery(sql); // 执行数据查询语句(select) )'`@rq!
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 4pFoSs?\
2)用PreparedStatement来执行sql语句 a.SxMF
String sql; ;vgaFc]
sql = "insert into user (id,name) values (?,?)"; ]#J-itO
PreparedStatement ps = cn.prepareStatement(sql); tnw6[U!rh=
ps.setInt(1,xxx); D(M^%z2N
ps.setString(2,xxx); `w%Qs)2
... qApf\o3[0
ResultSet rs = ps.executeQuery(); // 查询 .OD{^Kq2
int c = ps.executeUpdate(); // 更新 :z+l=d:4
ImI,q:[67
3、处理执行结果 0u ,nSvch
查询语句,返回记录集ResultSet _(:bGI'.m
更新语句,返回数字,表示该更新影响的记录数 DbK-3F_
ResultSet的方法 2r#W#z%vS
1、next(),将游标往后移动一行,如果成功返回true;否则返回false w'P!<JaZ
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 DgC;1U'
6"jV>CNc@
4、释放连接 lhJZPnx~
cn.close(); :-1
i1d
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection XE :JL_
'E#Bz"T
可滚动、更新的记录集 g}*F"k4j
1、创建可滚动、更新的Statement >66v+
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); =7<g;u
该Statement取得的ResultSet就是可滚动的 }%k3
2、创建PreparedStatement时指定参数 hN.{H:skL)
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); Y kcN-
ResultSet.absolute(9000); 7bx!A+, t
批量更新 R}\n@X*
1、Statement Wj31mV
Statement sm = cn.createStatement(); 1WLaJ%Fv
sm.addBatch(sql1); of?'FrU
sm.addBatch(sql2); !"N-To-c
... NEX{vZkgw
sm.executeBatch() R]Pv=fn
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 UU]a).rz
2、PreparedStatement %n>*jFC
PreparedStatement ps = cn.preparedStatement(sql); wm_o(Z}
{ mEDi'!YE"
ps.setXXX(1,xxx); 8hm|9
... Y@[Dy
ps.addBatch(); :LBRyBV
} WY" `wM
ps.executeBatch(); %P-z3 0FHp
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 Tjza3M
R(N5K4J
事务的处理 SpiI9)gp
1、关闭Connection的自动提交 \Dr?}D
cn.setAutoCommit(false); o-%DL*^5
2、执行一系列sql语句 A>W8^|l6+-
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close U<mFwJ C]
Statement sm ; `f+l\'.s
sm = cn.createStatement(insert into user...); Dg2=;)"L
sm.executeUpdate(); pcjb;&<
sm.close(); .@(9v.:_u
sm = cn.createStatement("insert into corp...); !_My]>S
sm.executeUpdate(); Fb9!x/$tGV
sm.close(); tgB\;nbB
3、提交 "OO"Ab{t
cn.commit(); BX=YS)
4、如果发生异常,那么回滚 6+Wkcrh
cn.rollback();