java 数据库基本操作 FJ54S
1、java数据库操作基本流程 U]R~ gy}#
2、几个常用的重要技巧: })Yv9],6
可滚动、更新的记录集 ^A9M;q
批量更新 eg<pa'Hw
事务处理 vWjnI*6T#
B{MaMf)
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 XRtD< jlA"
1、取得数据库连接 _mJG5(|
1)用DriverManager取数据库连接 5M F#&v
例子 H'DVwnn>ik
String className,url,uid,pwd; Da.G4,vLh
className = "oracle.jdbc.driver.OracleDriver"; :Ht;0|[H
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr;
]Oeh=gq
uid = "system"; $_Nf-:D*
pwd = "manager"; {ci.V*:"
Class.forName(className); MYdO jcN
Connection cn = DriverManager.getConnection(url,uid,pwd); "rhYCZ B
2)用jndi(java的命名和目录服务)方式 }m-"8\_D
例子 nZk+
String jndi = "jdbc/db"; k N7Bd}
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); WsGths+[
DataSource ds = (DataSource) ctx.lookup(jndi); |~0UM$OB^3
Connection cn = ds.getConnection(); uLR<FpM
多用于jsp中 eiVC"0-c}
2、执行sql语句 r!
%;R?c
1)用Statement来执行sql语句 v,@F|c?_S
String sql; =r2]uW9
Statement sm = cn.createStatement(); V3Z]DA
sm.executeQuery(sql); // 执行数据查询语句(select) ino:N5&;;
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); fmX!6Kv
2)用PreparedStatement来执行sql语句 Lgk
String sql; ~f\G68c
sql = "insert into user (id,name) values (?,?)"; zp}eLm:=d
PreparedStatement ps = cn.prepareStatement(sql); zUJZ`seF
ps.setInt(1,xxx); 4T6 {Y
ps.setString(2,xxx); &7e)O=
... ]=pR
ResultSet rs = ps.executeQuery(); // 查询 X{xBYZv4
int c = ps.executeUpdate(); // 更新 Fh$slow4!
.B2]xfo"`
3、处理执行结果 =q7Z qP
查询语句,返回记录集ResultSet $;N* c H~
更新语句,返回数字,表示该更新影响的记录数 q? qC
ResultSet的方法 (V`Md\NL`
1、next(),将游标往后移动一行,如果成功返回true;否则返回false hj%ye~|~
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 W !w, f;
/AY4M;}p
4、释放连接 {76c%<`WaP
cn.close(); Fb`a~c~s
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection GzXUU@p
)Z 9E=%
可滚动、更新的记录集 f5AjJYq1
1、创建可滚动、更新的Statement E>'a,!QPv
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); >{gPN"S"a
该Statement取得的ResultSet就是可滚动的 D"(L5jR8m@
2、创建PreparedStatement时指定参数 q;g>t5]a
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); eV:9y
ResultSet.absolute(9000); !* Ti}oIo&
批量更新 c#-U%qZ
1、Statement 'm1N/)F
Statement sm = cn.createStatement(); v\16RD
sm.addBatch(sql1); McH>"`
sm.addBatch(sql2); d@`M
CchCB
... ^k5ll=}
sm.executeBatch() 3vhnwDcK
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 %~L>1ShtU
2、PreparedStatement 5pr"d@.
PreparedStatement ps = cn.preparedStatement(sql); |(5W86C,ju
{ b2aF 'y/
ps.setXXX(1,xxx); \PDd$syDA
... fkf1m:Ckh
ps.addBatch(); 5^']+5_vb
} JlMT<;7\
ps.executeBatch(); O5$/55PI
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 G'3qzBJ#
3vcO!6Z5
事务的处理 zi`b2h
1、关闭Connection的自动提交 |
N0Z-|
cn.setAutoCommit(false); 5N%93{L
2、执行一系列sql语句 u[nyW3MZ
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close }*.0N;;C
Statement sm ; pw7[y^[Qg
sm = cn.createStatement(insert into user...); Ee`1F#c
sm.executeUpdate(); !Mi;*ZR
sm.close(); G}&Sle]
sm = cn.createStatement("insert into corp...); iw*Nq,(
sm.executeUpdate(); 311LC cRp
sm.close(); $O9^SB
3、提交 aW>6NDq(
cn.commit(); . e=C{
4、如果发生异常,那么回滚 8_T6_jL<
cn.rollback();