java 数据库基本操作 O$
p
1、java数据库操作基本流程 l:' 0
2、几个常用的重要技巧: ,q[aV 6kO
可滚动、更新的记录集 \&[Jtv *
批量更新 }02#[vg
事务处理 abs\Ku9
H@-txO1`::
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 g3fxf(iY(
1、取得数据库连接 c%?31t
1)用DriverManager取数据库连接 hU:
9zLe
例子 A@:h\<
String className,url,uid,pwd; ->H4!FS
className = "oracle.jdbc.driver.OracleDriver"; /RWQ+Zf-Y]
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; "`va_Mk
uid = "system"; F0Nl,9h('
pwd = "manager"; roiUVisq*
Class.forName(className); whoM$ &
Connection cn = DriverManager.getConnection(url,uid,pwd); *!mT#Vm^
2)用jndi(java的命名和目录服务)方式 QB3vp4pBg@
例子 =x_~7 Xc{
String jndi = "jdbc/db"; CP5vo-/)-
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); x-hr64WFK
DataSource ds = (DataSource) ctx.lookup(jndi); /y2)<{{I
Connection cn = ds.getConnection(); p'@|Oq&
多用于jsp中 Y.7iKMp(
2、执行sql语句 CO%o.j=1
1)用Statement来执行sql语句 6!QY)H^j9,
String sql; /=y _#l
Statement sm = cn.createStatement(); |8m2i1XG
sm.executeQuery(sql); // 执行数据查询语句(select) ca@?-)
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 7,^.h<@K
2)用PreparedStatement来执行sql语句 O6
:GE'S
String sql; lMn1e6~K
sql = "insert into user (id,name) values (?,?)"; {hP_"nN#
PreparedStatement ps = cn.prepareStatement(sql); vOF"p4 ^ 3
ps.setInt(1,xxx); W{)RJ1
ps.setString(2,xxx); =qg;K'M5
... ?.*^#>-
ResultSet rs = ps.executeQuery(); // 查询 ff{L=uj
int c = ps.executeUpdate(); // 更新 T(@J]Y-
goJK~d8M*
3、处理执行结果 Xc>M_%+R
查询语句,返回记录集ResultSet VuU{7:
更新语句,返回数字,表示该更新影响的记录数 ulA||
ResultSet的方法 3?n2/p
7=
1、next(),将游标往后移动一行,如果成功返回true;否则返回false AlVBhR`
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 GC#s;X
#8{U0 7]"
4、释放连接 OrG1Mfx&2%
cn.close(); w$`[C+L
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection ],?$&
@7}]\}SR
可滚动、更新的记录集 [?QU'[
1、创建可滚动、更新的Statement b23 5Zm
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); REK(^1
h
该Statement取得的ResultSet就是可滚动的 hxT{!g
2、创建PreparedStatement时指定参数 Hv3<gyD
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ;ZasK0
ResultSet.absolute(9000); oh?@[U
批量更新 @,9cpaL3
1、Statement )iU@P7W=
Statement sm = cn.createStatement(); m-w K8]t9
sm.addBatch(sql1); 9 SBVp6'
sm.addBatch(sql2); Rr% CP[bH
... [$x&J6jF.
sm.executeBatch() ]-2Q0wTj
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 .XZq6iF9
2、PreparedStatement l`mNOQ@}'
PreparedStatement ps = cn.preparedStatement(sql); 5`3Wua
{ >508-)'
ps.setXXX(1,xxx); :(?F(Q^
... Y!1x,"O'H
ps.addBatch(); CRh.1-
} 'ZiTjv]
ps.executeBatch(); SNUq
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 F\Z|JCA
z P`&X:8
事务的处理 R?Dc*,
1、关闭Connection的自动提交 GN=ugP 9
cn.setAutoCommit(false); X+$IaLfCxD
2、执行一系列sql语句 ~BbF:DS
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close #X`qkW.T<
Statement sm ; ) 8_x
sm = cn.createStatement(insert into user...); S^zt>
sm.executeUpdate(); XwlF[3VbiX
sm.close(); qX%oLa
sm = cn.createStatement("insert into corp...); Y0?<~Gf
sm.executeUpdate(); U;qGUqI
sm.close(); m\DI6O"u'
3、提交 \Ctl(uj
cn.commit(); UXdnN;0
4、如果发生异常,那么回滚 UVUoXv)N
cn.rollback();