java 数据库基本操作 TH; R
1、java数据库操作基本流程 J7= +
2、几个常用的重要技巧: Kqp(%8mf
可滚动、更新的记录集 KM}f:_J*lg
批量更新 ';TT4$(m
事务处理 C ~<'rO}|
E~%jX
}/
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 l)Pu2!Ic
1、取得数据库连接 56+s~hG
1)用DriverManager取数据库连接 )~+E[|
例子 ]l1\? I
String className,url,uid,pwd; :rHJ4Tl
className = "oracle.jdbc.driver.OracleDriver"; &y3OR1_Sm*
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; i=i(%yQ%
uid = "system"; 3Mxp)uG/
pwd = "manager"; W=#:.Xj[
Class.forName(className); bu:S:`
Connection cn = DriverManager.getConnection(url,uid,pwd); x^kp^
/f
2)用jndi(java的命名和目录服务)方式 ::ajlRZG
例子 PJ]];MQ
String jndi = "jdbc/db"; Y' %^NP}o
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); tE@;X=
DataSource ds = (DataSource) ctx.lookup(jndi); *pAV2V(!23
Connection cn = ds.getConnection(); l^|UCgRn
多用于jsp中 c0%"&a1]]V
2、执行sql语句 y.WEj?EL
1)用Statement来执行sql语句 txiP!+3OWB
String sql; 3pv4B:0
Statement sm = cn.createStatement(); T(f/ ?_%
sm.executeQuery(sql); // 执行数据查询语句(select) V}dJ.I /#
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 5Yl<h)1
2)用PreparedStatement来执行sql语句 oASY7k_3
String sql;
k\WR ]
sql = "insert into user (id,name) values (?,?)"; H
*[_cqnv
PreparedStatement ps = cn.prepareStatement(sql); POvP]G9'"
ps.setInt(1,xxx); y^%n'h{
ps.setString(2,xxx); k Mu8"Az
... vg3=8>#
ResultSet rs = ps.executeQuery(); // 查询 x7~r,x(xM
int c = ps.executeUpdate(); // 更新 `glBV`?^
QA<Jr5Ys
3、处理执行结果 vH#huZA?7
查询语句,返回记录集ResultSet f>W-
更新语句,返回数字,表示该更新影响的记录数 S-k8jm
ResultSet的方法 A<1hOSCz\
1、next(),将游标往后移动一行,如果成功返回true;否则返回false lEhk'/~
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 ,wIONDnLZ
/% M/
4、释放连接 $e*ce94
cn.close(); u/M+u;
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection w+yC)Rmz
5<UVD:~z
可滚动、更新的记录集 DV _2P$tT|
1、创建可滚动、更新的Statement b*`lk2oMa/
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); <4P4u*/o
该Statement取得的ResultSet就是可滚动的 Jh
]i]7r
2、创建PreparedStatement时指定参数 hnDBFQ{
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); @>p<3_Y1
ResultSet.absolute(9000); 3wC' r
批量更新 Qj.l:9%
1、Statement >rJnayLF
Statement sm = cn.createStatement(); c6X}2a'
sm.addBatch(sql1); %jJ>x3$F
sm.addBatch(sql2); /J:bWr
... /+\uqF8F
sm.executeBatch() PDrZY.-
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 pXJpK@z
2、PreparedStatement $`z)~6'
PreparedStatement ps = cn.preparedStatement(sql); bpKZ3}U
{ ?i06f,-
ps.setXXX(1,xxx); X_$Cb<e
... ^!9~Nwn
ps.addBatch(); Bh=u|8yxc
} DsT>3
ps.executeBatch(); D (h18
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 Z(Bp 0a
S%yd5<%_
事务的处理 qL6
|6-?
1、关闭Connection的自动提交 *T~Ve;3h;
cn.setAutoCommit(false); TW[_Ko86
2、执行一系列sql语句 :j]vf8ec
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close
^V#@QPK9
Statement sm ; sIK;x]Q)
sm = cn.createStatement(insert into user...); k[HAkB \{
sm.executeUpdate(); 76Vl6cPu>
sm.close(); `.x
Fiyc
sm = cn.createStatement("insert into corp...); /ew
Ukc8,
sm.executeUpdate(); v7DE
sm.close(); ^Nmg07_R
3、提交 {6~l$
cn.commit(); IaT$6\>
4、如果发生异常,那么回滚 C\di 7 z:
cn.rollback();