package stuman;4 g5 |1 B( ]( _' ?0 r7 j
import java.io.*;
2 q$ ?5 }3 {& `) V" mimport java.sql.*;
. k% J* J( ]$ y; u. Ypublic class sqlBean{/// 2 i {) n" c- @6 U# u
' J: W: S; g. ^) }! D% y7 Vpublic Connection conn=null; & y2 ~0 L5 T! }9 Z/ L5 y5 o8 S
0 @; ]7 l2 ]7 ^8 W7 r Zpublic ResultSet rs=null;
/ K' O) y/ ? P9 o5 ?
) F% o+ C( u+ `: N5 S- eprivate String DatabaseDriver="oracle.jdbc.driver.OracleDriver"; 2 ]9 D. U9 U) S$ w' w! |7 ?
% I+ p6 u$ S/ q) C D+ U7 v" I) C
private String DatabaseConnStr="jdbc racle:thin 192.168.0.26:1521 rcl,'scott',tiger";
( ^2 i" _ t" c% B* ^public void setDatabaseDriver(String Driver){ V" S. Z4 N: f: |' K
this.DatabaseDriver=Driver; 4 n) s: j. x+ H% ?3 n
} 8 [7 _5 f! {: @" |
public String getDatabaseDriver(){ * A, Z2 O1 Y! X) H
return (this.DatabaseDriver); " V2 D% x7 j8 R3 T1 O; S/ ^# {1 \& z, [
}
5 U+ ?9 f( ]! b/ i& G6 Q
) T2 ^! a! }, R! l/ spublic void setDatabaseConnStr(String ConnStr){
; Y- ]# z! _2 u* x/ L8 k( xthis.DatabaseConnStr=ConnStr;
8 K! ?5 K+ ?' x) y# x% I5 _7 `} ; _6 p4 a- }; j1 F9 T2 t2 i
public String getDatabaseConnStr(){
: i& n) B; K4 d! |# areturn (this.DatabaseConnStr);
! q6 e& ?* j& x% X7 A}
( W: y! w! R4 R! i/ }2 y
0 V+ s2 \$ @2 T/ d$ H, xpublic sqlBean(){/////构造函数
7 C9 N' F" D& |3 f) e! P O" gtry{
3 I R B' |2 S3 k9 M) @* \. n' Q6 y% }3 B- ~6 D5 @- q+ ~
8 x7 i( z! J/ H# v
Class.forName(DatabaseDriver);
- }0 k9 H" k( l+ v} + }! m; q' `( r. e6 y/ s+ w; K
catch(java.lang.ClassNotFoundException e){
. {& B4 X# \5 [" V; pSystem.err.println("加载驱动器有错误:"+e.getMessage( )); / A# Y' H% F- G3 n6 Y
System.out.print("执行插入有错误:"+e.getMessage());//输出到客户端
* j _0 C! U, @) I! W} + g$ A1 e6 T! X0 v a2 O1 e
}
& f' o5 e1 p& [% L
/ a& n9 Y* |/ }) B! F9 n6 Z
9 e' U6 [3 U& G- _public int executeInsert(String sql){
% s6 a u+ R1 D6 B9 n& yint num=0;
2 g/ a9 `) _% p! l3 Q- Btry{
D- M3 h3 `: JConnection conn = DriverManager.getConnection("jdbc racle:thin 192.168.0.26:1521 rcl", "scott", "tiger");
3 y* p4 y& N5 j3 |//conn = DriverManager.getConnection(strcon,"scott","tiger");
+ x8 \& Z/ j7 E g# d" m# ^, b
6 D, Z& H H n( u: I0 UStatement stmt=conn.createStatement( ); 2 k {7 ^2 Z9 l
num=stmt.executeUpdate(sql);
! J4 Z8 u) w/ }! X} . m; @/ @7 C; R
catch(SQLException ex){ * \5 X5 e- I/ } U: S9 R$ }% j! s
System.err.println("执行插入有错误:"+ex.getMessage() ); # N" a2 z4 l, o- t% @
System.out.print("执行插入有错误:"+ex.getMessage());//输出到客户端
3 p( G9 h; W" t O}
7 j8 x/ R3 l, }* I8 `" J
' ^) b- y8 j9 }: P$ {CloseDataBase();
2 U' U+ ~. I0 k0 I+ }5 hreturn num;
; {/ g9 f' `' m S8 K1 T} ! I& b7 t) ]8 O6 Q$ |
% A ^* N) k m$ kpublic ResultSet executeQuery(String sql){
4 |3 m4 s: m0 I2 K, E. o/ l, nrs=null; ! H$ M6 ]' y* a6 E
try{
! a% ^0 b5 ]1 W. |, x$ ?4 H//conn = DriverManager.getConnection("jdbc dbc:ClassDB","limq","123");- W7 j1 b+ W- n* g9 d
Connection conn=DriverManager.getConnection("jdbc racle:thin 192.168.0.26:1521 rcl", "scott", "tiger");
% _8 ~ P5 j7 A, C2 P) T
) L: s" G0 y+ L2 T9 xStatement stmt=conn.createStatement( ); & }! s& b3 r4 T3 Z
rs=stmt.executeQuery(sql);, ]! a1 U, R v7 h4 `, C
} - P: ]6 l& V3 ~
catch(SQLException ex){
5 |( \2 G* r F# W8 w% zSystem.err.println("执行查询有错误:"+ex.getMessage() ); - C/ b# X$ z2 f8 L4 S8 W
System.out.print("执行查询有错误:"+ex.getMessage()); //输出到客户端 {2 x4 Y9 [8 }
}
' f, h+ p* M* f2 I/ w2 S
& [7 x$ X( _1 L7 ^return rs; & c5 s) D1 c& R( B
}
# E6 Q& j# |) F! ~0 u2 V// delete data
0 T, Z7 B; f) p, R# y9 ]public int executeDelete(String sql){
0 m2 a6 v( j0 x% Q; Kint num=0;
8 p9 ?! t& Y# x; }1 [try{ ( Z$ `2 E2 ]' y+ J; _# T
$ R' X* e }1 e v
//conn = DriverManager.getConnection("jdbc dbc:ClassDB","limq","123");1 h. D! d- r0 q! q$ z; E
Connection conn=DriverManager.getConnection("jdbc racle:thin 192.168.0.26:1521 rcl", "scott", "tiger");8 J* D# P$ Q: N0 @( D5 D
0 f% r, g& g3 c' K! `$ AStatement stmt=conn.createStatement( );
" o! q+ B8 w' M% Vnum=stmt.executeUpdate(sql); + V) x4 U T, w1 i
} / A, Z( G7 P. f
catch(SQLException ex){ % C8 H, g5 P1 g) _9 E& ?9 p. `
System.err.println("执行删除有错误:"+ex.getMessage() ); $ V8 U3 ]# b- o) Q6 v% X- p
System.out.print("执行删除有错误:"+ex.getMessage()); //输出到客户端 " P, B+ v2 L3 s- q* Z9 t7 d+ j' c
}
" F$ v5 ?6 r* h! w2 d8 ~9 Q/ k" ?CloseDataBase();
, Z$ n3 q: I) `1 D* c) h9 Nreturn num;. k/ h: [2 h0 q% U0 i
}
% j, i( K1 v o! }public void CloseDataBase(){
/ Y# x5 E* b5 a8 K. E$ o5 }try{
$ ~7 X$ I) ~& r3 cconn.close(); ( N( R' T' }4 E l
}
: s$ E6 |1 E! i/ n" T# R mcatch(Exception end){
+ I( h' v$ ~1 F/ \, Q/ oSystem.err.println("执行关闭Connection对象有错误:"+end.getMessage( ) );
! h e. T! v! ?* r& jSystem.out.print("执行执行关闭Connection对象有错误:有错误:"+end.getMessage()); //输出到客户端
) Z9 g2 c2 z; A1 o8 e} % g5 C) N3 ~ w: }
} $ w! g/ v$ @) z+ y: r
} 6 F6 B1 Q4 b. p& x# [
连接的代码这是。。 |