java 数据库基本操作 0_Elxc
1、java数据库操作基本流程 Tow! 5VAM
2、几个常用的重要技巧: j+q)
可滚动、更新的记录集 NpKyrXDJv
批量更新 dD~H ft
事务处理 f5{|_]q]
<r>Sj/w<D
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 )^"V}z
t
1、取得数据库连接 -AolW+Y
1)用DriverManager取数据库连接 y9LO;{(
例子 M&gi$Qs[E
String className,url,uid,pwd; T/ eX7p1
className = "oracle.jdbc.driver.OracleDriver"; W2zG"Q
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ,`k6@4
uid = "system"; /(u? k%Q
pwd = "manager"; VZ">vIRyi|
Class.forName(className); ]l +<-
Connection cn = DriverManager.getConnection(url,uid,pwd); v"mZy,u
2)用jndi(java的命名和目录服务)方式 &5z9C=]e
例子 6X?:mn'%QF
String jndi = "jdbc/db"; H8HVmfM
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); #Ak|p#7 ^
DataSource ds = (DataSource) ctx.lookup(jndi); {cO8q
}L
Connection cn = ds.getConnection(); ' u;Zw%O(J
多用于jsp中 qdmAkYUC
2、执行sql语句 :*DWL!a
1)用Statement来执行sql语句 FZZO-,xa
String sql; ~3Zz.!F
Statement sm = cn.createStatement(); nD]MgT
sm.executeQuery(sql); // 执行数据查询语句(select) ("}C& 6)cB
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 9k6/D.Dz
2)用PreparedStatement来执行sql语句 uqa
pj("
String sql; BIew\N
sql = "insert into user (id,name) values (?,?)"; V}7)>i$A
PreparedStatement ps = cn.prepareStatement(sql); ~{-Ka>A
ps.setInt(1,xxx); ])%UZM6
ps.setString(2,xxx); h| `R[
... /lPnf7
ResultSet rs = ps.executeQuery(); // 查询 =PNkzFUo
int c = ps.executeUpdate(); // 更新 7'Hh^0<
#b:YY^{g_
3、处理执行结果 gu~R4@3
查询语句,返回记录集ResultSet u2`j\
Vu
更新语句,返回数字,表示该更新影响的记录数 x*=m'IM[
ResultSet的方法 +xsGa{`
1、next(),将游标往后移动一行,如果成功返回true;否则返回false "USzk7=&.
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 %6Vb1?x
kzNRRs\e
4、释放连接 jvD_{r
cn.close(); R#8cOmZ
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection )PYh./_2
%|^,Q -i,
可滚动、更新的记录集 9ZatlI,
1、创建可滚动、更新的Statement v6[VdWOx5
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); G51-CLM,
该Statement取得的ResultSet就是可滚动的 7/k7V)
2、创建PreparedStatement时指定参数 .3V L
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); e>.^RtDF
ResultSet.absolute(9000); |cp_V
批量更新 KIR3m
)
1、Statement LpSF*xm
Statement sm = cn.createStatement(); zxD=q5in
sm.addBatch(sql1); `kv7Rr}Q
sm.addBatch(sql2); "L1LL
iS
... XP:fL
NpQ
sm.executeBatch() 55UPd#E'
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 K :+q9;g
2、PreparedStatement #w \x-i|
PreparedStatement ps = cn.preparedStatement(sql); >9i>A:
{ 7ncR2-{g
ps.setXXX(1,xxx); }LQV2 hKTG
... &)JoB
ps.addBatch(); \*qradgx$
} ?EPHq,
E
ps.executeBatch(); WS(m#WFQr
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 0R`>F">
G(Hr*T%
事务的处理 v.vkQQ0[9
1、关闭Connection的自动提交 +ZiYl[_|
cn.setAutoCommit(false); m .(\u?J
2、执行一系列sql语句 m_Z(osoE#W
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close h&v].l
Statement sm ; XeY[;}9
sm = cn.createStatement(insert into user...); 9) $[W
sm.executeUpdate(); X&5N89
sm.close(); Q=vo5)t
sm = cn.createStatement("insert into corp...); br
3-.g
sm.executeUpdate(); &DHIYj1 i
sm.close(); P2iuB|B@
3、提交 *zDDi(@vtK
cn.commit(); /-m)
4、如果发生异常,那么回滚 -MsL>F.]
cn.rollback();