java 数据库基本操作 '"'RC O
1、java数据库操作基本流程 lR]FQnZ
2、几个常用的重要技巧: @|e
we.r
可滚动、更新的记录集 kU.@HJ[@j
批量更新 =T1Xfib
事务处理 #qeC)T
6E.[F\u
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 s-~`Ao'
<
1、取得数据库连接 SIc~cZ!Yu
1)用DriverManager取数据库连接 _/Ay$l;F
例子 U\M9sTqo
String className,url,uid,pwd; ES8(:5
className = "oracle.jdbc.driver.OracleDriver"; \r [@A3O
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ]bYmM@
uid = "system"; }{Ra5-PY
pwd = "manager"; +[4y)y`
Class.forName(className); kO$n0y5e
Connection cn = DriverManager.getConnection(url,uid,pwd); ab]Q1kD
2)用jndi(java的命名和目录服务)方式 Tr;.O?@{t}
例子 $9:
@M.
String jndi = "jdbc/db"; O2"V'(
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 7zIfsb
DataSource ds = (DataSource) ctx.lookup(jndi); eBY/Y6 R
Connection cn = ds.getConnection(); / vu]ch
多用于jsp中 q+cD
2、执行sql语句 )g}G{9M^
1)用Statement来执行sql语句 h0I5zQZm
String sql; tD4-Llj6
Statement sm = cn.createStatement(); I&<'A[vHl
sm.executeQuery(sql); // 执行数据查询语句(select) 1aUg({
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); b~@+6?
2)用PreparedStatement来执行sql语句 m_,Jbf
String sql; cvhwd\
sql = "insert into user (id,name) values (?,?)"; kp#XpcS
PreparedStatement ps = cn.prepareStatement(sql); yB 'C9wEH
ps.setInt(1,xxx); +wQ}ZP&
ps.setString(2,xxx); 2b-g`60<
... M0OIcMTv
ResultSet rs = ps.executeQuery(); // 查询 k4E9=y?
int c = ps.executeUpdate(); // 更新 ,s2C)bb-
KVUub'k
3、处理执行结果 $`lm]} {&
查询语句,返回记录集ResultSet \,r*-jr
更新语句,返回数字,表示该更新影响的记录数 ]Tg@wMgI
ResultSet的方法 2 )3oX
1、next(),将游标往后移动一行,如果成功返回true;否则返回false %5nEyZOq
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 %~,Fe7#p
R.vOYzo
4、释放连接 _x^rHADp
cn.close(); i
^2A:6}?
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection uh \Tf5
u|6-[I
可滚动、更新的记录集 oK$Krrs0&
1、创建可滚动、更新的Statement ]'w5s dP
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); V`HnFAW
该Statement取得的ResultSet就是可滚动的 z4$9,p
`
2、创建PreparedStatement时指定参数 zQ<;3+*
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); nHRk2l|
ResultSet.absolute(9000); 4:pgZz!
批量更新 4^ U%` 1
1、Statement F^S]7{
Statement sm = cn.createStatement(); 69apTx
sm.addBatch(sql1); 4=;j.=>0X
sm.addBatch(sql2); (U
4n} J
... 1LAd5X
sm.executeBatch() "fUNrhCx
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 xq=!1>
2、PreparedStatement .yFO]
r1aL
PreparedStatement ps = cn.preparedStatement(sql); KWAd~8,mk
{ oe0YxSauL
ps.setXXX(1,xxx); Z:es7<#y
... XXA]ukj;r
ps.addBatch(); o=K9\ l
} G6G-qqXy6
ps.executeBatch();
]qu6/Z
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 Fw
t
c\&;Xr
事务的处理 \sfc!5G
1、关闭Connection的自动提交 '> n&3`r5
cn.setAutoCommit(false); 0CK
2、执行一系列sql语句 *c&OAL]
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close FK94CI
Statement sm ; `!(%Rk
sm = cn.createStatement(insert into user...); +
#E?)
sm.executeUpdate(); 7J
?s&x
sm.close(); c h((u(G
sm = cn.createStatement("insert into corp...); 7Z<GlNv
sm.executeUpdate(); (n7{?`Yid
sm.close(); MNb9 ~kM
3、提交 x$D^Bh,
cn.commit(); 9yWf*s<
4、如果发生异常,那么回滚 I,HtW ),
cn.rollback();