java 数据库基本操作 )|xu5.F
1、java数据库操作基本流程 XNWtX-[^@
2、几个常用的重要技巧: tfGs|x
可滚动、更新的记录集 t.28IHJ
批量更新 7,+eG">0
事务处理 .iRKuBM/
]EX6Y
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 RTcxZ/\"#
1、取得数据库连接 e=OHO,74z"
1)用DriverManager取数据库连接 .cHgYHa
例子 GHcx@||C?
String className,url,uid,pwd; [g/D<g5O
className = "oracle.jdbc.driver.OracleDriver"; v"o"W[
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; n9+33^ PT
uid = "system"; QPDh!A3T
pwd = "manager"; V2Vr7v=Y"
Class.forName(className); b?i+nhqI
Connection cn = DriverManager.getConnection(url,uid,pwd); Z)`)9]*
2)用jndi(java的命名和目录服务)方式 OB(oOPH
例子 \Mg_Q$
String jndi = "jdbc/db"; @./h$]6
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ,*XB11P
DataSource ds = (DataSource) ctx.lookup(jndi); 4|`>}Nu
Connection cn = ds.getConnection(); S\).0goOW
多用于jsp中 d2`g,~d
2、执行sql语句 E{|B&6$[}
1)用Statement来执行sql语句 q,,
String sql; Qu61$!
Statement sm = cn.createStatement(); 4`5yrCd
sm.executeQuery(sql); // 执行数据查询语句(select) v745FIy<
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); d&j
2)用PreparedStatement来执行sql语句 N; g@lyo
String sql; e?]5q ez
sql = "insert into user (id,name) values (?,?)"; H#SQ>vyAV
PreparedStatement ps = cn.prepareStatement(sql); '>"{yi-
ps.setInt(1,xxx); vV}w>Ap[
ps.setString(2,xxx); @L3XBV2
... )!"fUz$
ResultSet rs = ps.executeQuery(); // 查询 !RI _Uph
int c = ps.executeUpdate(); // 更新 )\akIA
_?
gCOr
3、处理执行结果 ljKIxSvCFp
查询语句,返回记录集ResultSet tqGrhOt
更新语句,返回数字,表示该更新影响的记录数 @sXv5kZ:
ResultSet的方法 dkC[SG`
1、next(),将游标往后移动一行,如果成功返回true;否则返回false SGAzeymw
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 $H)^o!
CxFd/X,
4、释放连接 .Kb3VNgwvm
cn.close(); L'= \|r
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection [8iY0m_Qe
\R#SoOd
可滚动、更新的记录集 3Qy@^"
1、创建可滚动、更新的Statement n=.P46|
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); sK}AS;:
该Statement取得的ResultSet就是可滚动的 '$9o(m#
2、创建PreparedStatement时指定参数 1$>+rW{a
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); u R0UfKK
ResultSet.absolute(9000); o`bc/3!
批量更新 E/zf9\
1、Statement PF%-fbh!~
Statement sm = cn.createStatement(); dHnCSOM<
sm.addBatch(sql1); >+2&7u
sm.addBatch(sql2); Cr.YSWg)4
... IO%kXF.[
sm.executeBatch() G|wtl(}3
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 n:5M
E*
2、PreparedStatement \Vyys[MMY8
PreparedStatement ps = cn.preparedStatement(sql); :viW
{ 5n@YNaoIb
ps.setXXX(1,xxx); XiW1X6
... ;*(-8R/
ps.addBatch(); u^Q`xd1
} GJ ^c^`
ps.executeBatch(); /F0q8j0
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 idI w7hi4
bZnOX*y]
事务的处理 kKX' Y+
1、关闭Connection的自动提交 y9:4n1fg
cn.setAutoCommit(false); )Qbd/zd\U
2、执行一系列sql语句 oZ'a}kF
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close :{7+[LcH7
Statement sm ; W2vL<
sm = cn.createStatement(insert into user...); rAenxZ,tF
sm.executeUpdate(); 4EB\R"rWXf
sm.close(); {r^_ g(.q
sm = cn.createStatement("insert into corp...); *6Wiq5M>.
sm.executeUpdate(); B8@mL-Z-;
sm.close(); ^? fOccfQ{
3、提交 fUT[tkb/!
cn.commit(); - x
4、如果发生异常,那么回滚 ai!u+L
cn.rollback();