java 数据库基本操作 qX&+
1、java数据库操作基本流程 ?23J(;)s
2、几个常用的重要技巧: -0uGzd+m*
可滚动、更新的记录集 A?tCa*b^
批量更新 6rS
? FG=
事务处理 0MT?}D&TL
,%Pn.E* r;
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 '>[ZfT
1、取得数据库连接 tzl,r"k3
1)用DriverManager取数据库连接 i K@RQi
例子 %B&O+~
String className,url,uid,pwd; .KYs5Qu
className = "oracle.jdbc.driver.OracleDriver"; pg!mOyn
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; .aL%}`8l?
uid = "system"; 0gyvRM@ x[
pwd = "manager"; D}%VZA}].
Class.forName(className); EAY+#>L*
Connection cn = DriverManager.getConnection(url,uid,pwd); Q3r]T.].h
2)用jndi(java的命名和目录服务)方式 };2Lrz9<
例子 $_%
String jndi = "jdbc/db"; n2aUj(Zs=
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); [p\xk{7Y
DataSource ds = (DataSource) ctx.lookup(jndi); p;[.&oJ
Connection cn = ds.getConnection(); H/f}tw
多用于jsp中 i Q3wi
2、执行sql语句 'bv(T2d~~
1)用Statement来执行sql语句 jKP75jm
String sql; .yzXw8~S
Statement sm = cn.createStatement(); 2!f'l'}
sm.executeQuery(sql); // 执行数据查询语句(select) B8cg[;e81
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); qPN
2)用PreparedStatement来执行sql语句 GDj_+G;tO\
String sql; ?,v@H$)3_
sql = "insert into user (id,name) values (?,?)"; X:FyNUa
PreparedStatement ps = cn.prepareStatement(sql); ;J?fK69%
ps.setInt(1,xxx); mGz'%?zj
ps.setString(2,xxx); 4YOLy\"S
... WbFCj0
ResultSet rs = ps.executeQuery(); // 查询 <q MX,h2
int c = ps.executeUpdate(); // 更新 qq^[(n
823y;
3、处理执行结果 |/-# N
查询语句,返回记录集ResultSet AED
9vDE
更新语句,返回数字,表示该更新影响的记录数 CE183l\
ResultSet的方法 bz&9]%S<
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ,0L< wa
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 :U1V 2f'l3
^wIP`dn
4、释放连接 (1,4egMpR
cn.close(); PzjIM!>
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 4/o9K*M+
54JI/!a
可滚动、更新的记录集 &=8ZGjR< }
1、创建可滚动、更新的Statement \ }-v
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Z,3CMWHg
该Statement取得的ResultSet就是可滚动的 G*v,-O
2、创建PreparedStatement时指定参数 _qit$#wK;
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); qyIy xJ
ResultSet.absolute(9000); 6{Bvl[mhI
批量更新 3,+UsB%
1、Statement .<P@6Jq
Statement sm = cn.createStatement(); (yu0iXZY
sm.addBatch(sql1); }Ny~.EV5^
sm.addBatch(sql2); +'e3YF+'
... a(U/70j
sm.executeBatch() /[3!kW
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 /Wjf"dG}
2、PreparedStatement 7")&njQ/x
PreparedStatement ps = cn.preparedStatement(sql); ^-}3+YA
{ H]lD*3b
ps.setXXX(1,xxx); GwD"j]
... L'BzefU;04
ps.addBatch(); TI'~K}Te
} {-IRX)m*
ps.executeBatch(); `Q^Vm3h
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 k/xNqN(
BW)t2kR&
事务的处理 lVb;,C%K
1、关闭Connection的自动提交 Z}O0DfT;
cn.setAutoCommit(false); v2#qs*sW8
2、执行一系列sql语句 Zfr?(y+3
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close /3vj`#jD
Statement sm ; Bsz;GnD|r
sm = cn.createStatement(insert into user...); a'@?c_y;$
sm.executeUpdate(); aG1[85:,\i
sm.close(); B415{
sm = cn.createStatement("insert into corp...); k.0pPl
sm.executeUpdate(); %8L5uMx
sm.close(); k|^nrjStC
3、提交 )ULxB'Dm
cn.commit(); wa9{Q}wSa
4、如果发生异常,那么回滚 ;/nR[sibN
cn.rollback();