java 数据库基本操作 ~K`1
1、java数据库操作基本流程 u5F}( +4r
2、几个常用的重要技巧: x5F@ad9
可滚动、更新的记录集 N"1QX6
批量更新 Q.ukY@L.'
事务处理 '\t7jQ
O]ZC+]}/
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ]nc2/S%
1、取得数据库连接 ._,trb>o
1)用DriverManager取数据库连接 KTv4< c]
例子 s#P:6]Ar
String className,url,uid,pwd; u E.^w;~2=
className = "oracle.jdbc.driver.OracleDriver"; _Wma\(3$
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; k FLT!k
uid = "system"; k{-`]qiK
pwd = "manager"; "@)lH
Class.forName(className); ?d5h9}B
Connection cn = DriverManager.getConnection(url,uid,pwd); L$hc,
2)用jndi(java的命名和目录服务)方式 R@n5AN(
例子 mPG7Zy$z
String jndi = "jdbc/db"; /buWAX1
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 7Ud'd<
DataSource ds = (DataSource) ctx.lookup(jndi); fnOIv#
Connection cn = ds.getConnection(); ]/44Ygz/
多用于jsp中 ?!7
SzLll
2、执行sql语句 c,$mWTC
1)用Statement来执行sql语句 1Is%]6
String sql; (Fqa][0
Statement sm = cn.createStatement(); }#
Xi`<{
sm.executeQuery(sql); // 执行数据查询语句(select) RH~sbnZ)F
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); b{pg!/N4
2)用PreparedStatement来执行sql语句 Hg whe=P
String sql; &^+3errO
sql = "insert into user (id,name) values (?,?)"; u`6/I#q`
PreparedStatement ps = cn.prepareStatement(sql); h>W@U9
ps.setInt(1,xxx); %)JRbX<c
ps.setString(2,xxx); Nf5WQTa4
... MD4\QNUa)*
ResultSet rs = ps.executeQuery(); // 查询 ^@"c`
int c = ps.executeUpdate(); // 更新 [+gzdLad
l&|)O6N
3、处理执行结果 4>k
I^
查询语句,返回记录集ResultSet -[$&s FD
更新语句,返回数字,表示该更新影响的记录数 0'@u!m?
ResultSet的方法 lsFfb'>
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 7m]t^^
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 vgo{]:Aj{
Mz\yPT;Y
4、释放连接 )!a$#"'
cn.close(); ETm]o
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection D$hQyhz'
WgPgG0VJE
可滚动、更新的记录集 B1+ZFQo
1、创建可滚动、更新的Statement qHJ'1~?q
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); m}pL`:e!
该Statement取得的ResultSet就是可滚动的 /RqhykgZ
2、创建PreparedStatement时指定参数 l5HWZs^
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); #>bT<
ResultSet.absolute(9000); XHQh4W3
批量更新 LzE/g)>
1、Statement 9[sG1eP!
Statement sm = cn.createStatement(); 5p
)IV>G
sm.addBatch(sql1); 9A+M|;O
sm.addBatch(sql2); 9GPb$gtx
... 7}o6_i
sm.executeBatch() EzpwGNfz }
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 !qaDn.9
2、PreparedStatement 6RP+4c
PreparedStatement ps = cn.preparedStatement(sql); n1?}Xq|
{ L$}g3{
ps.setXXX(1,xxx); LU(%K{9
... }$:#+
(17
ps.addBatch(); pyF5S,c
} XN(tcdCG
ps.executeBatch(); {_7Hz,2U
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 HEpM4xe$
8Z!*[c>K-?
事务的处理 =)*JbwQ
1、关闭Connection的自动提交 SB1[jcJ
cn.setAutoCommit(false); ]>vf 9]
2、执行一系列sql语句 X'@f"= v9k
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close I+~bCcgPi
Statement sm ; 9`INC~h
sm = cn.createStatement(insert into user...); z5 pc3:
sm.executeUpdate(); OAVQ`ek
sm.close(); E*^9|Y[
sm = cn.createStatement("insert into corp...); !;+U_j'Pg
sm.executeUpdate(); ob]dZ
sm.close(); ] R<FKJ[
3、提交 2Y;!$0_rv
cn.commit(); DM'qNgB7
4、如果发生异常,那么回滚 }!=U^A)
cn.rollback();