java 数据库基本操作 q$7w?(Lk
1、java数据库操作基本流程 hZIbN9)8A
2、几个常用的重要技巧: !LR9}Xon
可滚动、更新的记录集 JU Xo3D~
批量更新 dzk1 !yy
事务处理 /07iQcT(
t
$m:
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 `}:pUf
1、取得数据库连接
"tT68
1)用DriverManager取数据库连接 -6W$@,K
例子 P(oGNKAS
String className,url,uid,pwd; 4V<.:.k
className = "oracle.jdbc.driver.OracleDriver"; 9y'To JZ6
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ppuJC'GW
uid = "system"; Y sDai<
pwd = "manager"; %y)]Q|
Class.forName(className); A&N$=9.N1
Connection cn = DriverManager.getConnection(url,uid,pwd); GvzaLEo
2)用jndi(java的命名和目录服务)方式 B/Js>R
例子 0VnRtLnqI
String jndi = "jdbc/db"; ZAJ~Tbm[f
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); b{BiC&3
DataSource ds = (DataSource) ctx.lookup(jndi); V=gu'~
Connection cn = ds.getConnection(); (}RTHpD
多用于jsp中 dvE~EZcS
2、执行sql语句 aH7@:=B
1)用Statement来执行sql语句 G>edJPfQ
String sql; QsX`IYk
Statement sm = cn.createStatement(); :jAsm[
sm.executeQuery(sql); // 执行数据查询语句(select) :FUxe kz
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); z? Iu;X
2)用PreparedStatement来执行sql语句 s
.@S zq
String sql; v65]$%F?
sql = "insert into user (id,name) values (?,?)"; lFp : F5
PreparedStatement ps = cn.prepareStatement(sql); vYybQ&E/
ps.setInt(1,xxx); FwE<_hq//
ps.setString(2,xxx); v4qpE!W27~
... #/"Tb^c9
ResultSet rs = ps.executeQuery(); // 查询 C>Q|"Vf2
int c = ps.executeUpdate(); // 更新 WN $KS"b6}
V~_6t{L
3、处理执行结果 Alv"D
查询语句,返回记录集ResultSet c!kz wc(
更新语句,返回数字,表示该更新影响的记录数 %x./>-[t
ResultSet的方法 00LL&ot
1、next(),将游标往后移动一行,如果成功返回true;否则返回false tUksIUYD\
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ba tXj]:
>u\'k+=
4、释放连接 ,Yn$X
cn.close(); >Qqxn*O
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection '%&-`/x
SB|Cr:wM
可滚动、更新的记录集 >]HvXEdNZ|
1、创建可滚动、更新的Statement ta@fNS4
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); >guX,hx^
该Statement取得的ResultSet就是可滚动的 8Ow#W5_3|
2、创建PreparedStatement时指定参数 tl
9`
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); #nQboTB@
ResultSet.absolute(9000); >E7s}bL"
批量更新 4~AY:
ib|
1、Statement @X2 zIFm
Statement sm = cn.createStatement(); ?AVnv(_
sm.addBatch(sql1); bN&DotG
sm.addBatch(sql2); =)#<u9
qqL
... Z6zLL
sm.executeBatch() %(S!/(LWW
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ]|N"jr?7H
2、PreparedStatement cj4o[l
PreparedStatement ps = cn.preparedStatement(sql); F=?GV\Tw
{ [s+FX5' K
ps.setXXX(1,xxx); :j#zn~7
...
,
{}S<^?]
ps.addBatch(); u/CR7Y
} T2A74>Nw
ps.executeBatch(); _PLZ_c:O
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 e< G[!m
=eR#]d
事务的处理 Ax 4R$P.]u
1、关闭Connection的自动提交 T-\q3X|y/
cn.setAutoCommit(false); o{' JO3
2、执行一系列sql语句 /eBcPu"[Vb
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close (S?qxW?
Statement sm ; aI;fNy/K
sm = cn.createStatement(insert into user...); t]{, 7.S
sm.executeUpdate(); |RBL5,t^
sm.close(); a# Uk:O!
sm = cn.createStatement("insert into corp...); J[UTn'M8]
sm.executeUpdate(); #^_7i)=~
sm.close(); F ~e}=Nb
3、提交 XM3~]
cn.commit(); (SCZ.G(>
4、如果发生异常,那么回滚 BwYR"
cn.rollback();