java 数据库基本操作 LnKgT1
1、java数据库操作基本流程 (z.n9lkfi
2、几个常用的重要技巧: /}J_2
可滚动、更新的记录集 0[M2LF!m
批量更新 ?Z_T3/ f
事务处理 1G.?Y3DC<
F'sX ^/;
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 l2:-).7xt
1、取得数据库连接 Dr(2@0P
1)用DriverManager取数据库连接 vd(S&&]o1
例子 [7d(PEQL`
String className,url,uid,pwd; ]z5hTY
className = "oracle.jdbc.driver.OracleDriver"; !LM`2|3$
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ]1XtV<
uid = "system"; X7AxI\h
pwd = "manager"; c61OT@dZEA
Class.forName(className); 7s3=Fa:9Q
Connection cn = DriverManager.getConnection(url,uid,pwd); '|Bk}pl7
2)用jndi(java的命名和目录服务)方式 p
JT)X8K"
例子 /9&!u )+
String jndi = "jdbc/db"; Du65>O
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); {9-9!jN{"
DataSource ds = (DataSource) ctx.lookup(jndi); O39
Connection cn = ds.getConnection(); 'W4B
多用于jsp中 4v |i\V>M
2、执行sql语句 M2p|&Z%
1)用Statement来执行sql语句 <5}I6R;
String sql; Hg<aU*o;
Statement sm = cn.createStatement(); 7M7Lj0Y)L
sm.executeQuery(sql); // 执行数据查询语句(select)
6?*Do
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); )B"{B1(
2)用PreparedStatement来执行sql语句 y<j7iN
String sql; J`)/\9'&&
sql = "insert into user (id,name) values (?,?)"; M!5=3>Z
PreparedStatement ps = cn.prepareStatement(sql); 0C>_aj
ps.setInt(1,xxx); M>Tg$^lm
ps.setString(2,xxx);
]&"ii
... D
(8Z90
ResultSet rs = ps.executeQuery(); // 查询 a>W++8t1 ;
int c = ps.executeUpdate(); // 更新 @s
cn ?t
fdX|t"oz
3、处理执行结果 6E
K <9M
查询语句,返回记录集ResultSet &V$cwB
更新语句,返回数字,表示该更新影响的记录数 q4w]9b/
ResultSet的方法 u&uFXOc'
1、next(),将游标往后移动一行,如果成功返回true;否则返回false Zv!XNc!"$y
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 2 G2+oS
?
H`fJ<So?
4、释放连接 /CO=!*7fz
cn.close(); pTG[F
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection mj e9i
2(0%{*m
可滚动、更新的记录集 6q8}8;STTY
1、创建可滚动、更新的Statement Um\HX6
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ut\X{.r7
该Statement取得的ResultSet就是可滚动的 zJW2F_
2、创建PreparedStatement时指定参数 4)D~S4{E5
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); /7\q#qIm:
ResultSet.absolute(9000); =E]tEi
批量更新 o*/;Zp==
1、Statement Z\`SDC
Statement sm = cn.createStatement(); xtD(tiqh.;
sm.addBatch(sql1); G .<0^q,
sm.addBatch(sql2); og35Vs0
... BRM `/s
sm.executeBatch() kN1R8| pv
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ,LxZbo!
2、PreparedStatement Dt[+HCCY:
PreparedStatement ps = cn.preparedStatement(sql); 48^C+#Jbc
{ [ !#Dba#
ps.setXXX(1,xxx); )uOtQ0
... %V]v,
ps.addBatch(); \9OKf|#j
} =,;$d*h
ps.executeBatch(); -r<8mL:yW
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 Hy\q{
z-kv{y*Hu
事务的处理 X)hpbHa
1、关闭Connection的自动提交 yH-&o,
cn.setAutoCommit(false); |wv+g0]Pg^
2、执行一系列sql语句 )e'F[
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close WvT H+
Statement sm ; DFQ`(1Q
sm = cn.createStatement(insert into user...); b3[[ Ah-
sm.executeUpdate(); *5oQZ".vA*
sm.close(); \8<[P(!3
sm = cn.createStatement("insert into corp...); q?mpvpLG
sm.executeUpdate(); 2;>uP#1]
sm.close(); dtY8>klI
3、提交 8g)$%Fy+N
cn.commit(); CQ. C{
4、如果发生异常,那么回滚 M0lJyzJ
cn.rollback();