java 数据库基本操作 0Ju{6x(|
1、java数据库操作基本流程 -]e@cevy
2、几个常用的重要技巧: a/ZfPl0Ns[
可滚动、更新的记录集 `xSXGI
批量更新 0/Csc\Xl
事务处理 cQny)2k*x
/[OMpP
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 OX"`VE
1、取得数据库连接 R+\5hI@ >i
1)用DriverManager取数据库连接 };*5+XY^
例子
]%."
String className,url,uid,pwd; RwE]t$T/
className = "oracle.jdbc.driver.OracleDriver"; \3l;PY
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ZD/!C9:&.0
uid = "system"; ;p/@tr9
pwd = "manager"; 8c9_=8vw
Class.forName(className); &Ru6Yt0W
Connection cn = DriverManager.getConnection(url,uid,pwd); Dz?F,g_
2)用jndi(java的命名和目录服务)方式 _?ym,@}#
例子 Z+?j8(:n
String jndi = "jdbc/db"; 2+enRR~
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); h5JXKR.1]c
DataSource ds = (DataSource) ctx.lookup(jndi); ll#PCgIm
Connection cn = ds.getConnection(); iAN#TCwLT7
多用于jsp中 ~4M]SX1z
2、执行sql语句 ,oCr6 ]
1)用Statement来执行sql语句 i<
ih :
String sql; Wq4?`{
Statement sm = cn.createStatement(); nT>?}/S
sm.executeQuery(sql); // 执行数据查询语句(select) Oj:`r*z43
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); Lv_>cFJ}[
2)用PreparedStatement来执行sql语句 }IV7dKzl
String sql; cH#`f4
sql = "insert into user (id,name) values (?,?)"; =<g\B?s]
PreparedStatement ps = cn.prepareStatement(sql); C}!|K0t?
ps.setInt(1,xxx); Y4_i=}\*vf
ps.setString(2,xxx); Xf0pQ]8\
... p"T4;QBxQ
ResultSet rs = ps.executeQuery(); // 查询 G*QQpSp
int c = ps.executeUpdate(); // 更新 gC 4w&yL
4l|Am3vzX
3、处理执行结果 _]\mh,}
查询语句,返回记录集ResultSet ,=mn*
更新语句,返回数字,表示该更新影响的记录数 43eGfp'
ResultSet的方法 {E9Y)Z9
1、next(),将游标往后移动一行,如果成功返回true;否则返回false |89`O^
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 u!Z&c7kPI
~&pk</Dl
4、释放连接 GcKJpI\sB
cn.close(); eaI&DP
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 1G\ugLm
sB6UlX;b:
可滚动、更新的记录集 .(sT?M`\J
1、创建可滚动、更新的Statement (i`DUF'#y
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Eb.{M
该Statement取得的ResultSet就是可滚动的 =q._Qsj?fu
2、创建PreparedStatement时指定参数 o5)U3U1|
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); A`@we
ResultSet.absolute(9000); 'K0Y@y
批量更新 4U((dx*m
1、Statement W>"i0p
Statement sm = cn.createStatement(); RGiA>Z:W
sm.addBatch(sql1); n_aKciF
sm.addBatch(sql2); A81kb
... xTe?*
sm.executeBatch() p~r +2(J
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 pd|c7D!6U,
2、PreparedStatement 4[6A~iC_
PreparedStatement ps = cn.preparedStatement(sql); '\9A78NV{;
{ $r dA0%;
ps.setXXX(1,xxx); )wKuumet
... TPkm~>zD.
ps.addBatch(); xT@\FwPr
} 4Ld0AApncy
ps.executeBatch(); ^,?]]=mE
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 [P[syi#]t
+%FGti$[
事务的处理 pdE=9l'
1、关闭Connection的自动提交 kJ~^
}o
cn.setAutoCommit(false); MOj 0"x)
2、执行一系列sql语句 Gm*i='f!?
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close sI~{it#
Statement sm ; KB-7]H
sm = cn.createStatement(insert into user...); r+) A)a,
sm.executeUpdate(); 6OVAsmE
sm.close(); $
@^n3ZQ4
sm = cn.createStatement("insert into corp...); s |qB;
sm.executeUpdate(); n&@\[,B
sm.close(); )9Jt550(
3、提交 md<%Z4+
cn.commit(); 8zr)oQ:
4、如果发生异常,那么回滚 LaLA}1!
cn.rollback();