java 数据库基本操作
g\a q#QV
1、java数据库操作基本流程 {Z~ze` N/
2、几个常用的重要技巧: ,twm)%caU
可滚动、更新的记录集 f4|ir3oy
批量更新 e\*N Lj_(
事务处理 P Qi=
9;
aOUs:<
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 8ROZ]Xh,x
1、取得数据库连接 th{Ib@o
1)用DriverManager取数据库连接 r#6djs1
例子 #!4
HSBf
String className,url,uid,pwd; I5rAL\ y-G
className = "oracle.jdbc.driver.OracleDriver"; -8t&&fIA
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr;
n3s
uid = "system"; U{9yfy
pwd = "manager"; IBh?vh
Class.forName(className); )hfI,9I~
Connection cn = DriverManager.getConnection(url,uid,pwd); B+ZhQW
2)用jndi(java的命名和目录服务)方式 0qN+W&H
例子 rp!{QG
String jndi = "jdbc/db"; l<s6Uu"
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); <VT|R~
DataSource ds = (DataSource) ctx.lookup(jndi); okbW. ~
Connection cn = ds.getConnection(); (
D@U%
多用于jsp中 Qf}}/k|)k
2、执行sql语句 {9nH#yv
1)用Statement来执行sql语句 QnIF{TS=
String sql; e:|Bn>*
Statement sm = cn.createStatement(); ):5H,B+Vr&
sm.executeQuery(sql); // 执行数据查询语句(select) v-B&"XGy:
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); 73+)> "x>
2)用PreparedStatement来执行sql语句 E*}1_,q)
String sql; vUJQ<D
sql = "insert into user (id,name) values (?,?)"; 0?'v|5}
PreparedStatement ps = cn.prepareStatement(sql); g+KuK`\N%
ps.setInt(1,xxx); iE"+-z\U
ps.setString(2,xxx); /)XN^Jwa;m
... VyOpPIP
ResultSet rs = ps.executeQuery(); // 查询 mX@!O[f%9e
int c = ps.executeUpdate(); // 更新 bN>|4hS
?T8^tGD[
3、处理执行结果 5?Rzyfwk|
查询语句,返回记录集ResultSet V<t!gT#&o!
更新语句,返回数字,表示该更新影响的记录数 SD1M`PI
ResultSet的方法 a]?o"{{+
1、next(),将游标往后移动一行,如果成功返回true;否则返回false 'w`9lIax
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 #AH<dS
p+xjYU4^C
4、释放连接 7)l+hZ
cn.close(); "jP{m;p
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection C\1x3
`4t*H>:y
可滚动、更新的记录集 5uL!Ae
1、创建可滚动、更新的Statement W JG8E7
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); 0M;aTM
该Statement取得的ResultSet就是可滚动的 :qK^71gz
2、创建PreparedStatement时指定参数 `it
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); [^\HP]*Q{
ResultSet.absolute(9000); |SwW*C
批量更新 !u=A9i!
1、Statement ac/<N%
Statement sm = cn.createStatement(); aHSl_[
sm.addBatch(sql1); *nV*WUS3
sm.addBatch(sql2); $ I|K<slV
... Y|F~w~Cb
sm.executeBatch() Y86mg7[U/
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 f^@DuI
2、PreparedStatement kD_616
PreparedStatement ps = cn.preparedStatement(sql); )t$o0!
{ k '-5&Q
ps.setXXX(1,xxx); lQf38u||
... ~_|ZUb
ps.addBatch(); crr#tad.
} ?;CMsO*q
ps.executeBatch();
7D\:i1~
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 ew|e66Tw$
O|Y~^:ny
事务的处理 _K<Z
1、关闭Connection的自动提交 ~)]R
cn.setAutoCommit(false); nT/Azg
2、执行一系列sql语句 78FLy7
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close M IR))j;
Statement sm ; fO 6Jug
sm = cn.createStatement(insert into user...); w8(z\G_0
sm.executeUpdate(); h)sQ3B.}A
sm.close(); l]Q<BV
sm = cn.createStatement("insert into corp...); u=PYm+q{
sm.executeUpdate(); 3mLtnRX[m
sm.close(); ]}>uvl^l
3、提交 )~ghb"K
cn.commit(); a>BPK"K2
4、如果发生异常,那么回滚 t}f,j^`e
cn.rollback();