java 数据库基本操作 1ThqqB
1、java数据库操作基本流程 PHra+NY#A
2、几个常用的重要技巧: ZFxLBb:
可滚动、更新的记录集 K1q+~4>\|
批量更新 =r4!V>
事务处理 b"CAKl
(03pJV&K
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 Zi
ESlf$
1、取得数据库连接 UY>v"M
1)用DriverManager取数据库连接 9F##F-%x
例子 \8v91g91f
String className,url,uid,pwd; Fo|xzLm9*|
className = "oracle.jdbc.driver.OracleDriver"; GjT#%GBF
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; r o\1]`6
uid = "system"; E4oz|2!m
pwd = "manager"; WFv!Pbq,
Class.forName(className); cxyM\@QB3
Connection cn = DriverManager.getConnection(url,uid,pwd); %s=Dj2+
2)用jndi(java的命名和目录服务)方式 >fs2kha
例子 4^Rd{'mt
String jndi = "jdbc/db"; \k@$~}xD,
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); WZewPn>#q
DataSource ds = (DataSource) ctx.lookup(jndi); EbK0j?
Connection cn = ds.getConnection(); a)s;dp}T%
多用于jsp中 x\\7G^$<h
2、执行sql语句 j,-C{ K
1)用Statement来执行sql语句 M0'v&g
String sql; +wfVL|.Wq
Statement sm = cn.createStatement(); *dsX#Iz
sm.executeQuery(sql); // 执行数据查询语句(select) &0
\
ci9o
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); mOBACTY^
2)用PreparedStatement来执行sql语句 uh3)0.nR
String sql; h #.N3o
sql = "insert into user (id,name) values (?,?)"; N|Cs=-+
PreparedStatement ps = cn.prepareStatement(sql); <nHkg<O6Y
ps.setInt(1,xxx); jgu*Y{ocm
ps.setString(2,xxx); !!,0'c
... @!%n$>p/V
ResultSet rs = ps.executeQuery(); // 查询 .zj0Jy8N
int c = ps.executeUpdate(); // 更新 x4kWLy7Sz
`dkV_ O0
3、处理执行结果 v/Pw9j!r;m
查询语句,返回记录集ResultSet %V_-%/3Z
更新语句,返回数字,表示该更新影响的记录数 2W<n5o
ResultSet的方法 blt'={Z?.x
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 't (O$
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 FQsUm?ac:
]7YNIS
4、释放连接 )}lRd#V
cn.close(); G=/k>@Di
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection </~ 6f(mg
F2I 5qC/
可滚动、更新的记录集 Snw3`|Y~<
1、创建可滚动、更新的Statement qYB~VE03
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); RYR-K^;R
该Statement取得的ResultSet就是可滚动的 V2 d,ksKwn
2、创建PreparedStatement时指定参数 ^krk&rW3
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 'S4)?Z
ResultSet.absolute(9000); ^4Uw8-/ 9
批量更新 5]Da{Wmgs
1、Statement c-1q2y
Statement sm = cn.createStatement(); ;O#g"8
sm.addBatch(sql1); #;VA5<M8
sm.addBatch(sql2); U.0kR/>Z=
... E#%}ZY
sm.executeBatch() n{5NNV6
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 1}m3;
2、PreparedStatement 2b@tj
5
PreparedStatement ps = cn.preparedStatement(sql); @tUoD>f
{ 8F5|EpB9M
ps.setXXX(1,xxx); Gpj* V|J
... 8G^<[`.@j
ps.addBatch(); 5p"BD'^:
} _'0
@%P%
ps.executeBatch(); ]wn/BG)
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 A$/\1282
'o4p#`R:8
事务的处理 Z9`TwS@x[
1、关闭Connection的自动提交 /%rq
hHs
cn.setAutoCommit(false); <O~WB
2、执行一系列sql语句 wVl+]zB
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close e)^j+ l
Statement sm ; #$ thPZ
sm = cn.createStatement(insert into user...); BzJ;%ywS
sm.executeUpdate(); fRZ KEIyk
sm.close(); JgRYljQi2
sm = cn.createStatement("insert into corp...); _c(4o:
sm.executeUpdate(); T3%C%BcX
sm.close(); afEF]i
3、提交 L5fuM]G`
cn.commit(); dE`-\J
4、如果发生异常,那么回滚 T Eu'*>g
cn.rollback();