java 数据库基本操作 T , =ga
1、java数据库操作基本流程 DuvP3(K
2、几个常用的重要技巧: V8&/O)} o
可滚动、更新的记录集 U8-9^}DBA
批量更新 ~+>M,LfK
事务处理 wZa;cg.-q
(r[<g*+3
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 A2&&iL=j/
1、取得数据库连接 f
5i`B*/
1)用DriverManager取数据库连接 =zA=D.D2
例子 1MJ]Gh]5
String className,url,uid,pwd; ID+'$u&
className = "oracle.jdbc.driver.OracleDriver"; nu0bJ:0aLd
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; dr6 dK
uid = "system"; Xy*X4JJh^
pwd = "manager"; \ b9,>
Class.forName(className); na']{a1K
Connection cn = DriverManager.getConnection(url,uid,pwd); ;(0:6P8I
2)用jndi(java的命名和目录服务)方式
k7{fkl9|#
例子 ga^<_;5<
String jndi = "jdbc/db"; *gz {:}NX
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); #>'1oC{
DataSource ds = (DataSource) ctx.lookup(jndi); N/?MsrZw
Connection cn = ds.getConnection(); HHnabSn}{q
多用于jsp中 rF0zGNH
2、执行sql语句 ^RWt
1)用Statement来执行sql语句 P'9aZd
String sql; om_&|9B)
Statement sm = cn.createStatement(); h.=B!wKK
sm.executeQuery(sql); // 执行数据查询语句(select) |>3a9]
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); x}x@_w
2)用PreparedStatement来执行sql语句 }2c}y7B,_
String sql; >!)VkDAG
sql = "insert into user (id,name) values (?,?)";
P)ZSxU
PreparedStatement ps = cn.prepareStatement(sql); jZ
D\u%
ps.setInt(1,xxx); aJ)5 DlfLR
ps.setString(2,xxx); V2FE|+R%g
... M<$l&%<`G
ResultSet rs = ps.executeQuery(); // 查询 ` `;$Kr
int c = ps.executeUpdate(); // 更新 ')1sw%[2
peqFa._W
3、处理执行结果 H9)uni
查询语句,返回记录集ResultSet ''v1Pv-
更新语句,返回数字,表示该更新影响的记录数 d7^XP
ResultSet的方法 8e\v5K9
1、next(),将游标往后移动一行,如果成功返回true;否则返回false _&%!4n#>
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 e4)gF*
sId5pY!
4、释放连接 aq5<Ks `r
cn.close(); E7eVg*Cvi
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection ygfqP
&HXSO,@
可滚动、更新的记录集 FY|x<-f
1、创建可滚动、更新的Statement hE6tu'
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ewY[vbF
该Statement取得的ResultSet就是可滚动的 CQ( @7
2、创建PreparedStatement时指定参数 \7j)^
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); kxn;;
ResultSet.absolute(9000); *i?qOv/=>
批量更新 ?*s!&-KI
1、Statement _@OYC<
Statement sm = cn.createStatement(); yX~[yH+Pn
sm.addBatch(sql1); m~U{ V9;*
sm.addBatch(sql2); F>b6fUtR
... Uqpvj90sw
sm.executeBatch() 0&nF Vsz
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 654%X(:q
2、PreparedStatement ;Z`)*TRp4
PreparedStatement ps = cn.preparedStatement(sql); kTk?[BK
{ {f&ga
ps.setXXX(1,xxx); _uu:)%
... wwAT@=X*}
ps.addBatch(); iE Oyc59
} B7 PmG
f)b
ps.executeBatch(); .-|O "H$
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 5?fk;Q9+\
>@L
HJ61C
事务的处理 a2rv4d=
1、关闭Connection的自动提交 #`fT%'T!
cn.setAutoCommit(false); |@g1|OWd|
2、执行一系列sql语句 5->PDp
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close OX`n`+^D
Statement sm ; 6+u'Tcb
sm = cn.createStatement(insert into user...); OWjZ)f/
sm.executeUpdate(); 8
KkpXaz
sm.close(); Vx*q'~4y!|
sm = cn.createStatement("insert into corp...); h^0mjdSp,
sm.executeUpdate(); 4AM*KI
sm.close(); !qpu /
3、提交 P8VU&b\
cn.commit(); `l+SJLyJ%
4、如果发生异常,那么回滚 LX fiSM{o
cn.rollback();