java 数据库基本操作 wQW`Er3w
1、java数据库操作基本流程 5kqI
2、几个常用的重要技巧: &. _"rhz
可滚动、更新的记录集 Ee5YW/9]
批量更新 )EMlGM'2q
事务处理 5CnNp?.t^
d/GSG%zB
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 tnpEfi-
1、取得数据库连接 IV~)BW leT
1)用DriverManager取数据库连接 Z6B$\Q5Od
例子 R1JD{
String className,url,uid,pwd; cvw17j
className = "oracle.jdbc.driver.OracleDriver"; &NF$_*\E
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; z*HM_u
uid = "system"; '(iPI
pwd = "manager"; %nJo:/
Class.forName(className); dr#%~I
Connection cn = DriverManager.getConnection(url,uid,pwd); *~U*:>hS
2)用jndi(java的命名和目录服务)方式 y ;mk]
例子 5[g&0
String jndi = "jdbc/db"; }#g]qK
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); /y1+aTiJ
DataSource ds = (DataSource) ctx.lookup(jndi); L%[>z'Zp
Connection cn = ds.getConnection(); @nqM#
多用于jsp中
[<r.M<3
2、执行sql语句 b4:{PD~Mh
1)用Statement来执行sql语句 K1YxF
String sql; jNbVp{%/S}
Statement sm = cn.createStatement(); jhRr!
sm.executeQuery(sql); // 执行数据查询语句(select) _G)A$6weU
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ;Q3[} ]su
2)用PreparedStatement来执行sql语句 b1^wK"#
String sql; L=54uCv
Q
sql = "insert into user (id,name) values (?,?)"; u ^#UsOt+
PreparedStatement ps = cn.prepareStatement(sql); Sv=e|!3f[k
ps.setInt(1,xxx); #n&/v'!\
ps.setString(2,xxx); 4SUzR\
... T5`ML'Dej
ResultSet rs = ps.executeQuery(); // 查询 UZsvYy?
int c = ps.executeUpdate(); // 更新 }r18Y6
IqlCl>_j
3、处理执行结果 |FFz $'8)
查询语句,返回记录集ResultSet BN(=LQ2["
更新语句,返回数字,表示该更新影响的记录数 ;E{jn4B'
ResultSet的方法 7Z9'Y?[m
1、next(),将游标往后移动一行,如果成功返回true;否则返回false yC
?p,Ci,
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 =LY`K#
9PV]bt,
4、释放连接 _KloX{a
cn.close(); KKQT?/ {b
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection oFp1QrI3k8
U6|T<bsOl
可滚动、更新的记录集 l4mRNYv)z
1、创建可滚动、更新的Statement W*iTg%a\k
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); f>xi (0
该Statement取得的ResultSet就是可滚动的 ;HYEJ3
2、创建PreparedStatement时指定参数 ;4dFL\KU
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ta5_k&3N
ResultSet.absolute(9000); NHUJ:j@
批量更新 YXTV$A+lW
1、Statement +<$nZ=,hsy
Statement sm = cn.createStatement(); m|B)A"Sm
sm.addBatch(sql1); }>y!I5O
sm.addBatch(sql2); YeT{<9p
... K%`]HW@I{
sm.executeBatch() C ]B P}MY<
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 AEM;ZQU
2、PreparedStatement DXj>u9*%
PreparedStatement ps = cn.preparedStatement(sql); yQ^, >eh
{ {o^tSEN!-
ps.setXXX(1,xxx); H9'psv
... #B <%
ps.addBatch(); -Sh&x
} 2\&3x}@
ps.executeBatch(); s[eSPSFZ
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 :G98uX t
Fnk@)1
事务的处理 QSzht$8
1、关闭Connection的自动提交 3st?6?7|
cn.setAutoCommit(false); A*:|d~
2、执行一系列sql语句 ,gpEXUp\
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close ;`xCfOY(
Statement sm ; 2 Y9u9;ah
sm = cn.createStatement(insert into user...); tz?3R#rM
sm.executeUpdate(); wWx{#!W
sm.close(); iEI#J!~
sm = cn.createStatement("insert into corp...); P9:5kiP H
sm.executeUpdate(); FS)#
v
sm.close(); >jiez,
3、提交 r"K!]Vw
cn.commit(); O..{wdZy
4、如果发生异常,那么回滚 ^AI02`c.
cn.rollback();