java 数据库基本操作 'xGhMgR;
1、java数据库操作基本流程 Zis,%XY
2、几个常用的重要技巧: :Ev
gUA\4
可滚动、更新的记录集 hpb|| V
批量更新 z+{qQ!
事务处理 ,f$P[c
k:R\;l5
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 ] \_tO
1、取得数据库连接 ce}A!v
1)用DriverManager取数据库连接 }6/M5zF3
例子 ~uty<fP
String className,url,uid,pwd; fe98Y-e
className = "oracle.jdbc.driver.OracleDriver"; HbsNF~;
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; Opc szq5n
uid = "system"; TnK<Wba
pwd = "manager"; %HoD)OJe
Class.forName(className); hRu}P"
Connection cn = DriverManager.getConnection(url,uid,pwd); $5)#L$!,]
2)用jndi(java的命名和目录服务)方式 NimgU Fa
例子 (EY@{'.&
String jndi = "jdbc/db"; 3?]81v/
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); h%ys::\zF
DataSource ds = (DataSource) ctx.lookup(jndi); WcNQF!f
Connection cn = ds.getConnection(); dB0#EJaE
多用于jsp中 3WGE T[3
2、执行sql语句 $S|+U}]C
1)用Statement来执行sql语句 :VZS7$5
String sql; ~io. TS|r
Statement sm = cn.createStatement(); [Tp?u8$p`
sm.executeQuery(sql); // 执行数据查询语句(select) Zja3HGL
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); AG=PbY9
2)用PreparedStatement来执行sql语句 }3X/"2SW^
String sql; 8TT#b?d
sql = "insert into user (id,name) values (?,?)"; Cd
2<r6i
PreparedStatement ps = cn.prepareStatement(sql); ;Jg$C~3tf
ps.setInt(1,xxx); &zX W
ps.setString(2,xxx); H/x0'
... x"e;T,c
ResultSet rs = ps.executeQuery(); // 查询 IONo&~-l
int c = ps.executeUpdate(); // 更新 vjx'yh|
*$fM}6}
3、处理执行结果 \]]K{DO
查询语句,返回记录集ResultSet B=& [Z2
更新语句,返回数字,表示该更新影响的记录数 @tm2Y%Y!
ResultSet的方法 aO&{.DO2
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 9U6$-]J
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 bHnKtaK4c
<m`CLVx8m
4、释放连接 /-[vC$B"
cn.close(); iIX%%r+
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection A'z]?xQR
Ia}qDGqPp!
可滚动、更新的记录集 >B**fZ~L
1、创建可滚动、更新的Statement ZY`9
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); Uq#2~0n>
该Statement取得的ResultSet就是可滚动的 %Tp
k1
2、创建PreparedStatement时指定参数 3Z9Yzv)A
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); (l{8Ixs
ResultSet.absolute(9000); ;P)oKx
批量更新 JP<j4/
1、Statement M1-tRF
Statement sm = cn.createStatement(); sPvs}}Z]P
sm.addBatch(sql1); 2[+.*Ef
sm.addBatch(sql2); pxTtV g.
... ;QXg*GNAv$
sm.executeBatch() :5%98V>02
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 bTimJp[b
2、PreparedStatement C`i#7zsH
PreparedStatement ps = cn.preparedStatement(sql); X1.-C@o
{ KqntOo}
y)
ps.setXXX(1,xxx); n~ad#iN
... `~)?OTzU#
ps.addBatch(); ?DUim1KG
} #RR;?`,L}
ps.executeBatch(); t"GnmeH
i
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 ,W)DQwAg
MSS[-}
事务的处理 ZL<X*l2
1、关闭Connection的自动提交 F8-GnTxa
cn.setAutoCommit(false); SED52$zA
2、执行一系列sql语句 Wn@oG@}~
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close 5WHz_'c
Statement sm ; >2{Y5__+e
sm = cn.createStatement(insert into user...); qSr]d`7@
sm.executeUpdate(); giNXXjl
sm.close(); J\*uW|=F
sm = cn.createStatement("insert into corp...); h#r~2\q4ei
sm.executeUpdate(); /e>%yq<9B
sm.close(); D=z~]a31!
3、提交 -\f7qRW^U
cn.commit(); #17 &rizl
4、如果发生异常,那么回滚 OXrm!'
cn.rollback();