java 数据库基本操作 bI|G
%
1、java数据库操作基本流程 h2f8-}fsq
2、几个常用的重要技巧: I2}eFz&FE
可滚动、更新的记录集 ?@,EGY<
批量更新 Fc5t,P
事务处理 8\{z>y
F[Mwd &P@
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 fxPg"R!1i
1、取得数据库连接 gAdqZJR%]
1)用DriverManager取数据库连接 :M6v<Kg{;
例子 n.2:fk
String className,url,uid,pwd; j\~,Gtn>Z
className = "oracle.jdbc.driver.OracleDriver"; =FhP$r*
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; qc
@cdi
uid = "system"; ./k7""4
pwd = "manager"; wCNn/%C
Class.forName(className); I
]ZZN6"
Connection cn = DriverManager.getConnection(url,uid,pwd); *YeQCt-l
2)用jndi(java的命名和目录服务)方式 ;Go^)bN
;
例子 S\8v)|Pr
String jndi = "jdbc/db"; eN,9N]K
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ga%\n!S
DataSource ds = (DataSource) ctx.lookup(jndi); 2vjkThh`I
Connection cn = ds.getConnection(); ?#=xx.cF
多用于jsp中 . waw=C
2、执行sql语句 'Tjvq%ks
1)用Statement来执行sql语句 "nu]3zcd
String sql; sb{K%xi%
Statement sm = cn.createStatement(); O%\cRn8m
sm.executeQuery(sql); // 执行数据查询语句(select) zvdut ,6<
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); "4\
2)用PreparedStatement来执行sql语句 3<
?+Yhq
String sql; >bf.T7wy
sql = "insert into user (id,name) values (?,?)"; mW%8`$rVEO
PreparedStatement ps = cn.prepareStatement(sql); s<F*kLib
ps.setInt(1,xxx); <z,)4z++
ps.setString(2,xxx); ==m[t-
9x
... ^BA%]pe$I
ResultSet rs = ps.executeQuery(); // 查询 `/>kN%
int c = ps.executeUpdate(); // 更新 Dc-K08c
.5G`Y
3、处理执行结果 fF0i^E<
查询语句,返回记录集ResultSet T3zovnR
更新语句,返回数字,表示该更新影响的记录数 ]5f;Kz)
ResultSet的方法 "Bf8mEmp
1、next(),将游标往后移动一行,如果成功返回true;否则返回false OLb s~
>VA
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 rV%T+!n%c
6[A\cs
4、释放连接 Ia#!T"]@W6
cn.close(); FHr)xqo=~
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection /o;L,mcx*
js81@WX!c
可滚动、更新的记录集 I!Z`'1"
1、创建可滚动、更新的Statement 3tTOs
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ~hvj3zC5xz
该Statement取得的ResultSet就是可滚动的 ~k?rP}>0
2、创建PreparedStatement时指定参数 -| m3=#
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); JK =A=
ResultSet.absolute(9000); IHO*%3mA/
批量更新 }b(hD|e
1、Statement Th9V8Rg+E
Statement sm = cn.createStatement(); JfN5#+_i
sm.addBatch(sql1); !t23
_b0
sm.addBatch(sql2); *XhlIQ
... = ){G
sm.executeBatch() I
</P_:4G
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 imYfRi=$
2、PreparedStatement _f%s]
PreparedStatement ps = cn.preparedStatement(sql); /@ @F
nQ++
{ ^~[7])}g6
ps.setXXX(1,xxx); v zg^tJ
... Hloe7+5UD
ps.addBatch(); ^}-l["u`
} cRnDAn#42
ps.executeBatch(); larv6ncV
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 Dz~0(
-pYmM d,
事务的处理 Ea@0>_U|
1、关闭Connection的自动提交 f1_; da
cn.setAutoCommit(false);
pRobx
2、执行一系列sql语句 L K#A
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close kuH%aM<R
Statement sm ; ;]-08lzO<4
sm = cn.createStatement(insert into user...); dP8qP_77A~
sm.executeUpdate(); kT@ITA22
sm.close(); I+& T}R
sm = cn.createStatement("insert into corp...); ;\0|1Eem`
sm.executeUpdate(); '0+I' _(
sm.close(); ZwMVFC-d
3、提交 d*^JO4'
cn.commit(); !
*sXLlS
4、如果发生异常,那么回滚 ':4<[Vk
cn.rollback();