java 数据库基本操作 rCqwJoC`v
1、java数据库操作基本流程 'J*'{
2、几个常用的重要技巧: 7)D[ }UXz
可滚动、更新的记录集 K+/wJ9^B
批量更新 V(K;Gc
事务处理 ^vh!1"T
& +`g~6U
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 p5rq>&"
1、取得数据库连接 ,^
,R .T
1)用DriverManager取数据库连接 @P0rNO%y
例子 hB<(~L?A]
String className,url,uid,pwd; _T.`+0UV
className = "oracle.jdbc.driver.OracleDriver"; uUp>N^mmVH
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; KgYQxEbIW
uid = "system"; tol-PJS}
pwd = "manager"; DJdhOLx
Class.forName(className); Jon3ywd1Y
Connection cn = DriverManager.getConnection(url,uid,pwd); KRm)|bgE
2)用jndi(java的命名和目录服务)方式 B:i$
例子 P;XA|`&
String jndi = "jdbc/db"; '_DB0_Dp
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); x/]G"?Uix
DataSource ds = (DataSource) ctx.lookup(jndi); 1)}hzA
Connection cn = ds.getConnection(); Q>X1 :Zn3
多用于jsp中 3r^||(_u
2、执行sql语句 SsMs#C8u%
1)用Statement来执行sql语句 !}mM"|<
String sql; d+h~4'ebv
Statement sm = cn.createStatement(); !RLXB$@`
sm.executeQuery(sql); // 执行数据查询语句(select) oP7)
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close();
StNA(+rT
2)用PreparedStatement来执行sql语句 3^H-,b0^
String sql; 6e,IjocsB
sql = "insert into user (id,name) values (?,?)"; 4Af7x6a;
PreparedStatement ps = cn.prepareStatement(sql); s 64@<oU<"
ps.setInt(1,xxx); .pxUO3g
ps.setString(2,xxx); Rbgy?8#9
... Tsu\4
cL]
ResultSet rs = ps.executeQuery(); // 查询 asvM/ 9
int c = ps.executeUpdate(); // 更新 ] -C*d$z
$WW7,
3、处理执行结果 %Y.@AiViz
查询语句,返回记录集ResultSet _Nz?fJ:$@
更新语句,返回数字,表示该更新影响的记录数 F`gK6;zp
ResultSet的方法 M_$;"NS+}
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 1,P2}mYv
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 E_D@7a
9QF,ynE
4、释放连接 Qdc#v\B
cn.close(); _w <6o<@
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection N-<,wUxf
CC`#2j
可滚动、更新的记录集 >A L^y(G
1、创建可滚动、更新的Statement 0LHge7482
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); |n s9ziTDI
该Statement取得的ResultSet就是可滚动的 44B9JA7u
2、创建PreparedStatement时指定参数 1X&scVw
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); R6o07.]
ResultSet.absolute(9000); 7S_"h*Ud
批量更新 *$t =Lh
1、Statement 4kNSF
Statement sm = cn.createStatement(); y>J6)F
=
sm.addBatch(sql1); <HW2W"Go\
sm.addBatch(sql2); O~Dm|hP
... 'A/{7*,
sm.executeBatch() t<p4H^
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 kI*f}3)Y
2、PreparedStatement dlV HyCW
PreparedStatement ps = cn.preparedStatement(sql); mFC9\
{ 1[Jv9S*f/
ps.setXXX(1,xxx); >hotkMX `3
... j{%'A
ps.addBatch(); 6,p;8I
} 0)|;uW
ps.executeBatch(); Eo<N
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 U4y ?z
q+67Wc=
事务的处理 >$A, B
1、关闭Connection的自动提交 <qx qlEQT
cn.setAutoCommit(false); 4':U rJ+
2、执行一系列sql语句 OimqP
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close iS8yJRy
Statement sm ; VSc)0eyn
sm = cn.createStatement(insert into user...); Oufdi3h
sm.executeUpdate(); .|J-(J<>[.
sm.close(); S\118TpD
sm = cn.createStatement("insert into corp...); -~=:tn)0
sm.executeUpdate(); [iG4qI
sm.close(); V34]5
3、提交 Dj{t[z]$k
cn.commit(); ].*I Z
4、如果发生异常,那么回滚 McQWZ<
cn.rollback();