java 数据库基本操作 zN:K%AiGxe
1、java数据库操作基本流程 .[JYj(p
2、几个常用的重要技巧: <\pfIJr$
可滚动、更新的记录集 t<|NLk.
批量更新 MgNU``
事务处理 6Qy@UfB
!=:$lzS^
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 /x[jQM\
1、取得数据库连接 +i2}/s@JJ
1)用DriverManager取数据库连接 @>)r}b
例子 ^]a #7/]o
String className,url,uid,pwd; P:aJ#
className = "oracle.jdbc.driver.OracleDriver"; "0cID3A$
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ek}a}.3 {
uid = "system"; zOa_X~!@
pwd = "manager"; 9)gC6IiW
Class.forName(className); L G1r]2
Connection cn = DriverManager.getConnection(url,uid,pwd); \8 h;K>=h
2)用jndi(java的命名和目录服务)方式 eK!V
);
例子 IuRmEL_Q_
String jndi = "jdbc/db"; [ zEUH:9D
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); )_i
qAqkS
DataSource ds = (DataSource) ctx.lookup(jndi); vbD{N3p)?n
Connection cn = ds.getConnection(); YGPy@-,E
多用于jsp中 5wh|=**/
2、执行sql语句 (m:Zk$
1)用Statement来执行sql语句 Oms. e
String sql; dOoK Lry
Statement sm = cn.createStatement(); Jh?dw3Ai^
sm.executeQuery(sql); // 执行数据查询语句(select) !gv`FE9y
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); X6mqi;+
2)用PreparedStatement来执行sql语句 qQsku;C?i
String sql; v>-VlQ
sql = "insert into user (id,name) values (?,?)"; dnb)/
PreparedStatement ps = cn.prepareStatement(sql); n_(/JE>
ps.setInt(1,xxx); PX
n;C/
ps.setString(2,xxx); f1 _<G
... OI0;BBZ
ResultSet rs = ps.executeQuery(); // 查询 d~`x )B(
int c = ps.executeUpdate(); // 更新 JMz;BAHT
7e#?e+5+A
3、处理执行结果 Tp_L%F
查询语句,返回记录集ResultSet KFvQ
更新语句,返回数字,表示该更新影响的记录数 %d(^d
ResultSet的方法 .%Ta]!0
1、next(),将游标往后移动一行,如果成功返回true;否则返回false
X~<("
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 *EZHJt9
e*;c(3>(
4、释放连接 F>-B3x
cn.close(); NX/;+{
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 8$ma;U d
(s7;^)}zx
可滚动、更新的记录集 lobGj8uxq
1、创建可滚动、更新的Statement 75T7+:p
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); B,@c;K
该Statement取得的ResultSet就是可滚动的 ]):<ZsT
2、创建PreparedStatement时指定参数 C~N/A73gF
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); %y|)=cm[
ResultSet.absolute(9000); {jho&Ai
批量更新 k'IYA#T6
1、Statement R@6zGZ1
Statement sm = cn.createStatement(); _;~,Cgfi
sm.addBatch(sql1); I]Dl /
sm.addBatch(sql2); ~D5\O6mU-
... OQ>x5?um
sm.executeBatch() mysetv&5
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 R&Jm
+3N
2、PreparedStatement CO2C{~Q5
PreparedStatement ps = cn.preparedStatement(sql); ]zQo>W$
{ ;r>snJ=M
ps.setXXX(1,xxx); +tk{"s^r*
... bVL9vNK
ps.addBatch(); 3plzHz ,x
} 'C
~y5j
ps.executeBatch(); 8-_QFgY
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 _&j}<K$-(
vt;{9\Y
事务的处理 nM-h&na{s
1、关闭Connection的自动提交 V {pj~D.E
cn.setAutoCommit(false); lI-L`
x
2、执行一系列sql语句 _/s(7y!
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close Lv'D^'I
Statement sm ; &*7?)eI!i
sm = cn.createStatement(insert into user...); DV\`Wv
sm.executeUpdate(); B]Y}Hu
sm.close(); j^;I3_P
sm = cn.createStatement("insert into corp...); jGEt+\"/QJ
sm.executeUpdate(); lm xr oHE
sm.close(); -t2+|J*
3、提交 -#2)?NkeE
cn.commit(); _jNj-)RB_
4、如果发生异常,那么回滚 v}tag#f5>?
cn.rollback();