java 数据库基本操作 YxGcFjJ
1、java数据库操作基本流程 lg}HGG
2、几个常用的重要技巧: NJ MJ
可滚动、更新的记录集 X]y)ZF26
批量更新 Dl&GJ`&:p
事务处理 <X_!x_x
jhGlG-^
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 PU {uE[
1、取得数据库连接 ;&b%Se@#p
1)用DriverManager取数据库连接 u0RS)&
例子 FkqQf8HB
String className,url,uid,pwd; /_\#zC[
className = "oracle.jdbc.driver.OracleDriver"; #n
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; L!'k !k
uid = "system"; =l9T7az
pwd = "manager"; &W6^6=E{g
Class.forName(className); k{AyD`'Q
Connection cn = DriverManager.getConnection(url,uid,pwd); mF09U(ci
2)用jndi(java的命名和目录服务)方式 :+%Zh@u\
例子 >az;!7~cD
String jndi = "jdbc/db"; B(DrY1ztj
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); [,~TaP}m
DataSource ds = (DataSource) ctx.lookup(jndi); -/D|]qqHm
Connection cn = ds.getConnection(); 46h@j>/K
多用于jsp中 `aqrSH5^h
2、执行sql语句 MqKye8h9f
1)用Statement来执行sql语句 {S<>&?XB
String sql; qUo-Dq>
Statement sm = cn.createStatement(); @4!x>q$3
sm.executeQuery(sql); // 执行数据查询语句(select) e9^2,:wLB
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close();
tehUD&
2)用PreparedStatement来执行sql语句 )2Hff.
String sql; nd{R
9B
sql = "insert into user (id,name) values (?,?)"; ;$BdP7i:
PreparedStatement ps = cn.prepareStatement(sql); DXQi-+?
ps.setInt(1,xxx); %gcc
y|
ps.setString(2,xxx); S*"u/b;
... L fl-!1
ResultSet rs = ps.executeQuery(); // 查询 ?`zgq>R}w[
int c = ps.executeUpdate(); // 更新 1j\aH&)GH
6`$[Ini
3、处理执行结果 *]x*B@RF
查询语句,返回记录集ResultSet E4D (,s
更新语句,返回数字,表示该更新影响的记录数 nN3$\gHp8i
ResultSet的方法 [ut#:1h^
1、next(),将游标往后移动一行,如果成功返回true;否则返回false Ra3ukYG[
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 !7U\J]
,}C8;/V
4、释放连接 }4nT.!5
cn.close(); *OdX u&5
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection g6sjc,`
bQaoMZB
可滚动、更新的记录集 P|^$kK
1、创建可滚动、更新的Statement fj4^VXD
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); n~Szf
该Statement取得的ResultSet就是可滚动的 }~o
ikN:
2、创建PreparedStatement时指定参数 z8Q"%@
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ]v5-~E!
ResultSet.absolute(9000); Y'Z+, CNf
批量更新 HXJ9xkrr
1、Statement -U>7
H`5
Statement sm = cn.createStatement(); (tl}q3U
sm.addBatch(sql1); rwpgBl
sm.addBatch(sql2); 0]x;n+G[q
... s6=YV0w(
sm.executeBatch() LQ-6vrbs
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 j1$<] f
2、PreparedStatement WA
LGIW
PreparedStatement ps = cn.preparedStatement(sql); =V|Nn0E
{ ?z"KnR+?Q
ps.setXXX(1,xxx); `<j_[(5yb
... 1.R
kIB
ps.addBatch(); X^< >6|)
} vZajT!h
ps.executeBatch();
'H FK Bp
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 >Wh3MG6
y67uH4&Vm
事务的处理 PaVO"y]C
1、关闭Connection的自动提交 b4 hIeBI\
cn.setAutoCommit(false); yty`2$O
2、执行一系列sql语句 =J@`0H"
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close cD{8|B*
Statement sm ; 9B)lGLL}q
sm = cn.createStatement(insert into user...); xaL#MIR"u"
sm.executeUpdate(); x.EgTvA&d
sm.close(); h)E|?b_
sm = cn.createStatement("insert into corp...); ]0D9N"
sm.executeUpdate(); u fw cF*
sm.close(); DMkhbo&+
3、提交 ?En7_X{C?
cn.commit(); F@hYA
4、如果发生异常,那么回滚 (L|}`
cn.rollback();