java 数据库基本操作 X7b!;%3@
1、java数据库操作基本流程 3wo'jOb
2、几个常用的重要技巧: )tCx5 9
可滚动、更新的记录集 ,A?{~?u.
批量更新 @x*.5:[
事务处理 EFD?di)s
_}^u-fJ/~
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 S,VyUe4P4
1、取得数据库连接 |lY`9-M`I
1)用DriverManager取数据库连接 "H@Fe
例子 A`g.[7
String className,url,uid,pwd; -FaaFw:Z;A
className = "oracle.jdbc.driver.OracleDriver"; cX Ma\#P
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; <oQ6 Z X
uid = "system"; !x6IV25
pwd = "manager"; Wy!uRzbBv
Class.forName(className); lZBv\JE
Connection cn = DriverManager.getConnection(url,uid,pwd); Gg}t-_M
2)用jndi(java的命名和目录服务)方式 c{ 7<H
例子 !;jgzi?z
String jndi = "jdbc/db"; \:h0w;34O
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); Eh:yRJ_8
DataSource ds = (DataSource) ctx.lookup(jndi); :Nkz,R?
Connection cn = ds.getConnection(); &D^e<j}RQ
多用于jsp中 dt0T t
2、执行sql语句 +~:x}QwGT
1)用Statement来执行sql语句 n}f3Vrl
String sql; j+ I*Xw
Statement sm = cn.createStatement(); -&$%|cyThQ
sm.executeQuery(sql); // 执行数据查询语句(select) 51z /
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 3#B@83C0Z
2)用PreparedStatement来执行sql语句 fH; |Rm
String sql; t={po QC~
sql = "insert into user (id,name) values (?,?)"; +<z7ds{Z
PreparedStatement ps = cn.prepareStatement(sql); fs7~NY
ps.setInt(1,xxx); pRb<wt7v
ps.setString(2,xxx); }&C dsCM>2
... ?S8$5gA
ResultSet rs = ps.executeQuery(); // 查询 A_aO}oBX
int c = ps.executeUpdate(); // 更新 fG3wc
l~
PMQb\%iE"
3、处理执行结果 G%Y*q(VrEu
查询语句,返回记录集ResultSet
\_?yzgf
更新语句,返回数字,表示该更新影响的记录数 pTN%;`)
{
ResultSet的方法 xS-w\vbLV
1、next(),将游标往后移动一行,如果成功返回true;否则返回false b#e]1Q
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 @PKAz&0
\6U 2-m'
4、释放连接 1T:)Zv'
cn.close(); ?l(nM+[kSL
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection z"9aAytd
r.?qEe8VV
可滚动、更新的记录集 GsI[N%
1、创建可滚动、更新的Statement . c#90RP
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Oxpo6G
该Statement取得的ResultSet就是可滚动的 58 kv#;j
2、创建PreparedStatement时指定参数 4a#B!xW
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); A (PE
ResultSet.absolute(9000); n&(3o6i'
批量更新 0=2H9v
1、Statement IcRM4Ib))Q
Statement sm = cn.createStatement(); 87R%ke
sm.addBatch(sql1); e#K rgUG
sm.addBatch(sql2); x-tm[x@;o
... u6]gQP">I
sm.executeBatch() N!]PIWnC
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ,nI_8r"M>
2、PreparedStatement $3lt{ %
PreparedStatement ps = cn.preparedStatement(sql); <1TlW
~q<
{ !,I7 ?O
ps.setXXX(1,xxx); u<x[5xH+
... j)<;g(
ps.addBatch(); Oib[\O7[z
} |{zHM2 3gD
ps.executeBatch(); 5aa}FdUq
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 (\T8!s{AO
@T9m}+fR
事务的处理 A{G5Plrh
1、关闭Connection的自动提交 O 0Vn";Q 4
cn.setAutoCommit(false); )j]gm i"
2、执行一系列sql语句 V|+ `L-
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close F|DR
Statement sm ; Z3OZPxm
sm = cn.createStatement(insert into user...); )r-T=
sm.executeUpdate(); *xEI
Zx
sm.close(); zuK/(qZ
sm = cn.createStatement("insert into corp...); z]'|nX
sm.executeUpdate(); -$'~;O3s
sm.close(); USlF+RY@3L
3、提交 B?$S~5
}
cn.commit(); U+(Z#b(Q
4、如果发生异常,那么回滚 (N)r#"FV
cn.rollback();