java 数据库基本操作 s7}
)4.vO
1、java数据库操作基本流程 6Ymk8.PF
2、几个常用的重要技巧: p'} %pAY
可滚动、更新的记录集 #7ZBbq3=
批量更新 Sxu
v}y\
事务处理 dS=,. }
Oh4WYDyT
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 =ApT#*D)o
1、取得数据库连接 :|3C-+[
1)用DriverManager取数据库连接 e'&{KD,-T
例子 )yZE>>3-
String className,url,uid,pwd; BZshTP[`
className = "oracle.jdbc.driver.OracleDriver"; ]#.# ]}=
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; .utL/1Ej
uid = "system"; { rn~D5R
pwd = "manager"; oP
0j>i,"&
Class.forName(className); ,[#f}|s_
Connection cn = DriverManager.getConnection(url,uid,pwd); 7HFO-r118
2)用jndi(java的命名和目录服务)方式 gMn)<u >
例子 B ;$8<
String jndi = "jdbc/db"; \YS\*'F
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); Z Uv_u6aD
DataSource ds = (DataSource) ctx.lookup(jndi); =^v Ub
Connection cn = ds.getConnection(); V=~dgy~@
多用于jsp中 Hefqzu
2、执行sql语句 B=`!
1)用Statement来执行sql语句 {piS3xBi
String sql; Q.\ovk~,a
Statement sm = cn.createStatement(); <~w#sIh
sm.executeQuery(sql); // 执行数据查询语句(select) "O
"@HVF@
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); b@hoH)<9E
2)用PreparedStatement来执行sql语句 9t1_"{'N1
String sql; #u@!O%MJ
sql = "insert into user (id,name) values (?,?)"; DYK|"@
PreparedStatement ps = cn.prepareStatement(sql); %C<eR_
ps.setInt(1,xxx); EMbsKG
ps.setString(2,xxx); kq-RM#Dj:
... +i =78
ResultSet rs = ps.executeQuery(); // 查询 N0C5FSH
int c = ps.executeUpdate(); // 更新 a\E]ueVD2j
7F\g3^z9`
3、处理执行结果 Nl _Jp:8s
查询语句,返回记录集ResultSet N0PX<$y
更新语句,返回数字,表示该更新影响的记录数 $49tV?q5
ResultSet的方法 'C<=b UM
1、next(),将游标往后移动一行,如果成功返回true;否则返回false V-3]h
ba,
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 jtwO\6 t&
^*OA%wg3=h
4、释放连接 Nfh(2gK+
cn.close(); l ,.;dw
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection \
PqV|
:e;fs.C
可滚动、更新的记录集 #Uu"olX7
1、创建可滚动、更新的Statement psVRdluS
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); qxx.f58H
该Statement取得的ResultSet就是可滚动的 , +^db)
2、创建PreparedStatement时指定参数 |IvX7%*]~
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); d?n~9_9e
ResultSet.absolute(9000); vI@8DWs
批量更新 _?"J.i
1、Statement l?;S>s*\?
Statement sm = cn.createStatement(); plq\D.C
sm.addBatch(sql1); hCgNS1%4
sm.addBatch(sql2); y8@!2O4
... M*N8p]3Cq
sm.executeBatch() ^8iy(
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 mqL+W
2、PreparedStatement eu=2a>
PreparedStatement ps = cn.preparedStatement(sql); Lnzhs;7L
{ :`K;0`C+
ps.setXXX(1,xxx); X)~-MY*p
... ?0x;L/d])
ps.addBatch(); 4/4IZfznX
} {`LV{!
ps.executeBatch(); *))|ZE6jI
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 79v&6Io
fu/c)D6u*m
事务的处理 sIpK@BQ'
1、关闭Connection的自动提交 cW
RY[{v
cn.setAutoCommit(false); ;#due
2、执行一系列sql语句 5eYCnc9
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close `6/7},"9t
Statement sm ; So:89T
sm = cn.createStatement(insert into user...); yWuq/J:
sm.executeUpdate(); bpzA '
g>
sm.close(); \0$?r4A
sm = cn.createStatement("insert into corp...); ;3!TOY"j;e
sm.executeUpdate(); Ud](hp"
sm.close(); FD<~?-
3、提交 c1`o3gb
cn.commit(); .jCdJ
=z
4、如果发生异常,那么回滚 Z8 x(_ft5
cn.rollback();