java 数据库基本操作 G!e}j
@@
1、java数据库操作基本流程 -~<q,p"e
2、几个常用的重要技巧: }QWTPRn
可滚动、更新的记录集 RKoP6LGw
批量更新 :{wsd$Qlj
事务处理 0XQ".:+h
LRCS)UBY(.
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 zgq_0w~X
1、取得数据库连接 MUCJ/GF*
1)用DriverManager取数据库连接 v'
9( et
例子 c5=v`hv
String className,url,uid,pwd; !ulLGmUn
className = "oracle.jdbc.driver.OracleDriver"; 5|6z1{g8
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ."!8B9s
uid = "system"; PBAz`y2
pwd = "manager"; YL9t3]
Class.forName(className); Lilk8|?#W
Connection cn = DriverManager.getConnection(url,uid,pwd); 282+1X
2)用jndi(java的命名和目录服务)方式 ^EuyvftZ
例子 os(Jr!p_=
String jndi = "jdbc/db"; shDt&_n
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); HjUw[Yz+6
DataSource ds = (DataSource) ctx.lookup(jndi); I*vj26qvg
Connection cn = ds.getConnection(); (}~eD
多用于jsp中 wCq)w=,
2、执行sql语句 nIT ^'
1)用Statement来执行sql语句 Kc9mI>u H
String sql; 4ye`;hXy
Statement sm = cn.createStatement(); WnJLX ^;
sm.executeQuery(sql); // 执行数据查询语句(select) I?> -
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); #)PGQ)(
2)用PreparedStatement来执行sql语句 6XOpB^@
String sql; zNsL^;uT
sql = "insert into user (id,name) values (?,?)"; -X&!dV:= 4
PreparedStatement ps = cn.prepareStatement(sql); 2W"cTm
ps.setInt(1,xxx); AG$-U2ap
ps.setString(2,xxx); a_pCjG89
... =qS^Wz.
ResultSet rs = ps.executeQuery(); // 查询 DETajf/<F
int c = ps.executeUpdate(); // 更新 Z|Lh^G
];b!*Z
3、处理执行结果 :i,c<k
查询语句,返回记录集ResultSet ,8J*S
更新语句,返回数字,表示该更新影响的记录数 9$P l'>5
ResultSet的方法 F'5d\ v
1、next(),将游标往后移动一行,如果成功返回true;否则返回false :`>+f.)
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 n7, 6a
~U7\ LBF
4、释放连接 )Py+jc.
cn.close(); Z'>eT)
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection G%p!os\>
>Dp6@%
可滚动、更新的记录集 ^zWO[$n}tP
1、创建可滚动、更新的Statement vU$O{|J
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ' ! UF&
该Statement取得的ResultSet就是可滚动的 >h!.Gj
2、创建PreparedStatement时指定参数 8v)~J}[ Bz
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); !{]v='
ResultSet.absolute(9000); Y^jnlS)h
批量更新 S^Wqa:;
1、Statement SG|i/K|7
Statement sm = cn.createStatement(); yz2oS|0 '
sm.addBatch(sql1); R 6yvpH
sm.addBatch(sql2); R8r[;u\iV
... H`6Jq?\
sm.executeBatch()
S9"y@F
<
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 ANpY qV
2、PreparedStatement WlQ&Yau
PreparedStatement ps = cn.preparedStatement(sql); Etr8lm E
{ =iK6/ y`
ps.setXXX(1,xxx); GaK_9Eg-2
... E]eqvT NH
ps.addBatch(); %*Z2Gef?H
} }PIGj} F/
ps.executeBatch(); ;DgX"Uzm
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 9CU6o:'fW
)V$!
事务的处理 }rMpp[
1、关闭Connection的自动提交 dI0>m:RBz
cn.setAutoCommit(false); hA,rSq
2、执行一系列sql语句 XFf+efh
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close iJaNP%N
Statement sm ; lRATrp#T
sm = cn.createStatement(insert into user...); i8[Y{a*
sm.executeUpdate(); -Ib+ /'
sm.close(); +SA<0l
sm = cn.createStatement("insert into corp...); w6In{uO-Z
sm.executeUpdate(); nhXp_Z9
sm.close(); `1d`9AS2g
3、提交 /qhm9~4e3
cn.commit(); UVBw;V
4、如果发生异常,那么回滚 W$MEbf%1
cn.rollback();