java 数据库基本操作
Y t(D
1、java数据库操作基本流程 n(:<pz
2、几个常用的重要技巧: L)e"qC_-
可滚动、更新的记录集 H QqFrR
批量更新 HI.*xkBXl&
事务处理 66yw[,Y
-ss= c #
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 USg"wJY
1、取得数据库连接 C/kf?:j
1)用DriverManager取数据库连接 ~iL^KeAp
例子 uo9#(6
String className,url,uid,pwd; Q]ersA8 V>
className = "oracle.jdbc.driver.OracleDriver"; dSM\:/t
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; F.9}jd{
uid = "system"; hZ&KE78?
pwd = "manager"; Pfd1[~,
Class.forName(className); +7_qg
i7:
Connection cn = DriverManager.getConnection(url,uid,pwd); broLC5hbQU
2)用jndi(java的命名和目录服务)方式 rB>ge]$.
例子 cD!,ZL
String jndi = "jdbc/db"; &> sbsx\y
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); lx)^wAO4
DataSource ds = (DataSource) ctx.lookup(jndi); @DN/]P
Connection cn = ds.getConnection(); 8&<mg;H,
多用于jsp中 jK|n^5\
2、执行sql语句 e4z`:%vy
1)用Statement来执行sql语句 Q6h+.
String sql; PL/g| ;
Statement sm = cn.createStatement(); -F 5BJk
sm.executeQuery(sql); // 执行数据查询语句(select) honh'j
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); $0])%
2)用PreparedStatement来执行sql语句 iT]t`7R
String sql; Rh>B#
\
sql = "insert into user (id,name) values (?,?)"; $7x2TiAL
PreparedStatement ps = cn.prepareStatement(sql); s8h*nZ)v
ps.setInt(1,xxx); +QChD*
ps.setString(2,xxx); #:K=zV\
... F/5&:e?( )
ResultSet rs = ps.executeQuery(); // 查询 8z=#
0+0
int c = ps.executeUpdate(); // 更新 _$~>O7
7J'%;sH
3、处理执行结果 0At0`Q#
查询语句,返回记录集ResultSet @8d 3
更新语句,返回数字,表示该更新影响的记录数 m1$tf
^
ResultSet的方法 inut'@=G/
1、next(),将游标往后移动一行,如果成功返回true;否则返回false vFPY|Vzh
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ?Ga8.0Z~KT
9*qwXU_aV
4、释放连接 ~?Zib1f)
cn.close(); PR:k--)D
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection oC0ndp~+&
56V|=MzX]
可滚动、更新的记录集 HD j6E"
1、创建可滚动、更新的Statement FI.te3i?7
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); fBS a8D3}`
该Statement取得的ResultSet就是可滚动的 a"Qf
2、创建PreparedStatement时指定参数 4~fYG| a
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); NL21se
ResultSet.absolute(9000); %M6OLq!K
批量更新 K;F1'5+=D
1、Statement 01cBAu
Statement sm = cn.createStatement(); Q\Ek U.[I
sm.addBatch(sql1); SUS=sR/N
sm.addBatch(sql2); fG0 ?"x@>
... gZ @+62
sm.executeBatch() J8ni}\f
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 4cjfn'x
2、PreparedStatement fdl.3~.C
PreparedStatement ps = cn.preparedStatement(sql); c(Q@5@1y:
{ ;ALWL~Xm
ps.setXXX(1,xxx); ddHl&+G
... ORM>|&
ps.addBatch(); ztp|FUi
} b8WtNVd
ps.executeBatch(); cu!%aM,/<-
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 jn(x-fj6R
vsGKCrLwh
事务的处理 Al>d
21U
1、关闭Connection的自动提交 YxF@1_g
cn.setAutoCommit(false); sd%j&Su#4
2、执行一系列sql语句 #GzALF97
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close nrac)W
Statement sm ; t G_4>-Y#w
sm = cn.createStatement(insert into user...); (bwD:G9
sm.executeUpdate(); B[b>T=
sm.close(); yRXML\Ge
sm = cn.createStatement("insert into corp...);
X%Ok ">
sm.executeUpdate(); Be6Yh~m
sm.close(); R1];P*>%gZ
3、提交 BT7{]2?&V
cn.commit(); gInh+XZs
4、如果发生异常,那么回滚 p-4$)w~6i
cn.rollback();