java 数据库基本操作 :}He\V
1、java数据库操作基本流程
: |>h7v
2、几个常用的重要技巧: m~iXl,r
可滚动、更新的记录集 ]J1dt N=
批量更新 LdYB7T,
事务处理 v> LIvi|]
h9t$Uz^N
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 MU`1LHg
1、取得数据库连接 0at/c-K`
1)用DriverManager取数据库连接 jZu[n)u'C
例子 {3|t;ZHk
String className,url,uid,pwd; |B?cVc0
className = "oracle.jdbc.driver.OracleDriver"; g#"zQv ON
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; C8J[Up
uid = "system"; 1T"`vtR
pwd = "manager"; F|'>NL-=
Class.forName(className); &p'Y^zL-
Connection cn = DriverManager.getConnection(url,uid,pwd); hr#M-K
2)用jndi(java的命名和目录服务)方式 {BP{C=p
例子 "M<8UE \n
String jndi = "jdbc/db"; %6|nb:Oa
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 5MroNr
DataSource ds = (DataSource) ctx.lookup(jndi); H9'$C/w
Connection cn = ds.getConnection(); &W|[r(
多用于jsp中 I,E?h?6Y
2、执行sql语句 &fDIQISC
1)用Statement来执行sql语句 Tr_w]'
String sql; !{ y@od@T
Statement sm = cn.createStatement(); "IZa!eUW
sm.executeQuery(sql); // 执行数据查询语句(select) 0pZ4BZdT|
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); {j{u6i
2)用PreparedStatement来执行sql语句 8o3E0k1
String sql; xsIY7Ss U
sql = "insert into user (id,name) values (?,?)"; J4k=A7^N
PreparedStatement ps = cn.prepareStatement(sql); 2":pE U{E
ps.setInt(1,xxx); Q1U\D
ps.setString(2,xxx); h=W:^@G
... 1vS#K=sb
ResultSet rs = ps.executeQuery(); // 查询 Ow+GS{-q
int c = ps.executeUpdate(); // 更新 LD+{o 4i
216 RiSr*
3、处理执行结果 TJ2=m9Z
查询语句,返回记录集ResultSet {0[tNth'h
更新语句,返回数字,表示该更新影响的记录数 >BV^H.SO|1
ResultSet的方法 x)
,eI'mf
1、next(),将游标往后移动一行,如果成功返回true;否则返回false ]3D0R;
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 b_$4V3TA
AiwOc+R
4、释放连接 tP:lP#9
cn.close(); BOX{]EOj
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection 9e<.lb^tP
hwPw]Ln/
可滚动、更新的记录集 h){0rX@:&
1、创建可滚动、更新的Statement @D]5c ivm_
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); ^ sOQi6pL
该Statement取得的ResultSet就是可滚动的 =J18eH!]
2、创建PreparedStatement时指定参数 &xU[E!2H%
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); ZJnYIK
ResultSet.absolute(9000); `"Jj1O@
批量更新 Q$a{\*[:+
1、Statement +! ]zA4x
Statement sm = cn.createStatement(); DEBB()6,
sm.addBatch(sql1); .6ylZ
sm.addBatch(sql2); evya7^,F
... 3$jT*OyG#
sm.executeBatch() )cX*I gO
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 Ab~3{Q]#
2、PreparedStatement qFicBpB
PreparedStatement ps = cn.preparedStatement(sql); B~'vCuE
{ Q3XpHnufu+
ps.setXXX(1,xxx); P9/q|>F
... `}D,5^9]
ps.addBatch(); kI,yU}<Fq
} Q{O+
ps.executeBatch(); Giid~e33
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 S){)Z
8f_l}k$Eg
事务的处理 1gE [v
1、关闭Connection的自动提交 Bj+S"yS
cn.setAutoCommit(false); #QS`_TlKk
2、执行一系列sql语句 ^4y,W]JUDt
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 6,^>mNm
Statement sm ; kVuUjP6(c
sm = cn.createStatement(insert into user...); fJ=0HNmX
sm.executeUpdate(); sSr&:BOsi
sm.close(); 5us:adm[pD
sm = cn.createStatement("insert into corp...); Z|&MKG24
sm.executeUpdate(); ^3G{|JB!+
sm.close(); kYM~d07 V
3、提交 |O{m2Fi
cn.commit(); 2% MC Yn
4、如果发生异常,那么回滚 im${3 >26
cn.rollback();