java 数据库基本操作 a4[t3U
1、java数据库操作基本流程 6>]w1
H
2、几个常用的重要技巧: =4$ErwI_dm
可滚动、更新的记录集 HbRvU}C1
批量更新 >6R3KJe
事务处理 r
)HZaq
DL<;qhte
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ,{; *b
v
1、取得数据库连接 guG&3{&\s
1)用DriverManager取数据库连接 TuEM
例子 WvZt~x&2
String className,url,uid,pwd; Z9.0#Jnu
className = "oracle.jdbc.driver.OracleDriver"; iu?gZVyka
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; {_mVfFG
uid = "system"; sh R|
pwd = "manager"; UwxszEHC
Class.forName(className); e#)NYcr6
Connection cn = DriverManager.getConnection(url,uid,pwd); P{x6e/
2)用jndi(java的命名和目录服务)方式 %Zp|1J'"
例子 \Si p
String jndi = "jdbc/db"; 1F_$[iIX]
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); CBv0fQtL
DataSource ds = (DataSource) ctx.lookup(jndi); Cs(sar:7
Connection cn = ds.getConnection(); >(-A"jf
多用于jsp中 *4e?y
2、执行sql语句 z-qbe97
1)用Statement来执行sql语句 XF+4*),
String sql; I(Z\$
Statement sm = cn.createStatement(); I tb_ H
sm.executeQuery(sql); // 执行数据查询语句(select) zE<Iv\Q
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); dr(-k3ex
2)用PreparedStatement来执行sql语句 14"+ctq
String sql; +4
h!;i
sql = "insert into user (id,name) values (?,?)"; i)'tt9f$
PreparedStatement ps = cn.prepareStatement(sql); p="0Y<2l
ps.setInt(1,xxx); J?dLI_{<
ps.setString(2,xxx); !Sw=ns7
... e_|Z&
ResultSet rs = ps.executeQuery(); // 查询 4i
PVpro
int c = ps.executeUpdate(); // 更新 ~8yh,U
Z+u.LXc|c
3、处理执行结果 51`&%V{daL
查询语句,返回记录集ResultSet }h=PW'M{
更新语句,返回数字,表示该更新影响的记录数 T9I$6HAi
ResultSet的方法 ]B UirJ,2
1、next(),将游标往后移动一行,如果成功返回true;否则返回false eXMIRus(
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 -r_,#LR!l
x.#E3xI
4、释放连接 gXlcB~!
cn.close(); x9AFN
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection #%2 d;V
cS'{h
可滚动、更新的记录集 zPxR=0|
1、创建可滚动、更新的Statement W7Y@]QMX
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ggL/7I(
该Statement取得的ResultSet就是可滚动的 /y$ Fw9R;
2、创建PreparedStatement时指定参数 b*.aaOb
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 6UqAs<c9
ResultSet.absolute(9000); vJaWHC$q
批量更新 x(cv}#}S8
1、Statement i%JJ+9N
Statement sm = cn.createStatement(); Ix6\5}.c 9
sm.addBatch(sql1); 0ki- /{;
sm.addBatch(sql2); XPU>} 4{
... |1"&[ .
sm.executeBatch() EG`6T
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 k#zDY*kj
2、PreparedStatement ;Y[D#Ja-
PreparedStatement ps = cn.preparedStatement(sql); ^~.AV]t|
{ lOp.cU
ps.setXXX(1,xxx); E]rXp~AZm
... u5Vgi0}A
ps.addBatch(); TIxOMY y
} I`_I^C3
ps.executeBatch(); rVqQo`K\
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 j<P;:
s~].iQJ{B
事务的处理 W2#<]]-
1、关闭Connection的自动提交 K6t"98
cn.setAutoCommit(false); vX\9#Hj
2、执行一系列sql语句 rHTZM,zM=H
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close gu!!}pwV9
Statement sm ; pa1<=w
sm = cn.createStatement(insert into user...); 9xO@_pkX
sm.executeUpdate(); (^35cj{s
sm.close(); AU3Rz&~
sm = cn.createStatement("insert into corp...); [B#XA}w
sm.executeUpdate(); 9zb1t1[W
sm.close(); mmbe.$73
3、提交 )\#*~73
cn.commit(); h@Ea5x
4、如果发生异常,那么回滚 mpug#i6q
cn.rollback();