java 数据库基本操作 uH~ TugQ~
1、java数据库操作基本流程 V8| q"UX
2、几个常用的重要技巧: 9 Le/'o vq
可滚动、更新的记录集 $TH'"XK
批量更新 3HDnOl8t
事务处理 D+@/x{wX2
Oujlm|
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 Ra15d^
1、取得数据库连接 \M1M2(@pDJ
1)用DriverManager取数据库连接 ]CtoK%k
例子 (qq$y
#$
String className,url,uid,pwd; #xJGuYdv
className = "oracle.jdbc.driver.OracleDriver"; '"G
%0y
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; WPh |~]by<
uid = "system";
DFZ:.6p
pwd = "manager"; p7ns(g@9
Class.forName(className); o sgS?=8
Connection cn = DriverManager.getConnection(url,uid,pwd); &>wce5uV
2)用jndi(java的命名和目录服务)方式 OKLggim{
例子 J=Y( *D7Q
String jndi = "jdbc/db"; qyG636i
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); Gh>fp
DataSource ds = (DataSource) ctx.lookup(jndi); yADN_
Connection cn = ds.getConnection(); TG%hy"k
多用于jsp中 Lb3K};SIV
2、执行sql语句 \i;~~;D
1)用Statement来执行sql语句 lXL7q?,9
String sql; H2p XJ/XF
Statement sm = cn.createStatement(); >cr_^(UW&
sm.executeQuery(sql); // 执行数据查询语句(select) Vlxb<$5Nh
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); GVHfN5bTqn
2)用PreparedStatement来执行sql语句 g,GbaaXH
String sql; BC0c c[x
sql = "insert into user (id,name) values (?,?)"; h9OL%n 7m'
PreparedStatement ps = cn.prepareStatement(sql); y:6'&`L
ps.setInt(1,xxx); {ALBmSapK"
ps.setString(2,xxx); 1&dsQ,VDl
... cTIwA:)D
ResultSet rs = ps.executeQuery(); // 查询 }+RF~~H/
int c = ps.executeUpdate(); // 更新 zt>_)&b
#* /W!UOu
3、处理执行结果 >^\>-U|
查询语句,返回记录集ResultSet LXfeXWw?,
更新语句,返回数字,表示该更新影响的记录数 ?e|:6a+[f
ResultSet的方法 j'Q-*-3
1、next(),将游标往后移动一行,如果成功返回true;否则返回false m+8b2H:V
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 )s7 Tv#[
qLi1yH
4、释放连接
a):Run
cn.close(); S%gO6&^
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection R{Kd%Y:2Y
*Wo$$T
可滚动、更新的记录集 /$.vHt5nt
1、创建可滚动、更新的Statement '<W,-i
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); }GNH)-AG)$
该Statement取得的ResultSet就是可滚动的 ?;#3U5$v
2、创建PreparedStatement时指定参数 J]^gF|
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); }br<2?y,
ResultSet.absolute(9000); 88=FPEU
批量更新 cyP*QW[
1、Statement .dLX'84fY
Statement sm = cn.createStatement(); Ac(irPrD
sm.addBatch(sql1); r~!%w(N|M
sm.addBatch(sql2); }/}`onRZ
...
M=abJ4
sm.executeBatch() \V-
Y,!~5
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 E9*?G4P{l
2、PreparedStatement Iybpk?,M+
PreparedStatement ps = cn.preparedStatement(sql); w,#W&>+&
{ ieLN;)Iy^
ps.setXXX(1,xxx); 0BP~0z
... c1!/jTX$
ps.addBatch();
j.v _
} jL).B&
ps.executeBatch(); k<";t
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 xdU
pp~}+.
`*9FKs
事务的处理 WK)k -A^q
1、关闭Connection的自动提交 4qcIoO
cn.setAutoCommit(false); VRP.tD
2、执行一系列sql语句 n.UM+2G
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close ZO6bG$y64
Statement sm ; 5)NfZN#&