java 数据库基本操作 w 3kX!%a:
1、java数据库操作基本流程 0q6xXNAX
2、几个常用的重要技巧: dp}s]`x+
可滚动、更新的记录集 _9f7@@b
批量更新 #IvHxSo&
事务处理 )Szn,
vC^Ul
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 b9R0"w!ml
1、取得数据库连接
i"`N5
1)用DriverManager取数据库连接 :P8X?C63W]
例子 X<sM4dwxE
String className,url,uid,pwd; <s=i5t
My5
className = "oracle.jdbc.driver.OracleDriver"; Xk] uXx:TN
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; kxCN0e#_
uid = "system"; NG5k9pJ
pwd = "manager"; GLp~SeF#
Class.forName(className); f4;V7DJ
Connection cn = DriverManager.getConnection(url,uid,pwd); vd9PB N
2)用jndi(java的命名和目录服务)方式 U<|*V5
例子 9K>~9Za
String jndi = "jdbc/db"; Qk2*=BVh
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); l0r^LK$
DataSource ds = (DataSource) ctx.lookup(jndi); {)I&&fSz
Connection cn = ds.getConnection(); 2WS Wfh
多用于jsp中 Gs/G_E(T
2、执行sql语句 /b]+RXvxj
1)用Statement来执行sql语句 0DaKd<Scv
String sql; /Yj; '\3
Statement sm = cn.createStatement(); b63DD(
sm.executeQuery(sql); // 执行数据查询语句(select) =j%ORD[
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close();
qN'%q+n
2)用PreparedStatement来执行sql语句 iU|X/>k?
String sql; pmiC|F83!8
sql = "insert into user (id,name) values (?,?)"; .[
s6x5M
PreparedStatement ps = cn.prepareStatement(sql); 4}t$Lf_
ps.setInt(1,xxx); Bxf&gDwjgr
ps.setString(2,xxx); "td ,YVK
... %<>|cO
ResultSet rs = ps.executeQuery(); // 查询 To;r#h
int c = ps.executeUpdate(); // 更新 r.' cjUs
3
jghV?I{T
3、处理执行结果 0pBG^I`_
查询语句,返回记录集ResultSet +.a->SZ5"
更新语句,返回数字,表示该更新影响的记录数 ~3$:C#"Dl
ResultSet的方法 m' eM&1Ba
1、next(),将游标往后移动一行,如果成功返回true;否则返回false :m0pm@
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 L4<=,}KS
z>HM$n`YD
4、释放连接 7Q|v5@;pU
cn.close(); nu X`>Oy
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection acI%fYw5p`
~Efi|A/
可滚动、更新的记录集 h`D+NZtWm
1、创建可滚动、更新的Statement ([NS%
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ,o\~d?4
该Statement取得的ResultSet就是可滚动的 H284
]i
2、创建PreparedStatement时指定参数 wx^1lC2
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); %.s"l6 W
ResultSet.absolute(9000); +L
pMNnl6
批量更新 t x1(6V&l;
1、Statement mW#p&{
Statement sm = cn.createStatement(); N#^o,/
sm.addBatch(sql1); O/ZyWT
sm.addBatch(sql2); O*1la/~m
... ~./M5P!\
sm.executeBatch() 0T:ZWRjH
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 \P9HAz'6
2、PreparedStatement -P'c0I9z
PreparedStatement ps = cn.preparedStatement(sql); lsOZ%p%fV
{ =
$6pL
ps.setXXX(1,xxx); KCfcEz
... ~ym-Szo
ps.addBatch(); 74a>}+"
} W4=<hB
ps.executeBatch(); r%II`
i
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 !{4bC
^qPS&G
事务的处理 %|3NCyJ*7
1、关闭Connection的自动提交 oHx =Cg;
cn.setAutoCommit(false); 6E.64+PJw
2、执行一系列sql语句 nNcmL/(
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close B1 [O9 U:
Statement sm ; si|b>R&Z
sm = cn.createStatement(insert into user...); 3EX41)u
sm.executeUpdate(); G 8F43!<
sm.close(); l}mzCIw%
sm = cn.createStatement("insert into corp...); [X=Ot#?u ~
sm.executeUpdate(); & ^JY
sm.close(); df!n.&\y!
3、提交 AME6Zu3Y
cn.commit(); qGKQrb,K
4、如果发生异常,那么回滚 S-)%#
cn.rollback();