java 数据库基本操作 j3{I /m
1、java数据库操作基本流程 6@{(;~r
2、几个常用的重要技巧: B8V>NvE~o
可滚动、更新的记录集 4E]l{"k<
批量更新 aWWU4xe
事务处理 mKL<<L[
Li/O
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 toya fHf
1、取得数据库连接 i|w81p^o
1)用DriverManager取数据库连接 0?\Zm)Q~(
例子 im9G,e
String className,url,uid,pwd; wsIW
|@
className = "oracle.jdbc.driver.OracleDriver"; &,c``z
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; ZUVA EH%
uid = "system"; PE}:ybsX
pwd = "manager"; l_P-j96WD
Class.forName(className); {*0<T|<n
Connection cn = DriverManager.getConnection(url,uid,pwd); ![YX]+jqNp
2)用jndi(java的命名和目录服务)方式 @eD):Y
例子 tD(7^GuR
String jndi = "jdbc/db"; +cgSC5nR
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); RrX[|GLSJ
DataSource ds = (DataSource) ctx.lookup(jndi); h|VeG3H
Connection cn = ds.getConnection(); <lw`
3aa(
多用于jsp中 j9?}j#@
2、执行sql语句 EQb7-vhg
1)用Statement来执行sql语句 _aFl_\3>
String sql; !}v=N";c
Statement sm = cn.createStatement(); p^%YBY#,H
sm.executeQuery(sql); // 执行数据查询语句(select)
FT#8L
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); u37'~&o{U
2)用PreparedStatement来执行sql语句 s+,OxRVw(
String sql; Rzbj
sql = "insert into user (id,name) values (?,?)"; s>;v!^N?u
PreparedStatement ps = cn.prepareStatement(sql); 4zev^FR
ps.setInt(1,xxx); bJRN;g
ps.setString(2,xxx); 66/3|83Z
... 5][Ztx
ResultSet rs = ps.executeQuery(); // 查询 5R@
int c = ps.executeUpdate(); // 更新 \6E|pbJ}x
!sDh4jQ`
3、处理执行结果 ^?0DP>XA
查询语句,返回记录集ResultSet PP;}e
更新语句,返回数字,表示该更新影响的记录数 +BVym~*^
ResultSet的方法 8$85^Of
1、next(),将游标往后移动一行,如果成功返回true;否则返回false zVXC1u9B
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 Ir`eL
/<@SFF.
4、释放连接 *c~T@m~DR
cn.close(); !46RGU:I
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection k9 "[H'
uD1e!oU
可滚动、更新的记录集 D7lK30
1、创建可滚动、更新的Statement "!Uqcay-
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); x(hE3S#+
该Statement取得的ResultSet就是可滚动的 YQ+tDZY8`
2、创建PreparedStatement时指定参数 #E?(vA1
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); Mr;E<Lj ^K
ResultSet.absolute(9000); VL%UR{
批量更新 ~$iIVJ`
1、Statement P3cR l']
Statement sm = cn.createStatement(); _LMM,!f
sm.addBatch(sql1); LR.Hh
sm.addBatch(sql2); 6+.uU[x@
... N^HUijw<
sm.executeBatch() 2^mJ+v<
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 9o;^[Ql-
2、PreparedStatement _,xc[ 07
PreparedStatement ps = cn.preparedStatement(sql); g!$!F>[
{ KM}f:_J*lg
ps.setXXX(1,xxx); qfL~Wp2E;
... Ge-CY
ps.addBatch(); tk!t
Y8j
} TD'L'm|2
ps.executeBatch(); aGJC1x
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 lG4H:[5V
'MEz|Z
事务的处理 U}6.h&$
1、关闭Connection的自动提交 OTGofd2zf
cn.setAutoCommit(false); <KE 1f7c
2、执行一系列sql语句 )~+E[|
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close +=q$ x Ia
Statement sm ; (g[h
8
c
sm = cn.createStatement(insert into user...); _A+s)]}
sm.executeUpdate(); B^j
sm.close(); :"=ez<t
sm = cn.createStatement("insert into corp...); e\Y*F
sm.executeUpdate(); mz@T
sm.close(); 3Mxp)uG/
3、提交 ]Y2RqXA*
cn.commit(); g#F?!i-[F
4、如果发生异常,那么回滚 2"Ecd
cn.rollback();