java 数据库基本操作 V3@^bc!
1、java数据库操作基本流程 K3
]hUe#
2、几个常用的重要技巧:
& k1Ez
可滚动、更新的记录集 )-
2^Jvc
批量更新 Yl-09)7s
事务处理 5r
zB"L
X*S|aNaLWW
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 C8&)-v|
1、取得数据库连接 @ULr)&9
1)用DriverManager取数据库连接 |":^3
例子 6"_FjS3Sl
String className,url,uid,pwd; vj{h*~
className = "oracle.jdbc.driver.OracleDriver"; []LNNO],X
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ? `FI!3j
uid = "system"; 0JNG\ARC
pwd = "manager"; d6hWmZVC
Class.forName(className); P\N`E?lJL
Connection cn = DriverManager.getConnection(url,uid,pwd); g-*@I`k[
2)用jndi(java的命名和目录服务)方式 3QV|@5L`[
例子 II~D66 bF
String jndi = "jdbc/db"; sF|<m)Kt{W
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); ;Rwr5
DataSource ds = (DataSource) ctx.lookup(jndi); Z71"d"
Connection cn = ds.getConnection(); yRvq3>mU
多用于jsp中 OSkZW
2、执行sql语句 (#Y2H
1)用Statement来执行sql语句 t}'Oh}CG
String sql; pOH_ CXw
Statement sm = cn.createStatement(); <'GI<Hc
sm.executeQuery(sql); // 执行数据查询语句(select) N@j|I* y|
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); jr!x)yd
2)用PreparedStatement来执行sql语句 S4?ssI
String sql; QKOo
#7
sql = "insert into user (id,name) values (?,?)"; 7J>n;8{%?
PreparedStatement ps = cn.prepareStatement(sql); lZ_i~;u4@v
ps.setInt(1,xxx); 37lmB
'~
ps.setString(2,xxx); 9 .%{M#j
... oz[E>%
ResultSet rs = ps.executeQuery(); // 查询 AV&W&$
int c = ps.executeUpdate(); // 更新 ]Ff&zBJ
IOIGLtB
3、处理执行结果 @@# G.
查询语句,返回记录集ResultSet Sm,%>
更新语句,返回数字,表示该更新影响的记录数 Uyi_B.:`
ResultSet的方法 =cRJtn
1、next(),将游标往后移动一行,如果成功返回true;否则返回false
tb@/E
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 \>I&UFfH)4
)cOm\^,
4、释放连接 9B*SWWAj
cn.close(); 4H1s"mP<
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection >_&+gn${
-?e~S\JH
可滚动、更新的记录集 Q) FL|
1、创建可滚动、更新的Statement Wigm`A=,r
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 6dg[
该Statement取得的ResultSet就是可滚动的 k87B+0QEL
2、创建PreparedStatement时指定参数 1~5={eI
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); Qiw Zk<rb
ResultSet.absolute(9000); eKLxNw5
批量更新 PU-;Q@< E
1、Statement U15Hq*8Z
Statement sm = cn.createStatement(); yY,.GzIjCj
sm.addBatch(sql1); YjG0: 9
sm.addBatch(sql2); f#^%\K:YYR
... 4Q3Q.(
sm.executeBatch() 5(DCq(\P*
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 q:nYUW o
2、PreparedStatement 'VF9j\a
PreparedStatement ps = cn.preparedStatement(sql); TWxMexiW
{ ,P9B8oIq
ps.setXXX(1,xxx); !})+WSs'"s
... \ &_
-
ps.addBatch(); >#>YoA@S
} wmT3 >
ps.executeBatch(); :l*wf/&z
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 9 -TFyZYU
J.O;c5wL
事务的处理 7dU X(D,?
1、关闭Connection的自动提交 %7V?7BE
cn.setAutoCommit(false); _;0:wXib=
2、执行一系列sql语句 G-}
zkax
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close y8,es$
Statement sm ; xp,H5
m%
sm = cn.createStatement(insert into user...); ^{Mx?]z
sm.executeUpdate(); @];Xbbw+c
sm.close(); Y
@K9Hl
sm = cn.createStatement("insert into corp...); 0e/~H^,SQ
sm.executeUpdate(); uHwuw_eK`
sm.close(); My5X%)T>P
3、提交 LFh(.
}
cn.commit(); NG b`f-:jw
4、如果发生异常,那么回滚 0jg-]
cn.rollback();