java 数据库基本操作 ga!t:O@w
1、java数据库操作基本流程 bY]aADv\
2、几个常用的重要技巧: A.(Z0,S-i
可滚动、更新的记录集 m[%&KW(
批量更新 ve'h z{W
事务处理 6$`8y,TMSt
^Z;5e@S
java数据库操作基本流程:取得数据库连接 - 执行sql语句 - 处理执行结果 - 释放数据库连接 a^|mF#
z
1、取得数据库连接 0urQA_JC
1)用DriverManager取数据库连接 fF<~2MiKw
例子 4R}2H>VV%
String className,url,uid,pwd; z${DW@o3
className = "oracle.jdbc.driver.OracleDriver"; $1/yc#w
u
url = "jdbc:oracle:thin:@127.0.0.1:1521:orasvr; |"\A5v|1
uid = "system"; h\:"k_u#
pwd = "manager"; 7!z0)Ai_>=
Class.forName(className); !~PV\DQN
Connection cn = DriverManager.getConnection(url,uid,pwd); 'BtvT[KM
2)用jndi(java的命名和目录服务)方式 j#.Aiy:,
例子 _18) XR
String jndi = "jdbc/db"; dd_n|x1
Context ctx = (Context) new InitialContext().lookup("java:comp/env"); i.6c;KU
DataSource ds = (DataSource) ctx.lookup(jndi); UG 9uNgzQ/
Connection cn = ds.getConnection(); %nT!u!#
多用于jsp中 )g+~"&Gcx
2、执行sql语句 $,F1E VJ
1)用Statement来执行sql语句 CO-9-sQx
String sql; AvH^9zEE(
Statement sm = cn.createStatement(); qy/xJ>:
sm.executeQuery(sql); // 执行数据查询语句(select) f D2.Zh
sm.executeUpdate(sql); // 执行数据更新语句(delete、update、insert、drop等)statement.close(); eUQrn>`
2)用PreparedStatement来执行sql语句 x7> '
1
String sql; `Z0FQ( r_
sql = "insert into user (id,name) values (?,?)"; sYYNT*
PreparedStatement ps = cn.prepareStatement(sql); "! m6U#^
ps.setInt(1,xxx); $CRu?WUS]'
ps.setString(2,xxx); l*":WzRGvF
... g-Vxl|hR
ResultSet rs = ps.executeQuery(); // 查询 d3<7t
int c = ps.executeUpdate(); // 更新 sA#}0>`3S
^#KkO3
3、处理执行结果 2old})CLJ
查询语句,返回记录集ResultSet ^e1@o\]
更新语句,返回数字,表示该更新影响的记录数 /&_$+Iun
ResultSet的方法 MA6(VII
1、next(),将游标往后移动一行,如果成功返回true;否则返回false )pbsvR_
2、getInt("id")或getSting("name"),返回当前游标下某个字段的值 nD{o8;
jH({Qc,97
4、释放连接 fX2sjfk
cn.close(); #Ipi 3
一般,先关闭ResultSet,然后关闭Statement(或者PreparedStatement);最后关闭Connection Vo"Wr>F
8,7^@[bzXx
可滚动、更新的记录集 Y;-$w|&P>
1、创建可滚动、更新的Statement ~l+2Z4nV
Statement sm = cn.createStatement(ResultSet.TYPE_SCROLL_ENSITIVE,ResultSet.CONCUR_READ_ONLY); +0_e a~{
该Statement取得的ResultSet就是可滚动的 ]{s0/(EA
2、创建PreparedStatement时指定参数 TD!--l*gL
PreparedStatemet ps = cn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY); SYkwM6
ResultSet.absolute(9000); s'b 4Me
批量更新 Y 3h`uLQ
1、Statement _(l?gj
Statement sm = cn.createStatement(); ?(0=+o(`
sm.addBatch(sql1); qILb>#
sm.addBatch(sql2); C3)*Mn3%P
... xhK8Q
sm.executeBatch() XXPn)kmWR
一个Statement对象,可以执行多个sql语句以后,批量更新。这多个语句可以是delete、update、insert等或兼有 vhIZkz!9
2、PreparedStatement m Q4(<,F
PreparedStatement ps = cn.preparedStatement(sql); "ngULpb{R
{ JlR$"GU
ps.setXXX(1,xxx); ~@ =(#tO.
... }IEwGoDwNs
ps.addBatch(); =h0vdi%{
} %;_94!(hC
ps.executeBatch(); Xdh2
一个PreparedStatement,可以把一个sql语句,变换参数多次执行,一次更新。 ^F,sV*
2. '` mGu
事务的处理 'b)qP|
1、关闭Connection的自动提交 iR?}^|]
cn.setAutoCommit(false); 7UIf
2、执行一系列sql语句 aD]!
eP/)
要点:执行每一个新的sql语句前,上一次执行sql语句的Statement(或者PreparedStatemet)必须先close wg%g(FO
Statement sm ; &hEn3u
sm = cn.createStatement(insert into user...); CRBj>
sm.executeUpdate(); Z<^;Ybw{`Z
sm.close(); `AYq,3V
sm = cn.createStatement("insert into corp...); }@eIO|
sm.executeUpdate(); :*f 2Bn
sm.close(); @}=(4%
3、提交 hw$!LTB2
cn.commit(); d~1uK-L]*
4、如果发生异常,那么回滚 rk6K0TQ8
cn.rollback();