java 数据库基本操作
1W;3pN
1、java数据库操作基本流程
(H9%a-3
2、几个常用的重要技巧: uVqJl{e\
可滚动、更新的记录集 ovCk:Vz
批量更新 @6GM)N\{[
事务处理 7|6tH@4Ub
w_^&X;0^
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 h~elF1dG
1、取得数据库连接 bWv6gOPR3
1)用DriverManager取数据库连接 PK C``+Ki
例子 K_nN|'R-
String className,url,uid,pwd; >c7/E
className = "oracle.jdbc.driver.OracleDriver"; fRT:@lV
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; bi!4I<E>k
uid = "system"; <Q=ES,M
pwd = "manager"; ^e8R43w:!
Class.forName(className); 5h[u2&;G
Connection cn = DriverManager.getConnection(url,uid,pwd); p)tac*US
2)用jndi(java的命名和目录服务)方式 QN-n9f8
例子 CzzG
String jndi = "jdbc/db"; +nd'Uf
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); lf|e8kU\f
DataSource ds = (DataSource) ctx.lookup(jndi); U6X~]| o
Connection cn = ds.getConnection(); xpyb&A
多用于jsp中 *NV`6?o@6
2、执行sql语句 K_`*ZV{r
1)用Statement来执行sql语句 w;QDQ
fx0
String sql; $E|W|4N
Statement sm = cn.createStatement(); #`GW7(M
sm.executeQuery(sql); // 执行数据查询语句(select) G"MpA[a_
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); zx(j6
2)用PreparedStatement来执行sql语句 *ILS/`mdav
String sql; ~1Tz[\H#R
sql = "insert into user (id,name) values (?,?)"; T-&CAD3 ,O
PreparedStatement ps = cn.prepareStatement(sql); fokT)nf~^8
ps.setInt(1,xxx); (Wq9YDD@
ps.setString(2,xxx); mkBQX
... QC <(rx
ResultSet rs = ps.executeQuery(); // 查询 h9+ylHW_cp
int c = ps.executeUpdate(); // 更新 G !1- 20
f'FY<ed<w
3、处理执行结果 V@>?lv(\
查询语句,返回记录集ResultSet NJUYeim;
更新语句,返回数字,表示该更新影响的记录数 -f9M*7O<gf
ResultSet的方法 K?[pCF2C
1、next(),将游标往后移动一行,如果成功返回true;否则返回false [tMf KO
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值
+ y.IDn^
,_rarU)[J
4、释放连接 CG9X3%xO%
cn.close(); )[oU|!@
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection *BXtE8
BU
$%r|V*5
可滚动、更新的记录集 6xL=JSi~
1、创建可滚动、更新的Statement 0y;&L63>T
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); CI{]o&Tf
该Statement取得的ResultSet就是可滚动的 MVt#n\_BZV
2、创建PreparedStatement时指定参数 #EHBS~^
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); qoZ* sV
ResultSet.absolute(9000); 6j"(/X|Ex5
批量更新 h| UT/:
1、Statement IU$bP#<
Statement sm = cn.createStatement(); TP{a*ke^5,
sm.addBatch(sql1); sxThz7#i)
sm.addBatch(sql2); |~\K:[T&
... +crAkb}i
sm.executeBatch() `zzX2R Je
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 mApn(&
2、PreparedStatement x(]s#D!)
PreparedStatement ps = cn.preparedStatement(sql); ~;eWQwD
{ ,xD{A}}V
ps.setXXX(1,xxx); jLQjv
... {Y/|7Cl0
ps.addBatch(); eU%5CVH.v
} TdKl`"Iy
ps.executeBatch(); h*MR5qa
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 "[[fQpe4@
tMAa$XrZj
事务的处理 ^<E+7
1、关闭Connection的自动提交 9Biw!%a
cn.setAutoCommit(false); Dx <IS^>i
2、执行一系列sql语句 !FSraW2
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close $,aU"'D
Statement sm ; =R>Sxaq
sm = cn.createStatement(insert into user...); yQi|^X~?$
sm.executeUpdate(); p1?}"bHk
sm.close(); =rBFMTllM
sm = cn.createStatement("insert into corp...); 7Ck;LF}>0
sm.executeUpdate(); =\XAD+
sm.close(); =fsaJ@q,R
3、提交 d:pp,N~2o
cn.commit(); h.?[1hT4R
4、如果发生异常,那么回滚 G0Wd"AV+
cn.rollback();