java 数据库基本操作 c@9jc^CJ
1、java数据库操作基本流程 PhBdm'
2、几个常用的重要技巧: 7L~LpB
可滚动、更新的记录集 NX7(;02
批量更新 lg` Qi&
事务处理 >;V ?s]
#U45H.Rz
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 @V{s'V
1、取得数据库连接
Td tn-
1)用DriverManager取数据库连接 Y@x }b{3
例子 HDqPqrWm
String className,url,uid,pwd; fFP>$
className = "oracle.jdbc.driver.OracleDriver"; T \%{zz_(
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; s`"o-w\$>
uid = "system"; [DrG;k ?
pwd = "manager"; Ei!t#'*D<
Class.forName(className); vzD3_
?D
Connection cn = DriverManager.getConnection(url,uid,pwd); Q`mw2$zv
2)用jndi(java的命名和目录服务)方式 3C'`c=
例子 /3|uU
String jndi = "jdbc/db"; wq&|V
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); [pMJ9
d$
DataSource ds = (DataSource) ctx.lookup(jndi); xbJ@ z{
Connection cn = ds.getConnection(); Wy^43g38'p
多用于jsp中 w5*?P4P
2、执行sql语句 P<P4*cOV
1)用Statement来执行sql语句 )zw}+z3st
String sql; B.w ihJVDg
Statement sm = cn.createStatement(); ]~S,K}T
sm.executeQuery(sql); // 执行数据查询语句(select) }p-<+sFo
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); Mda~@)7$
2)用PreparedStatement来执行sql语句 MQ;c'?!5[!
String sql; +C3IP
sql = "insert into user (id,name) values (?,?)"; VB6EM|bphl
PreparedStatement ps = cn.prepareStatement(sql); `:WVp~fn
ps.setInt(1,xxx); n{vp&
ps.setString(2,xxx); 3/a$oO
... Co6ghH7T
ResultSet rs = ps.executeQuery(); // 查询 weQC9e~d{-
int c = ps.executeUpdate(); // 更新 I)$` @.
e ='bc7$
3、处理执行结果 lK;/97Ze
查询语句,返回记录集ResultSet V[D[MZ
更新语句,返回数字,表示该更新影响的记录数 BM bT:)%
ResultSet的方法 dhl[JC~ _
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 4k'2FkDA
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 hgCF!eud
tBEZ4 W>67
4、释放连接 zrfE'C8O
cn.close(); ' k~'aZ
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 0{|ib !
?^iX%
可滚动、更新的记录集 Jej P91
1、创建可滚动、更新的Statement 5`m RrEA
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); z_fR?~$N2
该Statement取得的ResultSet就是可滚动的 2w`k h=
2、创建PreparedStatement时指定参数 v~-z["=}!
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); bA]/p%rZ8
ResultSet.absolute(9000); 4u5^I;4pL
批量更新 :ie7HF
1、Statement C D#:*
Statement sm = cn.createStatement(); Y9F78=Q
sm.addBatch(sql1); SI_{%~k*B
sm.addBatch(sql2); M$O}roOa
... c-nBB
sm.executeBatch() Hbogi1!al|
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 I!bzvPJ]xc
2、PreparedStatement AHsp:0Ma#
PreparedStatement ps = cn.preparedStatement(sql); xLht6%o*
{ 'A91i
ps.setXXX(1,xxx); 3UeG>5R
... jJ%
*hDZ6t
ps.addBatch(); f(q^R
} <p<jXwl
ps.executeBatch(); ,ry2J,IT7
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 .S/W_R
:b+C<Bp64r
事务的处理 6hKavzSi
1、关闭Connection的自动提交 M ,.++W\
cn.setAutoCommit(false); (:3rANY|
2、执行一系列sql语句 ;c73:'e
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close K~$o2a
e
Statement sm ; n y6-_mA]
sm = cn.createStatement(insert into user...); E"k\eZns&
sm.executeUpdate(); @DK,ka(
sm.close(); Nt42v
sm = cn.createStatement("insert into corp...); cWIX!tc8
sm.executeUpdate(); 'qBg^c
sm.close(); Q7]:vs)%
3、提交 ,X6.p
cn.commit(); jYKs| J)[
4、如果发生异常,那么回滚 Y604peUF
cn.rollback();