java 数据库基本操作 r)gK5Mv
1、java数据库操作基本流程 336ETrG^0
2、几个常用的重要技巧: ;a?<7LIx
可滚动、更新的记录集 =AO
(
批量更新 C+'-TLeu
事务处理 (?l ]}p^[
>5t!
Xt
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ;O7"!\
1、取得数据库连接 (xG%H:6,
1)用DriverManager取数据库连接 n$2oM5<
例子 BWxfY^,'&6
String className,url,uid,pwd; T+L=GnYl
className = "oracle.jdbc.driver.OracleDriver"; WVR/0l&bU
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; Q\4tzb]
uid = "system"; K/zb6=->
pwd = "manager"; yBy7d!@2
Class.forName(className); E_~e/y"-
Connection cn = DriverManager.getConnection(url,uid,pwd); ]EHsRd
2)用jndi(java的命名和目录服务)方式 0J+WCm`
例子 yP7b))AW9
String jndi = "jdbc/db"; 2-@)'6"n
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); Movm1*&=
DataSource ds = (DataSource) ctx.lookup(jndi); *IOrv)
Connection cn = ds.getConnection(); c>$d!IKCL
多用于jsp中 x\'3UKQP+^
2、执行sql语句 ,f^fr&6jb
1)用Statement来执行sql语句 Gy\]j
String sql; +(=-95qZ
Statement sm = cn.createStatement(); n{N0S^h
sm.executeQuery(sql); // 执行数据查询语句(select) PPl o0R
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); no8\Oees
2)用PreparedStatement来执行sql语句 4^r6RS@z
String sql; 9}QIqH\p
sql = "insert into user (id,name) values (?,?)"; _]@u)$
PreparedStatement ps = cn.prepareStatement(sql); vu)EB!%[
ps.setInt(1,xxx); E"'u2jEG^
ps.setString(2,xxx); GZi`jp
... oh-EEo4,
ResultSet rs = ps.executeQuery(); // 查询 6hj[/O)E
int c = ps.executeUpdate(); // 更新 d:hnb)I$*
__eB 7]#E
3、处理执行结果 (W#CDw<ja
查询语句,返回记录集ResultSet G2N0'R"
更新语句,返回数字,表示该更新影响的记录数 )Wle
CS_
ResultSet的方法 ^.:&ZsqV
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 8Ygf@*9L4
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 Ye]K 74M.
?5CE<[
4、释放连接 d;<'28A
cn.close(); =COQv= GT
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 1n<4yfJ
gbYM1guiD
可滚动、更新的记录集 eyh}O
1、创建可滚动、更新的Statement l 7uTk5
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); adu6`2*$
该Statement取得的ResultSet就是可滚动的 x"sbm
2、创建PreparedStatement时指定参数 p>eYi \'
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 8x-19#
ResultSet.absolute(9000); @?e~l:g})g
批量更新 qqo#H O
1、Statement ^;ZpK@Luk
Statement sm = cn.createStatement(); ]d[e
sm.addBatch(sql1); [>mH
sm.addBatch(sql2); |J4sQ!%K
... |=ph&9
sm.executeBatch() Z$INmo6
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 Wu*
4r0
2、PreparedStatement vE,^K6q0`
PreparedStatement ps = cn.preparedStatement(sql); i7-i!`<
{ DN)o|p
ps.setXXX(1,xxx); 31c*^ZE.
... e`b#,=
ps.addBatch(); ~IW{^u
} G\F>*
ps.executeBatch(); 66F?exr
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 U!-Nx9
Dq~;h \='
事务的处理 ~Z/,o)
1、关闭Connection的自动提交 9MfU{4:;I
cn.setAutoCommit(false); Z6${nUX
2、执行一系列sql语句 >Y8\f:KQ
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close fWq*Op.]c
Statement sm ; hZHM5J~
sm = cn.createStatement(insert into user...); (o IGp
sm.executeUpdate(); XEA5A.uc
sm.close(); 04dz?`HuB
sm = cn.createStatement("insert into corp...); -O\i^?lD;
sm.executeUpdate(); w -o#=R_
sm.close(); #at`7#K@
3、提交 ?[Y(JO#
cn.commit(); Q*T'tkp
4、如果发生异常,那么回滚 cg3}33Z;6
cn.rollback();