java 数据库基本操作 Pymh^i
1、java数据库操作基本流程 Tx?@*Q
2、几个常用的重要技巧: nPIR1Z
可滚动、更新的记录集 3^-)gK
批量更新 /G{3p&9
事务处理 y $DB
Umwg
iw
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 [c!vsh]^
1、取得数据库连接
iIEIGQx
1)用DriverManager取数据库连接 ~V-
o{IA
例子 }]GK@nn7
String className,url,uid,pwd; 5sCky)N
className = "oracle.jdbc.driver.OracleDriver"; b!HFv;^N
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ;WAu]C|
uid = "system"; _ktSTzH0
pwd = "manager"; ?d#(ian
Class.forName(className); ?'#;Y"RT
Connection cn = DriverManager.getConnection(url,uid,pwd); (X7yNIPfA
2)用jndi(java的命名和目录服务)方式 Jsnmn$C
例子 3@ukkO)
String jndi = "jdbc/db"; zr9Pm6Rl
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); &E'>+6
DataSource ds = (DataSource) ctx.lookup(jndi); RkV3_c
Connection cn = ds.getConnection(); Sm_:SF!<D6
多用于jsp中 ^A<.s_
2、执行sql语句 h=y(2xA
1)用Statement来执行sql语句 :Du{8rV
String sql; u]-El}*[
Statement sm = cn.createStatement(); K~%5iVO~\
sm.executeQuery(sql); // 执行数据查询语句(select) U"kK]Stk<
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 1'pQ,
2)用PreparedStatement来执行sql语句 Cv7RCjMw
String sql; ~HI0<;r=eL
sql = "insert into user (id,name) values (?,?)"; s ;Nu2aOp7
PreparedStatement ps = cn.prepareStatement(sql); XUNgt(OGR'
ps.setInt(1,xxx); & ~G
ps.setString(2,xxx); <4HuV.K
...
F%$Ws>l
ResultSet rs = ps.executeQuery(); // 查询 00wH#_fm
int c = ps.executeUpdate(); // 更新 ]Oh>ECA|D
CrX-?$
3、处理执行结果 ?iO^b.'I#
查询语句,返回记录集ResultSet 7IW7'klkvD
更新语句,返回数字,表示该更新影响的记录数 \mit&EUh}
ResultSet的方法 A_
z:^9
1、next(),将游标往后移动一行,如果成功返回true;否则返回false %a^!~qV
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 P3FpU<OBwp
]
r+I D
4、释放连接 2xBGs9_Y
cn.close(); JJOs
L!@
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 2-2LmxLG
3lgyX/?o
可滚动、更新的记录集 h4xdE0
1、创建可滚动、更新的Statement 62'0 )Cy^
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); XxQ2g&USk
该Statement取得的ResultSet就是可滚动的 =,Um;hU3r
2、创建PreparedStatement时指定参数 a#**96Av
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); #^w 1!xXD
ResultSet.absolute(9000); +mPB?5
批量更新 }slEkpk?]
1、Statement '~=xP
Statement sm = cn.createStatement(); ky"7 ^
sm.addBatch(sql1); fb=vO U
sm.addBatch(sql2); l{{ #tW
... 4[j) $!l`
sm.executeBatch() w8Vzx8
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 md_s2d
2、PreparedStatement \aRB
PreparedStatement ps = cn.preparedStatement(sql); ;G&O"S><]c
{ ~i {)J
ps.setXXX(1,xxx); T U6EE
... ~a)20
ps.addBatch(); r|$g((g
} "d*
ps.executeBatch(); Ase 1 R=0
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 !}m8]&
9uo\&,,
事务的处理 7cSvAX0Z.
1、关闭Connection的自动提交 }z@hx@N/
cn.setAutoCommit(false); ~.SU$
2、执行一系列sql语句 :udZfA\sW
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close xBd%e-r
Statement sm ; wOSNlbQ5jl
sm = cn.createStatement(insert into user...); RT9|E80
sm.executeUpdate(); L(YT6Vmm+t
sm.close(); '7%9Sqx
sm = cn.createStatement("insert into corp...); 3c"{Wu-}
sm.executeUpdate(); v8=MO:>{R
sm.close(); E$baQU hKS
3、提交 uu #+|ZD
cn.commit(); o
W [-?
4、如果发生异常,那么回滚 RR9s%>^
cn.rollback();