java 数据库基本操作 y/Nvts2!C
1、java数据库操作基本流程 &&tQ,5H5
2、几个常用的重要技巧: R*QL6t
可滚动、更新的记录集 9}5Q5OZ
批量更新 /Bb\jvk-E
事务处理 gBresHrlH
_hXadLt
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 8)sqj=
1、取得数据库连接 *S;v406
1)用DriverManager取数据库连接 ~C[R%%Gu
例子 qA*QFQ'-
String className,url,uid,pwd; uD<*g(R
className = "oracle.jdbc.driver.OracleDriver"; [=XsI]B\
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; TCB<fS~U-
uid = "system"; & {B,m%G
pwd = "manager"; )0/DY
Class.forName(className); `<[Zs]Fe4
Connection cn = DriverManager.getConnection(url,uid,pwd); %M ~X:A;4
2)用jndi(java的命名和目录服务)方式 ,A_itRHH
例子 G;,2cu
K
String jndi = "jdbc/db"; kigc+R
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); qk<tLvD_'
DataSource ds = (DataSource) ctx.lookup(jndi); Th@L68
Connection cn = ds.getConnection(); yzXwxi1#
多用于jsp中 lK}F>6^\
2、执行sql语句 eZf-i1lJ
1)用Statement来执行sql语句 z07!i@ue~
String sql; !dmI}<@&k
Statement sm = cn.createStatement(); 1{"e'[L
sm.executeQuery(sql); // 执行数据查询语句(select) Lw-)ijBW
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); LkJ3 :3O
2)用PreparedStatement来执行sql语句 b7HS3NYk
String sql; jLcW;7OAC
sql = "insert into user (id,name) values (?,?)"; (swP#t5S
PreparedStatement ps = cn.prepareStatement(sql); 0*h\/!e
ps.setInt(1,xxx); _:=w6jCk
ps.setString(2,xxx); KLbP;:sr
... oA73\BFfP
ResultSet rs = ps.executeQuery(); // 查询 #B>Hq~ vrC
int c = ps.executeUpdate(); // 更新 7CNEP2}:R
]%G[<zD,1
3、处理执行结果 (}bP`[@rX!
查询语句,返回记录集ResultSet ]`+>{Sx 1
更新语句,返回数字,表示该更新影响的记录数 |L0 s
ResultSet的方法 $JcU0tPq0
1、next(),将游标往后移动一行,如果成功返回true;否则返回false {Uu7 @1@n
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 t?{E_70W
kvryDM
4、释放连接 %!x\|@C
cn.close(); U9kt7#@FDK
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection fz,8 <
3+Xz5>"a
可滚动、更新的记录集 H.Pts>3r(
1、创建可滚动、更新的Statement 2<U5d`
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); \@gs8K#
该Statement取得的ResultSet就是可滚动的 !)
LMn
2、创建PreparedStatement时指定参数 5a-8/.}cP
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); t3G%}d?
ResultSet.absolute(9000); v@< "b U
批量更新 ^D/*Hp _
1、Statement 5GC{)#4
Statement sm = cn.createStatement(); YAd.i@^
sm.addBatch(sql1); <A+Yo3|7
sm.addBatch(sql2); @lBR;B"
... ]vhh*
sm.executeBatch() O{LWQ"@y
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 H@'Y>^z?
2、PreparedStatement fv#e 8y
PreparedStatement ps = cn.preparedStatement(sql); dht1I`i"B
{ o^_z+JFwb
ps.setXXX(1,xxx); KJJ8P`Kx
... Ge|caiH1I
ps.addBatch(); Z#MPlw0B
} Hd6Qy {,*-
ps.executeBatch(); ]Jm9D=
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 =suj3.
_ ?=bW
事务的处理 q'{E $V)E
1、关闭Connection的自动提交 tUL(1:-C
cn.setAutoCommit(false); $wC]S4C
2、执行一系列sql语句 wGAN"K:e
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close / ijj;9EB
Statement sm ; oP_'0h0X
sm = cn.createStatement(insert into user...); e)>Z&e,3
sm.executeUpdate(); SIzW3y[
sm.close(); a&4>xZU #
sm = cn.createStatement("insert into corp...); ejD;lvf
sm.executeUpdate(); +-`Q}~s+
sm.close(); W<k) '|
3、提交 kLADd"C
cn.commit(); qDNqd
4、如果发生异常,那么回滚 KZ;U6TBiB
cn.rollback();