java 数据库基本操作 rg0ma
1、java数据库操作基本流程 [A}rbD K
2、几个常用的重要技巧: G+B~Ix-
可滚动、更新的记录集 WZOY)>K
批量更新 JnHo 9K2.
事务处理 +!QJTn"3
T\Uek-(
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ~m|Mg9-
1、取得数据库连接 QO"oEgB`+Z
1)用DriverManager取数据库连接 : ^ 8
例子 |
8qBm
String className,url,uid,pwd; \Mg`(,kwe
className = "oracle.jdbc.driver.OracleDriver"; [((;+B
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; IbcZ@'RSw
uid = "system"; PW3GL3+
pwd = "manager"; p>_;^&>&
Class.forName(className); gM [w1^lj
Connection cn = DriverManager.getConnection(url,uid,pwd); yLsz8j-QJ
2)用jndi(java的命名和目录服务)方式 -P&6L\V
例子 Cy*|&=>j
String jndi = "jdbc/db"; LH:i| I
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); qc#)!
DataSource ds = (DataSource) ctx.lookup(jndi); 6a;v&5
Connection cn = ds.getConnection(); 0i8LWX_M
多用于jsp中 v)2M1
2、执行sql语句 JHf
1)用Statement来执行sql语句 ='TE,et@d
String sql; u_7~TE3W
Statement sm = cn.createStatement(); fX
jG5Tv
sm.executeQuery(sql); // 执行数据查询语句(select) QdLYCR4f
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); xQw7 :18wQ
2)用PreparedStatement来执行sql语句 :>itXD!
String sql; tK
k#LWB
sql = "insert into user (id,name) values (?,?)"; v\`9;QV5
PreparedStatement ps = cn.prepareStatement(sql); `bc;]@"
ps.setInt(1,xxx); lY*[tmz)
ps.setString(2,xxx); *Z_C4Tj
... XJ2^MF2BU
ResultSet rs = ps.executeQuery(); // 查询 V5 U?F6
int c = ps.executeUpdate(); // 更新 ={hX}"*D
kD[ r.Dma
3、处理执行结果 Py`N4y~
查询语句,返回记录集ResultSet (|wz7AY2
更新语句,返回数字,表示该更新影响的记录数 !ZU2{
ResultSet的方法 -R{V-
1、next(),将游标往后移动一行,如果成功返回true;否则返回false *!^<m0
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 |AC1\)2tT
4[r/}/iGo
4、释放连接 jF[ 1za
cn.close(); )/t?!T.[
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection _{jjgQJ5
9M"].~iNE
可滚动、更新的记录集 jSc#+_y
1、创建可滚动、更新的Statement S(:l+JP
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); >[6{LAe~hp
该Statement取得的ResultSet就是可滚动的 hVUP4 A
2、创建PreparedStatement时指定参数 !z{-?o/
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ?aW^+3i
ResultSet.absolute(9000); ^9-&o
批量更新 n&A'C\
1、Statement %7g:}O$
Statement sm = cn.createStatement(); 0kDK~iT
sm.addBatch(sql1); #Km:}=
sm.addBatch(sql2); Q?AmOo-a
... s}j1"@
sm.executeBatch() OCy0#aPRS
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 t*@z8<H
2、PreparedStatement nL:SG{7
PreparedStatement ps = cn.preparedStatement(sql); TPhTaKCio
{ ?|e'Gbb_
ps.setXXX(1,xxx); #P#-xz
... 8.bKb<y
ps.addBatch(); flgRpXt
} bxK(9.
ps.executeBatch(); ,<DB&&EV8
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 A8A~!2V
?X?&~3iD%
事务的处理 0b91y3R+
1、关闭Connection的自动提交 e"r)R8
cn.setAutoCommit(false); 9z?oB&5
2、执行一系列sql语句 j]0^y}5f+s
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close [Pe#kzLX
Statement sm ; ,@z4I0cTi\
sm = cn.createStatement(insert into user...); sS
TPMh
sm.executeUpdate(); C6_@\&OA
sm.close(); %7`f{|.
sm = cn.createStatement("insert into corp...); @5)
8L/[l
sm.executeUpdate(); fx8EB8A7K7
sm.close(); FI8Oz,
3、提交 |_u8mV
cn.commit(); YJxw 'U
>P
4、如果发生异常,那么回滚 &4dz}zz90
cn.rollback();