java 数据库基本操作 }B9~X
1、java数据库操作基本流程 MjXE|3&
2、几个常用的重要技巧: hN_f h J
可滚动、更新的记录集 Am4^v?q
批量更新 W6Aj<{\F
事务处理 6;[/9
1S(\2{Ylo
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 7Cd_zZ
1、取得数据库连接 X:``{!~geo
1)用DriverManager取数据库连接 u|OzW}xb7j
例子 >g>`!Sf
String className,url,uid,pwd; =GKS;d#/
className = "oracle.jdbc.driver.OracleDriver"; MYw8wwX0kJ
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; 0+<eRR9-
uid = "system"; 4o4 =
pwd = "manager"; 4`U0">gY
Class.forName(className); 24jtJC,7
Connection cn = DriverManager.getConnection(url,uid,pwd); xBRh!w
2)用jndi(java的命名和目录服务)方式 ey\m)6A$
例子 A6NxM8ybn+
String jndi = "jdbc/db"; Ed^uA+D
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); {s8U7rmML
DataSource ds = (DataSource) ctx.lookup(jndi); << ;HY}s
Connection cn = ds.getConnection(); 7{An@hNh
多用于jsp中 LZc$:<J<6
2、执行sql语句 Yb%-tv:
1)用Statement来执行sql语句 .-KtB(t
String sql; ]KXMGH_
Statement sm = cn.createStatement(); S'!q}|7X3
sm.executeQuery(sql); // 执行数据查询语句(select) =%3b@}%HqS
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); `e $n$Bh
2)用PreparedStatement来执行sql语句 ![@T iM
String sql; 45+%K@@x
sql = "insert into user (id,name) values (?,?)"; 2\nN4WL
5.
PreparedStatement ps = cn.prepareStatement(sql); \/*Nf?;
ps.setInt(1,xxx); Wyq~:vU.S
ps.setString(2,xxx); _}e7L7B7g
... fzS`dL5,W
ResultSet rs = ps.executeQuery(); // 查询 mGe|8In
int c = ps.executeUpdate(); // 更新 @1qdd~B}
9:%n=U Rd
3、处理执行结果 n|x$vgb
查询语句,返回记录集ResultSet AUxM)H
更新语句,返回数字,表示该更新影响的记录数 (/SGT$#8
ResultSet的方法 i>Fvmw
1、next(),将游标往后移动一行,如果成功返回true;否则返回false P1i*u0a
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ^}o7*
*!g 24
4、释放连接 ;Rhb@]X
cn.close(); ms}f>f=
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection @GG(7r\/B
V \6(d
可滚动、更新的记录集 y7JZKtsFA
1、创建可滚动、更新的Statement ?Ml%$z@b?
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ^Ue0mC7m
该Statement取得的ResultSet就是可滚动的 H\fcY p6
2、创建PreparedStatement时指定参数 Sk/#J!T8{
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); U~*c#U"bh
ResultSet.absolute(9000); iUI y,Y
批量更新 pd4cg?K
1、Statement g@@&sB-A"
Statement sm = cn.createStatement(); 6P~aW
sm.addBatch(sql1); gwSN>oj
&
sm.addBatch(sql2); /Fv/oY
... J ;UBnCg
sm.executeBatch() q]6_rY.
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 I#U>5"%\a
2、PreparedStatement [dj5$l|
PreparedStatement ps = cn.preparedStatement(sql); u R\m`
{ rQ
ps.setXXX(1,xxx); %M{k.FE(
... OE'K5oIM
ps.addBatch(); }xDB ~k
} ~{kM5:-iw
ps.executeBatch(); A3AP51
!
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 M o}H_8y
T&r +G!2
事务的处理 .3VK;au\\
1、关闭Connection的自动提交 #>8T*B
cn.setAutoCommit(false); e,f ;
2、执行一系列sql语句 PSTu /^
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close t`"^7YFS>
Statement sm ; iOT)0@f'
sm = cn.createStatement(insert into user...); =-$!:W~
sm.executeUpdate(); ^
<qrM
sm.close(); CQdBf3q
sm = cn.createStatement("insert into corp...); E'5Ajtw;
sm.executeUpdate(); UvkJ?Bu
sm.close(); *Ph]F$ZP
3、提交 dG&2,n'f
cn.commit(); aje^Z=]
4、如果发生异常,那么回滚 -uWKY6
:5
cn.rollback();