java 数据库基本操作 }(,{^".[}
1、java数据库操作基本流程 U+C^"[B
2、几个常用的重要技巧: M27H{}v
可滚动、更新的记录集 u4bVp+
批量更新 qh6rMqq
事务处理 }0iHf'~DH*
Xz9[0;Q
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 qW'L}x
1、取得数据库连接 J~50#vHY
1)用DriverManager取数据库连接 Nr).*]g@~
例子 >]o>iOz;]
String className,url,uid,pwd; Z]x6np
className = "oracle.jdbc.driver.OracleDriver"; mI]gDL1
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; 5"X@<;H%
uid = "system"; %0Qq~J@Lu
pwd = "manager"; ?'tRu !~
Class.forName(className); lD-2 5~YV
Connection cn = DriverManager.getConnection(url,uid,pwd); ^AiQNL}
2)用jndi(java的命名和目录服务)方式 1N<n)>X4
例子 z4;@"B
String jndi = "jdbc/db"; {s@ 0<!
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 5:C>:pA V
DataSource ds = (DataSource) ctx.lookup(jndi); m]H]0T
Connection cn = ds.getConnection(); `5rfO6;
多用于jsp中 [HL>Lp&A?
2、执行sql语句 ZOpKi:\
1)用Statement来执行sql语句 $?dQ^]<,
String sql; sZ;Gb^{Z
Statement sm = cn.createStatement(); 1'F!C
sm.executeQuery(sql); // 执行数据查询语句(select) @^o7UzS4z
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); B<HN$/
2)用PreparedStatement来执行sql语句 v`]y:Ku|wR
String sql; ~>P(nI
sql = "insert into user (id,name) values (?,?)"; uPjp5;V
PreparedStatement ps = cn.prepareStatement(sql); `uZMln @
ps.setInt(1,xxx); <]X6%LX
ps.setString(2,xxx); 9X
+dp
... xGOVMo
+
ResultSet rs = ps.executeQuery(); // 查询 L./c#b!{
int c = ps.executeUpdate(); // 更新 g-1j#V`5
\CVHtV
3、处理执行结果 Xo&\~b#-
查询语句,返回记录集ResultSet cbs ;
更新语句,返回数字,表示该更新影响的记录数 H8=:LF
ResultSet的方法 !l Egta[Ql
1、next(),将游标往后移动一行,如果成功返回true;否则返回false F^aD#
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 WtaOf_
`j!_tE`
4、释放连接 E.+%b;Eqe
cn.close(); 9NNXj^7
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection i5&,Bpfo-
$EEn]y
可滚动、更新的记录集 ST;o^\B
1、创建可滚动、更新的Statement `w`F-ke]I
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); =LKM)d=1
该Statement取得的ResultSet就是可滚动的 E|+<m!
2、创建PreparedStatement时指定参数 %g{)K)$,ui
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); jA[Ir3
ResultSet.absolute(9000); >EZZEd
批量更新 29VX-45
1、Statement xplV6q`
Statement sm = cn.createStatement(); Wq"-T.i
sm.addBatch(sql1); /oLY\>pD
sm.addBatch(sql2); MLg{Y?@
... _[-W*,xJ)
sm.executeBatch() kyt HOn#
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 C'R6mz% Q?
2、PreparedStatement |0?v4%g
PreparedStatement ps = cn.preparedStatement(sql); 2eA.04F
{ 3D1y^I
ps.setXXX(1,xxx); ts}OE
... A*A/30o|R
ps.addBatch(); 3vjOfr`
} dv+ZxP%g
ps.executeBatch(); $mE3 FJP>
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 *?]<=IV?
jzGK(%sw"
事务的处理 xI~AZ:m
1、关闭Connection的自动提交 }P-C-L{yE(
cn.setAutoCommit(false); {@3v$W~7M
2、执行一系列sql语句 8lGM>(:o
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close ,<)D3K<
Statement sm ; L F } d
sm = cn.createStatement(insert into user...); TA2ETvz^
sm.executeUpdate(); ZS;V?]\(
sm.close(); E_DQ.!U!o
sm = cn.createStatement("insert into corp...); odC"#Rb
sm.executeUpdate(); Xo]2iQy
sm.close(); yU4mS;GX
3、提交 } .Z`
cn.commit(); 9V[}#(f$
4、如果发生异常,那么回滚 gIusp917
cn.rollback();