java 数据库基本操作 _sf#J|kQ
1、java数据库操作基本流程 JW% /^'
2、几个常用的重要技巧: mOz&6T<|
可滚动、更新的记录集 p'%: M
批量更新 ~*PK080N}
事务处理 K5)yM @cq
.cH{WZ
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 6Bq~\b^
1、取得数据库连接 l#5~t|\
1)用DriverManager取数据库连接 DQ n`@
例子 )ZgER[
String className,url,uid,pwd; x8pbO[_|
className = "oracle.jdbc.driver.OracleDriver"; S`W'G&bCj
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; a$xeiy9
uid = "system"; iKF$J3a\2f
pwd = "manager"; I", &%0ycm
Class.forName(className); iBtjd`V*
Connection cn = DriverManager.getConnection(url,uid,pwd); [`hE^chd
2)用jndi(java的命名和目录服务)方式 {#w A!>.
例子 6m-:F.k1(
String jndi = "jdbc/db"; rt 3f7 s*
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); kY'<u
DataSource ds = (DataSource) ctx.lookup(jndi); |Uy e>%*}4
Connection cn = ds.getConnection(); 0U~;%N+lv
多用于jsp中 _Ra<|NVQh
2、执行sql语句 #4P3xa
1)用Statement来执行sql语句 n ,&/D
String sql; {XDY:`vZ}
Statement sm = cn.createStatement(); Uxk[O
sm.executeQuery(sql); // 执行数据查询语句(select) {;Y 89&*R
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); ==h|+NFa
2)用PreparedStatement来执行sql语句 :~ZqB\>i
String sql; .0Iun+nUD
sql = "insert into user (id,name) values (?,?)"; QX/X {h6
PreparedStatement ps = cn.prepareStatement(sql); *%OYAsc
ps.setInt(1,xxx); Hyq@O8
ps.setString(2,xxx); l\T!)Ql
... I+Ncmg )>
ResultSet rs = ps.executeQuery(); // 查询 Xx3g3P
int c = ps.executeUpdate(); // 更新 w'oo-.k
z_:eM7]jv
3、处理执行结果 J0ZxhxX35
查询语句,返回记录集ResultSet *]}CSZ[>
更新语句,返回数字,表示该更新影响的记录数 {uaZ<4N.
ResultSet的方法 4GU/V\e|
1、next(),将游标往后移动一行,如果成功返回true;否则返回false eq@am(#&kY
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 W.#}qK"
q
G%P>Ag
4、释放连接 Hhe{ +W@~
cn.close(); yyY~ *Le
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection lC'{QUC
u0bfX,e2U
可滚动、更新的记录集 ?Do^stq'4
1、创建可滚动、更新的Statement V-KL%
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); bH\'uaJ
该Statement取得的ResultSet就是可滚动的
N|!MO{sB
2、创建PreparedStatement时指定参数 biK)&6|`sa
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); fBf4]^
ResultSet.absolute(9000); 74@lo-/LY
批量更新 X(Y#9N"
1、Statement P"(z jG9-
Statement sm = cn.createStatement(); heE}_,$|
sm.addBatch(sql1); ia%z+:G
sm.addBatch(sql2); 8)^B32
... F_A%8)N
sm.executeBatch() h4hN1<ky\
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 j[J5y#
2、PreparedStatement YG0Px Zmi
PreparedStatement ps = cn.preparedStatement(sql); C5O5S:|'
{ X,C*qw@
ps.setXXX(1,xxx); B :.@Qi^
... GXDC@+$14
ps.addBatch(); b]!9eV$
} G(U 9rJ9
ps.executeBatch(); lLb:f6N
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 @s_3 0+
Ds%9cp*6
事务的处理 U@Z>/ q
1、关闭Connection的自动提交 nNt*} k
cn.setAutoCommit(false); X+=-f^)&
2、执行一系列sql语句 Nls83 W
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 8YuJ8KC
Statement sm ; -PNi^
K_
sm = cn.createStatement(insert into user...); )y9 ;OA
sm.executeUpdate(); Y/.AUN
Z
sm.close(); &+mV7o
sm = cn.createStatement("insert into corp...); V]79vC
sm.executeUpdate(); Z[",$Lt
sm.close(); Ye9Y^+-
3、提交 x(L(l=^"
cn.commit(); /b{o3, #.M
4、如果发生异常,那么回滚 WtEI] WO
cn.rollback();