java 数据库基本操作 .qPfi]
ty
1、java数据库操作基本流程 "8
mulE,
2、几个常用的重要技巧: %4KJ&R
(>[
可滚动、更新的记录集 -Dm.z16
批量更新 6(^9D_"@
事务处理 ?i=!UN
\)]2Uh|
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 N9|.D.#MF
1、取得数据库连接 Oo .Qz
1)用DriverManager取数据库连接 ~ b_gwJ'
例子 #iDFGkK/
String className,url,uid,pwd; ! HC<aWb
className = "oracle.jdbc.driver.OracleDriver"; BT#g?=n#`
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; }f'1x%RS^
uid = "system"; j}*+-.YF
pwd = "manager"; JB_`lefW,'
Class.forName(className); @h,$&=HY
Connection cn = DriverManager.getConnection(url,uid,pwd); ~8{3Fc 0
2)用jndi(java的命名和目录服务)方式 !QspmCo+
例子 GLF"`M /g
String jndi = "jdbc/db"; Y6PA\7Y\
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); p>O< "X@
DataSource ds = (DataSource) ctx.lookup(jndi); Y/(-mcR
Connection cn = ds.getConnection(); ?zu{&aOX|
多用于jsp中 :J-5Q]#
2、执行sql语句 wKbymmG
1)用Statement来执行sql语句 ;O11)u?/s|
String sql; X5<.%@Z
Statement sm = cn.createStatement(); .)zISa*Xy
sm.executeQuery(sql); // 执行数据查询语句(select) T$;XJx
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); $ 3B?
2)用PreparedStatement来执行sql语句 ,4,c-
String sql; VrxH6 Y
sql = "insert into user (id,name) values (?,?)"; uy:=V}p
PreparedStatement ps = cn.prepareStatement(sql); }O
ps.setInt(1,xxx); ptQ(7N
ps.setString(2,xxx); VAt9JE;#
... @/FX7O{n:
ResultSet rs = ps.executeQuery(); // 查询 D:EF@il
int c = ps.executeUpdate(); // 更新 ;P~S/j[ 8
VC7F#a*V
3、处理执行结果 i8.[d5
查询语句,返回记录集ResultSet nWu4HFi
更新语句,返回数字,表示该更新影响的记录数 AMz=HN
ResultSet的方法 2&URIQg*J
1、next(),将游标往后移动一行,如果成功返回true;否则返回false Y1\vt+`O
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 SqB|(~S
AoeW<}MO
4、释放连接 "M &4c:cz
cn.close(); s\!vko'M
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection -~f.>@Wb
s3 $Q_8H
可滚动、更新的记录集 Jo <6M'
1、创建可滚动、更新的Statement tvRy8u;
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); n.RhA-O
该Statement取得的ResultSet就是可滚动的 J}CK|}
2、创建PreparedStatement时指定参数 jF9CTL<
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); 09s}@C
ResultSet.absolute(9000); {E|gV9g
批量更新 RiG!TTa
b
1、Statement He3zV\X[Z
Statement sm = cn.createStatement(); e]?S-J' z
sm.addBatch(sql1); =i?,y +<
sm.addBatch(sql2); 'O9=*L)X
... f34&:xz2U
sm.executeBatch() Lm#d.AD)
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 4V8wB}y7e
2、PreparedStatement cyg>hX{U
PreparedStatement ps = cn.preparedStatement(sql); ^^uD33@_
{ eCD,[At/
ps.setXXX(1,xxx); +to9].O7y
... 7+4"+CA
ps.addBatch(); o#/iR]3
} =]"|x7'!
ps.executeBatch(); dC#\ut%l
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 vW3Zu B
*DzPkaYD>
事务的处理 Y3>\;W*?
1、关闭Connection的自动提交 8-YrmP2k
cn.setAutoCommit(false); "\?G
2、执行一系列sql语句 S]O Hv6
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close uf]$@6)
Statement sm ; >+8I =S
sm = cn.createStatement(insert into user...); J?fh3RW9
sm.executeUpdate(); N)WG~=Gi
sm.close(); % 6.jh#C
sm = cn.createStatement("insert into corp...); RNtA4rC>#
sm.executeUpdate(); t'x:fO?cp
sm.close(); $VIq)s2az|
3、提交 vK`h;
cn.commit(); 5>Yd\(`K
4、如果发生异常,那么回滚 FH`&C*/F0Y
cn.rollback();