该用户从未签到
|
- package s2.jsp.zhangixao.dao;
1 J* l! {8 ]. f5 R/ M; E
. g" M: `; G. p' B4 m4 T' \4 u- import java.sql.Connection;
3 m, C3 ~: n- u# q9 g - import java.sql.DriverManager;, v5 b1 E8 _! B" {* ^- l
- import java.sql.PreparedStatement;, q* f! S, o0 h$ }
- import java.sql.ResultSet;
7 e5 _* @( `3 _' ? - import java.sql.SQLException;
' _8 r t. Y9 Q6 p - /** a% p! z1 h6 G) Z) \5 K
- * 访问数据库% R) S% `8 I) I
- * @author Administrator
! E4 _# ]" v$ Z0 r0 P* Q: E% ]0 a - *
+ p8 w( Y0 Y' |$ q: ^( b - */
6 p3 f) I0 @/ \0 I- y0 \ - public class MessageBase {
- i3 `4 X. r/ d1 Q% M1 k) Q+ y- j - private static final String DRIVER="com.microsoft.sqlserver.jdbc.SQLServerDriver";
6 u5 I b0 A, D* a9 M2 } - private static final String URL="jdbc:sqlserver://localhost:1433;DataBaseName=messageboard";* @% u9 S$ K3 s/ A( v- |
- private static final String DBNAME="sa";5 n- K& q# R8 I5 o6 j- z2 c1 g" @
- private static final String DBPASS="";( V, C: J% T$ o) T1 @/ H ?
- /**0 w! T1 V# M& I: C9 Y
- * 连接数据库# @: R7 `2 X; ~* U
- * @return
2 G6 o9 U% d" X8 S( M - */
+ ?* a3 v( S) `4 d - public static Connection getConnection(){
8 Z2 T5 k' K2 A' `, N' Q - Connection con=null;
4 j) k& a# [+ _0 G% r8 ^( H - try {
0 k% N9 e g( k9 q5 u. p - Class.forName(DRIVER);- Z' j2 v; U) n8 l
- con=DriverManager.getConnection(URL,DBNAME,DBPASS);
( |& W" e' @' T3 f3 A - } catch (ClassNotFoundException e) {
& {7 G# ]! f2 d8 w$ X! s& q' k; ?; A - System.out.println("加载驱动出现异常");$ t# ?7 e+ `4 g' ]6 I$ j. V
- e.printStackTrace();9 Z( M r; H4 a: h+ L* x' L
- } catch (SQLException e) {
; y6 L# H( I. m( D8 T - System.out.println("数据库连接出现异常");( Y2 H6 u; ~2 t( a0 d0 b
- e.printStackTrace();" n: P8 y# L- o, G
- }0 |: A2 x/ Z; y2 K
- return con;" ]9 k5 M& T! m" V
- } e& T/ |" P& Q! V
- /**
o A( B5 U" o3 F. V - * 关闭数据库
) q+ K' W. i$ z g+ s+ A4 J - * @param con, \3 o( O3 V. P- D) B7 H9 U, |) ^
- * @param past
9 i1 J: J3 {! v' k5 U - * @param rs% P% R; s# u1 Q# U: r- ~
- */ M6 @1 g$ {! v; P
- public static void CloseAll(Connection con,PreparedStatement past,ResultSet rs){
8 [) [3 g' @" C( X# N- u1 y: k -
" c. z- Q( M6 M - if (rs!=null) {
. t# x; T: N- | - try {7 E% t0 A+ T3 S0 o& U3 f# C: i3 O
- rs.close();: T! D, Y/ y% z2 `/ |
- } catch (SQLException e) {
. [$ ^( S& o0 s: k r; }9 \! q - System.out.println("rs 关闭出现异常");9 M- ~0 B6 Z. {5 s7 I. d
- e.printStackTrace();* h7 E5 }4 a3 D! M- u
- }
1 N" x( b M) T5 b" |9 _9 q+ f - }
. m6 g) d# ]. N1 q - if (past!=null) {
* p! {7 B1 b( s0 p, S! \ - try {( k5 x) T0 w3 Q2 y/ }4 y+ m2 M
- past.close();
?7 T7 S+ z$ `9 z; z: V7 k$ W. r - } catch (SQLException e) {
* n! S. K! F- U; N* N3 q! r - System.out.println("past 关闭出现异常");1 h0 D1 Y+ x# W" A' P, T
- e.printStackTrace();/ l3 o) U- W1 x4 K* r
- }4 T" U6 k0 S$ i$ l! I8 l
- }2 t) {* b. P$ ?
- if (con!=null) {0 L2 ^; q) M; n" u; q8 _
- try {
1 p5 H- q2 h |7 v+ L/ G# m - con.close();
$ T f* v: [( Z1 g# P9 ` - } catch (SQLException e) {4 T0 i: p, i( {8 `
- System.out.println("con 关闭出现异常");
" i* s; k+ k- [+ }* @8 M/ k - e.printStackTrace();+ q% o. T; q3 E, [3 n; v& R1 C
- }
) W' z! ?0 w+ ]7 k3 k" W. G - }
) I" @ B4 l( u( M8 J! Y - }6 _0 j# n. ?7 D$ G
- /*** N3 C7 j, o) u
- * 执行数据的增删改操作
9 ?3 l8 Q: Q" j' D; H - * @param sql2 M) C; R$ E* j7 L( k& F7 K( Z+ S6 z5 g
- * @param getValues& j2 q d# Q& H$ f# s
- * @return
/ ?1 I& K9 b6 | - */5 k4 g& K, n, j
- public static int executeUpdate(String sql,String[]getValues){
8 K% _; O ~; b) k2 D7 A: T - int t=0;& m- |: h, r& [6 h/ W
- PreparedStatement past=null;
$ @) _0 l. Z% ?0 L4 L$ |6 n - Connection con=null;# Z3 ]: `& u" m6 y
- try {
. E/ \7 S) Y b4 c - con=getConnection();7 x! \: t& b. Y7 v
- past=con.prepareStatement(sql);
2 ]- o6 G4 G1 x7 g# m" Z: D \ - if (getValues!=null) {9 K& _, p' n5 K% S# @
- for (int i = 0; i < getValues.length; i++) {
) G' j; B, C: V* E2 P - past.setString(i+1,getValues[i]);8 N( v% z/ _& \# X
- }
, ]! ~$ T9 o! |, x( |9 p - }
# h( L/ i w0 Q$ d" T! ~+ T$ @. T - t=past.executeUpdate();
7 ?. T" f: Z2 @& e- M1 X - } catch (SQLException e) {& w' G0 K/ e, I7 a: n- T# F
- System.out.println("执行数据库操作出现异常");
P* m- s/ B6 w4 F; s7 }( ^3 M9 { - e.printStackTrace();8 C* S4 k% F( A; E; R* T* ~( q, t
-
# w. q5 I1 @% s% \% f, w( ^ - }finally{
0 q" n; J9 f) _+ S; o$ D$ ] - MessageBase.CloseAll(con, past, null);5 d9 P+ A4 m! a1 X A
- }# V+ d% W1 ?+ l2 L- \) u2 D" S
- return t;9 G! e5 f$ y! g( {+ L
- }
% R F3 L7 b$ ]3 k9 B; l/ b/ M5 n4 y - /**; ]4 n6 x/ C& y* z" Q4 T9 b2 |
- * 测试连接
$ O Q Z! K* G0 v2 n! e) x - * @param args
% U) h. ^& N- @( E; q- n# g8 u! I - */
) T2 {# q& a: V3 b* S+ T: E - public static void main(String[] args) {2 \! F- j* k- u. I9 I% ^$ D
- Connection conn=getConnection();
. S1 P1 l! \# X - if(conn!=null){ w1 B9 G8 v% ]2 |6 i+ i; j
- System.out.println("连接成功");
4 g K3 [' C, o- b1 ~3 |) O - }else{
! l; V0 {9 V: _# u - System.out.println("连接失败");
* @1 j Q- O" W; A) x6 { - }
# K z0 ^/ k, R/ J: Y V+ f) G" ~ - }
+ c3 P! P& w- ~& q - }6 m: u+ `) f Z4 L
复制代码- package s2.jsp.zhangixao.dao;* S! u) V/ T3 z# n) ~
- & H2 X4 P5 N: P8 Z
- import java.util.List;' |7 S5 H3 J; j; h3 T& Z
- 9 M k5 O0 D! Z* T& B: I
- import s2.jsp.zhangxiao.entity.Message;! R' r1 X9 v- O9 h4 T
- 2 W/ J6 R# {8 S- }9 Y
- /**; r% J( b' \9 G% }9 j$ g* D
- * 留言板接口9 |) M6 ^! m& C, H; n/ e
- * @author Administrator9 q; G1 W' @; Y$ J5 E
- *8 O' S; h8 b2 [' [* @
- */5 o. U) l3 J$ z" \5 V
- public interface MessageDao {# D. q5 u; }: v! T" @
- //添加留言9 C( ~3 j& j6 ]. ^9 N/ i9 }4 ?. _
- public int addMessage(Message message);
2 P0 [& s5 j% H2 l! }* j - //查询全部留言
+ a8 w J0 o. E9 K( | - public List selcetMessage();
& [# H; B4 M c - }& G4 I2 p1 Q6 A: t
复制代码 项目源码下载地址: 2 P7 B+ @$ g8 R; W7 _6 _
% H9 a' _5 W1 I* `/ K- r( c0 l3 P* V- M; ~+ ?8 J7 W8 l
" v I: o! [" O- b: @5 I
, a; J( `9 H' ~1 \ |
|