java 数据库基本操作 PJ'@! jx
1、java数据库操作基本流程 9K#U<Q0b'
2、几个常用的重要技巧: Yn-;+ 4 K
可滚动、更新的记录集 |A:+[35
批量更新 "@&I*1&
事务处理 YGkk"gFIA
~)!vhdBe
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 [1.>9ngj
1、取得数据库连接 ](^BQc
1)用DriverManager取数据库连接 FdmoR;
例子 vv`,H~M6
String className,url,uid,pwd; K$~Ja
className = "oracle.jdbc.driver.OracleDriver"; \@*D;-b
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; W
sDFui
uid = "system"; YXTd^M~@D
pwd = "manager"; [f-<M@id/
Class.forName(className); > ^d+;~Q;
Connection cn = DriverManager.getConnection(url,uid,pwd); fvw&y+|y!
2)用jndi(java的命名和目录服务)方式 c +]5[6
例子 +q)B4A'J!
String jndi = "jdbc/db"; 'M3V#5l)@|
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); SWMi+)
DataSource ds = (DataSource) ctx.lookup(jndi); o%?~9rf]]
Connection cn = ds.getConnection(); M\be a
多用于jsp中 8f-B-e?k
2、执行sql语句 YN5p@b=FX
1)用Statement来执行sql语句 __,}/|K2
String sql; @m ?&7{y#?
Statement sm = cn.createStatement(); -wn(J5NnR
sm.executeQuery(sql); // 执行数据查询语句(select) Xq.GvZS`
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); !8OUH6{2
2)用PreparedStatement来执行sql语句 YX6[m6LU
String sql; yI}_
U
sql = "insert into user (id,name) values (?,?)"; +L<x0-&
PreparedStatement ps = cn.prepareStatement(sql); u[1'Ap
ps.setInt(1,xxx); "pkn
ps.setString(2,xxx); x-ZCaa}O
... Z/=HQ8
ResultSet rs = ps.executeQuery(); // 查询 k[;(@e@c
int c = ps.executeUpdate(); // 更新 HXRK<6k$
MNsgD3
3、处理执行结果 Ed&M
查询语句,返回记录集ResultSet ;p2a .P
更新语句,返回数字,表示该更新影响的记录数 4Awl
ResultSet的方法 -$5nqaK?
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ? Glkhf7(
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 GbbD)
aG/L'weR
4、释放连接 aT%6d@g
cn.close(); 4Nz]LK%@
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection \J3n[6;
K@+(6\6I
可滚动、更新的记录集 zrCQEQq
1、创建可滚动、更新的Statement gAViwy9{
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); >&2n\HR\
该Statement取得的ResultSet就是可滚动的 %^66(n)
2、创建PreparedStatement时指定参数 RF.8zea{O`
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 9mfP9
ResultSet.absolute(9000); ixI fJ
批量更新 N"#=Q=)x
1、Statement 5K %
Statement sm = cn.createStatement(); 9x9~u8j
sm.addBatch(sql1); fW.)!EPO
sm.addBatch(sql2); p}R3AJ
... qox31pnS
sm.executeBatch() 5$p7y:
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ]NgEN
2、PreparedStatement Hze~oAP+
PreparedStatement ps = cn.preparedStatement(sql); ]R s
{ Ww $?X LF
ps.setXXX(1,xxx); f8?c[%br
... \3v}:E+3
ps.addBatch(); !aub@wH3
} qT+:oMrTSm
ps.executeBatch(); \Z%V)ZRi=
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 %["V "{ z
"<I*ViZ
事务的处理 ISl-W1u}
1、关闭Connection的自动提交 7BDoF!kCx
cn.setAutoCommit(false); */yR_f
2、执行一系列sql语句 4w-P%-4
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 9Wi+7_)
Statement sm ; jFMf=u&U
sm = cn.createStatement(insert into user...); +XN/ bT
sm.executeUpdate(); b".e6zev
sm.close(); WF0[/Y
sm = cn.createStatement("insert into corp...); @G;\gJT*
sm.executeUpdate(); 2
.)`8|c9
sm.close(); -THU5AB
3、提交 C [h^bBq
cn.commit(); i VIpe
4、如果发生异常,那么回滚 v&i,}p^M5
cn.rollback();