java 数据库基本操作 ^V v7u@y
1、java数据库操作基本流程 ROr$S z
2、几个常用的重要技巧: ^-P lTmT
可滚动、更新的记录集 @DfjeS)u^
批量更新 or\
2)
事务处理 &fq-U5zH
dx}()i\@
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 Fkj\U^G
1、取得数据库连接 +bI &0`
1)用DriverManager取数据库连接 $@+\_f'bU>
例子 4VSIE"8e
String className,url,uid,pwd; VR2BdfKU,
className = "oracle.jdbc.driver.OracleDriver"; +w:[By"
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; wqyx{W`~w
uid = "system"; 0@{K'm/
pwd = "manager"; )!hDF9O
Class.forName(className); UL$^zR3%d
Connection cn = DriverManager.getConnection(url,uid,pwd); BgJ;\NV
2)用jndi(java的命名和目录服务)方式 Sm;&2"
例子 yPn5l/pDDr
String jndi = "jdbc/db"; ~<Uwumv
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); =G;whd}]
DataSource ds = (DataSource) ctx.lookup(jndi); e(x1w&8dB
Connection cn = ds.getConnection(); cG6Q$
多用于jsp中 9s6, &'
2、执行sql语句 nsij;C
1)用Statement来执行sql语句 1Jc-hrN-
String sql; }&d]Uv/4
Statement sm = cn.createStatement(); ,'m<um
sm.executeQuery(sql); // 执行数据查询语句(select) 0!o&=Qh
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); L{N9h1]
2)用PreparedStatement来执行sql语句 =et=X_3-
String sql; f8L
sql = "insert into user (id,name) values (?,?)"; 0^*4LM|z
PreparedStatement ps = cn.prepareStatement(sql); iW+ZI6@
ps.setInt(1,xxx); B-|:l7
ps.setString(2,xxx); > YKvwbCf8
... '{QbjG%<P
ResultSet rs = ps.executeQuery(); // 查询 }N:0%Gk[;
int c = ps.executeUpdate(); // 更新 E).Nu
V9I5/~0c
3、处理执行结果 [m?eSq6e2b
查询语句,返回记录集ResultSet ^,
q\S
更新语句,返回数字,表示该更新影响的记录数 D@!`b6
ResultSet的方法 lE`hC#m
1、next(),将游标往后移动一行,如果成功返回true;否则返回false zIf/j k
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 i*#Gq6qZq
NjMbQM4
4、释放连接 29z+<?K{
cn.close(); .8uJ%'$)
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection rg"W1m[k
_S{HVc
可滚动、更新的记录集 pjvChl5
1、创建可滚动、更新的Statement dMCV
!$
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); l6:k|hrm;
该Statement取得的ResultSet就是可滚动的 &7,Kv0j}
2、创建PreparedStatement时指定参数 ^j[>.D
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); U2$e?1y
ResultSet.absolute(9000); E[/<AY^@!z
批量更新 k+5:fB)z
1、Statement J)oa:Q
Statement sm = cn.createStatement(); eA$9)K1GO
sm.addBatch(sql1); s+2\uMwf*
sm.addBatch(sql2); 3cBuqQ
... Z=|:D,&
sm.executeBatch() 7h<B:~(K
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 m@;X%wf<U
2、PreparedStatement >7!4o9)c
PreparedStatement ps = cn.preparedStatement(sql); P+:FiVj@~
{ pR4{}=g,
ps.setXXX(1,xxx); R{NmWj['Mg
... k`62&"T
ps.addBatch(); <8|vj2d2
} ?y>xC|kt
ps.executeBatch(); Gn<s>3E
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 W(E!:
<:-|>R".
事务的处理 ;E l"dqH
1、关闭Connection的自动提交 \S[:
cn.setAutoCommit(false); rtS(iD@B"
2、执行一系列sql语句 -_[n2\|we)
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close rV<yM$IA
Statement sm ; CN#`m]l.
sm = cn.createStatement(insert into user...); '!]ry<
sm.executeUpdate(); bLUn>ch
sm.close(); ,DqI> vx|
sm = cn.createStatement("insert into corp...); A7>0Pn%D3
sm.executeUpdate(); t/yGMR=
sm.close(); k?0yH$)'t
3、提交 'uGn1|Pvy
cn.commit(); ZMids"Xdf
4、如果发生异常,那么回滚 NC)I u
cn.rollback();