该用户从未签到
|
- package s2.jsp.zhangixao.dao;
5 c6 M5 \: }" W3 O5 e O
5 \. a' W! F4 F* {- import java.sql.Connection;% A# k- M( n; s& z$ G7 z6 H
- import java.sql.DriverManager;
! ?, p3 ~/ y+ e - import java.sql.PreparedStatement;6 j: ^2 A; [ b/ z
- import java.sql.ResultSet;
& H3 t% K6 c2 R: z - import java.sql.SQLException;% v4 O* t; u% K0 n" y
- /**
5 J9 A5 D. I9 J! h& j - * 访问数据库. `* O/ k- t+ D r. F5 T
- * @author Administrator
" b& J& Y+ y4 z5 ~3 o - *
; @5 ~6 R4 g& k - */) s$ J7 z2 J2 I+ F: i
- public class MessageBase {. s/ q& i3 h, ?1 s" S; i
- private static final String DRIVER="com.microsoft.sqlserver.jdbc.SQLServerDriver";
* f1 f3 ?4 H4 P+ y - private static final String URL="jdbc:sqlserver://localhost:1433;DataBaseName=messageboard";
, F0 e" g% _0 j# B' y: q* Y - private static final String DBNAME="sa";
/ |' m3 [; z0 J - private static final String DBPASS="";
/ s+ ]6 m8 n/ n - /**' y) }8 `( H' K/ G
- * 连接数据库
/ n7 X8 d! J9 R( V: v, Y - * @return7 P% b1 z/ M) i9 L t. L, V
- */% l( a; w. q9 L2 q
- public static Connection getConnection(){
- N, Y/ k! ^4 b. r- _ - Connection con=null;+ b& `& U) o8 f. A
- try {
5 Q7 [% s* J: _" b9 l - Class.forName(DRIVER);
0 f# A6 l# D" c5 D - con=DriverManager.getConnection(URL,DBNAME,DBPASS);' T i/ s2 \1 ~# o
- } catch (ClassNotFoundException e) {+ l, X! D3 D& |; U
- System.out.println("加载驱动出现异常");. T, K3 f4 n/ Z1 f) ~! h
- e.printStackTrace();: ?0 O( P1 y6 t0 I) H
- } catch (SQLException e) {
3 N# Q) q5 [# g. F - System.out.println("数据库连接出现异常");
5 w" \' R& z$ z, S% \9 E - e.printStackTrace();
! y0 z- N& g8 g5 ?" L+ p0 o8 s - }7 O; d0 g0 z+ m( q7 I1 n9 K; U) z
- return con;
( g" M- {4 Q" K8 k - }
1 x% U; d% q: `" j z& H9 r( | - /**& e# s9 X" i* \0 R3 Y8 A* h
- * 关闭数据库
' o& t7 R# e: F) }; E) Z5 x - * @param con7 X) x0 ] V8 h' ^* c) X/ j& M" w) n
- * @param past
+ u- z9 [8 {3 y8 T) R& G - * @param rs( x& E. v8 ?8 J G& T% s3 q
- */2 b' O# \. ^+ D7 w9 i2 u
- public static void CloseAll(Connection con,PreparedStatement past,ResultSet rs){' c' N; u, G: d( d
-
9 n! x$ t d9 ~) j0 _- P - if (rs!=null) {& o5 o' I5 e! u
- try {
& e$ `8 l1 K. |5 v - rs.close();
5 @) R. A$ I% e - } catch (SQLException e) {
3 i7 H/ Z1 F$ [ z# b- F - System.out.println("rs 关闭出现异常");
- \) M( J* _2 j$ T - e.printStackTrace();& ]9 z6 r; f" l$ p7 [% @
- }! r0 F. [4 }1 v: H5 \ D* R
- }$ p/ `- N+ G) a. V
- if (past!=null) {
5 \- O0 W$ X: e, p - try {
' D+ W9 X) R5 G+ u& n - past.close();! E: \' F% n( X" V% L/ q
- } catch (SQLException e) {" k3 \4 X6 [6 s* F. e- m# {4 y
- System.out.println("past 关闭出现异常");5 b/ @/ x; Y9 b
- e.printStackTrace();
' {8 x* z- l4 B; s) V9 J* q - }) m$ N$ C. H, X: |1 Z: a9 u
- }* ~4 ^' Q5 C( }$ X7 ^0 N
- if (con!=null) {
: h* H- U7 k2 J% |% n - try {
9 B2 A8 @$ |3 [- `; V - con.close();
) j, g' S% [2 V, M# k D - } catch (SQLException e) {3 z3 { {/ ~% a- N8 ^3 b$ C0 j
- System.out.println("con 关闭出现异常");+ K4 \# S% ?6 ^
- e.printStackTrace();7 ~; t; L/ u! y
- }
7 ?6 V7 r% d9 O+ h( R - }9 ~; R4 m" A0 N* ~0 R- Y8 D
- }$ ~ ^! F6 t$ \6 C0 O- k
- /**9 U8 d9 a2 i1 u" U9 R7 b% s
- * 执行数据的增删改操作
8 N5 I% l1 K& q8 m, r* A2 \ - * @param sql( ~0 F7 o7 |8 t2 ]+ W
- * @param getValues
$ v! u3 n, l# u$ w1 N1 ^9 I( ~ - * @return% h6 l8 K* |+ d; E3 Y% Q& y
- */1 c* M# a* j6 Z! r( K( G5 q
- public static int executeUpdate(String sql,String[]getValues){+ z1 b2 }5 D' l+ D
- int t=0;
6 V! `1 ` s. }* e - PreparedStatement past=null;
) O) P7 d! b0 Z9 @$ F: b/ d$ j - Connection con=null;! C: {/ _$ Q; T2 ?, G6 M L" a
- try {
& }3 M) p/ o/ s - con=getConnection();, q1 m! T+ i3 q9 G% e6 j
- past=con.prepareStatement(sql);* i2 X6 x" p; [' z: b( n; T- p
- if (getValues!=null) {' L# h. H1 q; A' H1 D. z3 F
- for (int i = 0; i < getValues.length; i++) {, U) N- p5 ^2 z! x8 F L
- past.setString(i+1,getValues[i]);0 S' Q+ s7 V( a8 v. s0 x! ]8 B. u
- }
' |6 Z0 Q& \( k1 e0 t; i - }$ y& E0 ~: U9 v$ p
- t=past.executeUpdate();
' J6 x7 _, X( Q, T3 ~ N - } catch (SQLException e) {
$ ]& r6 }, t# {: s - System.out.println("执行数据库操作出现异常");9 r7 p) z$ V E) w n, W
- e.printStackTrace();$ R4 f E* T0 ^4 A
-
8 X) E$ l0 C# x* P* Q8 ?% \ - }finally{% g( a$ I1 o! I" p
- MessageBase.CloseAll(con, past, null);" M3 e k. X6 C
- }" p X8 \5 ^8 _
- return t;
/ [" L* F6 K; \( k6 h+ X1 g - }) M4 c8 f+ i9 d" Q: V; _
- /**
, h) b1 X" p% x* @% Q - * 测试连接
1 e" R& X7 Z7 u" Q1 r# @! H - * @param args
$ |) p! k$ u, g - */
2 Z( ^8 {+ [; W - public static void main(String[] args) {
- \$ O T% f- n5 Z9 _- P3 b5 M - Connection conn=getConnection();
) ^5 \7 ?/ C! v, [2 N, H5 X - if(conn!=null){" N3 u" ^8 U9 t% p9 l) ?9 ~; |
- System.out.println("连接成功");
0 m5 ^$ U& o# W) k - }else{5 h5 x( r* g F3 Q1 w6 y
- System.out.println("连接失败");3 g9 G# I4 }2 e& ~$ m% c! @6 x
- }
1 K q" g) O9 V! d6 K5 p7 G+ w - }
, W% h6 N/ I" W6 K9 f. K% @. i: n - }$ l& q( ~- U8 F5 p3 ]
复制代码- package s2.jsp.zhangixao.dao;$ p! a' ?* `3 ^# l; P% Z; t* w
p, m1 w, W* @' Z, i ~- import java.util.List;
( |* O) V% u7 ^. S7 z1 c
8 Z3 ]+ a/ [! q) c8 a+ G" p- import s2.jsp.zhangxiao.entity.Message;6 h0 |9 H) u# @; c$ V; ^
: B$ Q4 \$ G- p: g* o) k- /**
) ? B1 N4 m( C' \% i - * 留言板接口
! `" E. Z* j9 P% p - * @author Administrator
) ~; t" E; k( X$ o - *, q% e/ i. R" `( S- s4 ]
- */
. t, r; y+ W3 E# v+ B% J - public interface MessageDao {- j& y) m1 {+ w" m
- //添加留言% L7 m8 W' g# b, v
- public int addMessage(Message message);
: y7 s( Z* n- E/ \8 K - //查询全部留言
# B3 B Q3 _9 t - public List selcetMessage();& Y8 u. I! K5 N
- }1 J, Y; `* ?, {; |3 Z8 k
复制代码 项目源码下载地址: ) n) r: [1 y# h7 T9 f
& H1 X- F J0 d$ a1 w
9 ?# M( b, R. D+ h4 {. G
9 ]' z$ a9 T* I9 ?# V& n9 a) ]7 x- Z* R7 E6 Q
|
|