java 数据库基本操作 >R+-mP!nj
1、java数据库操作基本流程 ]JrD@ Vy
2、几个常用的重要技巧: {A/r)
可滚动、更新的记录集 EtKq.<SJ
批量更新 +/~]fI
事务处理 2R[v*i^S
/jG?PZ=m
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 }a7d(7
1、取得数据库连接 (/e&m=~
1)用DriverManager取数据库连接 f#0HiE!
例子 ]n!V
String className,url,uid,pwd; Mu\V3`j
className = "oracle.jdbc.driver.OracleDriver"; T/_u;My;
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; =AIFu\9#a`
uid = "system"; QK]P=pE'C
pwd = "manager"; Vu:ZG*^
Class.forName(className); ;W,* B.~
Connection cn = DriverManager.getConnection(url,uid,pwd); [';o -c"!
2)用jndi(java的命名和目录服务)方式 hdPGqJE
例子 %Mda<3P
String jndi = "jdbc/db"; !8H0.u
rw
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); 1dQAo1
DataSource ds = (DataSource) ctx.lookup(jndi); r&{8/ 5"
Connection cn = ds.getConnection(); nTeA=0 4
多用于jsp中 @dWA1tM
2、执行sql语句 l<v{8:,e #
1)用Statement来执行sql语句 JQV%W+-@
String sql; g3:@90Ba
Statement sm = cn.createStatement(); GV0\+A"vD
sm.executeQuery(sql); // 执行数据查询语句(select) AxH;psj
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 6g|,]{
2)用PreparedStatement来执行sql语句 ,:?ibE=
String sql; J,=K1>8s
sql = "insert into user (id,name) values (?,?)"; hX.cdt_?
PreparedStatement ps = cn.prepareStatement(sql); /5NWV#-
ps.setInt(1,xxx); _3`GZeGV
ps.setString(2,xxx); Jt_=aMY:7
... 6] x6FeuS
ResultSet rs = ps.executeQuery(); // 查询 T
lXS}5^
int c = ps.executeUpdate(); // 更新 gP%<<yl
:zHSy&i`
3、处理执行结果 q" VmuQ
查询语句,返回记录集ResultSet yKML{N1D
更新语句,返回数字,表示该更新影响的记录数 o?baiOkH
ResultSet的方法 \.i7(J]
1、next(),将游标往后移动一行,如果成功返回true;否则返回false :3D8rqi:
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 JHxcHh
:Awwt0
4、释放连接 Z",0 $Gxu
cn.close(); 1=5"j]0hY
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection +^AdD8U
E{,WpU
可滚动、更新的记录集 /TMVPnvz.
1、创建可滚动、更新的Statement 'V&g"Pb
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); q[U pP`Z%
该Statement取得的ResultSet就是可滚动的 vMzL+D2)
2、创建PreparedStatement时指定参数 )G2Bx+Z;L
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); Ne
u$SP
ResultSet.absolute(9000); -'&l!23a~
批量更新 XJ7B?Zg
1、Statement 7P$*qj~Vh
Statement sm = cn.createStatement(); ?NoNg^ Of
sm.addBatch(sql1); Otq3nBZ
sm.addBatch(sql2); &lzY"Y*hA0
... [G_ ;78
sm.executeBatch() 4e#g{,
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 G#7*O`
2、PreparedStatement $O |Xq7dp
PreparedStatement ps = cn.preparedStatement(sql); #un'?]tZF
{ [J2evi?
ps.setXXX(1,xxx); >!fTWdD^
... B&MDn']fV/
ps.addBatch(); W? G4>zA
} CEj_{uf|
ps.executeBatch(); Te+#
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。
K3zY-yIco
3~sV-
事务的处理 [Q T ;~5
1、关闭Connection的自动提交 \n}%RD-Ce
cn.setAutoCommit(false); c]*yo
2、执行一系列sql语句 R~=c1bpdq
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close z(A60b}
Statement sm ; fHaF9o+/b
sm = cn.createStatement(insert into user...); (Nzh1ul\}
sm.executeUpdate(); Ic3a\FTr\
sm.close(); ^iH[
22b4
sm = cn.createStatement("insert into corp...); K"l~bFCZ8
sm.executeUpdate(); 4zs0+d+
sm.close(); 3ML^ dZ'
3、提交 u&*[
cn.commit(); ~=yU%5 s@
4、如果发生异常,那么回滚 *L<EGFP
cn.rollback();