java 数据库基本操作 u~\u8X3
1、java数据库操作基本流程 ;wIpch e
2、几个常用的重要技巧: ozF>2`K
}
可滚动、更新的记录集
2&O!<C j
批量更新 &a% |L=FY
事务处理 xSZgQF~
1+RG@Cp
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 LY[XPV]t
1、取得数据库连接 4df)?/
1)用DriverManager取数据库连接 =vMFCp;mv
例子 EAU6z(X$
String className,url,uid,pwd; 7y:%^sl
className = "oracle.jdbc.driver.OracleDriver"; [f}YXQ0N)
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; mOr>*uR
uid = "system"; W~E%Eq3
pwd = "manager"; VS<E?JnbFV
Class.forName(className); [s$vY~_
Connection cn = DriverManager.getConnection(url,uid,pwd); q'77BRD3
2)用jndi(java的命名和目录服务)方式 k/YEUC5
例子 ~;k-/Z"
String jndi = "jdbc/db"; 7udMF3;>
Context ctx = (Context) new InitialContext().lookup("java:comp/env");
yTwv2l;U
DataSource ds = (DataSource) ctx.lookup(jndi); r7/y'Y]O
Connection cn = ds.getConnection();
@dQIl#
多用于jsp中 I.TdYSB
2、执行sql语句 >4`("#
1)用Statement来执行sql语句 XtVx
H4q
String sql; l=U@j
T
Statement sm = cn.createStatement(); Enn7p9&
sm.executeQuery(sql); // 执行数据查询语句(select) [!p>Id
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); -?`^^v
2)用PreparedStatement来执行sql语句 = ;#?CAa:
String sql; 6Y0k}+j|>E
sql = "insert into user (id,name) values (?,?)"; SuU,SE'TX
PreparedStatement ps = cn.prepareStatement(sql); n=l>d#}$%T
ps.setInt(1,xxx); .ml24SeC
ps.setString(2,xxx); %N_5p'W
... DcA{E8Y
ResultSet rs = ps.executeQuery(); // 查询 *,X;4?:,
int c = ps.executeUpdate(); // 更新 jIwz
G+)$P
}YWLXxb;
3、处理执行结果 ?Z=
%I$i
查询语句,返回记录集ResultSet ,\q9>cZ!
更新语句,返回数字,表示该更新影响的记录数 7{=/rbZT?
ResultSet的方法 FjqoO.
1、next(),将游标往后移动一行,如果成功返回true;否则返回false yjlX@YXnw
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 \\XvVi:B
ra=U,
4、释放连接 -iWt~
cn.close(); z^+f3-Z
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection oBiJiPE=`
`"zXf -qeE
可滚动、更新的记录集 GZ,`?
1、创建可滚动、更新的Statement m(SGE,("w
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ol7%$:S
该Statement取得的ResultSet就是可滚动的 T Z{';oU
2、创建PreparedStatement时指定参数 0(A`Ia
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); }Tf~)x
ResultSet.absolute(9000); A@xa$!4}
批量更新 ;`',M6g
1、Statement F7lhLly
Statement sm = cn.createStatement(); SYd4 3PA
sm.addBatch(sql1); "s[wLclfG
sm.addBatch(sql2); 8)HUo?/3
... Bee`Pp2
sm.executeBatch() gKoB)n<[
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 O4J <u-E$
2、PreparedStatement [E<NEl*
PreparedStatement ps = cn.preparedStatement(sql); m/uBM6SXx
{ >J!4x(;Yh
ps.setXXX(1,xxx); 7p*PDoM6`
... .1<QB{4~v
ps.addBatch(); P}hHx<L
} t=o2:p6&
ps.executeBatch(); l
Os91+.%
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 / r6^]grg
#&<>|m
事务的处理 <y[LdB/a
1、关闭Connection的自动提交 4\
R2\
cn.setAutoCommit(false); z5`AJrj%
2、执行一系列sql语句 *Z'*^Y1le
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close V
.+ mK|)
Statement sm ; =REMSej
sm = cn.createStatement(insert into user...); x9Um4!/t
sm.executeUpdate(); tb36c<U-
sm.close(); t4(Z@X$
sm = cn.createStatement("insert into corp...); +*&bgGhT
sm.executeUpdate(); a!rU+hiC
sm.close(); __N<
B5E
3、提交 VbX+`CwH
cn.commit(); 2GeJ\1k
4、如果发生异常,那么回滚 art
L
cn.rollback();