java 数据库基本操作 Z$!>hiz2
1、java数据库操作基本流程 `tA~"J$32l
2、几个常用的重要技巧: K] ;`
可滚动、更新的记录集 j`jF{k b
批量更新 !4-B
xeNY\
事务处理 #4S">u
z%cq%P8g
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 O8:$sei$
1、取得数据库连接 [kwVxaI
1)用DriverManager取数据库连接 ,!+>/RlJ
例子 -w
nlJi1f
String className,url,uid,pwd; v`3q0,,
className = "oracle.jdbc.driver.OracleDriver"; %^){Z,}M}
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ufF$7@(+
uid = "system"; OZ 4uk.)
pwd = "manager"; xG sg'
Class.forName(className); X,VOKj.%
Connection cn = DriverManager.getConnection(url,uid,pwd); '>dsROB->
2)用jndi(java的命名和目录服务)方式 3vRRL
例子 g]au|$L4
String jndi = "jdbc/db"; P 1`X<A
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); z5G<h
DataSource ds = (DataSource) ctx.lookup(jndi); <)n8lIK
Connection cn = ds.getConnection(); #\9sCnb
多用于jsp中 #T<<{ RA
2、执行sql语句 S1oRMd)r
1)用Statement来执行sql语句 sLiKcR8^
String sql; ',GWH:B
Statement sm = cn.createStatement(); Z)E[Bv=
sm.executeQuery(sql); // 执行数据查询语句(select) UjLZ!-}
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 2{^k*Cfd
2)用PreparedStatement来执行sql语句 d]Y-^&]{]
String sql; 5bU[uT,`6
sql = "insert into user (id,name) values (?,?)"; *L_ +rJj,
PreparedStatement ps = cn.prepareStatement(sql); Pd-0u>k
ps.setInt(1,xxx); W,&z:z>
ps.setString(2,xxx); 0<f\bY02
... v+XB$j^H
ResultSet rs = ps.executeQuery(); // 查询 H]e%8w))0
int c = ps.executeUpdate(); // 更新 vg@kPuOiO
uNnx
i
3、处理执行结果 W*A-CkrO
查询语句,返回记录集ResultSet DyeV
uB
更新语句,返回数字,表示该更新影响的记录数 =7%1]
ResultSet的方法 xb/L AlJ
1、next(),将游标往后移动一行,如果成功返回true;否则返回false E__^>=
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 UeNa
7hAFK
4、释放连接 #wz1uw[pI!
cn.close(); YC!Tgb~H
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection lGHU{7j\
yt,xA;g
可滚动、更新的记录集 Fy1@B(V%
1、创建可滚动、更新的Statement L"|4
v
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); xEv]VL:
该Statement取得的ResultSet就是可滚动的 ?kBi9^)N4
2、创建PreparedStatement时指定参数 AQX~do\A
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); Y r3h=XY
ResultSet.absolute(9000); CZ&VP%
批量更新 xj6ht/qq
1、Statement ybWb'+x
Statement sm = cn.createStatement(); Vgy}0pCl
sm.addBatch(sql1); E-Z6qZ^
sm.addBatch(sql2); xWkCP2$?P
... >E*j4gg
sm.executeBatch() JkT, i_
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 T)%34gN
2、PreparedStatement 9
Yv;Dom
PreparedStatement ps = cn.preparedStatement(sql); uJ:'<dJ
{ @C[]o.r
ps.setXXX(1,xxx); OcR6\t'
...
r!Ujy .R
ps.addBatch(); D0T0Km/"
} 76e%&ZG)Q
ps.executeBatch(); ZJUTti D
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 3GMRH;/w
Ejc%DSG
事务的处理 h<KE)^).
1、关闭Connection的自动提交 U)IW6)q
cn.setAutoCommit(false); 9+'QH
2、执行一系列sql语句 l :sZ
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close Z}#,E;
Statement sm ; Q-<,+[/
sm = cn.createStatement(insert into user...); s)_Xj`Q#
sm.executeUpdate(); V}?d
,.m`{
sm.close(); {Rc!S? 8
sm = cn.createStatement("insert into corp...); Y@)iPK@z
sm.executeUpdate(); _`6fGu& W
sm.close(); *}BaO*A
3、提交 MUo}Qi0K
cn.commit(); Z";~]]$!Y
4、如果发生异常,那么回滚 e[txJ*SuO
cn.rollback();