java 数据库基本操作 8WXQOo8
1、java数据库操作基本流程 4K\G16'$v
2、几个常用的重要技巧: 8Vr%n2M
可滚动、更新的记录集 AE[b},-[
批量更新 JRB9rSN^
事务处理 l3)}qu
oKuI0-*mR
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 pFOx>u2`a
1、取得数据库连接 0Tx6zO
1)用DriverManager取数据库连接 qLD
?juas
例子 Q'=x|K#xj
String className,url,uid,pwd; b,7k)ND1F
className = "oracle.jdbc.driver.OracleDriver"; T&6l$1J
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; |fK1/<sz#
uid = "system"; Te"ioU?.
pwd = "manager"; $a.JSXyxL
Class.forName(className); h9}+l
Connection cn = DriverManager.getConnection(url,uid,pwd); Hj^1or3R]
2)用jndi(java的命名和目录服务)方式 ]Sf]J4eQ
例子 -t!~%_WCv
String jndi = "jdbc/db"; (A9Fhun
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 0X6YdW _2X
DataSource ds = (DataSource) ctx.lookup(jndi); J')o|5S1N
Connection cn = ds.getConnection(); geru=7
多用于jsp中 LBYMCY
2、执行sql语句 m*&]!mM"0G
1)用Statement来执行sql语句 o#3ly-ht
String sql; ; ZA~p
Statement sm = cn.createStatement(); d,k!qjf=r
sm.executeQuery(sql); // 执行数据查询语句(select) T(id^ w
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); y0L_"e/
2)用PreparedStatement来执行sql语句 u^^[Q2LDU}
String sql; J,'M4O\S
sql = "insert into user (id,name) values (?,?)"; /:m->
T
PreparedStatement ps = cn.prepareStatement(sql); p|U?86t
ps.setInt(1,xxx); n]._uza
ps.setString(2,xxx); ~!B\(@GU
... Ia SR;/
ResultSet rs = ps.executeQuery(); // 查询 D+l AhEN
int c = ps.executeUpdate(); // 更新 !|S(Ms
L>jY.d2w=K
3、处理执行结果 n\mO6aJ
查询语句,返回记录集ResultSet G/)O@Ugp
更新语句,返回数字,表示该更新影响的记录数 )}Hpi<5N
ResultSet的方法 3#3n!(
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ^UP`%egR
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 0yk]o5a++
@ a! #G
4、释放连接 W=~~5jFX
cn.close(); Snj'y,p[
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection d[iQ`YW5
h79}qU
可滚动、更新的记录集 /CrSu
1、创建可滚动、更新的Statement Kg{+T`
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); x[
SDl(<@;
该Statement取得的ResultSet就是可滚动的 7`*h2 mgY
2、创建PreparedStatement时指定参数 ROH|PKb7
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); =Qy<GeY
ResultSet.absolute(9000); \j$&DCv
批量更新 q`Go`v
1、Statement C7]f*TSC4
Statement sm = cn.createStatement(); T^zXt?
sm.addBatch(sql1); S\CCrje
sm.addBatch(sql2); ?qb}?&1
... (d(CT;
sm.executeBatch() Amtq"<h9a
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 wW Lj?;bx
2、PreparedStatement u+9hL4
PreparedStatement ps = cn.preparedStatement(sql); k
R?qb6
{ y6g&Y.:o
ps.setXXX(1,xxx); >xN
.F/[K
... M[NV)q/)
ps.addBatch(); j
*
%
} 'NWfBJm
ps.executeBatch(); &h}#HS>l
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 \;,_S+Fz8
_P!m%34|
事务的处理 bL0yuAwF2
1、关闭Connection的自动提交 xVw9v6@`h
cn.setAutoCommit(false); 2R[:]-b
2、执行一系列sql语句 sU=H&D99
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close D(~U6SR
Statement sm ; %Tfbsyf%f
sm = cn.createStatement(insert into user...); ]=\].% >
sm.executeUpdate(); H%[eV8
sm.close(); C"y(5U)d
sm = cn.createStatement("insert into corp...); dn&s*
sm.executeUpdate();
{y)=eX9
sm.close(); .j ?W>F
3、提交 !Z1@}`V&;
cn.commit(); 0j^Kgx
4、如果发生异常,那么回滚 B`EJb71^Xy
cn.rollback();