package stuman;1 c# n e, p) S
import java.io.*; " O* m- z3 V, B
import java.sql.*;
3 {+ ~0 R- y8 F% fpublic class sqlBean{///
& k- N1 R5 f' L$ p; I+ o( C! ^+ i( |' x
public Connection conn=null; * L& q, h" c" @8 H# V
# h8 x: l4 L; i& w4 \
public ResultSet rs=null; . @ U: K# S2 Z1 i8 R
6 Z: m+ ?, g: ]$ _+ G( }
private String DatabaseDriver="oracle.jdbc.driver.OracleDriver";
$ U, @2 h7 J$ r: O8 M1 v9 H+ X1 {& e- @1 j" _3 z3 d
private String DatabaseConnStr="jdbc racle:thin 192.168.0.26:1521 rcl,'scott',tiger";
$ X8 F& a0 p2 I( w" F* Opublic void setDatabaseDriver(String Driver){
" m3 J/ @: K( K# |' b+ M" a2 ?+ kthis.DatabaseDriver=Driver;
6 K8 g) p5 x9 _9 l0 M5 ?, ]! j$ t}
8 y$ f# K. i7 F( G+ Epublic String getDatabaseDriver(){ # b4 G: @+ f- X; w1 E9 q
return (this.DatabaseDriver);
0 [, y% r1 x V8 s1 |} . d$ @; u3 q, o, S2 m$ b
8 H/ m N+ `8 V4 W4 t; [/ p7 c6 _
public void setDatabaseConnStr(String ConnStr){ # l+ A7 W' `! i5 v9 D* N3 u
this.DatabaseConnStr=ConnStr; : M1 r. S7 g' K6 S" S( W5 B) Y
}
7 k+ V0 n Z; I3 f6 fpublic String getDatabaseConnStr(){
& V% a+ B2 y& b0 P* L1 k- freturn (this.DatabaseConnStr);
) h- O, [$ D- F2 V% Y+ R3 f* c& i# m}
8 N# Y8 \9 t, t9 d, u0 W
: q6 m- T3 t, @public sqlBean(){/////构造函数 ( d3 C+ [" u" J J0 y% I
try{
' x( k# c& e7 q/ T. k" J* K0 J' } b1 ]: m
. M: F( P; F1 L l6 [
Class.forName(DatabaseDriver); / m R" Z7 z/ u8 L& f7 L7 F
}
: J7 X2 C9 `. m% q2 Vcatch(java.lang.ClassNotFoundException e){
: V& \: O3 w- p ~, K+ T8 q* NSystem.err.println("加载驱动器有错误:"+e.getMessage( )); . j& X/ X# E* `1 B. Y" O
System.out.print("执行插入有错误:"+e.getMessage());//输出到客户端
0 n: u$ J( Q7 N. {8 }3 \& ~}
, V' b' s# @" l( ]}
1 L0 U l- \* i; V+ H1 d. r6 i9 ?( E) L A) s0 h2 L
! r& D6 g5 M, U. t; O5 E/ T7 O* v5 k0 z, |
public int executeInsert(String sql){
) D X. X4 i6 I0 H: Gint num=0;3 B+ b% |7 @! G1 T
try{
) i a4 x/ g2 n! G+ D o: J( f9 fConnection conn = DriverManager.getConnection("jdbc racle:thin 192.168.0.26:1521 rcl", "scott", "tiger");4 m# Q" H2 _8 c5 ~- O
//conn = DriverManager.getConnection(strcon,"scott","tiger");1 x5 @* t3 d! G7 ]4 G
# ~# O$ J% T1 @
Statement stmt=conn.createStatement( ); : X' ~, {) g6 c, Q; Y) w: b' r
num=stmt.executeUpdate(sql);
; U2 B8 N- q* ~/ @( ~, e( ]6 k}
- L9 ? t8 V6 a1 x. ]catch(SQLException ex){ - ^' n4 K x. R6 ^9 y# l3 V
System.err.println("执行插入有错误:"+ex.getMessage() );
; S" j! f& t0 r2 b# sSystem.out.print("执行插入有错误:"+ex.getMessage());//输出到客户端
|+ ?4 C' F, ~3 L- L4 b5 L0 D}" ]( M* k- {# B9 C6 }' j d& ]6 ]3 |% j- O
5 d8 h, E+ {$ w! F
CloseDataBase();
4 ~/ r' T" D. Nreturn num;: ~$ A3 ~8 S1 l h) r& q8 g
} 3 e1 R$ _) }5 U
0 W3 I7 | P1 d% }" L
public ResultSet executeQuery(String sql){ ) o" f4 w8 L5 ^% m8 }" }
rs=null; 8 p+ r% b- x. D. W+ P+ H" S
try{ 3 o. b) z2 Y7 R5 @& J; s# o+ _
//conn = DriverManager.getConnection("jdbc dbc:ClassDB","limq","123");5 C; }( E: f5 |$ k' H
Connection conn=DriverManager.getConnection("jdbc racle:thin 192.168.0.26:1521 rcl", "scott", "tiger");! d+ _# m* |8 j' C* m9 I2 q
! T5 U& @3 w2 j2 G+ nStatement stmt=conn.createStatement( ); # l/ c$ O2 i; I; l) s; V, b
rs=stmt.executeQuery(sql);& w8 F! L) i1 D8 }
}
2 U5 t) [! E" ^4 F! fcatch(SQLException ex){
0 p& e3 k1 _( J7 i( q! a+ I0 OSystem.err.println("执行查询有错误:"+ex.getMessage() );
9 H. B8 C5 f5 _5 U& {7 SSystem.out.print("执行查询有错误:"+ex.getMessage()); //输出到客户端 / S" n8 v2 e: [
}
! D2 t6 Y" M0 [4 I& @1 z( y3 y- f) K9 {! L; A# W- ~7 f0 n
return rs;
3 L7 h4 v6 f5 O} 2 d {5 L9 m( Q3 [% q
// delete data & u# V3 ^6 @ p$ Q6 `5 c
public int executeDelete(String sql){
8 b& ]9 |. q' t" K$ x! Q( r& p- ~int num=0;
# l. K: P o$ i8 \try{ 3 J* V. j* G6 t! K* B
0 Z0 X- X, U i1 R- l1 Y
//conn = DriverManager.getConnection("jdbc dbc:ClassDB","limq","123");
4 T# f5 t. Y, TConnection conn=DriverManager.getConnection("jdbc racle:thin 192.168.0.26:1521 rcl", "scott", "tiger");% X* q$ x' |. Z9 E
4 Z" l6 j2 @; M& V' G& j) j6 FStatement stmt=conn.createStatement( );
: Q2 A& v6 `+ i+ m2 L6 m1 Rnum=stmt.executeUpdate(sql);
0 x3 D" a* D: f, u9 Z& z} 7 U2 K x5 ]" a! l, x
catch(SQLException ex){
6 ?7 ? F0 X; \5 r) L0 GSystem.err.println("执行删除有错误:"+ex.getMessage() );
6 B$ O# g0 S6 D- O) F) b; vSystem.out.print("执行删除有错误:"+ex.getMessage()); //输出到客户端
7 I. \$ E" |% C: ?. c; g}
$ w/ N, H/ x: p1 |1 h/ X/ p( WCloseDataBase();
, K$ K$ r5 O0 u6 @+ preturn num;$ \4 E& c( _' ?: {+ f1 L( T
} % `' Q+ u" z f! n
public void CloseDataBase(){ ) B1 H3 H- A* Z: M- }# `
try{ ( s% x4 `; `: C$ F) x O) N6 {
conn.close();
. ^! \0 u3 Y. Q} & L+ v/ K' Q2 U/ K8 l' E9 J+ @
catch(Exception end){ 5 V% f( V4 c3 T/ J
System.err.println("执行关闭Connection对象有错误:"+end.getMessage( ) ); 4 _4 p4 x5 i( R1 Q
System.out.print("执行执行关闭Connection对象有错误:有错误:"+end.getMessage()); //输出到客户端 i, r+ j3 G7 i' t( r0 m* ^
} : J1 d6 O2 e# W3 A4 D
} ) D7 v: P% w" y2 N) w% c Z
} 9 @- ^- Y; K1 P+ ^) Y7 ?# n
连接的代码这是。。 |