java 数据库基本操作 yH*hL0mO
1、java数据库操作基本流程 Sa L"!uAk
2、几个常用的重要技巧: $30oc
Tt{
可滚动、更新的记录集 W7t
>&3l
批量更新 |~z3U>
事务处理 Odm#wL~E
IE2CRBfs
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 )IQ*
1、取得数据库连接 X:>$8 ^gS
1)用DriverManager取数据库连接 `)T&~2n
例子 >QXzMN}o
String className,url,uid,pwd; _IWxYp
className = "oracle.jdbc.driver.OracleDriver"; 2d-{Q8Pi
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; cgyp5\*>+
uid = "system"; K4C^m|e
pwd = "manager"; |pJC:woq
Class.forName(className); <$%ql'=
Connection cn = DriverManager.getConnection(url,uid,pwd); 9z:K1
2)用jndi(java的命名和目录服务)方式 :Zza)>l
例子 UVrQV$g!
String jndi = "jdbc/db"; xq2V0Jp1u
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); I"-dTa
DataSource ds = (DataSource) ctx.lookup(jndi); ;+sl7qlA4
Connection cn = ds.getConnection(); xOythvO
多用于jsp中 t-WjL@$F/
2、执行sql语句 6Opa{]
1)用Statement来执行sql语句 r088aUO
P
String sql; ^5>s7SGB"
Statement sm = cn.createStatement(); $_sYfU9
sm.executeQuery(sql); // 执行数据查询语句(select) jo}1u_OJ
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); -ey)J
+?t
2)用PreparedStatement来执行sql语句 Z^+rQ.%n"&
String sql; qe?Qeh(!X
sql = "insert into user (id,name) values (?,?)"; +Gow5-(
PreparedStatement ps = cn.prepareStatement(sql); % #u.J
ps.setInt(1,xxx); l;OYUq~F
ps.setString(2,xxx);
[>f]@>
... 6gnbkpYi
ResultSet rs = ps.executeQuery(); // 查询 &f-hG3/M
int c = ps.executeUpdate(); // 更新 ND5$bq Nu?
iRNLKi
3、处理执行结果 3Hw[s0[$
查询语句,返回记录集ResultSet ;FU|7L$H
更新语句,返回数字,表示该更新影响的记录数 }k7_'p&yk
ResultSet的方法 YGp)Oy}:
1、next(),将游标往后移动一行,如果成功返回true;否则返回false /;Yy@oc
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 `N}d}O8
S/.^7R7{f
4、释放连接 oaK.kOo
cn.close(); JEhm1T
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection ,X68xk.'
eCWPhB6l
可滚动、更新的记录集 dQD$K|aUp
1、创建可滚动、更新的Statement : lgi>^
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Ow@v"L;jF!
该Statement取得的ResultSet就是可滚动的 M(enRs3`O
2、创建PreparedStatement时指定参数 L2fZ{bgy
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ,(N[*)G
ResultSet.absolute(9000); )o{aeV
批量更新 m2xBS!fm
1、Statement io.]'">
Statement sm = cn.createStatement(); .IgRY\?Q
sm.addBatch(sql1); K*Ks"Vx
sm.addBatch(sql2); <r~wZ}s
... qM",( Bh
sm.executeBatch() ]]2k}A[-I
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 5dl,co{q
2、PreparedStatement QB&BTT=!
PreparedStatement ps = cn.preparedStatement(sql); T_LLJ}6M
{ @pFj9[N
ps.setXXX(1,xxx); 71"+<C .
... ]a?bzOr,
ps.addBatch(); $shp(T,q
} X:EEPGE
ps.executeBatch(); 7C7>y/uS
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 7O)" `
#H~_K}Ks
事务的处理 \S ."?!U
1、关闭Connection的自动提交 booRrTS
cn.setAutoCommit(false); .TpsJXF
2、执行一系列sql语句 M:n 6BC>t"
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close ~Y7dH
Dn
Statement sm ; Vn, ><g
sm = cn.createStatement(insert into user...); Xj@+{uvQB
sm.executeUpdate(); `)Ky0&?
sm.close(); \+m$
sm = cn.createStatement("insert into corp...); *jITOR!uF`
sm.executeUpdate(); pK}=*y~$
sm.close(); ? mv:neh
3、提交 IRW^ok.'b!
cn.commit(); V5p0h~PK
4、如果发生异常,那么回滚 jVWK0Zba
cn.rollback();