java 数据库基本操作 bFfDaO<k
1、java数据库操作基本流程 >UV=k :Q
2、几个常用的重要技巧: B\>3[_n
可滚动、更新的记录集 _9z+xl
批量更新 p8z"Jn2P
事务处理 %z["TVH
eGI&4JgJ.
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 'uLYah
1、取得数据库连接 px^brzLQo
1)用DriverManager取数据库连接 Bs<LJzS{V
例子 e!4Kl:
String className,url,uid,pwd; 1tH#QZIT
className = "oracle.jdbc.driver.OracleDriver"; W\z<p P
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; uJJP<mDgA
uid = "system"; DjiWg(X
pwd = "manager"; =fI0q7]ndz
Class.forName(className); !6*4^$i#o
Connection cn = DriverManager.getConnection(url,uid,pwd); 5pq9x4&
2)用jndi(java的命名和目录服务)方式 7zu3o
例子 O9:J
^g
String jndi = "jdbc/db"; "IoY$!Hk
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); p5bM/{DP;K
DataSource ds = (DataSource) ctx.lookup(jndi); z2SR/[I?
Connection cn = ds.getConnection(); ,.,Y{CP
多用于jsp中 V V Aw y6
2、执行sql语句 TA+/35^?
1)用Statement来执行sql语句 <}AmzeHr+
String sql; OJ}aN>k
Statement sm = cn.createStatement(); mtNB09E(
sm.executeQuery(sql); // 执行数据查询语句(select) %?z;'Y7D
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); L$}'6y/@
2)用PreparedStatement来执行sql语句 HjX)5@"o(
String sql; *
Vymb
sql = "insert into user (id,name) values (?,?)"; &-ZRS/_d>
PreparedStatement ps = cn.prepareStatement(sql); PML84*K -
ps.setInt(1,xxx); ;}AcyVV
ps.setString(2,xxx); N<|-b0#Z6
... mC EWp
ResultSet rs = ps.executeQuery(); // 查询 CdiL{zH\3
int c = ps.executeUpdate(); // 更新 21\?FQrz
)H1chNI)
3、处理执行结果 eRIdN(pP
查询语句,返回记录集ResultSet 9q"G g?
更新语句,返回数字,表示该更新影响的记录数 h>"Z=y
ResultSet的方法 cP8@'l@!
1、next(),将游标往后移动一行,如果成功返回true;否则返回false Ky'\t7p u
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 1)!]zV
GoG_4:^#h
4、释放连接 L9 H.DNA
cn.close(); _2Fa.gi
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection Xd9<`gu
W7
9.,#
可滚动、更新的记录集 Bqb3[^;~
1、创建可滚动、更新的Statement z';h5GNd>z
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); $dHD
该Statement取得的ResultSet就是可滚动的 w7_2JS
2、创建PreparedStatement时指定参数 ,9/s`o
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); +F6R@@rWr
ResultSet.absolute(9000); {>.qo<k
批量更新
XOJ@-^BX
1、Statement L&~>(/*7U
Statement sm = cn.createStatement(); r7N%onx
sm.addBatch(sql1); #>qA&*+{n
sm.addBatch(sql2); ,NQ>,}a0
... x:IY6 l
sm.executeBatch() u2Qs}FX
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 IR*:i{
2、PreparedStatement xqaw00,s
PreparedStatement ps = cn.preparedStatement(sql); hin6cac
{ p:8]jD@}%
ps.setXXX(1,xxx); kA&ul
... wGA%h.[M|
ps.addBatch(); =|bW >y
} eR5+1b
ps.executeBatch(); x8*@<]!
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 & A @!g
m{sch`bP
事务的处理 74*iF'f?c
1、关闭Connection的自动提交 Gh9dv|m=[;
cn.setAutoCommit(false); hdee]qLS
2、执行一系列sql语句 vghn+P8
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close &8 4Izs/[
Statement sm ; [{9&KjI0K
sm = cn.createStatement(insert into user...); Q@#Gm9m
sm.executeUpdate(); G3t
4$3|
sm.close(); 0B~Q.tyP
sm = cn.createStatement("insert into corp...); \{`*`WQF
sm.executeUpdate(); K?aUIkVs
sm.close(); 9:6d,^X
3、提交 *gXm&/2*
cn.commit(); 5V/CYcO
4、如果发生异常,那么回滚 bLyG3~P;0
cn.rollback();