java 数据库基本操作 $b(CN+#
1、java数据库操作基本流程 Q[{RNab
2、几个常用的重要技巧: l];/,J^
可滚动、更新的记录集 6n^@Ps
批量更新
RdBIbm
事务处理 u4j"U6"]M
Y>6N2&Q
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 )2a)$qx;
1、取得数据库连接 ]I_*+^?tI
1)用DriverManager取数据库连接 aW-6$=W
例子 ;y_ ]w6|n
String className,url,uid,pwd; _n1[(I
className = "oracle.jdbc.driver.OracleDriver"; 'o~gT ;T#
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; (x
fN=Te,-
uid = "system"; ``%yVVg}
pwd = "manager"; w2db=9
Class.forName(className); F1A40h7R$Y
Connection cn = DriverManager.getConnection(url,uid,pwd); !Au#j^5K-o
2)用jndi(java的命名和目录服务)方式 $<AaeyR!N
例子 Q':hmulT!
String jndi = "jdbc/db"; o7t{?|
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 5owK2
DataSource ds = (DataSource) ctx.lookup(jndi); bQ(-M:
Connection cn = ds.getConnection(); rr,w/[
多用于jsp中 \<ysJgqUG
2、执行sql语句 ^e=G} N^
1)用Statement来执行sql语句 gB~^dv {
String sql; YS_3Cq
Statement sm = cn.createStatement(); C]p@7"l
sm.executeQuery(sql); // 执行数据查询语句(select) /'VbV8%
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 0( *L)s,5
2)用PreparedStatement来执行sql语句 ;tSAQ
String sql; j+@3.^vK
sql = "insert into user (id,name) values (?,?)"; AJm$(3?/D
PreparedStatement ps = cn.prepareStatement(sql); tv26eK
38
ps.setInt(1,xxx); 1
+[sM
ps.setString(2,xxx); T7%!JBg@
... L$BV`JWPw
ResultSet rs = ps.executeQuery(); // 查询 Nte$cTjX
int c = ps.executeUpdate(); // 更新 9z..LD(
ES?*w@x
3、处理执行结果 ?w+ V:D
查询语句,返回记录集ResultSet `XpQR=IOMb
更新语句,返回数字,表示该更新影响的记录数 z$WLx
ResultSet的方法 X8">DR&>Y
1、next(),将游标往后移动一行,如果成功返回true;否则返回false u~aRFQ:
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 Qz3Z_V4k9
aL%E#
4、释放连接 4hODpIF
cn.close(); SiUu**zC
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection yOt#6Vw
Fn7OmxfD
可滚动、更新的记录集 Qn,6s%n
1、创建可滚动、更新的Statement _&/ {A|n
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); a6-.|tt#t
该Statement取得的ResultSet就是可滚动的 B0%=! &
2、创建PreparedStatement时指定参数 9h?'zyX
B
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); f:-l}Zj
ResultSet.absolute(9000); Zskj?+1
批量更新 -58q6yA
1、Statement ;0Pv49q
Statement sm = cn.createStatement(); nQoQNB
sm.addBatch(sql1); J|].h
sm.addBatch(sql2); ?*%_:fB
... (
*Xn"o
sm.executeBatch() (6Od
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 fum.G{}
2、PreparedStatement ,T`,OZm
PreparedStatement ps = cn.preparedStatement(sql); y?3.W
{ ]jFl?LA%7
ps.setXXX(1,xxx); H#DvCw
... 8'HS$J;C
ps.addBatch(); {eV8h}KIl
} `/ayg:WSU
ps.executeBatch(); uINdeq 7|F
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 0'fswa)
XS">`9o!
事务的处理 ".tL+A[
1、关闭Connection的自动提交 Ff%V1BH[
cn.setAutoCommit(false); -X~mW
2、执行一系列sql语句 dWPQp*f2
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close `r -jWK\
Statement sm ; i*Ldec^
sm = cn.createStatement(insert into user...); k%sH0 9
sm.executeUpdate(); 2h'Wu
qO
sm.close(); BUJ\[/
sm = cn.createStatement("insert into corp...); `}$o<CJ
sm.executeUpdate(); qfyZda0d
sm.close(); |7tD&9<
3、提交 =I'3C']Z W
cn.commit(); o[T+/Ej&
4、如果发生异常,那么回滚 !6T"J!F#
cn.rollback();