java 数据库基本操作 Ygk_gBRiC
1、java数据库操作基本流程 xP'0a
2、几个常用的重要技巧: VnW6$W?g
可滚动、更新的记录集 bdstxjJ`
批量更新 hQx*#:ns
事务处理 +'gO%^{l
BkB_?^Nv8
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 f> Jj5he/
1、取得数据库连接 Rs"=o>Qu
1)用DriverManager取数据库连接 6agG*x
例子 8a8a:d
String className,url,uid,pwd; 36OQHv;&
className = "oracle.jdbc.driver.OracleDriver"; SeXgBbGAne
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; 9Zl4NV&B
uid = "system"; z9IW&f~~P
pwd = "manager"; u]NsCHKlT
Class.forName(className); `{{6vb^g
Connection cn = DriverManager.getConnection(url,uid,pwd); UZs '[pm)
2)用jndi(java的命名和目录服务)方式 cJ$jU{}
例子 9*s8%pL
String jndi = "jdbc/db"; |
CFG<]
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); y%%VJ}'X!
DataSource ds = (DataSource) ctx.lookup(jndi); cy,6^d
Connection cn = ds.getConnection();
n(Nu
多用于jsp中 q]: 72+
2、执行sql语句
sG#O s
1)用Statement来执行sql语句 ?1\I/'E9
String sql; wicsf<]
Statement sm = cn.createStatement(); #Q7:Mu+
sm.executeQuery(sql); // 执行数据查询语句(select) L^t%p1R
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); .B~yI3D`M
2)用PreparedStatement来执行sql语句 B)@Xz<Q
String sql; rT4Q^t"
sql = "insert into user (id,name) values (?,?)"; aPxSC>p
PreparedStatement ps = cn.prepareStatement(sql); 9~Sa7P
ps.setInt(1,xxx); agwbjkU/
ps.setString(2,xxx); 7WmLC
... fpQFNV
ResultSet rs = ps.executeQuery(); // 查询 wT!?.Y)aj
int c = ps.executeUpdate(); // 更新 `uPO+2
E va&/o?P|
3、处理执行结果 wry`2_c
查询语句,返回记录集ResultSet m,+PYq
更新语句,返回数字,表示该更新影响的记录数 9J7yR}2-F
ResultSet的方法 5(CInl
1、next(),将游标往后移动一行,如果成功返回true;否则返回false m33&obSP
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 i5le0lM
Te}gmt+#%
4、释放连接 d>F7i~W
cn.close(); ;/+< N
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection [/hoNCH!
Ld_u Me?Z
可滚动、更新的记录集 LI}e_=E
1、创建可滚动、更新的Statement 19GF%+L
,
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); <$?#P#A
该Statement取得的ResultSet就是可滚动的 sT1OAK\^
2、创建PreparedStatement时指定参数 U3Gg:onuE
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); .CEC
g*f
ResultSet.absolute(9000); I_f%%N%
批量更新 Zex~ $r
1、Statement Pn^:cr|
Statement sm = cn.createStatement(); [p'2#Et
sm.addBatch(sql1); *%jXjTA0D
sm.addBatch(sql2); U>!TM##1QD
... k8ILo)
sm.executeBatch() aoW2 c1`?Z
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 3"Oipt+
2、PreparedStatement STu(I\9
PreparedStatement ps = cn.preparedStatement(sql); JzywSQ
{ 1d49&-N
ps.setXXX(1,xxx); <FkaH8,7
... n5~Dxk
ps.addBatch(); aO1.9!<v
} 8HLL3H0
ps.executeBatch(); T$MXsq
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 OcF_x/#
|g{50r'=
事务的处理 J ##a;6@
1、关闭Connection的自动提交 Yl au
cn.setAutoCommit(false); W<&/5s
2、执行一系列sql语句 5KB Z-,
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close nWCJY:q;5
Statement sm ; n+=7u[AZi
sm = cn.createStatement(insert into user...); th*!EFA^o
sm.executeUpdate(); <k1muSe
sm.close();
'uz o[>p
sm = cn.createStatement("insert into corp...); R $<{"b
sm.executeUpdate(); !2AD/dtt
sm.close(); ;ja~Q .}4
3、提交 oD2! [&
cn.commit(); ?XVE{N
4、如果发生异常,那么回滚 bh8GP]*E|
cn.rollback();