java 数据库基本操作 Q{5.;{/eC
1、java数据库操作基本流程 ao0^;
2、几个常用的重要技巧: Pe-rwM
可滚动、更新的记录集 ujl?!
批量更新 vRn]u57O
事务处理 M]M>z>1*v
y\4/M6
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 7SN61)[m
1、取得数据库连接 acar-11_o/
1)用DriverManager取数据库连接 L0I|V[
例子 K'/if5>Bc
String className,url,uid,pwd; +J~%z*A
className = "oracle.jdbc.driver.OracleDriver"; tSnsjd<6.
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ]jPP]Z:y
uid = "system"; =c$x xEDD
pwd = "manager"; "Bwmq9Jq
Class.forName(className); 15En$6>
Connection cn = DriverManager.getConnection(url,uid,pwd); Q^=0p0
2)用jndi(java的命名和目录服务)方式 6nJQP a
例子 *YX5bpR?
String jndi = "jdbc/db"; (`_fP.Ogb
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); u.G aMl4 (
DataSource ds = (DataSource) ctx.lookup(jndi); FhPCFmmUT
Connection cn = ds.getConnection(); p-lFzNPc0
多用于jsp中 ]d~{8h!G
2、执行sql语句 '/9q7?[E!
1)用Statement来执行sql语句 ;;m;f^]}
String sql; DSWmQQ
Statement sm = cn.createStatement(); ?Ok&,\F@E
sm.executeQuery(sql); // 执行数据查询语句(select) rC]k'p2x
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); QhLgFu
2)用PreparedStatement来执行sql语句 19-V;F@;
String sql; m>F:dI
sql = "insert into user (id,name) values (?,?)"; C@[U:\
PreparedStatement ps = cn.prepareStatement(sql); *z#du*f[
ps.setInt(1,xxx); ZR-64G=L,
ps.setString(2,xxx); UCkV;//.
... \{!,a
ResultSet rs = ps.executeQuery(); // 查询 KK5_;<
int c = ps.executeUpdate(); // 更新 -"{g kjuv
3IjsV5a
3、处理执行结果 G,c2?^#n
查询语句,返回记录集ResultSet @/ nGc9h
更新语句,返回数字,表示该更新影响的记录数 : 2$*'{mM
ResultSet的方法 eX lJ=S}
1、next(),将游标往后移动一行,如果成功返回true;否则返回false *W^a<Zm8>
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 @$t\yBSK
GKOl{och
4、释放连接 nz'6^D7`r
cn.close(); G<$8g-O;D
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection @|sBnerE
,!LY:pMK
可滚动、更新的记录集 U* c'xoP
1、创建可滚动、更新的Statement Fq!_VF^r
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ,Vo[mB
该Statement取得的ResultSet就是可滚动的 H3`.Y$z
2、创建PreparedStatement时指定参数 @$ju Qm
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ].5q,A]
ResultSet.absolute(9000); ~t/i0pKq.
批量更新 M#-E
1、Statement l(-"rE
Statement sm = cn.createStatement(); (;^>G[
sm.addBatch(sql1); GQJ4d-w
sm.addBatch(sql2); hQ!59
... j_~mP>el)
sm.executeBatch() i7v=o#
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 '*&dP"
2、PreparedStatement {o 5^nd
PreparedStatement ps = cn.preparedStatement(sql); I} 5e{jBB
{ ](8F]J ,
ps.setXXX(1,xxx); <5
OUk
... : vx<m_
ps.addBatch(); T9!NuKfur
} om9'A=ZU
ps.executeBatch(); e=s85!
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 &zJ\D`\,O
dFhyT.Y?
事务的处理 Iz-mUD0;
1、关闭Connection的自动提交 Q<g>WNb
cn.setAutoCommit(false); /Hq
2、执行一系列sql语句 ~tV7yY|zr
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 6,M$TA
Statement sm ; XGbpH<
sm = cn.createStatement(insert into user...); [^bq?w
sm.executeUpdate(); JR
xY#k
sm.close(); `4X.UPJ
sm = cn.createStatement("insert into corp...); 5*-RIs! 2
sm.executeUpdate(); &Td)2Wt
sm.close(); c3ru4o*K
3、提交 ~e]B[>PT
cn.commit(); }&v-<qC^
4、如果发生异常,那么回滚 tPN CdA
cn.rollback();