package stuman;
, T6 L; }4 D) z- iimport java.io.*; % H. R: y( z; |8 ]; S4 R
import java.sql.*;
; j: t+ Y6 X" M. b4 Lpublic class sqlBean{/// 3 n' n: F% O( d2 o/ K( |6 X
7 X, l6 r$ x0 n. C5 Q3 Epublic Connection conn=null;
* B! p1 U* O; y6 {8 A# k9 [4 I% e$ i @
public ResultSet rs=null; 6 m7 |$ i* v3 m
6 @" D9 p( Y- ~$ `( [! s
private String DatabaseDriver="oracle.jdbc.driver.OracleDriver";
8 [9 ^, y& D) \
# G1 S9 N9 ?! pprivate String DatabaseConnStr="jdbc racle:thin 192.168.0.26:1521 rcl,'scott',tiger";
! r& D# t. m$ Q# P% _8 xpublic void setDatabaseDriver(String Driver){ 2 r" n- k! \8 Q
this.DatabaseDriver=Driver; ' W# N1 ]3 |7 p3 p- C! S0 H
}
8 N# }% s% j1 g1 zpublic String getDatabaseDriver(){ 9 `- ~2 ?7 M, K( x8 }
return (this.DatabaseDriver); & Q9 I4 b7 R! }1 D; g9 V. n3 Z; b
} 4 Z5 v. j/ O5 \& j9 m, ~$ r
0 v+ e# f+ H1 m/ M2 ]public void setDatabaseConnStr(String ConnStr){ 9 Z0 z. m) G/ D3 l5 i) Z
this.DatabaseConnStr=ConnStr; 6 f' G6 }& @& d
}
! F3 Z2 x0 W2 z& V1 u" {public String getDatabaseConnStr(){ + H/ \3 n6 `% ^- M
return (this.DatabaseConnStr);
7 S) h) l. m. r6 q+ p8 R} ; M X2 }, [- e4 D
# S; z( p: L7 a2 n3 b8 i- K4 E
public sqlBean(){/////构造函数 ! `! S3 ?, M1 E6 T( a
try{
( X. C) x8 z1 @& S/ w" E4 S0 a" f
( h$ }7 R* D; H! C7 S
$ G8 q: R7 j4 x2 cClass.forName(DatabaseDriver); 0 M; }6 F) C$ y8 Q
}
4 |9 n. P6 L2 i# m- jcatch(java.lang.ClassNotFoundException e){
/ Y! F' d: u: h; x/ G) k4 o" DSystem.err.println("加载驱动器有错误:"+e.getMessage( ));
$ J. D2 R X# O' B' y6 O5 bSystem.out.print("执行插入有错误:"+e.getMessage());//输出到客户端 ; F9 k# M+ r% {
} & [0 t4 h: _( r3 L. A& {8 }! p
} : O; |3 b; \9 a8 J1 w' `2 x
0 ]; W$ Q; Z! ]6 E" q7 K; C' J
" U! A* M5 J, l6 l! L Cpublic int executeInsert(String sql){ : [/ a/ e7 h4 }) \/ k8 B" t$ {
int num=0;
4 V, e7 M0 v8 n a( ctry{ 9 w3 b, I: m" ?
Connection conn = DriverManager.getConnection("jdbc racle:thin 192.168.0.26:1521 rcl", "scott", "tiger");
( v# ^; b! C7 c//conn = DriverManager.getConnection(strcon,"scott","tiger");
3 P1 I7 |7 k" o9 a' h6 I+ {7 I
' M! g+ q8 j9 JStatement stmt=conn.createStatement( );
3 n1 H: e! g9 _0 X+ enum=stmt.executeUpdate(sql); $ I" u) G( d% E( z# {8 ^- y
}
* y; q. f6 h: u2 i4 ?. Fcatch(SQLException ex){ # W+ g' Y0 @; p( K6 n) w4 i
System.err.println("执行插入有错误:"+ex.getMessage() ); - Q l' g, @& x4 n
System.out.print("执行插入有错误:"+ex.getMessage());//输出到客户端 ) ~2 r, p, \5 K% ~2 _( z" y( H
}
9 Y0 V* h& m, F- n- a) u1 {
4 J9 d9 ^. K0 j r) JCloseDataBase();
, I% g$ U# F" D0 x+ `! D# @2 oreturn num;
" ^" V1 x$ E7 ? x+ l& c+ c}
8 F' F2 ?1 Y9 J- t; a" Y8 T& o( i, r
public ResultSet executeQuery(String sql){ 9 |" q8 u; O: t2 A2 ?
rs=null; 6 V& k' ]' v( L- N' s5 E
try{
: ]) W( }* |( T( m: Z//conn = DriverManager.getConnection("jdbc dbc:ClassDB","limq","123");! j1 O+ x" r) `
Connection conn=DriverManager.getConnection("jdbc racle:thin 192.168.0.26:1521 rcl", "scott", "tiger");
4 B0 f9 [" Z' K G% F+ A: Q$ x }7 u( e1 A$ _
Statement stmt=conn.createStatement( );
7 V6 ^& V5 K" Z1 G, v# qrs=stmt.executeQuery(sql);- M% F" `3 s" m' _! u4 T
} % e6 ~1 d! p) P+ z& \/ M) C
catch(SQLException ex){ 2 g( }- {( ^* C( I0 C
System.err.println("执行查询有错误:"+ex.getMessage() );
, D _8 S1 M$ G: V; M, |0 Z# ASystem.out.print("执行查询有错误:"+ex.getMessage()); //输出到客户端 + } X' f# R4 B! n. z
} 3 @6 ^ s+ t$ m7 L. c
" u! Y5 v. g& a$ |- Q5 L6 Sreturn rs; ; v, z# q5 e6 ]4 \+ m: f
} ! x$ U8 V, L) g D' s: I5 a
// delete data
' h7 _7 `$ {- H8 |1 Kpublic int executeDelete(String sql){
$ i8 p1 }# e4 e8 aint num=0;
, @7 k7 ]0 C Y( J/ m. ctry{ : f( q' Y' s7 B8 J: H
6 g% U+ I0 E# n- c$ Q//conn = DriverManager.getConnection("jdbc dbc:ClassDB","limq","123");
+ n% A K0 q8 Q/ ]% c$ LConnection conn=DriverManager.getConnection("jdbc racle:thin 192.168.0.26:1521 rcl", "scott", "tiger");
; G& R' M, o" B1 \+ ^* B: T. H9 V+ p& ]( S$ t
Statement stmt=conn.createStatement( ); . O/ N* f. ?% v4 T# \
num=stmt.executeUpdate(sql);
* W5 J$ P! g+ Q. {* W' W3 R# _}
) `. p4 F5 c6 D5 @7 S1 y7 z8 I/ n( \* qcatch(SQLException ex){
/ D, c4 `6 A7 j6 D% e* R+ n" rSystem.err.println("执行删除有错误:"+ex.getMessage() ); 0 y8 C( G# ^- K0 b
System.out.print("执行删除有错误:"+ex.getMessage()); //输出到客户端
. X- F. Q* g8 |* d% a. H}
- y' m% L* R# e- m& ZCloseDataBase();
, e9 n0 O! e- c! X- T& a8 c; s8 ]return num;3 W4 T N2 L4 X) ]: s
}
4 N& _! o" C# cpublic void CloseDataBase(){ / }0 N0 v2 u( |6 R. v, H, \. M5 J
try{
@9 B! R. O; n' _8 a1 r- [conn.close(); - a3 R; v% w. B
}
9 \4 D. [% l; acatch(Exception end){
( A+ R8 G# e! ^* I0 H5 L9 \System.err.println("执行关闭Connection对象有错误:"+end.getMessage( ) );
" V. E. G2 N2 {/ \0 s) zSystem.out.print("执行执行关闭Connection对象有错误:有错误:"+end.getMessage()); //输出到客户端
, \/ t2 z% x- o9 v# H3 ]} ' v6 _3 B8 B4 Z" R# n! l- ?! T! l
}
7 ]6 c3 F4 G1 u/ a N' r3 a}
3 @6 [+ @5 {" D G连接的代码这是。。 |