该用户从未签到
|
- package s2.jsp.zhangixao.dao;
$ b* z1 k4 O( A. r - 5 Q2 D2 y" { X0 ]
- import java.sql.Connection;
) F- v$ _9 }* M+ D8 G - import java.sql.DriverManager;
4 S) k) w+ k4 l2 y* b - import java.sql.PreparedStatement;
8 D8 g5 s- G# Q - import java.sql.ResultSet;
& P# h4 m* F7 Y) c! d - import java.sql.SQLException;
# r5 |6 Z- P* Q3 p! q% e/ H - /**/ K( p$ B4 k" A# n! _$ i% d9 j; x8 e
- * 访问数据库2 q; B5 c8 j( ~& t" C1 ?( L
- * @author Administrator
: t5 v2 q8 N- p: {) N$ v, } - *- I! h0 G: b" K( _# [& P6 E( L7 n
- */
$ z5 v5 o8 G5 _5 P - public class MessageBase {
# K- \, ]/ [6 b' p9 F: _* y - private static final String DRIVER="com.microsoft.sqlserver.jdbc.SQLServerDriver";
4 D0 W' G+ s: A) \ - private static final String URL="jdbc:sqlserver://localhost:1433;DataBaseName=messageboard";' k3 } K' D* y+ G
- private static final String DBNAME="sa";7 x6 u7 {" k H( p
- private static final String DBPASS="";. f. a! \) c( g% X! Y
- /**
; t! a! X8 ]. R$ X) [! k0 i" } - * 连接数据库; ]2 n( M, ^/ m _7 d% ]8 D7 y
- * @return6 ~! h" t; E" C6 r; T
- */
4 @. W$ ], _1 {+ { - public static Connection getConnection(){
$ k0 h3 R( ] u0 x& t - Connection con=null;
( T/ [" Z* a% T0 J: H" U8 N - try {
9 k9 w4 g, Z- r. f. e9 H' J - Class.forName(DRIVER);
" P: r$ {' X# t+ S. V$ _7 y+ P; _ - con=DriverManager.getConnection(URL,DBNAME,DBPASS);
- ^& }: b% E2 q - } catch (ClassNotFoundException e) {
2 x, z+ ~1 f, t" n* n: k& V1 O - System.out.println("加载驱动出现异常");
^; O3 Y# I) o2 A$ B - e.printStackTrace();3 S: j- Z5 u, M" c' O; u! Z9 K
- } catch (SQLException e) {
: S( K1 _/ P$ V7 l4 b8 r - System.out.println("数据库连接出现异常");; v% E$ {4 {& [$ c
- e.printStackTrace();
7 }8 h, x: U: q$ `" Y - }0 b- M# `7 N6 o) w% o
- return con;$ ?- T3 r$ o7 d. S
- }: p6 w/ B+ \1 l+ s9 v
- /**
& {( x$ n( }& M( [* } N - * 关闭数据库! Z5 d8 l1 w& p( I% U1 x4 |
- * @param con
# Z! r* C+ ?6 q' ]8 b% L - * @param past
" R; X R, A% C - * @param rs- P G( V8 v x& E" s" g
- */" [9 u7 F3 J/ Q6 d2 s
- public static void CloseAll(Connection con,PreparedStatement past,ResultSet rs){4 f$ o9 }: m7 L3 T! ~6 d. w2 P% n
-
0 g( V' B+ V# f$ V* } - if (rs!=null) {+ f1 s* \: e+ [# @; W/ F
- try {
( b3 t" x" W) X' G7 G" a" v% F$ m - rs.close();
6 T+ o! r( X& L3 U - } catch (SQLException e) {
. [- S: c/ A8 _& r: Z# v - System.out.println("rs 关闭出现异常");, V8 c% B: ^; f' q" E/ o
- e.printStackTrace();8 v2 D2 O! r' ~; D! C
- }
, a( Z9 m7 p `' S+ `4 S7 e - }% u& Z7 V* X5 j- C5 m, Q/ R( j1 S
- if (past!=null) {
& a0 s3 c% q" |+ ]) k; o - try {
8 E. @$ G6 j( e - past.close();) P3 B0 |7 g# h. q' @/ j! O
- } catch (SQLException e) {$ y) M9 I7 \1 a) p3 X: V: Z) u
- System.out.println("past 关闭出现异常");5 @9 `! P3 D6 |* F
- e.printStackTrace();3 h7 U( e9 f k; [0 X; Y9 N) l
- }0 g2 k0 j; H" p2 {
- }
# \7 B' {: G. x6 j& v1 n# ~, V% U - if (con!=null) {& w! ?6 f8 z3 k5 O
- try {
# n! u1 X+ O. X# X9 @0 V - con.close();4 c9 y+ G, h2 C( {
- } catch (SQLException e) {) I9 F& x+ k p5 r' x
- System.out.println("con 关闭出现异常");7 J: |4 [$ G0 M/ Y1 |+ D# N1 A) `
- e.printStackTrace();
# c6 L7 M7 W' R9 I7 m - }
- S. B @" M+ B: u - }
9 n$ N3 \7 @3 s, F$ r' U4 } - }$ I! C1 _* I9 @
- /** H. p6 d, ?/ r; I" b' Y
- * 执行数据的增删改操作
9 C8 E# n9 `& s# x6 p - * @param sql t; u$ ` Z; y. V' o$ c) y% M6 I
- * @param getValues
], ^( U% n' { - * @return* y- k2 _3 E( ~! T! L
- */4 a6 @: I2 s d5 Z5 }% f9 S2 N
- public static int executeUpdate(String sql,String[]getValues){4 L7 E" @6 G7 q$ r/ C
- int t=0;
2 j, { n- ?+ e6 i: Y - PreparedStatement past=null;# z$ `& m; u/ B5 q. N; V
- Connection con=null;) h; Z+ ^) r) a8 a. ?" _
- try {
' m, o5 B( r$ M7 @- T- S - con=getConnection();
0 m j: g2 L* M5 b - past=con.prepareStatement(sql);5 _- c0 A: r0 W: f9 _4 w
- if (getValues!=null) {0 m/ x- L: R- ~/ o2 ]
- for (int i = 0; i < getValues.length; i++) {
7 ^7 o7 D; e5 ^, L! h2 |& L7 O - past.setString(i+1,getValues[i]);7 ]. e5 @) E0 I ?
- }
6 X$ `& C9 D, q - }6 I' @. c& `3 z' n+ h! ^6 g. V% m
- t=past.executeUpdate();6 B+ M7 Q3 `' u( u. I2 t
- } catch (SQLException e) { h5 k& M, U! }5 M8 m
- System.out.println("执行数据库操作出现异常");
2 ~8 u- N: d; {% k - e.printStackTrace();
7 }) ~+ ]$ t) X/ M6 c - & N! s/ N+ l7 p! }# s* l6 P
- }finally{+ S- o/ y' o% k3 v/ i
- MessageBase.CloseAll(con, past, null);
- Q: U& @+ ^7 e/ W - }
# t- S* n4 F7 J( A - return t;
5 _! ~3 H( B# I" G# I0 \# s - }
: Q. t2 S1 V [3 i - /**
( N# Y% M( X% ?# P) u" z) @: W - * 测试连接3 q, H: V8 n( t$ J
- * @param args
! e7 }. K* P' Z1 Q( `7 ^: M - */- z- ?: P1 y) H: V0 X% w
- public static void main(String[] args) {
; ^( T2 X e- O9 K8 o. W( _ - Connection conn=getConnection();, V. H$ K$ @. M9 Z$ E
- if(conn!=null){
6 I. r# u" d0 f1 F6 z - System.out.println("连接成功");
7 p8 A- `9 s1 q. {+ }+ `& c - }else{ D/ Z# D+ U$ G0 L% [
- System.out.println("连接失败");: w* Y9 ?! R. r; r& k
- }; a" b" i7 K, n
- }
9 I4 n0 U$ T4 ]7 v1 A' n6 w2 _ - }
5 u ]! t& }5 ]# Y6 c
复制代码- package s2.jsp.zhangixao.dao;9 M4 m& u3 o m( w7 v: t, L
. ?: S. Q! m0 l" ^9 X& V- import java.util.List;$ A& x* V) L. G2 H
- 3 x) y! S" y- u
- import s2.jsp.zhangxiao.entity.Message;) P+ U" ]$ }. t( V! O! E! j
- " A5 w& }4 X2 d- T
- /**/ [8 h8 H4 w; F- b+ p- v
- * 留言板接口/ k6 f; h: Z0 G4 q) B
- * @author Administrator
% t4 P6 ]2 `) `' S - *2 c" ?2 a6 i0 v
- */
3 _, }" z9 V: y- K - public interface MessageDao {3 N) p. J: ^2 _( ^# n- E
- //添加留言( ~8 [0 a( l- r" q' [1 d1 |
- public int addMessage(Message message);: S+ ]8 I6 V* R1 J7 w/ ?
- //查询全部留言 z: Y! @8 i8 u7 R, _
- public List selcetMessage();* |! x9 d& x( N7 v5 z" k
- }# c+ C4 ^2 Z* o, Y r# r7 d
复制代码 项目源码下载地址: 7 z) E/ S( u# T9 v
, `2 @8 B U6 f" |' `3 y, ~2 h
. \& Y7 G, z, e* ]
D& d l8 C( l3 O5 G, v4 \, W/ }1 d! y
9 I6 e. u1 d) ^; f
|
|