java 数据库基本操作 E\m?0]W|
1、java数据库操作基本流程 r\],5x'xSu
2、几个常用的重要技巧: ~R)w
9uq
可滚动、更新的记录集 @{I55EQ]
批量更新 "G6d'xkP
事务处理 idO3/>R
[
BqZLqGOKu
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 3=bzIU
1、取得数据库连接 ' 1P_*
1)用DriverManager取数据库连接 m OmT]X
例子 N0
?O*a
String className,url,uid,pwd; Rz=]KeZu
className = "oracle.jdbc.driver.OracleDriver"; |w~zh6~
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; rLL;NTN+/
uid = "system"; ^D4 b\mF
pwd = "manager"; =Bo0Oei
Class.forName(className); <S$y=>.9
Connection cn = DriverManager.getConnection(url,uid,pwd); 1b|<
2)用jndi(java的命名和目录服务)方式 ;SC|VcbyH
例子 vy|}\%*r~
String jndi = "jdbc/db"; ;k/0N~
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); D@
=.4z
DataSource ds = (DataSource) ctx.lookup(jndi); )1x333.[c
Connection cn = ds.getConnection(); 3'/wRK l
多用于jsp中 KMbBow3o*~
2、执行sql语句 Q ;k_q3
1)用Statement来执行sql语句 Wnf`Rf)1z
String sql; q6_1`Ew
Statement sm = cn.createStatement(); 9 oq(5BG,
sm.executeQuery(sql); // 执行数据查询语句(select) _l8oB)
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); '.kbXw0}
2)用PreparedStatement来执行sql语句 *;gi52tM
String sql; R:ar85F
sql = "insert into user (id,name) values (?,?)"; HYg_{
PreparedStatement ps = cn.prepareStatement(sql); xD1wHp!+
ps.setInt(1,xxx); HKxrBQr78
ps.setString(2,xxx); UVI=&y]c,p
... "R9kF-
ResultSet rs = ps.executeQuery(); // 查询 H`io|~Q
int c = ps.executeUpdate(); // 更新 in+`zfUJ9
{?L}qV
3、处理执行结果 YYM
查询语句,返回记录集ResultSet W}=2?vHV=
更新语句,返回数字,表示该更新影响的记录数 v#/,,)m
ResultSet的方法 m",bfZ
1、next(),将游标往后移动一行,如果成功返回true;否则返回false RgRcW5VxK
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 0?`#ko7~d
X*Q7Yu
4、释放连接
w^p2XlQ<
cn.close(); }Ql;% 7
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection s[s^z<4G
9n%W-R.
可滚动、更新的记录集 ljf9L:L
1、创建可滚动、更新的Statement EhVnt#`Si
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); r}5GJ|p0
该Statement取得的ResultSet就是可滚动的 Z$hxo)|
2、创建PreparedStatement时指定参数 rvfl~<G*
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); Z'j<wRf
ResultSet.absolute(9000); jS- QTG!=
批量更新 eBN>|mE4N
1、Statement 1bDc ct
Statement sm = cn.createStatement(); ]D]K_`!K
sm.addBatch(sql1); ~ZDdzp>
sm.addBatch(sql2); tllg$CQ5
... b~~}(^Bg
sm.executeBatch() 0WPxzmY
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 4OIN@n*4
2、PreparedStatement ypifXO;m7
PreparedStatement ps = cn.preparedStatement(sql); iH$N HfH
{ i*; V4zh
ps.setXXX(1,xxx); dJ;;l7":~
... G?V3lQI1n
ps.addBatch(); gSv<.fD"
} $N
]P#g?Q
ps.executeBatch(); ;kF p)*i
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 23fAc"@ B
SwL\=nq+~
事务的处理 EXi+pm
1、关闭Connection的自动提交 50Jr(OeU<
cn.setAutoCommit(false); ujSzm=_P
2、执行一系列sql语句 Bh.'%[',
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 'qD9kJ`
Statement sm ; U!`'Qw;
sm = cn.createStatement(insert into user...); *K 7L5.
sm.executeUpdate(); (l^lS=x
sm.close(); \ lKQ'_
sm = cn.createStatement("insert into corp...); <;T7qEIlo
sm.executeUpdate(); )-
\w
sm.close(); JjCf<ktE.
3、提交 S:j0&*
cn.commit(); *Xo f;)Z^
4、如果发生异常,那么回滚 Q6>vF)(
-
cn.rollback();