java 数据库基本操作 ul$k xc=N
1、java数据库操作基本流程 Fcz7
2、几个常用的重要技巧: ce@1#}*
可滚动、更新的记录集 F_.rLgGY
批量更新 CT,P Q
事务处理 Yl4XgjG
t%Sgw%f
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ^)oBa=jL4
1、取得数据库连接 Cp4 U`]
1)用DriverManager取数据库连接 ix2V?\
例子 `Y>'*4a\
String className,url,uid,pwd; *:S_v.Y3"
className = "oracle.jdbc.driver.OracleDriver"; $p:RnH\H1
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; vy&'A$ H
uid = "system"; sG{f xha
pwd = "manager"; SO @d\H
Class.forName(className); n@|5PI"bx
Connection cn = DriverManager.getConnection(url,uid,pwd); @h7)M:l
2)用jndi(java的命名和目录服务)方式 D$@5$./
例子 qF'lh
String jndi = "jdbc/db"; O*0%AjT6
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); c\A
4-08
DataSource ds = (DataSource) ctx.lookup(jndi); \PReQ|[ah
Connection cn = ds.getConnection(); {Tx"G9
多用于jsp中 'u@,,FFz[K
2、执行sql语句 gQ90>P:
1)用Statement来执行sql语句 O0^m_
String sql; )Y4;@pEU
Statement sm = cn.createStatement(); W]Bc7JM]T+
sm.executeQuery(sql); // 执行数据查询语句(select) e1cqzhI=nA
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); HiAj3
2)用PreparedStatement来执行sql语句 7PTw'+{
String sql; nv$>iJ^~H
sql = "insert into user (id,name) values (?,?)"; 6Qtyv
PreparedStatement ps = cn.prepareStatement(sql); jW]Q-
ps.setInt(1,xxx); BoJpf8e'-e
ps.setString(2,xxx); bu0i#
... zF:
:?L~
ResultSet rs = ps.executeQuery(); // 查询 M%&1j >d
int c = ps.executeUpdate(); // 更新 +;r1AR1)x
0?V{u`*
3、处理执行结果 0zQ~'x
查询语句,返回记录集ResultSet mIW8K
):
更新语句,返回数字,表示该更新影响的记录数 75v7w
ResultSet的方法 ^IQtXae6M
1、next(),将游标往后移动一行,如果成功返回true;否则返回false DVJuX~'|!
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 gq%U5J"x;J
^wass_8
4、释放连接 qwhDv+o
cn.close(); >EE}P|=-
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection R+sv? 4k
p1F{ v^
可滚动、更新的记录集 y{>T['"@
1、创建可滚动、更新的Statement S\76`Ot
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); u~rPqBT{d3
该Statement取得的ResultSet就是可滚动的 Q|KD$2rB
2、创建PreparedStatement时指定参数 c,>y1%V*S{
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); {L'uuG\9U
ResultSet.absolute(9000); 3~q#P
批量更新 B*Z}=$1j
1、Statement !NqLBrcv 0
Statement sm = cn.createStatement(); &=f] a
sm.addBatch(sql1); ,FIG5-e,}
sm.addBatch(sql2); xAwP
... af@R\"N9c
sm.executeBatch() ZR]p7{8B
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 -HwqR Ys
2、PreparedStatement y^0
mf|
PreparedStatement ps = cn.preparedStatement(sql); +MR]h
[
{ xig4H7V
ps.setXXX(1,xxx); q$7w?(Lk
... N)X3pWC8
ps.addBatch(); o[I
s$j
} i/{dD"HwM
ps.executeBatch(); h 8<s(WR
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 P*|qbY
h
?_@nQ!
事务的处理 xiv8q/
1、关闭Connection的自动提交 sA~Ijg"6
cn.setAutoCommit(false); D`'h8:\
2、执行一系列sql语句 w`GjQIA
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close zK_Q^M`
Statement sm ; ''^2rF^
sm = cn.createStatement(insert into user...); y$Fk0s*>
sm.executeUpdate(); ]qb>O:T
sm.close(); *j~ObE_y
sm = cn.createStatement("insert into corp...); -e\OF3Td
sm.executeUpdate(); ]FNe&o1zX
sm.close(); $b U.6
3、提交 /&N\#;kK?b
cn.commit(); 5X PoQ^
4、如果发生异常,那么回滚 XqLR2d
cn.rollback();