java 数据库基本操作 rtoSCj:
1、java数据库操作基本流程 %uF:)
2、几个常用的重要技巧: ;B(;2.<"J
可滚动、更新的记录集 S`fu+^cv
批量更新 e_\SSH@tw
事务处理 =y`-sU Hx
2~+'vi
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ud5x$`
1、取得数据库连接 MV7}
1)用DriverManager取数据库连接 /]P%b K6B
例子 bl6':m+
String className,url,uid,pwd; 'w: tq
className = "oracle.jdbc.driver.OracleDriver"; nsy!p5o
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; aIY$5^x
uid = "system"; dV'6m@C
pwd = "manager"; zjzqKdy}F
Class.forName(className); _$~ex ~v
Connection cn = DriverManager.getConnection(url,uid,pwd); !N@Yh"c
2)用jndi(java的命名和目录服务)方式 ~y( ,EO
例子 !x+MVJ]
String jndi = "jdbc/db"; 6f<*1YR
F
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); hrUm}@d
DataSource ds = (DataSource) ctx.lookup(jndi); 8s\8`2=
Connection cn = ds.getConnection(); 8.6no
多用于jsp中 0q-0zXlSL
2、执行sql语句 V7qCbd^>XJ
1)用Statement来执行sql语句 94S .9A
String sql; })h'""i&xn
Statement sm = cn.createStatement(); R V_MWv
sm.executeQuery(sql); // 执行数据查询语句(select) UXXqE4x
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ";%e~
=
2)用PreparedStatement来执行sql语句 o;Hd W
String sql; 77Q4gw~2U
sql = "insert into user (id,name) values (?,?)"; ^'
edE5
PreparedStatement ps = cn.prepareStatement(sql); Q%_!xQP`
ps.setInt(1,xxx); (Q*2dd>
ps.setString(2,xxx); ljaAB+
... >"2\D|-/
ResultSet rs = ps.executeQuery(); // 查询 3 LZL!^ 5N
int c = ps.executeUpdate(); // 更新 r? 6Z1
~)oWSo5ll
3、处理执行结果 f=-!2#%
查询语句,返回记录集ResultSet
oi%5t)VsS
更新语句,返回数字,表示该更新影响的记录数 bqf]$}/8k
ResultSet的方法 +?J_6Mo@X
1、next(),将游标往后移动一行,如果成功返回true;否则返回false fS8XuT
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 v)v{QNQp^
|TNiKy
4、释放连接 #]N&6ngJ
cn.close(); Rz])wBv e
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection S]#=ES'^/
~ ]m@k'n
可滚动、更新的记录集 q_%w
l5\F
1、创建可滚动、更新的Statement ~0Q\Lp);
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); * 7zN
该Statement取得的ResultSet就是可滚动的 uj+.L6S
2、创建PreparedStatement时指定参数 XQ+-+CD
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); CU7iva
ResultSet.absolute(9000); P"h,[{Y*>
批量更新 ,&O:/|c E
1、Statement .aAw7LW
Statement sm = cn.createStatement(); KY(l<pm
sm.addBatch(sql1); Sf.8Ibw
sm.addBatch(sql2); 7kWZMi
... HCe-]nMd
sm.executeBatch() >k&lGF<nl
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 4p/V6kr&r
2、PreparedStatement :a^,Ei-&
PreparedStatement ps = cn.preparedStatement(sql); (0+ GLI8
{ D=pI'5&
ps.setXXX(1,xxx); ^QHMN 7r/
... g en3"\Og{
ps.addBatch(); j_YZ(: =
}
m%[2x#
ps.executeBatch(); 2=UTH%1D
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 6r-<XNv)0
H?zCIue3
事务的处理 cvLcre% >A
1、关闭Connection的自动提交 [b)K@Ha
cn.setAutoCommit(false); 7+2aG
2、执行一系列sql语句 $4ZDT]n
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 80l3.z,:
Statement sm ; [7Kj$PB3
sm = cn.createStatement(insert into user...); L-X
_b3E\
sm.executeUpdate(); uBL~AC3>O
sm.close(); Aaw:B?4)
sm = cn.createStatement("insert into corp...); YQ[&h
sm.executeUpdate(); 3Jk?)Dy
sm.close(); AQBx
k[
3、提交
vGLb2Q
cn.commit(); HU.6L'H*
4、如果发生异常,那么回滚 Wn9Mr2r!*,
cn.rollback();